rabbitMQ的發布模式怎么實現

這篇“rabbitMQ的發布模式怎么實現”文章的知識點大部分人都不太理解，所以小編給大家總結了以下內容，內容詳細，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“rabbitMQ的發布模式怎么實現”文章吧。

Springboot rabbit MQ 發布/訂閱模式

生產者聲明兩個隊列和一個扇出交換機，并將兩個隊列綁定到交換機

開關有四種類型：fanout、direct、topic和header(文末有介紹)

導入 com.example.rabbitmq.constant.RabbitConstant；
導入 org.springframework.amqp.core.*；
導入 org.springframework.context.annotation.Bean；
導入 org.springframework.context.annotation.Configuration；@Configuration公共類 RabbitPublishSubscribeProvider { 
    @Bean
    公共隊列 pubsubQueueFirst() { 
        return new Queue(RabbitConstant.PUBLISH_SUBSCRIBE_FIRST_QUEUE_NAME); 
    } 
    @Bean
    公共隊列 pubsubQueueSecond() { 
        return new Queue(RabbitConstant.PUBLISH_SUBSCRIBE_SECOND_QUEUE_NAME); 
    } 
    @Bean
    公共 FanoutExchange fanoutExchange() {        // 創建扇出類型開關，表示交換機會向所有綁定隊列發送消息
        return new FanoutExchange(RabbitConstant.PUBLISH_SUBSCRIBE_EXCHANGE_NAME); 
    } 
    @Bean 
    public Binding pubsubQueueFirstBindFanoutExchange() { 
        // 隊列綁定開關
        return BindingBuilder.bind(pubsubQueueFirst()).to(fanoutExchange()); 
    } 
    @Bean 
    public Binding pubsubQueueSecondBindFanoutExchange() { 
        // 隊列二綁定開關
        return BindingBuilder.bind(pubsubQueueSecond()).to(fanoutExchange()); 
    } 
}

消費者監聽隊列并消費

導入 com.example.rabbitmq.constant.RabbitConstant；
導入 org.springframework.amqp.rabbit.annotation.RabbitHandler；
導入 org.springframework.amqp.rabbit.annotation.RabbitListener；
導入 org.springframework.stereotype.Component；
@Component public class RabbitPublishSubscribeConsumer { 
    @RabbitListener(queues = RabbitConstant.PUBLISH_SUBSCRIBE_FIRST_QUEUE_NAME) 
    @RabbitHandler 
    public void pubsubQueueFirst(String context) { 
        System.out.println("rabbit pubsub queue first receiver:" + context); 
    } 
    @RabbitListener(queues = RabbitConstant.PUBLISH_SUBSCRIBE_SECOND_QUEUE_NAME) 
    @RabbitHandler 
    public void pubsubQueueSecond(String context) {        System.out.println("rabbit pubsub 隊列第二個接收者：" + context); 
    } 
}

單元測試

@Test public void pubsub() { 
    rabbitTemplate.convertAndSend(RabbitConstant.PUBLISH_SUBSCRIBE_EXCHANGE_NAME, null, "發布/訂閱你好"); 
}

響應結果

以上就是關于“rabbitMQ的發布模式怎么實現”這篇文章的內容，相信大家都有了一定的了解，希望小編分享的內容對大家有幫助，若想了解更多相關的知識內容，請關注億速云行業資訊頻道。