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 MVC的国际化实现代码
本篇文章主要介绍了Spring MVC的国际化实现代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-08-08
JDK线程池和Spring线程池的使用实例解析
这篇文章主要介绍了JDK线程池和Spring线程池的使用实例解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-11-11
SpringBoot3.x使用es进行数据查询的方式
SpringBoot3中,Elasticsearch的版本升级至8.x,相关写法有所改变,SpringBoot2中的ElasticsearchRestTemplate已被移除,推荐使用ElasticsearchTemplate或ElasticsearchClient进行交互,本文介绍这两个类的使用方式,并说明了依赖引入和自动装配的配置,感兴趣的朋友一起看看吧
2025-12-12
Java内存分配与JVM参数详解(推荐)
本文详解JVM内存结构与参数调整,涵盖堆分代、元空间、GC选择及优化策略,帮助开发者提升性能、避免内存泄漏,本文给大家介绍Java内存分配与JVM参数详解,感兴趣的朋友一起看看吧
2025-06-06
intelliJ IDEA 多行选中相同内容的快捷键分享
这篇文章主要介绍了intelliJ IDEA 多行选中相同内容的快捷键分享，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2021-02-02
SpringBoot使用jsoup爬取HTML的方法
jsoup 是一款 Java 的 HTML 解析器,它提供了一套非常便利的 API,可通过 DOM、CSS 通过类似于 JQuery 的操作方法来取出和操作数据,这篇文章主要介绍了SpringBoot使用jsoup爬取HTML,需要的朋友可以参考下
2024-02-02
Java 重写与重载方法与区别详解
本篇文章通过实例详细介绍了重写与重载，以及他们的区别，需要的朋友可以参考下
2017-04-04
Java多线程产生死锁的必要条件
今天小编就为大家分享一篇关于Java多线程产生死锁的必要条件，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
2019-01-01
java环境变量配置超详细图文教程
在我们学习Java语言的时候,要在命令提示符里运用Java和Javac,用到这两个命令的时候就要配置Java环节变量才可以,这篇文章主要给大家介绍了关于java环境变量配置的相关资料,需要的朋友可以参考下
2023-10-10
javaweb实现百度GPS定位接口（经纬度）
这篇文章主要介绍了javaweb实现百度GPS定位接口（经纬度），文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-02-02