RabbitMq的使用

最近处理访客记录所以，来学习下rabbitMQ。之前同事已经写好了，这里只需要进行消费，后续会逐渐完善。

0.介绍

0.1交换机（Exchanges）

rabbitmq中生产者发送的消息都是发送到交换机，再由交换机推入队列。所以生产者不知道队列去了哪里，就靠Exchage来控制，交换机总共有以下几种类型。

0.1.1广播模式（fanout）

扇出所有消息进入队列，类似广播。

0.1.2直接交换（direct）

绑定相关的routerKey分发到不同的队列，简单说就是direct交换机接收了消息后，根据关键词分发队列。

0.1.2主题模式（topic）

direct路由比较单一，所以提升了routerKey的能力，在关键词标记下加上了通配符。
*(星号)可以代替一个单词
#(井号)可以替代零个或多个单词

1.公共配置类

spring:rabbitmq:host: 127.0.0.1port: 5672username: guestpassword: guest

/*** 类描述：RabbitMQ公共配置类** @ClassName RabbitMQConfig* @Author ward* @Date 2023-08-18 10:28*/
public class RabbitMQConfig {/*** RabbitMQ的队列主题名称*/public static final String RABBITMQ_TOPIC = "rabbitmqTopic";/*** RabbitMQ的DIRECT交换机名称*/public static final String RABBITMQ_DIRECT_EXCHANGE = "rabbitmqDirectExchange";/*** RabbitMQ的Direct交换机和队列绑定的匹配键 DirectRouting*/public static final String RABBITMQ_DIRECT_ROUTING = "rabbitmqDirectRouting";
}

2.消费消息的两种方式

把记录塞进队列里的时候，只是完成了第一步，那你肯定要对他进行消费。分为两种推模式和拉模式：推模式就是生产者发布消息时，主动推送给消费者；拉模式则是消费者发送请求后才会发送。

2.1

3.监听队列的两种方式

一种是@RabbitListener注解的方式，一种是实现springboot:ChannelAwareMessageListener接口的方式

3.1@RabbitListener

如果demoData想不转换成String直接推，得在这个数据流实现序列化。

innerRabbitTemplate.convertAndSend(InnerMQConfig.TOPIC_EXCHANGE, msgKey, JSONObject.toJSONString(demoData));

@Component
public class DemoRabbitMQListener {//定义方法进行信息的监听(queues表示队列名称)@RabbitListener(queues = "demo_queue")@RabbitHandlerpublic void demoQueue(Message message){System.out.println("message:"+message.getBody());}
}

3.2实现ChannelAwareMessageListener接口

听前辈说直接实现这个接口，就不用管底层是谁的消息队列了，因为是基于Springboot，后续我会逐步求证，做需求只能先用着。这个实现起来有点麻烦，我总结了以下顺序：

3.2.1.创建连接工厂（ConnectionFactory——MQ连接工厂 ）

publisherConfirms：消息发送到exchange，返回成功或者失败。
publishReturns：消息从exchange到queue，发送成功或者失败。
后续在DemoRabbitTemplate会演示回调

    @Bean(name = "DemoConnectionFactory")@Primarypublic ConnectionFactory connectionFactory() {//创建连接CachingConnectionFactory connectionFactory = new CachingConnectionFactory();// 主机地址connectionFactory.setHost(host);// 连接端口;默认为 5672connectionFactory.setPort(port);// 连接用户名；默认为guestconnectionFactory.setUsername(username);// 连接密码；默认为guestconnectionFactory.setPassword(password);// 虚拟主机名称;默认为 /connectionFactory.setVirtualHost(virtualHost);// 开启消息发送至RabbitMQ 的回调connectionFactory.setPublisherConfirms(true);// 开启消息发送至队列失败的回调connectionFactory.setPublisherReturns(true);return connectionFactory;}

3.2.2.初始化组件（rabbitAdmin ——对MQ进行初始化的Spring组件）

    @Bean(name = "DemoRabbitAdmin")@Primarypublic RabbitAdmin rabbitAdmin(@Qualifier("DemoConnectionFactory") ConnectionFactory connectionFactory) {RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);// 只有设置为 true，spring 才会加载 RabbitAdmin 这个类rabbitAdmin.setAutoStartup(true);return rabbitAdmin;}

3.2.3.创建交换器（exchange）

这里提供了两种等价的方式，喜欢哪种就用哪种。
durable：是否持久化，RabbitMQ关闭后，没有持久化的Exchange将被清除
autoDelete：是否自动删除，如果没有与之绑定的Queue，直接删除
internal：是否内置的，如果为true，只能通过Exchange到Exchange
arguments：结构化参数
在这里插入图片描述

看了源码之后发现默认只有名字的时候，其实持久化是开的的，自动删除默认就是关闭的。在这里插入图片描述

    /*创建交换器*/@Bean(DEMO_EXCHANGE)public TopicExchange exchange() {return new TopicExchange(DEMO_EXCHANGE, true, false);}

    /*创建交换器*/@Bean(DEMO_EXCHANGE)public Exchange exchange() {return ExchangeBuilder.topicExchange(DEMO_EXCHANGE).durable(true).build();}

3.2.4.创建队列（queue）

创建队列主要掌握这几个参数：
name: 队列名称。
durable： 队列是否持久化。 队列默认是存放到内存中的，rabbitmq重启则丢失，若想重启之后还存在则队列要持久化，保存到Erlang自带的Mnesia数据库中，当rabbitmq重启之后会读取该数据库。
exclusive：是否排他的队列。有两个作用：连接关闭时该队列自动删除；该队列只允许一个消费者访问。
autoDelete：是否自动删除，当最后一个消费者断开连接之后队列是否自动被删除。
arguments： 队列中的消息什么时候会自动被删除 （设置死信交换器和死信队列等设置）
在这里插入图片描述

    /*创建*/@Bean(QUEUE_NAME)public Queue QUEUE_DEMO() {return new Queue(QUEUE_NAME, true, false, false);}

3.2.5.绑定队列到交换机（binding）

    //绑定队列到交换机@Beanpublic Binding BINGING_EXCHANGE_QUEUE(@Qualifier(QUEUE_NAME) Queue queue,@Qualifier(DEMO_EXCHANGE) Exchange exchange) {return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY).noargs();}

3.2.6.创建监听容器（SimpleMessageListenerContainer）

    //创建监听容器@Beanpublic SimpleMessageListenerContainer simpleMessageListenerContainer(@Qualifier("DemoConnectionFactory") ConnectionFactory connectionFactory,DemoRabbitMQListener demoRabbitMQListener,@Qualifier(QUEUE_NAME) Queue queue) throws AmqpException {SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer(connectionFactory);//消费者个数listenerContainer.setConcurrentConsumers(listenerSize);listenerContainer.setQueues(queue);listenerContainer.setExposeListenerChannel(true);//设置接收方式，AUTO-自动接收，MANUAL-手动接收，NULL-不接收listenerContainer.setAcknowledgeMode(AcknowledgeMode.AUTO);//监听处理类（自己消费端写的类）listenerContainer.setMessageListener(demoRabbitMQListener);return listenerContainer;}

3.2.7.创建操作类（RabbitTemplate）

setConfirmCallback的消息回调是在生产者端要把参数丢进去的。

    @Bean(name = "DemoRabbitTemplate")@Primary//多个实现类使用该注解public RabbitTemplate rabbitTemplate(@Qualifier("DemoConnectionFactory") ConnectionFactory connectionFactory) {RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);//触发setReturnCallback回调必须设置mandatory=true,否则Exchange没有找到Queue就会丢弃掉消息,而不会触发回调rabbitTemplate.setMandatory(true);//设置连接工厂rabbitTemplate.setConnectionFactory(connectionFactory);//消息是否成功发送到Exchange回调rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {/*** 确认消息送到交换机(Exchange)回调* @param correlationData* @param ack* @param cause*/@Overridepublic void confirm(CorrelationData correlationData, boolean ack, String cause) {log.info("确认消息送到交换机(Exchange)结果：");log.info("相关数据：{}", correlationData);boolean ret = false;if (ack) {log.info("消息发送到交换机成功, 消息 = {}", correlationData.getId());//下面可自定义业务逻辑处理，如入库保存信息等} else {log.error("消息发送到交换机失败! 消息: {}}; 错误原因:cause: {}", correlationData.getId(), cause);//下面可自定义业务逻辑处理，如入库保存信息等}}});//消息是否从Exchange路由到QueuerabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {/*** 失败回调：只有消息没有投递给指定的队列* @param message  投递失败的消息详细信息* @param replyCode 回复的状态码* @param replyText 回复的文本内容* @param exchange 当时这个消息发给那个交换机* @param routingKey 当时这个消息用那个路由键*/@Overridepublic void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {//获取消息idString messageId = message.getMessageProperties().getMessageId();// 内容String result = null;try {result = new String(message.getBody(), "UTF-8");} catch (Exception e) {log.error("消息发送失败", e);}log.error("消息发送失败, 消息ID = {}; 消息内容 = {}", messageId, result);//下面可自定义业务逻辑处理，如入库保存信息等}});return rabbitTemplate;}

3.2.8.监听消费（RabbitMQListener）

这个类要注意用@Service或者@Compet注解让他交给IOC

@Service
@Slf4j
public class DemoRabbitMQListener implements ChannelAwareMessageListener {@Overridepublic void onMessage(Message message, Channel channel) throws Exception {log.info("message:{}", message.getBody());//todo: 接下来就是各自的业务逻辑，就是消费环节}
}

3.子标题

正文

在这里插入代码片

4.子标题

正文

在这里插入代码片

5.子标题

正文

在这里插入代码片

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

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

相关文章

TouchGFX之存储器映射闪存

TouchGFX之存储器映射闪存

对于大多数项目，建议使用外部闪存，因为这允许应用程序使用多个大型图像。 即便最普通的应用程序，内部闪存也可能会很快被占用完。 1.配置QSPI（嵌入式基础知识，此处不做分析） 2.编写W25Q256配置代码&#xf…
阅读更多...
Unity 图片资源的适配

Unity 图片资源的适配

前言 最近小编做Unity项目时，发现在资源处理这方面和Android有所不同；例如：Android的资源文件夹res下会有着mipmap-mdpi，mipmap-hdpi，mipmap-xhdpi，mipmap-xxhdpi，mipmap-xxxhdpi这五个文件夹&a…
阅读更多...
睡眠模式下如何快速唤醒电脑，看这里！

睡眠模式下如何快速唤醒电脑，看这里！

这篇文章解释了如何唤醒正在睡觉的电脑，以及如果正常方法不起作用该怎么办。 一、如何从睡眠中唤醒电脑 不管你使用的是什么操作系统，关闭睡眠模式就像唤醒电脑一样简单，你可以通过某种方式与电脑交互来完成： 移动鼠标 滑动触摸板 按键盘上的任意键 有些设备有点不同，只…
阅读更多...
前端需要理解的HTML知识

前端需要理解的HTML知识

HTML（超文本标记语言，HyperText Markup Language）不是编程语言，而是定义了网页内容的含义和结构的标记语言。。“超文本”（hypertext）是指连接单个网站内或多个网站间的网页的链接。HTML 使用“标记”&…
阅读更多...
C++信息学奥赛1119：矩阵交换行

C++信息学奥赛1119：矩阵交换行

解题思路&#xff1a;当输出时换行 解题程序&#xff1a; #include<iostream> using namespace std; int main() {int arr[5][5];// 输入矩阵元素for(int i0;i<5;i){for(int j0;j<5;j){cin>>arr[i][j];}} int n,m;cin>>n>>m;// 根据条件进行矩…
阅读更多...
java八股文面试[数据结构]——Map有哪些子类

java八股文面试[数据结构]——Map有哪些子类

知识来源&#xff1a; 【23版面试突击】 用过哪些Map类&#xff0c;都有什么区别&#xff0c;HashMap是线程安全的吗&#xff1f;_哔哩哔哩_bilibili https://www.cnblogs.com/bubbleboom/p/12694013.html
阅读更多...
OpenCV中QR二维码的生成与识别(CIS摄像头解析)

OpenCV中QR二维码的生成与识别(CIS摄像头解析)

1、QR概述 QR(Quick Response)属于二维条码的一种&#xff0c;意思是快速响应的意思。QR码不仅信息容量大、可靠性高、成本低&#xff0c;还可表示汉字及图像等多种文字信息、其保密防伪性强而且使用非常方便。更重要的是QR码这项技术是开源的&#xff0c;在移动支付、电影票、…
阅读更多...
Php“牵手”淘宝商品快递费用数据采集方法,淘宝API接口申请指南

Php“牵手”淘宝商品快递费用数据采集方法,淘宝API接口申请指南

淘宝天猫商品快递费用接口 API 是开放平台提供的一种 API 接口&#xff0c;它可以帮助开发者获取商品的详细信息&#xff0c;包括商品的标题、描述、图片&#xff0c;发货地址&#xff0c;快递费用&#xff0c;区域ID&#xff0c;等信息。在电商平台的开发中&#xff0c;快递费…
阅读更多...
使用ctcloss训练矩阵生成目标字符串

使用ctcloss训练矩阵生成目标字符串

首先我们需要明确 c t c l o s s ctcloss ctcloss是用来做什么的。比如说我们要生成的目标字符串长度为 l l l&#xff0c;而这个字符串包含 s s s个字符&#xff0c;字符串允许的最大长度为 L L L&#xff0c;这里我们认为一个位置是一个时间步&#xff0c;就是一拍&#xff0…
阅读更多...
2023网络建设与运维模块三：服务搭建与运维

2023网络建设与运维模块三：服务搭建与运维

任务描述： 随着信息技术的快速发展，集团计划2023年把部分业务由原有的X86架构服务器上迁移到ARM架构服务器上，同时根据目前的部分业务需求进行了部分调整和优化。 一、X86架构计算机操作系统安装与管理 1.PC1系统为ubuntu-desktop-amd64系统（已安装，语言为英文），登录用户…
阅读更多...
Python之Qt输出UI

Python之Qt输出UI

安装PySide2 输入pip install PySide2安装Qt for Python&#xff0c;如果安装过慢需要翻墙&#xff0c;则可以使用国内清华镜像下载&#xff0c;输入命令pip install --user -i https://pypi.tuna.tsinghua.edu.cn/simple PySide2&#xff0c;如下图&#xff0c; 示例Demo i…
阅读更多...
2023第四届中国白茶始祖文化节在世界白茶发源地福鼎举办

2023第四届中国白茶始祖文化节在世界白茶发源地福鼎举办

天下白茶&#xff0c; 源于太姥。农历七月初七&#xff0c;是中国白茶始祖太姥娘娘羽化成仙的纪念日&#xff0c;8月22日上午由福鼎市茶业协会、福鼎市中国白茶始祖太姥文化研究会指导&#xff0c;由福鼎市太姥山茶业商会主办&#xff0c;由福建省天湖茶业有限公司、福建品品香…
阅读更多...
最长有效括号——力扣32

最长有效括号——力扣32

int longestValidParentheses(string s){int res=0, n=s.size();int left=0
阅读更多...
Cyanine3 NHS ester生物分子的标记与共价结合1032678-38-8

Cyanine3 NHS ester生物分子的标记与共价结合1032678-38-8

​欢迎来到星戈瑞荧光stargraydye&#xff01;小编带您盘点&#xff1a; Cyanine3 NHS ester是一种荧光染料&#xff0c;可用于将含有游离氨基&#xff08;-NH2&#xff09;的生物分子如蛋白质、抗体、肽段、核酸等进行标记和共价结合。这个过程通常称为NHS酯化反应&#xff0c…
阅读更多...
2023年7月天猫糕点市场数据分析（天猫数据怎么看）

2023年7月天猫糕点市场数据分析（天猫数据怎么看）

烘焙食品行业是近几年食品领域比较火热的赛道之一&#xff0c;随着居民饮食结构的变化&#xff0c;人均消费水平的上升&#xff0c;蛋糕、面包等烘焙糕点越发成为消费者饮食的重要组成部分。同时&#xff0c;在烘焙糕点市场中&#xff0c;老品牌不断推新迭变&#xff0c;新品牌…
阅读更多...
SpringBoot内嵌Tomcat连接池分析

SpringBoot内嵌Tomcat连接池分析

文章目录 1 Tomcat连接池1.1 简介1.2 架构图1.2.1 JDK线程池架构图1.2.2 Tomcat线程架构 1.3 核心参数1.3.1 AcceptCount1.3.2 MaxConnections1.3.3 MinSpareThread/MaxThread1.3.4 MaxKeepAliveRequests1.3.5 ConnectionTimeout1.3.6 KeepAliveTimeout 1.4 核心内部线程1.4.1 …
阅读更多...
设计模式——开闭原则

设计模式——开闭原则

文章目录 基本介绍看下面一段代码方式 1 的优缺点改进的思路分析 基本介绍 开闭原则&#xff08;Open Closed Principle&#xff09;是编程中最基础、最重要的设计原则 一个软件实体如类&#xff0c;模块和函数应该对扩展开放(对提供方)&#xff0c;对修改关闭(对使用方)。用抽…
阅读更多...
SpringBoot+WebSocket搭建多人在线聊天环境

SpringBoot+WebSocket搭建多人在线聊天环境

一、WebSocket是什么&#xff1f; WebSocket是在单个TCP连接上进行全双工通信的协议&#xff0c;可以在服务器和客户端之间建立双向通信通道。 WebSocket 首先与服务器建立常规 HTTP 连接&#xff0c;然后通过发送Upgrade标头将其升级为双向 WebSocket 连接。 WebSocket使得…
阅读更多...
设计模式（3）抽象工厂模式

设计模式（3）抽象工厂模式

一、概述&#xff1a; 1、提供一个创建一系列相关或相互依赖对象的接口&#xff0c;而无须指定它们具体的类。 2、结构图&#xff1a; 3、举例代码&#xff1a; &#xff08;1&#xff09; 实体&#xff1a; public interface IUser {public void insert(User user);public…
阅读更多...
亚马逊云科技 云技能孵化营 初识机器学习

亚马逊云科技 云技能孵化营 初识机器学习

目录 前言 一、课程介绍 二、什么是机器学习 三、机器学习算法进阶过程 四、亚马逊云科技能给我们什么 总结 前言 近期参加了“亚马逊云科技 云技能孵化营”&#xff0c;该孵化营的亚马逊云科技培训与认证团队为开发者准备了云从业者的精要知识及入门课程&#xff0c;帮助…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023