RedisStreamMqDemo.zip

上传者: li_qinging | 上传时间: 2021-06-03 13:03:47 | 文件大小: 12KB | 文件类型: ZIP
基于Go语言,实现对Redis Stream消息队列客户端接口的封装,支持单条/批量添加消息,也支持阻塞和非阻塞的无消费组模式的消费,以及阻塞和非阻塞的消费组模式的消费,支持对消息队列,消费组和消费者基本信息的监控,并且包含生产者和消费者客户端测试代码。

文件下载

资源详情

[{"title":"( 12 个子文件 12KB ) RedisStreamMqDemo.zip","children":[{"title":"RedisStreamMqDemo","children":[{"title":"go.mod <span style='color:#111;'> 77B </span>","children":null,"spread":false},{"title":"testProduceClient.go <span style='color:#111;'> 2.34KB </span>","children":null,"spread":false},{"title":"go.sum <span style='color:#111;'> 1.11KB </span>","children":null,"spread":false},{"title":".idea","children":[{"title":".gitignore <span style='color:#111;'> 233B </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 2.67KB </span>","children":null,"spread":false},{"title":"RedisStreamMqDemo.iml <span style='color:#111;'> 330B </span>","children":null,"spread":false},{"title":"inspectionProfiles","children":[{"title":"Project_Default.xml <span style='color:#111;'> 1.13KB </span>","children":null,"spread":false}],"spread":true},{"title":"modules.xml <span style='color:#111;'> 293B </span>","children":null,"spread":false}],"spread":true},{"title":"testConsumerClient.go <span style='color:#111;'> 8.09KB </span>","children":null,"spread":false},{"title":"common","children":[{"title":"connHandle.go <span style='color:#111;'> 870B </span>","children":null,"spread":false},{"title":"define.go <span style='color:#111;'> 1.65KB </span>","children":null,"spread":false},{"title":"msgHandle.go <span style='color:#111;'> 13.54KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}]

评论信息

免责申明

【只为小站】的资源来自网友分享,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论 【只为小站】 经营者是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二条之规定,若资源存在侵权或相关问题请联系本站客服人员,zhiweidada#qq.com,请把#换成@,本站将给予最大的支持与配合,做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明