文件名称：simpleq:golang实现的消息队列服务，支持消费主题(topic)以及消费者分组(group)
文件大小：13KB
文件格式：ZIP
更新时间：2024-07-05 02:39:17
Go
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
【文件预览】：
simpleq-master
----client()
--------conn_pool.go(712B)
--------client_test.go(1KB)
--------client.go(3KB)
--------conn.go(536B)
----simpleq.conf(129B)
----server()
--------server.go(4KB)
----config()
--------Config.go(1KB)
----simpleq.go(919B)
----README.md(775B)
----build.sh(80B)
----version(5B)
----broker()
--------broker_test.go(388B)
--------message_store.go(2KB)
--------broker_store_test.go(1002B)
--------store_pool.go(2KB)
--------meta.go(2KB)
--------broker_store.go(4KB)
--------broker.go(1KB)
--------store.go(130B)