十七、SpringAMQP

目录

一、SpringAMQP的介绍：

二、利用SpringAMQP实现HelloWorld中的基础消息队列功能

1、因为publisher和consumer服务都需要amqp依赖，因此这里把依赖直接放到父工程mq-demo中

2、编写yml文件

3、编写测试类，并进行测试

三、在consumer中编写消费逻辑，监听simple.queue

1、导入依赖，刚才在父工程中已经导入了，所以省略

2、编写yml文件

3、新建类，实现消费逻辑

4、运行并测试

四、模拟WorkQueue，实现一个队列绑定多个消费者

1、编写生产者（生产50个消息）

2、编写消费者（一个消费者更快，一个消费者更慢）

3、测试

4、消费预取的修改

5、重新测试

五、发布和订阅

（一）利用SpringAMQP演示FanoutExchange的使用

1、新建config类，声明交换机和队列

2、启动项目，查看配置

3、编写消费者代码

4、编写生产者代码

5、运行代码，观察输出

（二）交换机的作用

（三）声明队列、交换机、绑定关系的Bean是什么?

（四）DirectExchange

1、编写消费者代码

2、编写生产者代码

（五）Direct交换机与Fanout交换机的差异

（六）TopicExchange

1、编写消费者代码

2、编写生产者代码

3、运行测试

4、描述下Direct交换机与Topic交换机的差异

（七）测试发送Object类型信息

1、新增队列

2、发送对象

3、查看

4、优化（使用jackson进行序列化）

5、接收消息

一、SpringAMQP的介绍：

  1. AMQP是一种高级消息队列协议。

  2. SpringAMQP是基于Spring Framework的AMQP扩展，提供了一个抽象层，使得使用AMQP进行消息传递变得更加简单。

  3. SpringAMQP支持多种消息传递模式，包括点对点、发布/订阅和请求/响应等。

  4. SpringAMQP提供了许多高级功能，例如队列管理、消息确认、事务和消息过滤等。

  5. SpringAMQP提供了集成测试工具和基于Spring Boot的自动配置，使得集成AMQP变得更加容易。

  6. 总之，SpringAMQP是一个灵活、可扩展的AMQP实现，它使得使用消息队列时变得更加容易和高效。

二、利用SpringAMQP实现HelloWorld中的基础消息队列功能

1、因为publisher和consumer服务都需要amqp依赖，因此这里把依赖直接放到父工程mq-demo中

<!--        AMQP依赖，包含RabbitMQ--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>

2、编写yml文件

logging:pattern:dateformat: MM-dd HH:mm:ss:SSS
spring:rabbitmq:host: 192.168.248.152port: 5672virtual-host: /username: itcastpassword: 123456

3、编写测试类，并进行测试

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringAmqpTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSendMassage(){String queue = "simple.queue";String massage="aaaaaaa";rabbitTemplate.convertAndSend(queue,massage);}
}

三、在consumer中编写消费逻辑，监听simple.queue

1、导入依赖，刚才在父工程中已经导入了，所以省略

2、编写yml文件

logging:pattern:dateformat: MM-dd HH:mm:ss:SSS
spring:rabbitmq:host: 192.168.248.152port: 5672virtual-host: /username: itcastpassword: 123456

3、新建类，实现消费逻辑

package cn.itcast.mq.listener;import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class SpringRabbitListener {@RabbitListener(queues = "simple.queue")public void listenSimpleQueue(String msg){System.out.println("消费者接收到消息："+msg);}
}

4、运行并测试

注意:

消息一旦消费就会从队列删除，RabbitMQ没有消息回溯功能

四、模拟WorkQueue，实现一个队列绑定多个消费者

1、编写生产者（生产50个消息）

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringAmqpTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testSendMassage(){String queue = "simple.queue";String massage="HelloWorld";for (int i = 0; i < 50; i++) {rabbitTemplate.convertAndSend(queue,massage);}}
}

2、编写消费者（一个消费者更快，一个消费者更慢）

