【RabbitMQ】三种Exchange模式——订阅、路由、通配符模式

本文主要是介绍【RabbitMQ】三种Exchange模式——订阅、路由、通配符模式，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

   前两篇博客介绍了两种队列模式，这篇博客介绍订阅、路由和通配符模式，之所以放在一起介绍，是因为这三种模式都是用了Exchange交换机，消息没有直接发送到队列，而是发送到了交换机，经过队列绑定交换机到达队列。

       

一、订阅模式(Fanout Exchange)：

   一个生产者，多个消费者，每一个消费者都有自己的一个队列，生产者没有将消息直接发送到队列，而是发送到了交换机，每个队列绑定交换机，生产者发送的消息经过交换机，到达队列，实现一个消息被多个消费者获取的目的。需要注意的是，如果将消息发送到一个没有队列绑定的exchange上面，那么该消息将会丢失，这是因为在rabbitMQ中exchange不具备存储消息的能力，只有队列具备存储消息的能力。

      

         

 

示例代码：

生产者：

public class Send {private final static String EXCHANGE_NAME = "test_exchange_fanout";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();//从连接中创建通道Channel channel = connection.createChannel();// 声明exchangechannel.exchangeDeclare(EXCHANGE_NAME, "fanout");// 消息内容String message = "商品已经新增，id = 1000";channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes());System.out.println(" [x] Sent '" + message + "'");channel.close();connection.close();}
}

消费者1：

public class Recv {private final static String QUEUE_NAME = "test_queue_fanout_1";private final static String EXCHANGE_NAME = "test_exchange_fanout";public static void main(String[] argv) throws Exception {// 获取到连接以及mq通道Connection connection = ConnectionUtil.getConnection();Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);// 绑定队列到交换机channel.queueBind(

这篇关于【RabbitMQ】三种Exchange模式——订阅、路由、通配符模式的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---