消息队列之RabbitMQ之主题（Topics）模式

packagecom.study.rabbitmq;
importorg.springframework.amqp.core.*;
importorg.springframework.beans.factory.annotation.Qualifier;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
/*** RabbitMQ配置文件*/@ConfigurationpublicclassRabbitmqConfig {
privatefinalStringEXCHANGE_NAME="boot_topic_exchange";
privatefinalStringQUEUE_NAME="boot_queue";
//创建交换机@Bean("bootExchange")
publicExchangegetExchange(){
returnExchangeBuilder                .topicExchange(EXCHANGE_NAME)//交换机类型                .durable(true)//是否持久化                .build();
    }
//创建队列@Bean("bootQueue")
publicQueuegetMessageQueue(){
// return new Queue(QUEUE_NAME);    }
//交换机绑定队列@BeanpublicBindingbindMessageQueue(@Qualifier("bootExchange") Exchangeexchange, 
@Qualifier("bootQueue") Queuequeue){
returnBindingBuilder            .bind(queue)
            .to(exchange)
            .with("#.message.#")
            .noargs();
    }
}

packagecom.study.rabbitmq;
importorg.junit.jupiter.api.Test;
importorg.springframework.amqp.rabbit.core.RabbitTemplate;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.boot.test.context.SpringBootTest;
@SpringBootTestpublicclassTestProducer {
//注入RabbitTemplate工具类@AutowiredprivateRabbitTemplaterabbitTemplate;
@TestpublicvoidtestSendMessage() {
rabbitTemplate.setConfirmCallback(newRabbitTemplate.ConfirmCallback() {
/*** 发送消息* 参数1 ：交换机* 参数2：路由key* 参数3：要发送的消息* */rabbitTemplate.convertAndSend("boot_topic_exchange", "message", "测试发送消息");
    }

packagecom.study.rabbitmq1.Consumer;
importcom.rabbitmq.client.Channel;
importorg.springframework.amqp.rabbit.annotation.RabbitListener;
importorg.springframework.stereotype.Component;
importjava.io.IOException;
//消费者@ComponentpublicclassConsumer {
//监听列队@RabbitListener(queues="boot_queue")
publicvoidlistenMessage(Messagemessage, Channelchannel)  {
inti=1/0;//模拟处理消息出现的bugSystem.out.println("接受消息："+message.getBody());
    }
}