RabbitMQ项目实战(一)

文章目录

  • RabbitMQ项目实战
    • 选择客户端
    • 基础实战

前情提要:我们了解了消息队列,RabbitMQ的入门,交换机,以及核心特性等知识,现在终于来到了激动人心的项目实战环节!本小节主要介绍通过Spring Boot RabbitMQ Starter 在SpringBoot项目中跑通测试RabbitMQ,话不多说,我们马上开始!

RabbitMQ项目实战

选择客户端

怎么在项目中使用RabbitMQ?

  1. 使用官方的客户端(类比jdbc)

优点:兼容性好,换语言成本低,比较灵活
缺点:太灵活,要自己去处理一些事情,比如要自己维护管理链接,很麻烦

  1. 使用封装好的客户端,比如Spring Boot RabbitMQ Starter(类比mybatis)

优点:简单易用,直接配置直接用,更方便地去管理链接
缺点:不够灵活,被框架限制

基础实战

我们使用Spring Boot RabbitMQ Starter
https://spring.io/guides/gs/messaging-rabbitmq/

  1. 引入依赖
    注意:使用的版本一定要和你的springboot版本一致,去maven中心仓库中找版本一致的
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-amqp -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>2.7.2</version>
</dependency>

2) 在yml中引入配置

spring:rabbitmq:host: localhostport: 5672password: guestusername: guest

3)创建交换机和队列,一般在项目启动之前执行创建一次即可

package com.yupi.springbootinit.bimq;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;/*** 用于创建测试程序用到的交换机和队列(只用在程序启动前执行一次)*/
public class MqInitMain {public static void main(String[] args) {try{ConnectionFactory factory  = new ConnectionFactory();factory.setHost("localhost");Connection connection = factory.newConnection();Channel channel = connection.createChannel();String EXCHANGE_NAME = "code_exchange";channel.exchangeDeclare(EXCHANGE_NAME,"direct");String queueName = "code_queue";channel.queueDeclare(queueName,true,false,false,null);channel.queueBind(queueName,EXCHANGE_NAME,"my_routingKey");}catch (Exception e){}}
}

4)生产者代码

package com.yupi.springbootinit.bimq;import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;import javax.annotation.Resource;@Component
public class MyMessageProducer {@Resourceprivate RabbitTemplate rabbitTemplate;public void sendMessage(String exchange,String routingKey,String message){rabbitTemplate.convertAndSend(exchange,routingKey,message);}
}

5)消费者代码

package com.yupi.springbootinit.bimq;import com.rabbitmq.client.Channel;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;@Component
@Slf4j
public class MyMessageConsumer {//使用@SneakyThrows注解简化异常处理//使得你可以在不声明抛出异常的方法中抛出受检异常,而无需捕获它们。这在一些特定情况下可能会很有用,但通常不建议频繁使用,因为它可能会破坏代码的可读性和健壮性。@SneakyThrows//使用@RabbitListener注解指定要监听的队列名称为"code_queue",并设置消息的确认机制为手动确认@RabbitListener(queues = {"code_queue"},ackMode = "MUNAL")// // 在RabbitMQ中,每条消息都会被分配一个唯一的投递标签,用于标识该消息在通道中的投递状态和顺序。通过使用@Header(AmqpHeaders.DELIVERY_TAG)注解,可以从消息头中提取出该投递标签,并将其赋值给long deliveryTag参数。public void reciveMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliverttag){log.info("receiveMessage message = {}", message);//手动确认消息的接收channel.basicAck(deliverttag,false);}
}

测试类测试

package com.yupi.springbootinit.bimq;import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;import javax.annotation.Resource;import static org.junit.jupiter.api.Assertions.*;
@SpringBootTest
class MyMessageProducerTest {@Resourceprivate MyMessageProducer myMessageProducer;@Testvoid sendMessage() {myMessageProducer.sendMessage("code_exchange", "my_routingKey", "你好呀");}
}