@Component
public class SpringRabbitListener {@RabbitListener(queues = "simple.queue")public void listenSimpleQueue(String msg){System.out.println("消费者0接收到消息："+msg+ LocalTime.now());try {Thread.sleep(20);} catch (InterruptedException e) {throw new RuntimeException(e);}}@RabbitListener(queues = "simple.queue")public void listenSimpleQueue1(String msg){System.err.println("消费者1接收到消息__________-："+msg+ LocalTime.now());try {Thread.sleep(200);} catch (InterruptedException e) {throw new RuntimeException(e);}}
}

3、测试

我们发现，虽然消费者0更快，但是它并没有承担更多的工作量；

这是因为消费预取机制会让消费者事先分配好要处理的消息，而不是按能力分配；

4、消费预取的修改

可以在yml文件中修改

    listener:simple:prefetch: 1 #表示预取上限为1

5、重新测试

五、发布和订阅

（一）利用SpringAMQP演示FanoutExchange的使用

1、新建config类，声明交换机和队列
@Configuration
public class FanoutConfig {///1@Beanpublic FanoutExchange fanoutExchange(){return new FanoutExchange("itcast.fanout");}@Beanpublic Queue fanoutQueue1(){return new Queue("fanout.queue1");}@Beanpublic Binding bindingQueue1(FanoutExchange exchange,Queue fanoutQueue1){return BindingBuilder.bind(fanoutQueue1).to(exchange);}///2@Beanpublic Queue fanoutQueue2(){return new Queue("fanout.queue2");}@Beanpublic Binding bindingQueue2(FanoutExchange exchange,Queue fanoutQueue2){return BindingBuilder.bind(fanoutQueue2).to(exchange);}
}
2、启动项目，查看配置

绑定成功

3、编写消费者代码
    @RabbitListener(queues = "fanout.queue1")public void listenFanoutQueue1(String msg){System.err.println("消费者1接收到消息__________-："+msg+ LocalTime.now());}@RabbitListener(queues = "fanout.queue2")public void listenFanoutQueue2(String msg){System.err.println("消费者2接收到消息__________-："+msg+ LocalTime.now());}
4、编写生产者代码
    @Testpublic void sendFanoutMassage(){String exchangeName = "itcast.fanout";String message = "Hello Every One";rabbitTemplate.convertAndSend(exchangeName,"",message);}
5、运行代码，观察输出

发现两个消费者都接收到了消息

（二）交换机的作用

  • 接收publisher发送的消息
  • 将消息按照规则路由到与之绑定的队列
  • 不能缓存消息，路由失败，消息丢失
  • FanoutExchange的会将消息路由到每个绑定的队列

（三）声明队列、交换机、绑定关系的Bean是什么?

  • Queue
  • FanoutExchange
  • Binding
     

（四）DirectExchange

实现：

1、编写消费者代码
    @RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue2"),exchange = @Exchange(name = "itcast.direct",type = ExchangeTypes.DIRECT),key = {"red","blue"}))public void listenDirectQueue1(String msg){System.err.println("消费者1接收到消息__________-："+msg+ LocalTime.now());}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue2"),exchange = @Exchange(name = "itcast.direct",type = ExchangeTypes.DIRECT),key = {"red","yellow"}))public void listenDirectQueue2(String msg){System.out.println("消费者2接收到消息__________-："+msg+ LocalTime.now());}
2、编写生产者代码
    @Testpublic void sendDirectMassage(){String exchangeName = "itcast.direct";String message = "Hello Every One1111";rabbitTemplate.convertAndSend(exchangeName,"blue",message);}
    @Testpublic void sendDirectMassage(){String exchangeName = "itcast.direct";String message = "Hello Every One1111";rabbitTemplate.convertAndSend(exchangeName,"red",message);}

（五）Direct交换机与Fanout交换机的差异

  • Fanout交换机将消息路由给每一个与之绑定的队列
  • Direct交换机根据RoutingKey判断路由给哪个队列
  • 如果多个队列具有相同的RoutingKey，则与Fanout功能类似
     

