RabbitMQ 使用之 spring-boot 方式

server:
  port: 8080
spring:
  rabbitmq:
    port: 5672
    username: admin
    password: admin
    addresses: 10.211.55.6
    virtual-host: /conan
    connection-timeout: 15000
    publisher-returns: true # 路由失败回调
    publisher-confirms: true # 发生确认
    template:
      mandatory: true # 必须设置成 true , 路由消息失败通知监听者, 而不是将消息丢弃
    listener:
      simple:
        prefetch: 1 # 消费者 每次取的消息数量
        acknowledge-mode: manual  # 手动签收, 需要手动 ACK

@Component
public class RabbitMQListener {
    @RabbitListener(queues = {"spring_boot_queue_publish_subcrible"})
    public void ListenerQueue(Message message) {
        System.out.println("message:" + message.getBody());
    }
}

 @RabbitListener(queues = {"spring_boot_queue_publish_subcrible2"})
    public void listenerWithAck(Message message, Channel channel) throws IOException {
        System.out.println("message:" + message.getBody());
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
    }

@Configuration
public class HelloWorldRabbitMqConfig {


    //定义交换机的名字
    public static final String  HELLO_EXCHANGE_NAME = "";
    //定义队列的名字
    public static final String HELLO_QUEUE_NAME = "spring_boot_queue_hello_world";


    //1、声明交换机
    @Bean("helloExchange")
    public Exchange helloExchange(){
        return ExchangeBuilder.topicExchange(HELLO_EXCHANGE_NAME).durable(true).build();
    }


    //2、声明队列
    @Bean("helloQueue")
    public Queue helloQueue(){
        return QueueBuilder.durable(HELLO_QUEUE_NAME).build();
    }
}

@Configuration
public class PublisRabbitMqConfig {
    //定义交换机的名字
    public static final String  EXCHANGE_NAME = "spring_boot_exchange_publish_subcrible";
    //定义队列的名字
    public static final String QUEUE_NAME = "spring_boot_queue_publish_subcrible";
    //1、声明交换机
    @Bean("publishExchange")
    public Exchange publishExchange(){
        return ExchangeBuilder.topicExchange(EXCHANGE_NAME).durable(true).build();
    }
    //2、声明队列
    @Bean("publishQueue")
    public Queue publishQueue(){
        return QueueBuilder.durable(QUEUE_NAME).build();
    }
    //3、队列与交换机进行绑定
    @Bean
    public Binding bindQueueExchange(@Qualifier("publishQueue") Queue queue, @Qualifier("publishExchange") Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with("aaa").noargs();
    }
}