image.png
打印出了日志,说明消费者收到了消息,测试通过!
既然测试已经通过,接下来那就把它运用到项目中去吧!欲知后事如何,且听下回分解~

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

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

相关文章

AppsFlyer 接入更新

SDK文档 最新的 SDK 已经支持了 UPM 的接入方式&#xff0c;直接输入链接就可以安装好&#xff0c; 只需要 resolve 通过然后就可以使用了。

盒子模型和圆角边框的属性

一、标准盒子模型 content padding border margin 定义 width 和 height 时&#xff0c;参数值不包括 border 和 padding 二、怪异盒子模型 能不能实现怪异盒子模型全看属性 box-sizing&#xff0c;box-sizing 属性的取值可以为 content-box 或 border-box。 content-b…

CentOS 7 中时间快了 8 小时

1.查看系统时间 1.1 timeZone显示时区 [adminlocalhost ~]$ timedatectlLocal time: Mon 2024-04-15 18:09:19 PDTUniversal time: Tue 2024-04-16 01:09:19 UTCRTC time: Tue 2024-04-16 01:09:19Time zone: America/Los_Angeles (PDT, -0700)NTP enabled: yes NTP synchro…

DRF分页接口

DRF分页接口 目录 DRF分页接口PageNumberPagination&#xff08;基本分页类&#xff09;LimitOffsetPagination&#xff08;偏移分类)CursorPagination&#xff08;游标分页&#xff09; 实战 PageNumberPagination&#xff08;基本分页类&#xff09; 特点 基于页码的分页方式…

CS信息系统建设和服务能力评估申报知识点

代科技快速发展&#xff0c;云计算、大数据、物联网、移动互联网等新一代信息技术发展迅速&#xff0c;信息化服务模式正经历着重大的变化。而CS信息系统建设和服务能力评估是反映信息系统建设和服务提供者的能力水平的一个证书&#xff0c;现在许多企业都在办理这个资质。那么…

2021年全国大学生电子设计竞赛D题——基于互联网的摄像测量系统(三)

13 测试方案和测量结果 测量一个边长为1米的正方形&#xff0c;取三个顶点分别作为O、A、B点。 在O点上方&#xff0c;用细线悬挂激光笔&#xff0c;激光笔常亮向下指示&#xff0c;静止时激光笔的光点和O点重合。 将两个D8M摄像头子卡插到DE10-Nano开发板上&#xff0c;放…

对象生命周期:Transient(瞬态)、Scoped(范围)、Singleton(单例)

在对象生命周期和依赖注入&#xff08;DI&#xff09;的上下文中&#xff0c;特别是在使用如Microsoft.Extensions.DependencyInjection&#xff08;.NET Core的DI容器&#xff09;等框架时&#xff0c;对象的生命周期通常被划分为几个不同的类型&#xff1a;Transient&#xf…

MySQL Linux环境安装部署

目录 1、mysql安装包下载 2、安装mysql服务 3、启动mysql服务 4、登录mysql服务 1、mysql安装包下载 1、查看centos的版本 cat /etc/redhat-release 2、进入官网地址下载对应系统版本的安装包 地址&#xff1a;MySQL :: Download MySQL Yum Repository 2、安装mysql服务 …

MySQL运维实战之ProxySQL(9.3)使用ProxySQL实现读写分离

作者&#xff1a;俊达 proxysql读写分离主要通过mysql_query_rules表中的规则来实现。 下面是具体的配置步骤&#xff1a; 1 hostgroup配置 insert into mysql_servers (hostgroup_id, hostname, port, max_replication_lag) values ( 100, 172.16.121.236, 3380, 3);inser…

恒峰智慧科技-森林消防便捷泵:轻松应对火灾危机!

在广袤无垠的森林中&#xff0c;绿色是生命的象征&#xff0c;是自然的馈赠。然而&#xff0c;当火魔无情地吞噬这片生命的绿洲时&#xff0c;我们需要一种快速、高效、可靠的消防工具来守护这片绿色。此时&#xff0c;森林消防便捷泵应运而生&#xff0c;成为了守护森林安全的…