基于@RabbitListener注解声明队列和交换机有哪些常见注解

  • @Queue
  • @Exchange
     

（六）TopicExchange

利用SpringAMQP演示TopicExchange的使用

1、编写消费者代码
    @RabbitListener(bindings = @QueueBinding(value = @Queue(name = "topic.queue1"),exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),key = "china.#"))public void listenTopicQueue1(String msg){System.out.println("消费者1接收到消息aaaaaa__-："+msg+ LocalTime.now());}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "topic.queue2"),exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),key = "#.news"))public void listenTopicQueue2(String msg){System.err.println("消费者2接收到消息a__-："+msg+ LocalTime.now());}
2、编写生产者代码
    @Testpublic void sendTopicMassage(){String exchangeName = "itcast.topic";String message = "Hello Every One12222";rabbitTemplate.convertAndSend(exchangeName,"china.news",message);}
3、运行测试

4、描述下Direct交换机与Topic交换机的差异

（七）测试发送Object类型信息

1、新增队列
    @Beanpublic Queue objectQueue(){return new Queue("object.queue");}
2、发送对象
    @Testpublic void sendObjectMassage(){Map<String ,Object> message = new HashMap<>();message.put("name","11");message.put("age","22");rabbitTemplate.convertAndSend("object.queue",message);}
3、查看

对象被序列化了，这种方式性能差，不安全（容易被注入）

4、优化（使用jackson进行序列化）

引入依赖 

        <dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId></dependency>

添加配置Bean

    @Beanpublic Jackson2JsonMessageConverter messageConverter(){return new Jackson2JsonMessageConverter();}

5、接收消息

编写配置Bean

    @Beanpublic Jackson2JsonMessageConverter messageConverter(){return new Jackson2JsonMessageConverter();}

编写消费者代码

@RabbitListener(queues = "object.queue")
public void listenObjectQueue1(Map<String,Object> msg){System.err.println("消费者接收到消息___da_______-："+msg+ LocalTime.now());
}

验证

注意：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/158313.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

HarmonyOS ArkTS 应用添加弹窗（八）

HarmonyOS ArkTS 应用添加弹窗（八）

概述 在我们日常使用应用的时候&#xff0c;可能会进行一些敏感的操作&#xff0c;比如删除联系人&#xff0c;这时候我们给应用添加弹窗来提示用户是否需要执行该操作&#xff0c;如下图所示&#xff1a; 弹窗是一种模态窗口&#xff0c;通常用来展示用户当前需要的或用户必须…
阅读更多...
去除表格中的网格线

去除表格中的网格线

去除表格中的网格线 在excel中如何得到下图2的效果 点开视图&#xff0c;去除网格线 最后输出为图片
阅读更多...
「L2C」型行业从线索到成交，听懂客户之「声」是关键

「L2C」型行业从线索到成交，听懂客户之「声」是关键

存量经营时代下&#xff0c;营销变得越来越难。无论是稳流量&#xff0c;或是促活跃&#xff0c;转化率就是难以提升。 相比传统快消行业&#xff0c;线索型&#xff08;L2C&#xff0c;Leads to Cash&#xff09;行业因为客单价高、决策周期长、用户触点分散等特性&#xff0…
阅读更多...
CRM系统中的联系人是什么？如何进行联系人管理？

CRM系统中的联系人是什么？如何进行联系人管理？

上手CRM系统前掌握专业术语是必要的功课&#xff0c;在第一次使用CRM系统时小编和大家一样&#xff0c;分不清楚线索、联系人、客户、商机之间的关系&#xff0c;今天我们就来着重分享一下CRM中联系人是什么&#xff1f;如何进行联系人管理&#xff1f; CRM系统联系人是指能够…
阅读更多...
2023年国自然植物科学相关面上项目信息公布（小麦、大麦、棉花、大豆、玉米）

2023年国自然植物科学相关面上项目信息公布（小麦、大麦、棉花、大豆、玉米）

