流程图概括

1.引入依赖

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

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();}//注册交换机@Beanpublic DirectExchange exchange(){//1.启动的时候，它会根据这个名称Direct_E01先去查找有没有这个交换机，如果有什么都不做，如果没有创建一个新的return  ExchangeBuilder.directExchange("Direct_E01").build();}//绑定交换机与队列关系@Beanpublic 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 {@Autowiredprivate 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 生产者

6.业务对象作为消息

6.1 自定义转换器（需要进行类型转换）

@Configuration
public class RabiitConfig {@Bean // 将对象转化成json字符串public MessageConverter  messageConverter(){return new  Jackson2JsonMessageConverter();}}

6.2 消费者直接接受业务对象

    @RabbitListener(bindings=@QueueBinding(value = @Queue(name = "Q01", durable = "true",autoDelete = "false",arguments = @Argument(name="x-queue-mode",value = "lazy")),exchange =@Exchange(name = "E01", durable = "true",autoDelete = "false"),key = "RK01"))public void receiveMessage(RegisterOk registerOk){System.out.println("消费者 收到消息："+registerOk);//新用户注册后，送100积分。}