RabbitMQ基礎(chǔ)<一>

聲明:以下都是自己的一點小想法,因技術(shù)能力有限,不對的地方或有補(bǔ)充的地方請留言

一. RabbitMQ聲明Exchange的兩種方式

1.@bean 方式
   @Bean
    public FanoutExchange declareExchange() {
        return new FanoutExchange(ExchangeName);
    }

優(yōu)勢:簡單易寫容易理解
缺點:結(jié)構(gòu)不清晰。當(dāng)聲明的Exchange 過多時不宜管理,想要找到對應(yīng)的Exchange可能要浪費半天時間,改動起來麻煩

2.實現(xiàn)ApplicationRunner
@Component
public class Ignition implements ApplicationRunner {

    private AmqpAdmin amqpAdmin;

    @Autowired
    public Ignition(AmqpAdmin amqpAdmin) {
        this.amqpAdmin = amqpAdmin;
    }

    @Override
    public void run(ApplicationArguments args) throws Exception {

        // 聲明Exchange
        declareExchange();
    }

    /**
     * 聲明Exchange
     */
    private void declareExchange() {
        TopicExchange exchange = new TopicExchange(ExchangeName, true, false);
        amqpAdmin.declareExchange(exchange);
    }

優(yōu)勢:結(jié)構(gòu)清晰,每一個聲明都能有效快速的找到。Exchange容易管理
缺點:編碼比第一種大。

二. RabbitMQ發(fā)送消息

  @Autowired
   private AmqpTemplate amqpTemplate;

    // 發(fā)送
    amqpTemplate.send(ExchangeName,routingKey, new Message(message.getBytes(), new MessageProperties()));

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn),斷路器,智...
    卡卡羅2017閱讀 136,578評論 19 139
  • http://liuxing.info/2017/06/30/Spring%20AMQP%E4%B8%AD%E6%...
    sherlock_6981閱讀 16,208評論 2 11
  • 1.1 spring IoC容器和beans的簡介 Spring 框架的最核心基礎(chǔ)的功能是IoC(控制反轉(zhuǎn))容器,...
    simoscode閱讀 6,851評論 2 22
  • Spring Web MVC Spring Web MVC 是包含在 Spring 框架中的 Web 框架,建立于...
    Hsinwong閱讀 22,942評論 1 92
  • 一行人走出學(xué)校,穿過學(xué)校旁邊的村子,跨過村尾的小橋,沿著山腳的梯田往山上走。山腰是一片茶子林,茶子林里的茶花一片雪...
    玉米金閱讀 204評論 0 0

友情鏈接更多精彩內(nèi)容