2024年申报国自然项目基金撰写及技巧http://mp.weixin.qq.com/s?__bizMzA4NTAwMTY1NA&mid2247575761&idx1&sn32dbacd3393f3b76a1e0668e4b8b3c89&chksm9fdd7c08a8aaf51ec31d4790067bb57751a09947eeb7e728b8c008d26b89adba37e0cab32a62&scene21#wechat_redi…
阅读更多...
梨花声音课堂，真诚和情感展现家庭生活场景，易使观众产生共鸣

梨花声音课堂，真诚和情感展现家庭生活场景，易使观众产生共鸣

在为家庭剧的配音工作时&#xff0c;配音员要能够传递出剧中角色在日常生活中所经历的情感波动&#xff0c;以及家庭关系中的温情、矛盾和解决问题的过程。家庭剧着重描绘亲情纽带和人物间的真挚交往&#xff0c;因此配音的真实感和情感表达尤为重要。以下是针对家庭剧配音的几…
阅读更多...
毕业设计2049网上选课系统JSP【程序源码+文档+调试运行】

毕业设计2049网上选课系统JSP【程序源码+文档+调试运行】

摘要 本文详细介绍了一个网上选课系统的设计与实现过程。该系统主要分为学生用户、管理员和教师用户三个模块&#xff0c;涵盖了用户登录、在线选课、信息管理、密码修改等功能。通过对系统功能的分析&#xff0c;进行了数据库设计和界面设计&#xff0c;并进行了测试和优化。…
阅读更多...
Java线程的学习

Java线程的学习

本来我以为这可能只是Java里的一小块知识点&#xff0c;但当我搜索自己关注的Up主的网课时&#xff0c;觉得还是开一个系列来记录好了。我的记录绝不仅仅是照搬课程中的内容&#xff0c;我会带上自己的理解以及示例代码、并且是按照本人的专业课老师上课的节奏来记录&#xff0…
阅读更多...
Redisson 分布式锁实战应用解析

Redisson 分布式锁实战应用解析

文章目录 前言一、Redisson介绍二、Redisson的使用1.1 引入依赖1.2 编写配置1.3 示例测试_011.4 示例测试_02 三、Redisson源码分析2.1 加锁源码2.2 看门狗机制 前言 分布式锁主要是解决分布式系统下数据一致性的问题。在单机的环境下&#xff0c;应用是在同一进程下的&#x…
阅读更多...
【报错记录】解决使用Kotlin写的SpringBoot项目使用Aspect切面无法生效的问题

【报错记录】解决使用Kotlin写的SpringBoot项目使用Aspect切面无法生效的问题

前言 为了能在SpringBoot使用Kotlin&#xff0c;真的是各种坑都彩礼一遍&#xff0c;这次遇到的问题是Aspect无法对Kotlin代码生效。我这里的使用场景是使用切面切Controller中的方法&#xff0c;用来对接口进行一些初始化和收尾工作。 Aspect在Controller类还是Java代码的时…
阅读更多...
迁新址 启新程｜美创科技杭州总部乔迁仪式圆满举行

迁新址 启新程｜美创科技杭州总部乔迁仪式圆满举行

“迁新址 启新程” 2023年11月21日 美创科技杭州总部乔迁仪式隆重举行 杭州未来科技城管委会、余杭国投集团、浙江省网络空间安全协会、浙江鸿程、华睿投资、金艮投资、如山资本、赛伯乐投资、宽带资本、普华投资、国中创投、密码资本、东方富海、之江商学、阿里云、联通&…
阅读更多...
cc linux用root用户执行chmod 777 -R ./提示 Operation not permitted怎么办？

cc linux用root用户执行chmod 777 -R ./提示 Operation not permitted怎么办？

如果你作为 root 用户执行 chmod 777 -R ./ 命令时收到 “Operation not permitted” 错误&#xff0c;可能有几个原因&#xff1a; 不可更改 (Immutable) 文件属性&#xff1a; 文件可能被设置为不可更改。即使是 root 用户也不能修改这些文件的权限。使用 lsattr 命令查看文件…
阅读更多...
Oracle与Redis Enterprise协同，作为企业缓存解决方案

