文件名称：nsqelastic:Nsq弹性集群
文件大小：24KB
文件格式：ZIP
更新时间：2024-05-27 07:30:41
Go
＃NSQ-弹性 ### Nsqelastic是nsqd集群的试用和实现。 该项目由deepglint.com Muse Group托管和开源。 ##设计原则： 以此来逐层管理资源。 ##客户交换规则： Nsq Elastic通过nsqlookupd逐个检查nsqd节点，以获取每个节点的指标以及分布在不同节点上的每个主题/渠道/客户端。 当客户端想要将消息发布到主题A时，该消息将被传输到承载主题A的节点。 当一个客户想要一个主题时，它应该用/ api / sub url询问Elastic，并告诉Elastic频道想要它，Elastic将检查数据结构，判断资源，最后返回节点地址。 然后，客户端可以访问该nsqd节点以对消息进行订阅。 ＃＃资源： ＃＃＃话题 主题是具有相同主题名称的消息集，只有1 nsqd不能承载太多实时主题，即使在理论上无限的### Nsqd上，也限制了计
【文件预览】：
nsqelastic-master
----models()
--------lookupd.go(2KB)
--------table_test.go(764B)
--------config.go(211B)
--------models.go(2KB)
----machinemanager.go(886B)
----dockermanager.go(31KB)
----n2n_test.go(1KB)
----n2n.go(11KB)
----controllers()
--------nsqcontroller.go(5KB)
--------n2ncontroller.go(6KB)
----client.go(1KB)
----n2n2.go(5KB)
----main.go(8KB)
----build4linux.sh(111B)
----README.md(2KB)
----util()
--------wait_group_wrapper.go(177B)