[{"_1":2,"_157":-5,"_158":-5},"loaderData",{"_3":4,"_13":14,"_20":21,"_135":136},"root",{"_5":-5,"_6":-7,"_7":8,"_9":-7,"_10":11,"_12":-7},"currentUser","primaryEmail","siteVerification","6LeIxAcTAAAAAJcZVRqyHh71UMIEGNQ_MXjiZKhI","toast","enableDev",false,"incidentStatus","routes/_layout",{"_15":-5,"_16":11,"_17":11,"_18":19},"username","isBillingDecouplingSeatCount","isSearchBoxExperimentEnabled","isAskGordonEnabled",true,"routes/_layout.r.$namespace.$reponame",{"_22":23,"_24":-5,"_25":11,"_26":11,"_27":28,"_29":30,"_31":-5,"_32":11,"_33":34,"_87":-5,"_88":89,"_128":-5,"_129":11,"_130":11,"_131":11,"_132":-5,"_133":134},"canonicalUrl","https://hub.docker.com/r/magarich/unisonmq/tags","mcpServer","canSeeDockerfile","canSeeAutobuilds","namespace","magarich","reponame","unisonmq","cloudBuildSource","isAutobuildsAvailable","repo",{"_35":36,"_42":43,"_45":46,"_47":48,"_49":11,"_50":51,"_52":53,"_54":55,"_38":30,"_27":28,"_57":58,"_59":44,"_60":61,"_62":63,"_64":65,"_66":-5,"_67":61,"_68":69,"_70":11,"_71":28,"_72":73,"_78":11,"_79":80,"_84":28,"_85":86},"categories",[37],{"_38":39,"_40":41},"name","Message queues","slug","message-queues","content_types",[44],"image","date_registered","2025-05-11T15:56:44.471217Z","description","lightweight message broker for asynchronous integrations","is_private","last_updated","2025-05-11T16:20:03.874806Z","last_modified","2025-05-11T17:50:39.140311Z","media_types",[56],"application/vnd.docker.container.image.v1+json","pull_count",277,"repository_type","star_count",0,"status",1,"status_description","active","source","collaborator_count","full_description","# UnisonMQ\n\n**UnisonMQ: High-Performance Message Broker for Modern Applications** 🚀 \nUnisonMQ is a lightweight yet powerful message broker designed for the .NET ecosystem. It combines ease of use, high performance, and flexibility, supporting both basic messaging scenarios and complex microservice architectures. Thanks to its modular design and open protocol, UnisonMQ integrates seamlessly into any infrastructure. 🌐 \n\n---\n\n### **Core Protocol Operations** 📡 \n1. **`PING` → `PONG`** 💡 \n Connection health check. Clients send `PING`, and the server responds with `PONG` to confirm availability. \n\n2. **`SUB [Id]`** 🔍 \n Subscribe to a topic with wildcard support (`*` for single tokens, `>` for nested hierarchies). An optional `Id` allows managing multiple subscriptions within a single connection. \n Example: \n ```plaintext\n SUB orders.*.created 123\n ```\n\n3. **`UNSUB [MaxMessages]`** 🚫 \n Unsubscribe using a subscription `Id`. If `MaxMessages` is specified, the broker will send up to that number of remaining messages before terminating the subscription. \n\n4. **`PUB \\r\\n`** 📤 \n Publish a message to a topic. The client specifies the data length (`length`) before sending the message body. \n Example: \n ```plaintext\n PUB alerts.system 11\n Hello World\n ```\n\n5. **`EXIT`** 🔌 \n Gracefully terminate the connection. The server releases all client-associated resources. \n\n---\n\n### **C# Client Libraries** 📦 \nIntegrate UnisonMQ into your projects using NuGet packages: \n- **Core Client**: \n ```bash\n dotnet add package UnisonMQ.Client\n ``` \n- **Dependency Injection Support**: \n ```bash\n dotnet add package UnisonMQ.DependencyInjection\n ``` \n\n**Example (Subscription and Publishing):** 💻 \n```csharp\nusing UnisonMQ.Client;\n\nawait using var client = new UnisonMqClientService(new UnisonMqConfiguration());\n\nif (!client.ConnectAsync())\n{\n Console.WriteLine(\"Failed to connect.\");\n return;\n}\n\nclient.Subscribe(\"sensors.*\", msg =>\n{\n switch (msg.Data)\n {\n case TemplateSensorData data:\n Console.WriteLine($\"Received temperature from {msg.Subject}: {data.Value}\");\n break;\n default:\n Console.WriteLine($\"Received message from {msg.Subject}: {msg.Data}\");\n break;\n }\n});\nclient.Publish(\"sensors.temperature\", new TemplateSensorData(Guid.NewGuid(), \"24.5°C\"));\n\nabstract class SensorData(Guid id)\n{\n public Guid Id { get; } = id;\n}\n\nclass TemplateSensorData(Guid id, string value) : SensorData(id)\n{\n public string Value { get; } = value;\n}\n```\n\n---\n\n### **Monitoring Stack (Prometheus + Grafana)** 📈 \nFrom the repository root: \n```bash\ndocker compose up -d\n``` \n- **Prometheus** 🎯 Collects metrics from UnisonMQ (port 5889). \n- **Grafana** 📉 Prebuilt dashboards for analyzing load, latency, and system health. \n \n---\n\n### **Telnet Compatibility** ⌨️ \nUnisonMQ works with any TCP client, including Telnet: \n```bash\ntelnet localhost 5888\n``` \n**Example Session:** 💬 \n```plaintext\n> ping\n< PONG\n> SUB alerts.* 1\n< +OK \n> PUB alerts.system 5 \n> READY \n< MSG alerts.system 1 5\n< READY\n< +OK\n> exit\n< +OK\n```\n\n---\n\n### **Prometheus Metrics** 📊 \nUnisonMQ exposes detailed Prometheus metrics: \n- **Network Stats** 🌐 Active connections, traffic volume. \n- **Operations** ⚙️ PUB/SUB counts, processing times. \n- **Resource Usage** 💻 CPU, memory, GC metrics. \n\n```promql\n# Example Query: Message publish rate 📤\nrate(broker_messages_published_total[1m])\n```\n\n---\n\n### **Why Choose UnisonMQ?** 🚀 \n- Ultra-low latency ⚡ with an optimized protocol. \n- Wildcard support 🌟 for flexible topic management. \n- Subscription control 🔑 via `Id`. \n- Built-in monitoring 👁️ via Prometheus/Grafana. \n- Seamless .NET integration 🔄. \n\nIdeal for **IoT** 📶, **microservices** 🧩, and **real-time systems** ⏱️ where speed and reliability are critical!\n\n---\n### **License** 📜 \nUnisonMQ is released under the **Apache License 2.0**. \nFor full details, see the [LICENSE](LICENSE) file in the repository. \n\n### **Author** 👨💻 \n- **[Magarich228](https://github.com/magarich228)** - Creator and maintainer of UnisonMQ. \n\n---\n\n**Happy messaging!** 🎉 ","has_starred","hub_user","immutable_tags_settings",{"_74":11,"_75":76},"enabled","rules",[77],".*","is_automated","permissions",{"_81":19,"_82":11,"_83":11},"read","write","admin","user","storage_size",81171530,"orgData","recentTags",[90],{"_91":44,"_92":93,"_94":95,"_96":97,"_98":99,"_100":101,"_50":117,"_118":93,"_119":28,"_120":56,"_38":121,"_122":123,"_124":108,"_125":117,"_126":65,"_127":19},"content_type","creator",19790056,"digest","sha256:7c049b355f442aa74794b236caee7f939a32f0a6ed1e0502a737842ccee03aae","full_size",81166145,"id",897054765,"images",[102],{"_103":104,"_94":95,"_105":106,"_107":108,"_109":110,"_111":112,"_113":106,"_114":-5,"_115":97,"_62":65,"_116":-5},"architecture","amd64","features","","last_pulled","2026-07-13T16:29:53.810760314Z","last_pushed","2025-05-11T16:20:02.385186589Z","os","linux","os_features","os_version","size","variant","2025-05-11T16:20:02.80517Z","last_updater","last_updater_username","media_type","latest","repository",27343133,"tag_last_pulled","tag_last_pushed","tag_status","v2","sbxKitMetadata","isPotentialSpam","isHubSbxKitsEnabled","displaySecurityMetadata","tagAttestations","tagsHaveAttestations",[],"routes/_layout.r.$namespace.$reponame.tags",{"_33":137,"_145":146,"_133":155,"_156":11},{"_35":138,"_42":140,"_45":46,"_47":48,"_49":11,"_50":51,"_52":53,"_54":141,"_38":30,"_27":28,"_57":58,"_59":44,"_60":61,"_62":63,"_64":65,"_66":-5,"_67":61,"_68":69,"_70":11,"_71":28,"_72":142,"_78":11,"_79":144,"_84":28,"_85":86},[139],{"_38":39,"_40":41},[44],[56],{"_74":11,"_75":143},[77],{"_81":19,"_82":11,"_83":11},"tags",{"_147":63,"_148":-5,"_149":-5,"_150":151},"count","next","previous","results",[152],{"_91":44,"_92":93,"_94":95,"_96":97,"_98":99,"_100":153,"_50":117,"_118":93,"_119":28,"_120":56,"_38":121,"_122":123,"_124":108,"_125":117,"_126":65,"_127":19},[154],{"_103":104,"_94":95,"_105":106,"_107":108,"_109":110,"_111":112,"_113":106,"_114":-5,"_115":97,"_62":65,"_116":-5},[],"canDeleteTags","actionData","errors"]

magarich/unisonmq

Tags for magarich/unisonmq