Spring Boot整合RabbitMQ

本文是作者原創,版權歸作者所有.若要轉載,請注明出處.

本文RabbitMQ版本為rabbitmq-server-3.7.17,erlang為erlang-22.0.7.請各位去官網查看版本匹配和下載,也可以留言,我發安裝包

 

在Spring項目中，可以使用Spring-Rabbit去操作RabbitMQ https://github.com/spring-projects/spring-amqp

尤其是在spring boot項目中只需要引入對應的amqp啟動器依賴即可，方便的使用RabbitTemplate發送消息，使用注解接收消息。

 

搭建生產者工程

1. 創建工程

創建生產者工程springboot-rabbitmq-producer

2. 添加依賴

　　　<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.4.RELEASE</version>
    </parent>

    <dependencies>
        <!-- 使用springmvc來進行測試 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--amqp的起步依賴-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <!--單元測試類-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
    </dependencies>

3. 啟動類

@SpringBootApplication
public class ProducerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProducerApplication.class, args);
    }

}

4. 配置RabbitMQ

application.yml，內容如下：

#tomcat端口
server:
  port: 8888
#Rabbitmq的配置
spring:
  rabbitmq:
    host: 192.168.75.163
    port: 5672
    virtual-host: /hello
    username: test01
    password: test01

創建RabbitMQ隊列與交換機綁定的配置類RabbitMQConfig

/**
 * RabbitMQ配置類
 */
@Configuration
public class RabbitMQConfig {
    //交換機名稱
    public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange";
    //隊列名稱
    public static final String ITEM_QUEUE = "item_queue";

    //聲明交換機
    @Bean("itemTopicExchange")
    public Exchange topicExchange(){
        return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build();
    }

    //聲明隊列
    @Bean("itemQueue")
    public Queue itemQueue(){
        return QueueBuilder.durable(ITEM_QUEUE).build();
    }

    //綁定隊列和交換機
    @Bean
    public Binding itemQueueExchange(@Qualifier("itemQueue") Queue queue,
                                     @Qualifier("itemTopicExchange") Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs();
    }

}

5 消息發送Controller

@RestController
public class SendMsgController {

    //注入RabbitMQ的模板
    @Autowired
    private RabbitTemplate rabbitTemplate;

    /**
     * 測試
     */
    @GetMapping("/sendmsg")
    public String sendMsg(@RequestParam String msg, @RequestParam String key){
        /**
         * 發送消息
         * 參數一：交換機名稱
         * 參數二：路由key: item.springboot-rabbitmq,符合路由item.#規則即可
         * 參數三：發送的消息
         */
        rabbitTemplate.convertAndSend(RabbitMQConfig.ITEM_TOPIC_EXCHANGE ,key ,msg);
        //返回消息
        return "發送消息成功！";
    }
}

6發送消息

http://localhost:8888/sendmsg?msg=springboot-rabbitmq-producer&key=item.springboot-rabbitmq

查看結果

 

 

 

 

 

 

 

 

搭建消費者工程

1. 創建工程

創建消費者工程springboot-rabbitmq-consumer

2. 添加依賴

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.4.RELEASE</version>
    </parent>

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

3. 啟動類

@SpringBootApplication
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

4. 配置RabbitMQ

application.yml，內容如下：

#端口,注意端口不要沖突
server:
  port: 9999
#Rabbitmq的配置
spring:
  rabbitmq:
    host: 192.168.75.163
    port: 5672
    virtual-host: /hello
    username: test01
    password: test01

5. 消息監聽處理類MyListener

@Component
public class MyListener {

    @RabbitListener(queues = "item_queue")
    public void msg(String msg){
        System.out.println("消費者消費消息了："+msg);
        //TODO 這里可以做異步的工作
    }
}

6. 測試(消息內容為test)

http://localhost:8888/sendmsg?msg=test&key=item.springboot-rabbitmq

查看結果