首先可以去官方看看第四章節(jié)講的一些內(nèi)容：https://www.rabbitmq.com/tutorials/tutorial-four-java.html

Routing：綁定交換機(jī)和隊(duì)列之間的關(guān)系。

上文我們用的fanout模式，屬于廣播模式，不能將交換機(jī)與相關(guān)隊(duì)列進(jìn)行綁定，用DIRECT模式，我們可以將詳細(xì)發(fā)送到交換機(jī)，再由交換機(jī)決定發(fā)送給隊(duì)列X，并決定往隊(duì)列中發(fā)送幾條消息。

1.生產(chǎn)者

package com.baidu.RabbitMQ.mq03;import java.io.IOException;import com.rabbitmq.client.AMQP; import com.rabbitmq.client.BuiltinExchangeType; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Consumer; import com.rabbitmq.client.DefaultConsumer; import com.rabbitmq.client.Envelope;public class MultiConsumerOne {private static final String Exchange_Name="rabbit:mq03:exchange:e01";private static final String Queue_Name_01="rabbit:mq03:queue:q01";private static final String Routing_Key_01="rabbit:mq03:routing:key:r01";public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("127.0.0.1");Connection connection = factory.newConnection();Channel channel = connection.createChannel();channel.exchangeDeclare(Exchange_Name, BuiltinExchangeType.DIRECT);channel.queueDeclare(Queue_Name_01, true, false, false, null);channel.queueBind(Queue_Name_01, Exchange_Name, Routing_Key_01);Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope,AMQP.BasicProperties properties, byte[] body) throws IOException {String message = new String(body, "UTF-8");System.out.println("消費(fèi)者1接收到消息成功---> "+message);}};channel.basicConsume(Queue_Name_01, true, consumer);} catch (Exception e) {e.printStackTrace();}} }

2.消費(fèi)者one

package com.baidu.RabbitMQ.mq03;import java.io.IOException;import com.rabbitmq.client.AMQP; import com.rabbitmq.client.BuiltinExchangeType; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Consumer; import com.rabbitmq.client.DefaultConsumer; import com.rabbitmq.client.Envelope;public class MultiConsumerOne {private static final String Exchange_Name="rabbit:mq03:exchange:e01";private static final String Queue_Name_01="rabbit:mq03:queue:q01";private static final String Routing_Key_01="rabbit:mq03:routing:key:r01";public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("127.0.0.1");Connection connection = factory.newConnection();Channel channel = connection.createChannel();channel.exchangeDeclare(Exchange_Name, BuiltinExchangeType.DIRECT);channel.queueDeclare(Queue_Name_01, true, false, false, null);channel.queueBind(Queue_Name_01, Exchange_Name, Routing_Key_01);Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope,AMQP.BasicProperties properties, byte[] body) throws IOException {String message = new String(body, "UTF-8");System.out.println("消費(fèi)者1接收到消息成功---> "+message);}};channel.basicConsume(Queue_Name_01, true, consumer);} catch (Exception e) {e.printStackTrace();}} }

?3.消費(fèi)者two

package com.baidu.RabbitMQ.mq03;import java.io.IOException;import com.rabbitmq.client.AMQP; import com.rabbitmq.client.BuiltinExchangeType; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Consumer; import com.rabbitmq.client.DefaultConsumer; import com.rabbitmq.client.Envelope;public class MultiConsumerTwo {private static final String Exchange_Name="rabbit:mq03:exchange:e01";private static final String Queue_Name_02="rabbit:mq03:queue:q02";private static final String Routing_Key_02="rabbit:mq03:routing:key:r02";private static final String Routing_Key_03="rabbit:mq03:routing:key:r03";public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("127.0.0.1");Connection connection = factory.newConnection();Channel channel = connection.createChannel();channel.exchangeDeclare(Exchange_Name, BuiltinExchangeType.DIRECT);channel.queueDeclare(Queue_Name_02, true, false, false, null);channel.queueBind(Queue_Name_02, Exchange_Name, Routing_Key_02);channel.queueBind(Queue_Name_02, Exchange_Name, Routing_Key_03);Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope,AMQP.BasicProperties properties, byte[] body) throws IOException {String message = new String(body, "UTF-8");System.out.println("消費(fèi)者1接收到消息成功---> "+message);}};channel.basicConsume(Queue_Name_02, true, consumer);} catch (Exception e) {e.printStackTrace();}} }

?

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ入门（四）-Routing（路由）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。