Springboot 实践（13）spring boot 整合RabbitMq

前文讲解了RabbitMQ的下载和安装，此文讲解springboot整合RabbitMq实现消息的发送和消费。

1、创建web project项目，名称为“SpringbootAction-RabbitMQ”

2、修改pom.xml文件，添加amqp使用jar包

   <!--  RabbitMQ -->

        <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>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>org.springframework.amqp</groupId>

            <artifactId>spring-rabbit-test</artifactId>

            <scope>test</scope>

        </dependency>

3、修改application.xml，配置服务器RabbitMQ服务器

spring:  

  rabbitmq:  #配置RabbitMQ

    host: 127.0.0.1

    port: 5672

    username: guest

    password: guest

    virtual-host: /

4、添加RabbitMQ配置文件

@Configuration//Rabbit配置类

public class RabbitConfig {

        private final String EXCHANGE_NAME = "boot_topic_exchange";

        private final String QUEUE_NAME = "boot_queue";

    //创建交换机

  @Bean("bootExchange")

  public Exchange getExchange()

    {

        return ExchangeBuilder

                .topicExchange(EXCHANGE_NAME)//交换机类型 ;参数为名字

                .durable(true)//是否持久化，true即存到磁盘,false只在内存上

                .build();

    }

    //创建队列

    @Bean("bootQueue")

    public Queue getMessageQueue()

    {

        return new Queue(QUEUE_NAME);

    }

    //交换机绑定队列

    @Bean

    //@Qualifier注解,使用名称装配进行使用

    public Binding bindMessageQueue(@Qualifier("bootExchange") Exchange exchange, @Qualifier("bootQueue") Queue queue)

    {

        return BindingBuilder

                .bind(queue)

                .to(exchange)

                .with("#.message.#")

                .noargs();

    }

}

5、添加producer生产者文件

@RestController

public class TestProducer {

    //注入RabbitTemplate工具类（rabbit内部的，可以发送消息）

    @Autowired

    private RabbitTemplate rabbitTemplate;

    @GetMapping("/sendMessage")

    public void testSendMessage()

    {

        /**

         * 发送消息

         * 参数1：交换机

         * 参数2：路由键

         * 参数3：要发送的消息

         */

        rabbitTemplate.convertAndSend("boot_topic_exchange","message","双十二开始了！");

    }

}

6、添加consumer消费者文件

//消费者

@Component

public class Consumer {

  //监听队列

  @RabbitListener(queues = "boot_queue")

  public void listenMessage(Message message)

  {

      System.out.println("接收消息："+message);

  }

}

7、测试

启动RabbitMQ服务器，启动后界面如下图所示：

启动SpringbootAction-RabbitMQ项目，项目启动后，在浏览器中输入http://localhost:2885/swagger-ui.html,界面如下：

测试消息生产者和消费者

选择“test-producer”，点击“Excute”，执行producer

观察项目后台console，显示如下：

从上图看，producer可以正常发布信息，同时consumer也正常消费了信息。