流程图概括
1.引入依赖
org.springframework.boot
spring-boot-starter-amqp
2. 配置RabbitMQ连接
在application.properties或application.yml中配置RabbitMQ服务器的连接参数：
3.DirectExchange
3.1消费者
@Configuration
public class DirectConsumer {
//注册一个队列
@Bean //启动多次为什么不报错？启动的时候，它会根据这个名称Direct_Q01先去查找有没有这个队列，如果有什么都不做，如果没有创建一个新的
public Queue queue(){
return QueueBuilder.durable(“Direct_Q01”).maxLength(100).build();
}
//注册交换机
@Bean
public DirectExchange exchange(){
//1.启动的时候，它会根据这个名称Direct_E01先去查找有没有这个交换机，如果有什么都不做，如果没有创建一个新的
return ExchangeBuilder.directExchange(“Direct_E01”).build();
}
//绑定交换机与队列关系
@Bean
public Binding binding(Queue queue,DirectExchange exchange){
return BindingBuilder.bind(queue).to(exchange).with("RK01");
}
//启动一个消费者
@RabbitListener(queues = "Direct_Q01")
public void receiveMessage(String msg){
System.out.println("收到消息："+msg);
}
}
3.2生产者
@Service
public class DirectProvider {
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(Object message) {
rabbitTemplate.convertAndSend("Direct_E01", "RK01", message);
}
}
3.3 一个交换机对多个队列的特点：
3.4 一个队列对多个消费者特点：
4.FanoutExchange
4.1 消费者
4.2生产者
5.TopicExchange
5.1 消费者
5.1 生产者
