文件名称：gmqtt:Golang MQTT网关
文件大小：225KB
文件格式：ZIP
更新时间：2024-05-09 02:12:46
mqtt iot kafka microservice broker
Micro MQ 以微服务+MQ构建支持高并发连接的分布式消息服务系统 Gateway节点Node通过订阅MQ消息的方式，完成消息在节点间的转发 根据业务场景的需求，需要考虑Node节点消息消费与生产速度的匹配 Client间的pub/sub关系比较多，如n个node, 发送m条消息/topic/node，节点消费的需求是n*m条/topic Client端多为pub操作，而系统下发消息较少的情况，节点消费需求则比较低 Gateway编程模型 Features 运行 服务依赖 根据配置选择 conf/conf.toml MQ conf.broker Kafka 服务注册与发现 conf.auth Etcd Consul 启动服务 # 启动Gateway，[-h]帮助查看可选参数 $ cd gateway $ go run -tags "consul" main.go # RPC Au