RabbitMQ direct交换器

1:队列和交换器屡次绑定spa

String[] routekeys={"routekey1","routekey2","routekey3"};队列

for(String routekey:routekeys){
  channel.queueBind(queueName,DirectProducer.EXCHANGE_NAME,routekey);
}路由

当发送者发送routekey一、routekey二、routekey3的路由键时,会匹配到这个消费者当中。io

 

2:一个链接,链接到多个信道route

/*建立一个信道*/channel

Channel channel1 = connection.createChannel();queue

Channel channel2 = connection.createChannel();co

当消费者建立多个信道,每一个信道都链接相同的交换器、队列、路由键(routekey)。connect

相同的路由键,会匹配到不一样的队列当中。

 

3:一个队列多个消费者

channel.queueBind(queueName,DirectProducer.EXCHANGE_NAME,routekey);

不一样的消费者,建立相同的队列,绑定相同的交换器,绑定相同的key。

MQ会使用轮训的方式,发送到不一样的消费者当中。

相关文章
相关标签/搜索