消息队列项目实例消息队列项目实例

package com.itbz.rabbitmq2.config; import org.springframework.amqp.core.*; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.security.KeyPair; @Configuration public class RabbitMqConfig { private final String EXCHANGE_NAME = "boot_topic_exchange"; private final String QUEUE_NAME = "boot_queue"; // 创建交换机 @Bean("bootExchange") public Exchange getExchange(){ return ExchangeBuilder .topicExchange(EXCHANGE_NAME) //交换机类型，内含交换机名字设置 .durable(true) //是否持久化 .build(); } // 创建队列 @Bean("bootQueue") public Queue getMessageQueue(){ return new Queue(QUEUE_NAME); //队列名 } // 交换机绑定队列 @Bean public Binding bindMessageQueue(@Qualifier("bootExchange") Exchange exchange, @Qualifier("bootQueue") Queue queue) { System.out.println("配置类生效"); return BindingBuilder .bind(queue) .to(exchange) .with("#.message.#") .noargs(); } }