RabbitMq 通过通过IP,Port等参数创建connection对象,然后实际上通信用的是channel,channel的建立基于connection
RPC 调用:
RPCClient通过channel.BasicPublish方法发送数据,接收数据在这里通过调用channel.BasicConsume实现,
这里有一点要注意channel.BasicConsume是将consumer注册到管道,而不是立刻去消费一条数据,
而这个被注册成功的consumer,服务端会默认的分配一个consumerTag给该consumer,并且服务器会为这个consumer建立一个临时用来
的返回数据的queue,这个临时的返回数据的queue的名字,就是这个consumerTag。
这里的RPCClient 最好是建立连接池来使用。一边减少服务器对于连接管理的资源消耗。