simpleq golang实现的消息队列服务,支持消费主题(topic)以及消费者分组(group) 目前实现了基本的功能模块,后面的精力主要放在主从复制,数据清除,还有性能优化。 使用方式 安装 需要go1.2或以上版本 go get github.com/wenzuojing/simpleq cd $GOPATH/src/github.com/wenzuojing/simpleq sh build.sh 启动 ./simpleq -conf simpleq.conf 发布消息 client, _ := SimpleqClient("localhost", 9090, 1) client.Publish([]byte("topic1"), []byte("hi wens")) 消费消息 client, _ := SimpleqClient("localhost", 9090