Oracle数据库 :查询表结构脚本

查询脚本 &#xff1a; SELECT CASE WHEN a.column_id1 THEN a.TABLE_NAME ELSE END AS 表名, a.column_id AS 序号, a.column_name as 列名, REPLACE(comments, CHR(10), ) as 列说明, a.data_type || ( || a.data_length || ) as 数据类型, a.DATA_LENGTH AS 长度, a.DATA_…

idea中停止运行Vue

在里面敲入Ctrlc 输入y确定即可。

代码随想录算法训练营第44天| 518.零钱兑换II*、 377. 组合总和 Ⅳ*

518.零钱兑换II* 力扣题目链接 代码 #### 示例代码 class Solution { public:int change(int amount, vector<int>& coins) {vector<int> dp(amount 1, 0);dp[0] 1;for (int i 0; i < coins.size(); i) { // 遍历物品for (int j coins[i]; j < a…

Git最佳实践指南:从配置到高效开发的全面教程20240418

引言 在现代软件开发中&#xff0c;版本控制系统是不可或缺的工具&#xff0c;而Git是其中最受欢迎的一种。无论是个人项目还是团队合作&#xff0c;合理的Git使用策略可以显著提高开发效率和代码质量。本文详细介绍了Git的实践流程&#xff0c;包括项目设置、日常开发操作和高…

【微服务-Ribbon】什么是负载均衡?微服务中负载均衡有哪些策略呢?

前面几篇文章&#xff0c;我们了解了一下Nacos的单机部署、集群部署以及微服务接入Nacos的步骤。从本篇开始&#xff0c;我们来看一下微服务第二个通用组件-负载均衡&#xff08;Ribbon&#xff09;。 1、Ribbon负载均衡器 负载均衡顾名思义&#xff0c;是指通过软件或者硬件…

电能质量分析仪是什么

TH-6500电能质量分析仪是一种用于记录和分析现场电能质量参数的设备。它能够检测并记录电力系统的电压波动、频率偏差、谐波、三相不平衡等参数&#xff0c;帮助用户了解电力系统的运行状态&#xff0c;及时发现并解决潜在的电能质量问题。 该设备具备多种测量功能&#xff0c…

供应LF1608-LR83KDAT 芯片

长期供应各品牌芯片&#xff1a; LF1608-LR83KDAT IMX290LQR-G STM32F103C8T6TR STM32F103C8T6TR STM32F103CBT7TR TPS3823-33DBVR IMX326 NM1482KSLAXCL-3B EM6AB160TSE-5G W25Q128JVSIQ FMN1ET1TCJ-25IG PN614G6D2TE-B8BE0 GD25Q128ESIG FM6BD1G1GMB-2.5BLCGE…

正则表达式=》判断中文字

判断中文字 //Name Classification string input = "Eng中"; string patternZh = @"^\(*([\u4E00-\u9FFF_\s\.\,\-]{1,98})?\)*$"; Match match = Regex.Match(input, patternZh); Console

AI系列:大语言模型的function calling(下)- 使用LangChain

目录 前言LangChain Tool/Function calling1. Tool/function加强功能LangChain的tool装饰器其他方式: Pydantic 2. 绑定tools/functions3. 调用大模型(LLM)4. function calling处理流程 LangChain版代码与原生LLM调用的比较参考 前言 在AI系列&#xff1a;大语言模型的functio…

嵌入式工程师有哪些必备技能,和电子爱好者有很大区别!

要掌握的技能实际上是非常多的。在这里&#xff0c;我来结合自己亲身经历&#xff0c;从技术、思维、项目管理等方面来谈一下我认为嵌入式开发需要掌握的技能。 技术方面 C语言和汇编语言能力 C语言是嵌入式开发最核心的编程语言。在我的初学阶段&#xff0c;我花费了很多时间…