脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → RabbitMQ 5种模式的注解绑定

SpringBoot整合RabbitMQ的5种模式的注解绑定详解

 更新时间：2024年01月25日 10:24:22   作者：小爽帅到拖网速  
这篇文章主要介绍了SpringBoot整合RabbitMQ的5种模式的注解绑定详解,RabbitMQ 是一个消息中间件,它接收消息并且转发,是"消费-生产者模型"的一个典型的代表,一端往消息队列中不断的写入消息,而另一端则可以读取或者订阅队列中的消息,需要的朋友可以参考下

RabbitMQ 5种模式的注解绑定

1、导入依赖

<!--AMQP依赖，包含RabbitMQ-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<!--对象转换-->
 <dependency>
     <groupId>com.fasterxml.jackson.dataformat</groupId>
     <artifactId>jackson-dataformat-xml</artifactId>
</dependency>

2、配置连接信息

spring:
	rabbitmq:
        host: localhost
        port: 5672
        username: root
        password: root
        virtual-host: /
       # listener:
     	#	 simple:
       	#	 prefetch: 1    # 工作队列能者多劳模式

3、5种使用模式

1、HelloWorld模式

一个队列一个消费者

// 消息发布
@Test
void testHelloWorldMode(){
    rabbitTemplate.convertAndSend("helloworld_queue","hello world!");
}
// 消息订阅
@RabbitListener(queuesToDeclare = {@Queue(name = "helloworld_queue")})
public void helloWorldC1(String msg){
    System.out.println("helloWorldC1:-------->"+msg);
}

在这里插入图片描述

2、Work模式 按均分配

一个队列，多个消费者

注意：一条消息只能被消费一次，默认是按均分配，在消费者开始消费之前队列中的消息就已经分配好了

往队列中放入50条消息

@Test
void testWorkMode(){
    String msg = "work mode";
    for (int i = 1; i <= 50; i++) {
        rabbitTemplate.convertAndSend("work_zs_queue","work mode"+i);
    }
}

创建两个消费者，并且设置20ms 和 200ms 的延迟

@RabbitListener(queuesToDeclare = {@Queue(name = "work_zs_queue")})
  @SneakyThrows
  public void workc1(String msg){
    Thread.sleep(20);
    System.out.println("workc1:---------------->"+msg);
  }
  @RabbitListener(queuesToDeclare = {@Queue(name="work_zs_queue")})
  @SneakyThrows
  public void workc2(String msg){
    Thread.sleep(200);
    System.err.println("workc2:------------------>"+msg);
  }

运行结果：

可以发现workc1比workc2提前完成消费任务，并且c1 c2是按照奇偶数顺序消费的任务，这也进一步验证了在消费开始前就已经分配好了任务

这种按均分配的效果效率低下，我们应该遵循能者多劳的方式去分配任务

能者多劳

修改配置文件，让消费者一次只能接收一个任务，当前任务消费完才可以接收下一个任务

spring:
  rabbitmq:
    host: 192.168.137.7
    port: 5672
    username: root
    password: root
    virtual-host: /
    listener:   # 消息确认机制
      simple:
        prefetch: 1

重新启动运行代码

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-yC6unliz-1651579009611)(项目规约.assets/image-20220503170440687.jpg)]

3、Fanout模式

fanout模式也叫广播模式，每一条消息多可以被绑定在同一个交换机上的所有队列的消费者消费

在这里插入图片描述

参数1：交换机：fanout_exchange

参数2：routingkey 在fanout模式不使用，会在direct和topic模式使用

参数3：发送的消息

@Test
  void testFanoutMode(){
    rabbitTemplate.convertAndSend("fanout_exchange","","fanout mode 1");
    rabbitTemplate.convertAndSend("fanout_exchange","","fanout mode 2");
  }

定义消费者

使用@RabbitListener注解中的bindings声明并绑定交换机和队列

@RabbitListener(bindings = @QueueBinding(
          value = @Queue(name = "fanout_queue1"),
          exchange = @Exchange(name = "fanout_exchange2",type = ExchangeTypes.FANOUT)
  ))
  public void fanoutc1(String msg){
    System.out.println("fanoutc1:------------------>"+msg);
  }
  @RabbitListener(bindings=@QueueBinding(
          value = @Queue(name = "fanout_queue2"),
          exchange = @Exchange(name = "fanout_exchange2",type = ExchangeTypes.FANOUT)
  ))
  public void fanoutc2(String msg){
    System.out.println("fanoutc1:------------------>"+msg);
  }

运行结果：

每一条消息都会被所有消费者消费

在这里插入图片描述

4、direct模式

direct模式与fanout模式的区别在于，队列都是绑定同一个交换机，但是在队列上会添加routingkey标识

消费者会根据不同的表示去消费对应队列中的消息

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "direct_queue1"),
        exchange = @Exchange(name = "direct_zs_exchange",type = ExchangeTypes.DIRECT),
        key = "zs_news1"
))
public void direct1(String msg){
  System.out.println("direct_queuq1:---------------------->"+msg);
}
@RabbitListener(bindings = @QueueBinding(
        value = @Queue(name = "direct_queue2"),
        exchange = @Exchange(name = "direct_zs_exchange",type = ExchangeTypes.DIRECT),
        key = "zs_news2"
))
public void direct2(String msg){
  System.out.println("direct_queuq2:---------------------->"+msg);
}

