SpringBoot快速整合RabbitMq小案例(使用步驟)

更新時間：2023年06月16日 08:26:10 作者：返回主頁有點兒意思

這篇文章主要介紹了SpringBoot快速整合RabbitMq小案例,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下

對于一個直接創(chuàng)建的springBoot項目工程來說，可以按照以下步驟使用rabbitmq

添加依賴：添加rabbitMQ的依賴。

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

配置連接：在配置文件中配置虛擬主機、端口號、用戶名、密碼等信息。

spring:
  rabbitmq:
    host: localhost
    port: 5672
    virtual-host: {你的虛擬主機}
    username: {你的用戶名}
    password: {你的密碼}

創(chuàng)建生產(chǎn)者：導入對應依賴后，使用rabbitTemplate，并調用convertAndSend來發(fā)送消息。

@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
    rabbitTemplate.convertAndSend("exchangeName", "routingKey", message);
}

來發(fā)送消息。

創(chuàng)建消費者：使用@RabbitListener注解在消息處理方法上，指定監(jiān)聽的隊列名稱，并在方法參數(shù)中接收消息。

@RabbitListener(queues = "queueName")
public void receiveMessage(String message) {
    // 處理接收到的消息
    System.out.println("Received message: " + message);
}

編寫配置類，使用@Bean注解在對應的方法上把方法的返回值（將隊列，交換機等信息）交由spring管理。

// 交換機名稱
    public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange";
    // 隊列名稱
    public static final String ITEM_QUEUE = "item_queue";
    //聲明交換機
    @Bean
    public Exchange exchange(){
        return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build();
    }
    //聲明隊列
    @Bean
    public Queue queue(){
        return QueueBuilder.durable(ITEM_QUEUE).build();
    }
    //隊列綁定到交換機
    @Bean
    public Binding binding(Queue queue,Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
    }

啟動應用程序或者寫測試類。

    @Autowired
    RabbitTemplate rabbitTemplate;
@Test
    public void testSendMessage(){
        rabbitTemplate.convertAndSend(RabbitmqConfig.ITEM_TOPIC_EXCHANGE, "item.insert", "新增商品的消息~~");
        System.out.println("消息發(fā)送成功");
    }

到此這篇關于SpringBoot快速整合RabbitMq小案例的文章就介紹到這了,更多相關SpringBoot整合RabbitMq內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: