AmqpAdmin amqpAdmin

pom文件如下： application.properties中配置如下： 自定义RabbitMQ配置类 如下实例，自定义了连接工厂和SimpleRabbitListenerContainerFactory 以及在项目启动时初始化了交换器、队列并进行了路由绑定。当然，如果MQ服务器实现配置了好交换机、路由以及绑定规则，则不需要这些自定义配置，直接使用消息模板进行发送即可。 引入rabbitmq相关的starter后，RabbitAutoConfiguration就会默认对RabbitMQ进行配置。 主要配置如下： 自动配置了连接工厂ConnectionFactory； RabbitProperties封装了RabbitMQ的属性配置； RabbitTemplate用来发送接收消息； AmqpAdmin–RabbitMQ系统管理功能组件。 这里使用RabbitTemplate测试消息发送和接收，源码如下： 发送后查看后台队列并获取消息如下图： 接收如下图所示： RabbitTemplate使用详解 先看启类继承图：...

1.在config配置类中定义 import org.springframework.amqp.core.*; import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; import org.springframework.amqp.support.converter.MessageConverter; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RabbitMQConfig { //定制JSON格式的消息转化器 @Bean public MessageConverter messageConverter(){ return new Jackson2JsonMessageConverter(); } // 1.fanout创建一个交换机...

本笔记内容为尚硅谷谷粒商城消息队列RabbitMQ部分 目录 4369, 25672 (Erlang发现&集群端口) 5672, 5671 (AMQP端口) 15672 (web管理后台端口) 61613, 61614 (STOMP协议端口) 1883, 8883 (MQTT协议端口) Networking and RabbitMQ — RabbitMQ <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 2、application.yml配置 spring.rabbitmq.host=192.168.88.130 spring.rabbitmq.port=5672 spring.rabbitmq.virtual-host=/ 3、测试RabbitMQ 1.