RabbitMQ基础篇之快速入门

一、目的需求

• 新建队列：创建 hello.queue1 和 hello.queue2 两个队列。
  
• 消息发送：通过交换机 amq.fanout 发送消息，测试消息是否能路由到这两个队列。
  

二、RabbitMQ 控制台使用步骤

1.创建队列

• 进入 RabbitMQ 控制台。
  
• 在 Queues 标签下，点击 Add a new queue。
  
• 填写队列名称（比方：hello.queue1）并点击 Add queue 完成队列创建。
  
• 同样的方式创建另一个队列 hello.queue2。
  

2.交换机概述

• RabbitMQ 控制台已经有一些默认的交换机，好比 amq.fanout，它是一个广播范例交换机，会将消息发送给全部绑定的队列。
  

3.向交换机发送消息

• 选择 Exchange 下的 amq.fanout 交换机。
  
• 点击 Publish message 进入消息发送界面。
  
• 填写消息内容（比方 hello mq），然后点击 Publish 发送消息。
  

4.结果分析

• 发送消息后，控制台会显示：
  
  
  
  • Publish：消息成功发送到交换机。
    
  • In：消息已进入交换机，但未能路由到队列。
    
  • Out：若路由成功，则显示消息已被路由到队列。
    
  
  

5.消息丢失缘故原由

• 消息丢失的缘故原由：如果交换机没有与任何队列建立绑定关系，消息会丢失。交换机本身没有存储消息的能力，只有路由功能。
  
• 交换机的作用：只负责将消息路由到绑定的队列，如果没有队列绑定，则消息会丢失。
  

三、绑定交换机与队列

• 回到交换机 amq.fanout 页面，点击 Bindings。
  
• 选择 Add binding from exchange，并选择目的队列 hello.queue1 或 hello.queue2，进行绑定。
  
• 同样的使用，将 hello.queue2 队列与交换机绑定。
  

四、测试消息发送

• 再次发布消息到交换机（比方：hello everyone）。
  
• 查抄交换机的消息状态：
  
  
  
  • Publish in：消息发送到交换机。
    
  • Publish out：消息从交换机转发到绑定的队列。
    
  
  
• 结果显示：消息已经成功路由到两个队列（hello.queue1 和 hello.queue2）。
  

五、消息检察

• 在队列中，可以通过点击 Get message 检察消息内容，模仿消耗者的消息接收。
  
• 消息可以检察，但不会丢失，纵然没有消耗者进行接收。
  

六、结论

• 交换机的作用：
  
  
  
  • 交换机只负责消息路由，不保存消息。
    
  • 如果路由失败，消息会丢失。
    
  • 交换机只能将消息发送到与其绑定的队列。
    
  
  
• 队列与交换机的绑定：
  
  
  
  • 只有交换机和队列之间建立了绑定关系，消息才能被精确路由到队列。
    
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。