快捷導(dǎo)航

spring AMQP代碼生成rabbitmq的exchange and queue教程

更新時(shí)間：2025年08月16日 14:00:31 作者：RR1335

使用Spring AMQP代碼直接創(chuàng)建RabbitMQ exchange和queue,并確保綁定關(guān)系自動(dòng)成立,簡(jiǎn)化消息隊(duì)列配置,此經(jīng)驗(yàn)分享供參考,歡迎支持腳本之家

spring AMQP代碼生成rabbitmq的exchange and queue

@Configuration
public class FanoutConfigure {

    @Bean
    public FanoutExchange fanoutExchange() {
        return ExchangeBuilder.fanoutExchange(FANOUT_BUILDER_EXCHANGE_NAME).build();
//        return new FanoutExchange(FANOUT_BUILDER_EXCHANGE_NAME);
    }

    @Bean
    public Queue fanoutQueue() {
//        return new Queue(FANOUT_BUILDER_QUEUE_NAME, true);
        return QueueBuilder.durable(FANOUT_BUILDER_QUEUE_NAME).build();
    }


    @Bean
    public Binding fanoutBinding(FanoutExchange fanoutExchange, Queue fanoutQueue) {
        // .with 實(shí)現(xiàn) routingKey 的匹配
        return BindingBuilder.bind(fanoutQueue).to(fanoutExchange);
    }

}

直接上代碼

    public static final String FANOUT_BUILDER_EXCHANGE_NAME = "fanoutbuild.exchange";
    public static final String FANOUT_BUILDER_QUEUE_NAME = "fanoutbuild.queue";

執(zhí)行結(jié)果

綁定關(guān)系成立。

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

Java 高并發(fā)八：NIO和AIO詳解
本文主要介紹Java 高并發(fā)NIO和AIO 的知識(shí)，這里整理了詳細(xì)的資料，并詳細(xì)介紹了 1. 什么是NIO 2. Buffer 3. Channel 4. 網(wǎng)絡(luò)編程 5. AIO的知識(shí)，有需要的小伙伴可以參考下
2016-09-09
java對(duì)接Pinata上傳文件到IPFS全過(guò)程
本文詳細(xì)介紹了如何使用Pinata API將文件上傳到IPFS網(wǎng)絡(luò),首先登錄Pinata官網(wǎng)并生成JWT令牌,然后在項(xiàng)目中導(dǎo)入OkHttp依賴并編寫(xiě)代碼,通過(guò)調(diào)用Pinata的API接口上傳文件,最后,通過(guò)Swagger調(diào)試接口并獲取上傳的文件CID
2025-11-11
Java將Exception信息轉(zhuǎn)為String字符串的方法
今天小編就為大家分享一篇Java將Exception信息轉(zhuǎn)為String字符串的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
2018-10-10
關(guān)于Linux服務(wù)器配置java環(huán)境遇到的問(wèn)題小結(jié)
這篇文章主要介紹了關(guān)于Linux服務(wù)器配置java環(huán)境遇到的問(wèn)題小結(jié),本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
2020-12-12
Java 過(guò)濾器實(shí)現(xiàn)敏感詞匯過(guò)濾功能
通過(guò)使用 Java 過(guò)濾器,我們可以輕松地實(shí)現(xiàn)敏感詞匯過(guò)濾的功能,以保護(hù)用戶免受不良內(nèi)容的侵害,讓我們通過(guò)一個(gè)簡(jiǎn)單的示例來(lái)演示我們的敏感詞匯過(guò)濾器是如何工作的,感興趣的朋友一起看看吧
2024-01-01
java單例模式實(shí)現(xiàn)面板切換
這篇文章主要為大家詳細(xì)介紹了java單例模式實(shí)現(xiàn)面板切換，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2017-11-11
java拼接字符串時(shí)去掉最后一個(gè)多余逗號(hào)的方法
這篇文章主要介紹了java拼接字符串時(shí)去掉最后一個(gè)多余逗號(hào)的方法,實(shí)例分析了java操作字符串的技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下
2015-03-03
java.lang.NoClassDefFoundError錯(cuò)誤的原因及解決方法
這篇文章主要給大家介紹了關(guān)于java.lang.NoClassDefFoundError錯(cuò)誤的原因及解決的相關(guān)資料,java.lang.NoClassDefFoundError是Java虛擬機(jī)在運(yùn)行時(shí)無(wú)法找到特定類的錯(cuò)誤,需要的朋友可以參考下
2023-10-10
SpringCloud中的Hystrix保護(hù)機(jī)制詳解
這篇文章主要介紹了SpringCloud中的Hystrix保護(hù)機(jī)制詳解,Hystrix,英文意思是豪豬,全身是刺,看起來(lái)就不好惹,是一種保護(hù)機(jī)制,Hystrix也是Netflix公司的一款組件,需要的朋友可以參考下
2023-12-12
解析mybatis-plus中的resultMap簡(jiǎn)單使用
mybatis-plus也只是聽(tīng)過(guò)，可是終究沒(méi)有使用過(guò)。于是自己花幾天晚上的時(shí)間研究mybatis-plus的使用。這篇文章主要介紹了mybatis-plus的resultMap簡(jiǎn)單使用,需要的朋友可以參考下
2021-11-11