设置RabbitMQ和Spring的整合
我们之前使用的Spring-Rabbit的xml方式，现在我们要改造成java方式，并且Spring Boot对RabbitMQ的使用做了自动配置，更加的简化了我们的使用。
1、 在导入spring-boot-starter-amqp的依赖；
2、 在application.properties文件中配置RabbitMQ的连接信息
3、 编写Rabbit的Spring配置类
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMQSpringConfig {
@Autowired
private ConnectionFactory connectionFactory;
// 管理
@Bean
public RabbitAdmin rabbitAdmin() {
return new RabbitAdmin(connectionFactory);
}
// 声明队列
@Bean
public Queue taotaoCartLoginQueue() {
// 默认就是自动声明的
return new Queue("TAOTAO-CART-LOGIN-QUEUE", true);
}
// 声明队列
@Bean
public Queue taotaoCartOrderSuccessQueue() {
// 默认就是自动声明的
return new Queue("TAOTAO-CART-ORDER-SUCCESS-QUEUE", true);
}
}
设置监听
