RabbitAdmin
code
- RabbitAdmin类能够很好的操做RabbitMQ,在Spring中直接进行注入便可。
- 注意:autoStartup必需要设置为true,不然Spring容器不会加载RabbitAdmin类
- RabbitAdmin底层实现就是从Spring容器中获取Exchange、Binding、RoutingKey以及Queue的@Bean声明
- 而后使用RabbitTemplate的execute方法执行对应的声明,修改,删除等一系列RabbitMQ基础功能操做
- 例如:添加一个交换机,删除一个绑定,清空一个队列里的消息等
@Bean public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){ RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory); rabbitAdmin.setAutoStartup(true); return rabbitAdmin; }
SpringAMQP
RabbitTemplate
SimpleMessageListenerContainer
MessageListenerAdapter
MessageConverter