在这里插入图片描述

@Test
void testDirectMode(){
  rabbitTemplate.convertAndSend("direct_zs_exchange","zs_news1","direct mode1");
  rabbitTemplate.convertAndSend("direct_zs_exchange","zs_news2","direct mode2");
}

在这里插入图片描述

5、topic模式

  • Topic交换机接收的消息RoutingKey必须是多个单词，以 **.** 分割
  • Topic交换机与队列绑定时的bindingKey可以指定通配符
  • #：代表0个或多个词
  • *：代表1个词
@RabbitListener(bindings = @QueueBinding(
          value = @Queue(name = "topic_queue1"),
          exchange = @Exchange(name = "topic_zs_exchange",type = ExchangeTypes.TOPIC),
          key = "zs_new.#"
  ))
  public void topic1(String msg){
    User user = JSONUtil.toBean(msg, User.class);
    System.out.println(user.toString());
  }
  @RabbitListener(bindings = @QueueBinding(
          value = @Queue(name = "topic_queue1"),
          exchange = @Exchange(name = "topic_zs_exchange",type = ExchangeTypes.TOPIC),
          key = "#.zs_new"
  ))
  public void topic2(String msg){
    User user = JSONUtil.toBean(msg, User.class);
    System.out.println(user.toString());
  }

在这里插入图片描述

@Test
void testTopicMode(){
  String jsonStr1 = JSONUtil.toJsonStr(new User("小爽", 22));
  rabbitTemplate.convertAndSend("topic_zs_exchange","zs_new.user",jsonStr1);
  String jsonStr2 = JSONUtil.toJsonStr(new User("路飞", 17));
  rabbitTemplate.convertAndSend("topic_zs_exchange","lufei.zs_new",jsonStr2);
}

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-bM3FuukA-1651579009617)(使用攻略.assets/image-20220503195525092.jpg)]

到此这篇关于SpringBoot整合RabbitMQ的5种模式的注解绑定详解的文章就介绍到这了,更多相关RabbitMQ 5种模式的注解绑定内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • IDEA中try catch抛异常快捷键分享

    IDEA中try catch抛异常快捷键分享

    在编写Java代码时,使用IDEA的快捷键CTRL+ALT+t可以快速生成try..catch语句块,有效提高编码效率,首先选择需要处理的代码片段,然后按下快捷键,选择try/catch选项,即可自动包围选中代码,这一快捷操作简化了异常处理步骤,减少了手动编写的时间,是编程中的实用技巧
    2024-10-10
  • Android中几种图片特效的处理的实现方法

    Android中几种图片特效的处理的实现方法

    这篇文章主要介绍了 Android中几种图片特效的处理的实现方法的相关资料,这里有放大缩小图片，获得圆角图片，获得带倒影图片的几种方法，需要的朋友可以参考下
    2017-08-08
  • Spring IOC和DI实现原理及实例解析

    Spring IOC和DI实现原理及实例解析

    这篇文章主要介绍了Spring IOC和DI实现原理及实例解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-06-06
  • springboot解决前后端分离时的跨域问题

    springboot解决前后端分离时的跨域问题

    这篇文章主要介绍了springboot如何解决前后端分离时的跨域问题，帮助大家更好的理解和学习使用springboot，感兴趣的朋友可以了解下
    2021-04-04
  • 分析mybatis运行原理

    分析mybatis运行原理

    Mybatis是一个优秀的持久层框架，它对JDBC操作数据库的过程进行封装，使开发者只需要关注sql本身。我们原来使用JDBC操作数据库，需要手动的写代码去注册驱动、获取connection、获取statement等等，现在Mybaits帮助我们把这些事情做了，我们只需要关注我们的业务sql即可
    2021-06-06
  • 教你怎么用java实现客户端与服务器一问一答

    教你怎么用java实现客户端与服务器一问一答

    这篇文章主要介绍了教你怎么用java实现客户端与服务器一问一答,文中有非常详细的代码示例,对正在学习java的小伙伴们有非常好的帮助,需要的朋友可以参考下
    2021-04-04
  • mybatis如何获取刚刚新插入数据的主键值id

    mybatis如何获取刚刚新插入数据的主键值id

    这篇文章主要介绍了mybatis如何获取刚刚新插入数据的主键值id问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-08-08
  • packages思维及使用Java添加Android平台特定实现

    packages思维及使用Java添加Android平台特定实现

    这篇文章主要为大家介绍了packages思维及使用Java添加Android平台特定实现在Flutter框架里的体现和运用详解，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-12-12
  • Spring Session的使用示例

    Spring Session的使用示例

    最近团队一个项目需要使用Session，之前没有在实际项目中使用过Spring-Session，这里记录一下使用的过程
    2021-06-06
  • Java线程通信详解

    Java线程通信详解

    本篇文章主要介绍了Java线程通信问题，线程通信用来保证线程协调运行，有需要的朋友可以了解一下。
    2016-10-10

最新评论