RabbitMQ direct交換器

1：隊列和交換器屢次綁定

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

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

當發送者發送routekey一、routekey二、routekey3的路由鍵時，會匹配到這個消費者當中。

 

2：一個鏈接，鏈接到多個信道

/*建立一個信道*/

Channel channel1 = connection.createChannel();

Channel channel2 = connection.createChannel();

當消費者建立多個信道，每一個信道都鏈接相同的交換器、隊列、路由鍵（routekey）。

相同的路由鍵，會匹配到不一樣的隊列當中。

 

3：一個隊列多個消費者

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

不一樣的消費者，建立相同的隊列，綁定相同的交換器，綁定相同的key。

MQ會使用輪訓的方式，發送到不一樣的消費者當中。