代码拉取完成，页面将自动刷新
同步操作将从 noear/folkmq 强制同步，此操作会覆盖自 Fork 仓库以来所做的任何修改，且无法恢复！！！
确定后同步将在后台操作，完成时将刷新页面，请耐心等待。
An in-memory messaging middleware (support for snapshot persistence, Broker clustering)
Run in Memory + snapshot persistence + Broker cluster mode (optional)
based on [Socket. D development] (https://socketd.noear.org/), it features full support), especially the single connection "multiplex"! Protocols such as udp can also be added
Use "multiplexing" + "running in memory" + "snapshot persistence" + "Broker cluster mode "(optional)
based on Socket.D Network Application protocol Development. New design, independent architecture!
| role | function |
|---|---|
| Producer | Publish messages, timed messages, sequential messages, expireable messages, transactional messages. Send Request (rpc) Qos0 and Qos1 are supported |
| Consumer | Subscribe, unsubscribe. Consumption -ACK (automatic, manual). Responding to a request |
| Server | Publish -Confirm, subscribe -Confirm, unsubscribe -Confirm, dispatch -Retry, dispatch -delay |
| Server | Single thread, run in memory, snapshot persistence (automatic, down, manual), Broker mode clustering, cluster hot scaling |
FolkMQ is a commercial open source software that:
FolkMQ runs purely in memory and can process hundreds of thousands of messages per second with minimum latency of less than a millisecond.
FolkMQ Broker cluster supports FolkMQ-Server node hot extension . When the flow is high, it can be added at any time, and the flow can be reduced when it is low
Messages are snapshot persisted (similar to redis) to local disk, and data backup is supported to prevent data loss
//Using MacBook pro 2020 + JDK8 native test, single client sending and receiving (running points inevitably have fluctuations, I chose the better one)
| QQ communication group：316697724 | Wechat communication group (input: FolkMQ when applying) |
|---|---|
 |
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
