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消息队列内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

一文搞懂Spring Security异常处理机制
这篇文章主要为大家详细介绍一下Spring Security异常处理机制，文中的示例代码讲解详细，对我们学习Spring Security有一定帮助，感兴趣的可以学习一下
2022-07-07
浅谈springboot项目中定时任务如何优雅退出
这篇文章主要介绍了浅谈springboot项目中定时任务如何优雅退出？具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-09-09
详细解读AbstractStringBuilder类源码
这篇文章主要介绍了详细解读AbstractStringBuilder类源码，具有一定参考价值，需要的朋友可以了解下。
2017-12-12
SpringCloud集成和使用OpenFeign的教程指南
在微服务架构中,服务间的通信是至关重要的,SpringCloud作为一个功能强大的微服务框架,为我们提供了多种服务间通信的方式,其中,OpenFeign是一个声明式的Web服务客户端,它使得编写Web服务客户端变得更加简单,本文将详细介绍如何在SpringCloud项目中集成和使用OpenFeign
2024-10-10
Java时间转换成unix时间戳的方法
这篇文章主要为大家详细介绍了Java时间转换成unix时间戳的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-12-12
Java 动态加载jar和class文件实例解析
这篇文章主要介绍了Java 动态加载jar和class文件实例解析，分享了相关代码示例，小编觉得还是挺不错的，具有一定借鉴价值，需要的朋友可以参考下
2018-02-02
Java毕业设计实战之养老院管理系统的实现
读万卷书不如行万里路，只学书上的理论是远远不够的，只有在实战中才能获得能力的提升，本篇文章手把手带你用java+SSM+JSP+Easyui+maven+mysql实现一个养老院管理系统,大家可以在过程中查缺补漏，提升水平
2022-03-03
详解JAVA使用Comparator接口实现自定义排序
这篇文章主要介绍了JAVA使用Comparator接口实现自定义排序，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-03-03
Spring如何通过@Lazy注解解决构造方法循环依赖问题
循环依赖其实就是循环引用,也就是两个或则两个以上的bean互相持有对方,最终形成闭环,这篇文章主要给大家介绍了关于Spring如何通过@Lazy注解解决构造方法循环依赖问题的相关资料,需要的朋友可以参考下
2023-03-03
SpringBoot项目配置postgresql数据库完整步骤(配置多数据源)
PostgreSQL是一种特性非常齐全的自由软件的对象-关系型数据库管理系统(ORDBMS),下面这篇文章主要给大家介绍了关于SpringBoot项目配置postgresql数据库(配置多数据源)的相关资料,需要的朋友可以参考下
2023-05-05