rabbitmq客户端连接池的golang管理包

brave · · 2405 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

# rabbitmqPool - rabbitmq的客户端连接池 - [github地址:https://github.com/Braveheart7854/rabbitmqPool](https://github.com/Braveheart7854/rabbitmqPool) - (使用rabbitmq文档提供的使用实例时,发现connection和channel没有实现复用,效率很低,由于一直没有找到实现connection和channel复用的相关代码库,故自己实现一个) - 在一台4核8G机子上ab压测http 10000次请求,1000并发时,qps为2000+。代码见https://github.com/Braveheart7854/asyncMessageSystem - 适当增大ConnectionNum和ChannelNum,可以提高性能 # 实现的功能 - 可以设置client与rabbitmq服务端的connection池 - 每个connection上建立的channel池 - 每个connection与channel都有断线重连机制 - 每个消息都有失败重试机制 - 每个消息都有confirm机制,避免生产者消息丢失 - 目前提供了生产者,而消费者后续会补上 # 依赖包 ``` github.com/streadway/amqp ``` # 开始使用 ``` go get github.com/Braveheart7854/rabbitmqPool ``` ##### 代码如下 ```go rabbitmqPool.AmqpServer = rabbitmqPool.Service{ AmqpUrl:"amqp://guest:guest@localhost:5672/", ConnectionNum:10, ChannelNum:100, } rabbitmqPool.InitAmqp() message,err := rabbitmqPool.AmqpServer.PutIntoQueue(ExchangeName,RouteKey,data) if err != nil{ //若有错误,则表示消息发送失败,做好失败消息处理 rabbitmqPool.Logger.Notice(message) } ```

有疑问加站长微信联系(非本文作者))

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

2405 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传