- ⑤. 测试:
- 启动所有消费者,然后使用生产者发送消息;在每个消费者对应的控制台可以查看到生产者发送的所有消息;达到广播的效果
- 在执行完测试代码后,其实到RabbitMQ的管理后台找到Exchanges选项卡,点击fanout_exchange的交换机,可以查看到如下的绑定
③. Routing路由模式
①. Routing模式和Publish/subscibe有啥区别？
Routing模式要求队列在绑定交换机时要指定routingkey,消息会转发到符合routingkey的队列
②. Routing路由模式
P:生产者,向Exchange发送消息,发送消息时,会指定一个routing key
X:Exchange(交换机),接收生产者的消息,然后把消息递交给与routing key完全匹配的队列
C1:消费者,其所在队列指定了需要routing key为error的消息
C2:消费者,其所在队列指定了需要routing key为info、error、warning的消息
③. 生产者
public class Producer { //交换机名称 static final String DIRECT_EXCHANGE = "direct_exchange"; //队列名称 static final String DIRECT_QUEUE_INSERT = "direct_queue_insert"; //队列名称 static final String DIRECT_QUEUE_UPDATE = "direct_queue_update"; public static void main(String[] args) throws Exception { //1. 创建连接； Connection connection = ConnectionUtil.getConnection(); //2. 创建频道； Channel channel = connection.createChannel(); //3. 声明交换机；参数1:交换机名称,参数2:交换机类型(fanout,direct,topic) channel.exchangeDeclare(DIRECT_EXCHANGE, BuiltinExchangeType.DIRECT); //4. 声明队列； /** * 参数1:队列名称 * 参数2:是否定义持久化队列(消息会持久化保存在服务器上) * 参数3:是否独占本连接 * 参数4:是否在不使用的时候队列自动删除 * 参数5:其它参数 */ channel.queueDeclare(DIRECT_QUEUE_INSERT, true, false, false, null); channel.queueDeclare(DIRECT_QUEUE_UPDATE, true, false, false, null); //5. 队列绑定到交换机；参数1:队列名称,参数2:交换机名称,参数3:路由key channel.queueBind(DIRECT_QUEUE_INSERT, DIRECT_EXCHANGE, "insert"); channel.queueBind(DIRECT_QUEUE_INSERT, DIRECT_EXCHANGE, "delete"); channel.queueBind(DIRECT_QUEUE_UPDATE, DIRECT_EXCHANGE, "update"); //6. 发送消息； String message = "你好！小兔纸。路由模式;routing key为insert"; /** * 参数1:交换机名称；如果没有则指定空字符串(表示使用默认的交换机) * 参数2:路由key,简单模式中可以使用队列名称 * 参数3:消息其它属性 * 参数4:消息内容 */ channel.basicPublish(DIRECT_EXCHANGE, "insert", null, message.getBytes()); System.out.println("已发送消息:" + message); message = "你好！小兔纸。路由模式 ；routing key 为 update "; /** * 参数1:交换机名称；如果没有则指定空字符串(表示使用默认的交换机) * 参数2:路由key,简单模式中可以使用队列名称 * 参数3:消息其它属性 * 参数4:消息内容 */ channel.basicPublish(DIRECT_EXCHANGE, "update", null, message.getBytes()); message = "你好！小兔纸。路由模式 ；routing key 为 delete "; /** * 参数1:交换机名称；如果没有则指定空字符串(表示使用默认的交换机) * 参数2:路由key,简单模式中可以使用队列名称 * 参数3:消息其它属性 * 参数4:消息内容 */ channel.basicPublish(DIRECT_EXCHANGE, "delete", null, message.getBytes()); System.out.println("已发送消息:" + message); //6. 关闭资源 channel.close(); connection.close(); } }
