spring boot 集成rabbitMQ（一）简单使用

1、引入rabbitMQ相关的jar包

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

2、配置文件设置

spring.rabbitmq.host=xx.xx.xx.xx
spring.rabbitmq.port=xxxx
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

2、简单配置rabbitMQ，默认是direct交换机（一个交换机对应一个队列），只需要配置好队列信息即可。

@Configuration
public class RabbitConfig {

    @Bean
    public Queue  testQueue(){
        return new Queue("test");
    }

}

3、发送端实现

 @RestController
 public class MQMessageSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;
    @RequestMapping(value = "/sendMessage")
    public void sendMessage(){
        String context="hello test";
        rabbitTemplate.convertAndSend("test",context);
    }

}

4、接收端

@Component
@RabbitListener(queues = "test")
public class MQMessageReceiver {

    @RabbitHandler
    public void process(String  context) {
        System.out.println("Receiver : " + context);
     }
}