SpringAMQP消息队列实战教程
更新时间：2024年02月27日 11:46:42 作者：zhyaw56zhu
这篇文章主要介绍了SpringAMQP消息队列的相关知识,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧
安装RabbitMQ
在linux上安装RabbitMQ,并运行
docker run \ -e RABBITMQ_DEFAULT_USER=zywzy \ -e RABBITMQ_DEFAULT_PASS=123321 \ --name mq \ --hostname mq1 \ -p 15672:15672 \ -p 5672:5672 \ -d \ rabbitmq:3-management
http://ip:15672 访问控制台, 用户名zywzy,密码123321
引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>配置文件
spring:
rabbitmq:
host: 172.27.99.52 # rabbitMQ的ip地址
port: 5672 # 端口
username: abc
password: 123321
virtual-host: /发送消息
@SpringBootTest
public class SpringAmqpTest {
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
public void testSendMessage2SimpleQueue() {
String queueName = "simple.queue";
String message = "hello, spring amqp!";
rabbitTemplate.convertAndSend(queueName, message);
}
}消费消息
@RabbitListener(queues = "simple.queue")
public void listenWorkQueue1(String msg) throws InterruptedException {
System.out.println("消费者1接收到消息：【" + msg + "】" + LocalTime.now());
}消息预取
每次只能取一条消息,处理完成才能取下一条消息
spring:
rabbitmq:
listener:
simple:
prefetch: 1到此这篇关于SpringAMQP消息队列的文章就介绍到这了,更多相关SpringAMQP消息队列内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
idea中MavenWeb项目不能创建Servlet的解决方案
这篇文章主要介绍了idea中MavenWeb项目不能创建Servlet的解决方案,本文给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下2020-02-02
这篇文章主要介绍了springboot框架各个层次基础,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-08-08
SpringCloud实现基于RabbitMQ消息队列的详细步骤
在Spring Cloud框架中,我们可以利用RabbitMQ实现强大而可靠的消息队列系统,本篇将详细介绍如何在Spring Cloud项目中集成RabbitMQ,并创建一个简单的消息队列,感兴趣的朋友一起看看吧2024-03-03
这篇文章主要介绍了Java并发编程之CountDownLatch原理详解,CountDownLatch类中使用了一个继承自AQS的共享锁Sync对象,构造CountDownLatch对象时会将传入的线程数值设为AQS的state值,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了浅谈SpringBoot2.4 配置文件加载机制大变化，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-08-08
Sharding-JDBC自动实现MySQL读写分离的示例代码
本文主要介绍了Sharding-JDBC自动实现MySQL读写分离，优点在于数据源完全有Sharding-JDBC托管，写操作自动执行master库，读操作自动执行slave库，感兴趣的可以了解一下2021-11-11
解决遇到Cannot resolve ch.qos.logback:logback-classic:
当使用Maven配置项目依赖时,可能会遇到无法解析特定版本的错误,例如,logback-classic版本1.2.3可能无法在配置的仓库中找到,解决方法包括检查仓库是否包含所需版本,或更新到其他可用版本,可通过Maven官网搜索并找到适用的版本,替换依赖配置中的版本信息2024-09-09
工作中,我们经常会遇到需要进行各种排序的需求，本文主要介绍了Java对中文进行排序的实现示例，具有一定的参考价值，感兴趣的可以了解一下2024-02-02
Springboot基于websocket实现简单在线聊天功能
这篇文章主要介绍了Springboot基于websocket实现简单在线聊天功能,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-06-06
这篇文章主要为大家介绍了java9版本特性资源自动关闭的语法增强的详细使用说明，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步2022-03-03
最新评论