Oracle与Redis Enterprise协同，作为企业缓存解决方案

来源&#xff1a;虹科云科技 虹科干货丨Oracle与Redis Enterprise协同&#xff0c;作为企业缓存解决方案 欢迎关注虹科&#xff0c;为您提供最新资讯&#xff01; 单独使用Oracle作为企业缓存数据库时&#xff0c;会出现哪些问题呢&#xff1f;使用Redis Enterprise与Oracle共…
阅读更多...
使用 Filebeat+Easysearch+Console 打造日志管理平台

使用 Filebeat+Easysearch+Console 打造日志管理平台

近年来&#xff0c;日志管理平台越来越流行。使用日志管理平台可以实时地、统一地、方便地管理和查看日志&#xff0c;挖掘日志数据价值&#xff0c;驱动运维、运营&#xff0c;提升服务管理效率。 方案架构 Beats 是轻量级采集器&#xff0c;包括 Filebeat、Metricbeat 等。E…
阅读更多...
基于vue的three.js学习

基于vue的three.js学习

vue安装three.js&#xff0c;并创建第一个入门场景 安装three.js npm install --save three引入three.js import * as THREE from threethree.js结构 three.js坐标 创建一个场景 scene场景&#xff0c;camera相机&#xff0c;renderer渲染器 创建一个场景 this.scene new T…
阅读更多...
这7款神仙软件，程序员必备！

这7款神仙软件，程序员必备！

如果你是程序员、开发者、网络运维等 IT 从业者日常工作中大家肯定会用到很多网站&#xff0c;今天给大家带来7款压箱底的神仙软件&#xff0c;希望可以帮助有需要的码农朋友实现更高效地办公。 一、Everything 适用&#xff1a;本地文件搜索神器 就是为了极速检索而生,其实…
阅读更多...
yapi==使用依赖包里的类作为入参/返回值导出后没有备注

yapi==使用依赖包里的类作为入参/返回值导出后没有备注

比如模块A中有个MyDemoEntity类&#xff0c;在B中以依赖的形式引入了A&#xff0c;并在B的接口中以MyDemoEntity作为返回值&#xff0c;导出到YAPI发现MyDemoEntity的备注没了。 解决&#xff1a; 将A的内容安装到本地MAVEN仓库&#xff0c;并且需要将源码也一起安装 <buil…
阅读更多...
探索锦食送如何通过API集成无代码开发技术提高电商平台和营销系统效率

探索锦食送如何通过API集成无代码开发技术提高电商平台和营销系统效率

探索锦食送无代码开发集成技术 随着电子商务和营销系统的快速发展&#xff0c;企业不断寻求更高效和灵活的管理方式。锦食送&#xff0c;作为高端餐饮外卖服务的领先者&#xff0c;通过无代码开发的API集成技术&#xff0c;实现了电商平台和营销系统的高效管理。这种创新的连接…
阅读更多...
# 学习 Prolog 和 离散逻辑的16个等价公式：一趟有趣的逻辑之旅

# 学习 Prolog 和 离散逻辑的16个等价公式：一趟有趣的逻辑之旅

Prolog 的语法很奇怪,需要一些时间来适应,所以我花了点时间,想用Prolot来学习和验证离散逻辑的16组等价公式。 1. 双重否定律 (Double Negation Law) A ⇔A 首先&#xff0c;我们来看看双重否定律。在 Prolog 中&#xff0c;我们可以这样验证它&#xff1a; fun1(A,Z):-memb…
阅读更多...
干货分享：本地生活服务商入驻申请需要哪些条件？附更快捷的方法！

干货分享：本地生活服务商入驻申请需要哪些条件？附更快捷的方法！

在数字化时代&#xff0c;本地服务市场已经成为各大平台争夺的重要阵地。抖音不仅在短视频市场占有一席之地&#xff0c;同时也在如火如荼的开发着本地服务市场&#xff0c;相继支付宝、视频号也推出了本地生活服务商模式。本文将介绍抖音本地生活服务商的申请条件&#xff0c;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023