spring boot使用RabbitMQ

引入RabbitMQ启动器

<!-- RabbitMQ启动器 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

配置RabbitMQ使得放入和取出的数据都是以Json的格式

@Configuration
public class RabbitMQConfig {

    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter();
    }

}

放数据、取数据

@Autowired
private RabbitTemplate rabbitTemplate;

//向rabbitMQ存数据
rabbitTemplate.convertAndSend("chen.direct","atguigu",new Person("chenli","123"));

//从rabbitMQ中取数据
Object o = rabbitTemplate.receiveAndConvert("atguigu");

配置监听，使得只要消息队列中存在数据，就会立即执行方法体

    @RabbitListener(queues = "atguigu")//queues里面放的是队列，可以是多个
    //监听消息队列的，只要队列一有Person类型的消息，就会被监听到，
    public void receive1(Person person){
        System.out.println("该方法，立即执行");
        System.out.println(person);
    }

    //监听消息队列的，只要队列一有String类型的消息，就会被监听到，
    @RabbitListener(queues = "atguigu")//queues里面放的是队列，可以是多个
    public void receive2(String str){
        System.out.println("监听消息队列的，只要队列一有消息，就会被监听到，该方法，立即执行");
        System.out.println(str);
    }

在启动类上加上@EnableRabbit注解，开启注解驱动，@RabbitListener就会生效

@SpringBootApplication
@EnableRabbit
public class RbmqApplication {

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

}