之前项目中需要写个Python 版本的Agent，里面用到了Rabbitmq，中间遇到了好多坑啊，最主要的原因就是Python的Rabbitmq 库没有java的完善，像spring-Rabbitmq，什么都给你处理了。但是在Python中各种异常都需要自己处理。
最近又开发了一个Golang的项目，里面也用到了rabbitmq ，google了一下，golang的Rabbitmq库，也不完善
1.多个channel共享一个connection
2.连接断开后的重建连接
项目目前也主要是为了解决这个问题，因此整了个Rabbitmq的Connection Pool (实际上是Channel Pool，存储了一个Connection的多个Channel)，实现思路可以参考设计的Struct
type MqConnection struct {
Lock sync.RWMutex
Connection *amqp.Connection
MqUri string
type ChannelContext struct {
Exchange string
ExchangeType string
RoutingKey string
Reliable bool
Durable bool
ChannelId string
Channel *amqp.Channel
type BaseMq struct {
MqConnection *MqConnection
//channel cache
ChannelContexts map[string]*ChannelContext
查看我定义的Struct，可以看到就是定义了一个struct 保存了Connection信息和全部的Channel信息。当使用BasMq的Publish方法时，首先判断是否已经存在对应的Channel了，如果有，就用已经存在的Channel。发送消息代码如下
func TestMyMqConnection1() {
var mq1 *mq.BaseMq
mq1 = mq.GetConnection("manager")
channleContxt := mq.ChannelContext{Exchange: "docker-exchange1",ExchangeType: "direct",RoutingKey: "docker1",Reliable: true,Durable: false}
for {
fmt.Println("sending message111")
mq1.Publish(&channleContxt,"helllosaga")
time.Sleep(10 * time.Second)
参数只传入Channel信息，RabbitmqServer 可以根据业务需求调整，具体可参考源码rabbitmq-golangclient
如果觉得编程之家网站内容还不错，欢迎将编程之家网站推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您喜欢交流学习经验，点击链接加入交流1群：1065694478(已满)交流2群：163560250
RabbitMQ
介绍
RabbitMQ
是一个由erlang开发的AMQP(Advanced Message Queue )的开源
实现
的产品，
RabbitMQ
是一个消息代理，从“生产者”接收消息并传递消息至“消费者”，期间可根据规则路由、缓存、持久化消息。“生产者”也即message发送者以下简称P，相对应的“消费者”乃message接收者以下简称C，message通过queue由P到C，queue存...
def __init__(self, #pylint: disable=R0913,R0914,R0912host=_DEFAULT,port=_DEFAULT,virtual_host=_DEFAULT,credentials=_DEFAULT,channel_max=_DEFAULT,frame_max=_DEFAULT,heartbeat=_DEFAULT,ssl=_DEFAULT,ssl...
直接（direct）主题（topic）标题（header）扇出（fanout）fanout 扇出不需要指定 routing_key,即使指定了也是无效。需要提前将 exchange 和 queue 绑定，一个 exchange 可以绑定多个 queue，一个queue可以绑定多个exchange。需要先启动 订阅者，此模式下的队列是 consumer 随机生成的，发布者 仅仅发布消息到 exchange ，由 exchange 转发消息至 queue。
