写了一个测试脚本,从数据读取一组数据,然后逐条publish到nats-server中, 确定每条都publish了, 有另外一个程序中subscribe订阅,在该程序发现最后一条一直没收到
学习官网例子时,会碰到的一个小错误
双机nsq如果部署集群,如何保证高可用性
用golang做了一个分布式结构的系统, 消息服务器用了rabbitmq, 整体是基于machinery+rabbitmq形式的分布式任务系统。在做压力测试时,发现rabbitmq的cpu使用率飙升
实现了一个io.Writer接口,允许zap日志写入,传递给界面,出现了日志被覆盖、重复的情况。
go实现的基于消息中间件的异步任务队列, 下面是学习笔记