RabbitMQ的基本使用

深碍√TFBOYSˉ_ 2022-04-04 14:46 264阅读 0赞

1.项目中引入

  1.     <dependency>  
  2.         <groupId>org.springframework.cloud</groupId>  
  3.         <artifactId>spring-cloud-starter-bus-amqp</artifactId>  
  4.     </dependency>

2.配置mq的信息

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70

3.创建一个接收消息的类

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 1

4.创建消息发送类

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 2

5.手工创建队列

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 3

6.运行发送端 ，查看mq控制台如下图

20181217215242102.png

7.自动创建mq队列

7.1先把rabbitMQ控制台上的myQueue队列删除。查看mq的队列如下图

20181218212244751.png

7.2 代码实现如下：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 4

7.3启动项目并在mq队列中查看 ，如下图表示自动创建成功。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 5

7.4发送消息让监听端接收消息

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 6

8、队列和Exchange的绑定

8.1代码如下

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 7

8.2启动项目后查看队列如下

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 8

9.消息分组

9.1代码部分

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 9

9.2发送方发送消息

20181218220447450.png

9.3接收方接收到消息后查看MQ，正式根据Routing Key 来发送到不同的队列上的。

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lpeWlqaWFueGlhbg_size_16_color_FFFFFF_t_70 10

发表评论

表情：
评论列表 （有 0 条评论，264人围观）

还没有评论，来说两句吧...

相关阅读

    相关 RabbitMQ基本使用

    消息队列（MQ） MQ全称Message Queue，是一种应用程序对应用程序的通信方式。应用程序通过读写出入队列的消息来通信，而无需专用连接来连接它们。消息传递指的是程序

    ￡神魔★判官ぃ￡神魔★判官ぃ/ 0 赞/ 122 阅读

    相关 RabbitMQ的基本使用

    MQ的应用场景 异步处理。比如注册，注册后会发送短信以及创建角色，这时候发送短信和创建角色可以异步进行，而不必等发送完短信之后再创建角色 流量削峰。若出现流量

    系统管理员系统管理员/ 0 赞/ 67 阅读

    相关 rabbitmq的基本使用

    现在微服务盛行， 我们通常会进行解耦， 这时候就需要异步的消息队列来帮助各个服务之间解耦 rabbitmq的基本概念介绍 rabbitmq的基本概念有消息produce

    亦凉亦凉/ 0 赞/ 296 阅读