复制
/** * 用于创建测试程序用到的交换机和队列（只用在程序启动前执行一次） */ @Slf4j @Component public class InitRabbitMqBean { @Value("${spring.rabbitmq.host:localhost}") private String host; @PostConstruct public void init() { try { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(host); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); String EXCHANGE_NAME = "code_exchange"; channel.exchangeDeclare(EXCHANGE_NAME, "direct"); // 创建队列，随机分配一个队列名称 String queueName = "code_queue"; channel.queueDeclare(queueName, true, false, false, null); channel.queueBind(queueName, EXCHANGE_NAME, "my_routingKey"); log.info("消息队列启动成功"); } catch (Exception e) { log.error("消息队列启动失败"); } } }
