SpringBoot集成RabbitMQ发送消息简略步骤

本篇记录下SpringBoot中集成RabbitMQ，并发送消息的步骤，简单几步，即可上手。

引入依赖

SpringBoot是兼容mq的，spring-boot-starter里面就有mq的集成，修改pom，增加如下dependency即可。

pom.xml

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

修改application.yml配置文件

增加相关rabbitMQ的配置 spring application.yml增加的内容如下：

spirng:
    rabbitmq:
        host: 127.0.0.1
        port: 5672
        username: admin
        password: admin
        virtual-host: some_vhost

Spring代码中增加相关配置

可以直接发送Java的Object，进而自动转化成JSON发送给MQ

MyConfiguration.java代码如下：

@Configuration
public class MyConfiguration extends WebMvcConfigurationSupport {

    @Autowired
    private Environment env;

    @Bean
    MessageConverter createMessageConverter() {
        return new Jackson2JsonMessageConverter();
    }

}

发送消息 

通过自动注入的RabbitTemplate（类似Redis的StringRedisTemplate的使用方式）

rabbitTemplate.convertAndSend可以发送String，也可以直接任何Object

测试代码如下：

@Autowired
RabbitTemplate rabbitTemplate;

private void test() {
   rabbitTemplate.convertAndSend("hello", message);
}