RabbitMQ的工作模式實例代碼分析

這篇文章主要講解了“RabbitMQ的工作模式實例代碼分析”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“RabbitMQ的工作模式實例代碼分析”吧！

SpringBoot RabbitMQ 工作模式

生產者聲明隊列并向隊列生成消息

導入 com.example.rabbitmq.constant.RabbitConstant；
導入 org.springframework.amqp.core.Queue；
導入 org.springframework.context.annotation.Bean；
導入 org.springframework.context.annotation.Configuration；
@Configuration公共類 RabbitWorkProvider { 
    @Bean
    公共隊列 workQueue() { 
        return new Queue(RabbitConstant.WORK_QUEUE_NAME); 
    } 
}

消費者監聽隊列并消費消息(有兩個消費者監聽同一個隊列)

導入 com.example.rabbitmq.constant.RabbitConstant；
導入 org.springframework.amqp.rabbit.annotation.RabbitHandler；
導入 org.springframework.amqp.rabbit.annotation.RabbitListener；
導入 org.springframework.stereotype.Component；
@Component public class RabbitWorkConsumer { 
    @RabbitListener(queues = RabbitConstant.WORK_QUEUE_NAME) 
    @RabbitHandler 
    public void workQueueListenerFirst(String context) { 
        System.out.println("rabbit workQueue listener first receiver:" + context); 
    } 
    @RabbitListener(queues = RabbitConstant.WORK_QUEUE_NAME) 
    @RabbitHandler 
    public void workQueueListenerSecond(String context) {        System.out.println("rabbit workQueue listener 第二個接收者：" + context); 
    } 
}

單元測試

@Test public void work() { 
    rabbitTemplate.convertAndSend(RabbitConstant.WORK_QUEUE_NAME, "工作你好！"); 
}

響應結果(由于有兩個消費者監聽同一個隊列，所以消息只能被其中一個消費者消費。默認情況下，消息是負載均衡發送給所有消費者的)

感謝各位的閱讀，以上就是“RabbitMQ的工作模式實例代碼分析”的內容了，經過本文的學習后，相信大家對RabbitMQ的工作模式實例代碼分析這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！