SpringAMQP消息隊列實戰(zhàn)教程

更新時間：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: /

發(fā)送消息

@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消息隊列內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

一文搞懂Spring?Security異常處理機制
這篇文章主要為大家詳細介紹一下Spring?Security異常處理機制，文中的示例代碼講解詳細，對我們學習Spring?Security有一定幫助，感興趣的可以學習一下
2022-07-07
淺談springboot項目中定時任務如何優(yōu)雅退出
這篇文章主要介紹了淺談springboot項目中定時任務如何優(yōu)雅退出？具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2020-09-09
詳細解讀AbstractStringBuilder類源碼
這篇文章主要介紹了詳細解讀AbstractStringBuilder類源碼，具有一定參考價值，需要的朋友可以了解下。
2017-12-12
SpringCloud集成和使用OpenFeign的教程指南
在微服務架構中,服務間的通信是至關重要的,SpringCloud作為一個功能強大的微服務框架,為我們提供了多種服務間通信的方式,其中,OpenFeign是一個聲明式的Web服務客戶端,它使得編寫Web服務客戶端變得更加簡單,本文將詳細介紹如何在SpringCloud項目中集成和使用OpenFeign
2024-10-10
Java時間轉(zhuǎn)換成unix時間戳的方法
這篇文章主要為大家詳細介紹了Java時間轉(zhuǎn)換成unix時間戳的方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-12-12
Java 動態(tài)加載jar和class文件實例解析
這篇文章主要介紹了Java 動態(tài)加載jar和class文件實例解析，分享了相關代碼示例，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下
2018-02-02
Java畢業(yè)設計實戰(zhàn)之養(yǎng)老院管理系統(tǒng)的實現(xiàn)
讀萬卷書不如行萬里路，只學書上的理論是遠遠不夠的，只有在實戰(zhàn)中才能獲得能力的提升，本篇文章手把手帶你用java+SSM+JSP+Easyui+maven+mysql實現(xiàn)一個養(yǎng)老院管理系統(tǒng),大家可以在過程中查缺補漏，提升水平
2022-03-03
詳解JAVA使用Comparator接口實現(xiàn)自定義排序
這篇文章主要介紹了JAVA使用Comparator接口實現(xiàn)自定義排序，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2019-03-03
Spring如何通過@Lazy注解解決構造方法循環(huán)依賴問題
循環(huán)依賴其實就是循環(huán)引用,也就是兩個或則兩個以上的bean互相持有對方,最終形成閉環(huán),這篇文章主要給大家介紹了關于Spring如何通過@Lazy注解解決構造方法循環(huán)依賴問題的相關資料,需要的朋友可以參考下
2023-03-03
SpringBoot項目配置postgresql數(shù)據(jù)庫完整步驟(配置多數(shù)據(jù)源)
PostgreSQL是一種特性非常齊全的自由軟件的對象-關系型數(shù)據(jù)庫管理系統(tǒng)(ORDBMS),下面這篇文章主要給大家介紹了關于SpringBoot項目配置postgresql數(shù)據(jù)庫(配置多數(shù)據(jù)源)的相關資料,需要的朋友可以參考下
2023-05-05