改动网站标题,门户系统是什么意思,上海国际物流网站建设,中国建设银行官企业网站文章目录 前言动态创建和管理Exchange、Queue动态消费Queue结论 前言
前面我们学习 RabbitMQ 的时候#xff0c;都是在编译的时候就确定了Exchange、Queue#xff0c;也就是说我们需要在程序启动之前就创建好需要的Exchange和Queue#xff0c;但是实际使用的时候#xff0… 文章目录 前言动态创建和管理Exchange、Queue动态消费Queue结论 前言
前面我们学习 RabbitMQ 的时候都是在编译的时候就确定了Exchange、Queue也就是说我们需要在程序启动之前就创建好需要的Exchange和Queue但是实际使用的时候我们往往不能够实现知道所有的Exchange和Queue而是在运行时才能够确定这些信息那么在 Spring 中如何动态的管理这些呢
动态创建和管理Exchange、Queue
在 Spring 中动态的创建和管理Exchange、Queue主要依赖于 RabbitAdmin 类这个 RabbitAdmin Spring 已经帮我们管理了只要我们导入了 RabbitMQ 的依赖就可以使用 Autowired 或者 Resource 将 RabbitAdmin 依赖注入就可以了
Autowired
private RabbitAdmin rabbitAdmin;注入 RabbitAdmin 之后我们就来看看如何创建 Exchange跟之前学习的差不多这里的创建 Exchange 也叫做声明交换机也就是 delareExchange()方法 方法需要的参数类型是 Exchange 类型也就是前面我们学习的 fanout、direct、topic 三种类型 所以在声明交换机之前需要先创建出一个对应类型的交换机
public void createExchange(String name) {FanoutExchange exchange new FanoutExchange(name .exchange);
}创建完成之后将这个交换机以参数的形式传入到 declareExchange 方法中
public void createExchange(String name) {FanoutExchange exchange new FanoutExchange(name .exchange);rabbitAdmin.declareExchange(exchange);
}上面是声明交换机的方式那么声明队列的方式也是类似的先创建队列然后再声明队列
Queue queue new Queue(message.queue);
rabbitAdmin.declareQueue(queue);声明完成Exchange和Queue之后接下来就是声明Exchange和Queue的Binding关系了声明绑定关系同样如此还是先创建Binding然后是声明Binding
Binding binding new Binding(message.queue, Binding.DestinationType.QUEUE,name.exchange,message,null);
rabbitAdmin.declareBinding(binding);注意因为declare 方法的第一个和第三个参数的类型都是 String 类型所以为了区分出哪个参数是队列的名字哪个参数的是交换机的名字就是用了第二个参数来指明。如果先绑定的是 Queue也就是第一个参数是队列的名字那么第二个参数就是 Binding.DestinationType.QUEUE如果第一个参数是交换机的名字那么第二个参数就是 Binding.DestinationType.EXCHANGE。
动态消费Queue
和创建和管理Exchange、Queue一样如果我们不想简单的消费队列而是经过一些逻辑之后才进行消费的话该如何做呢之前都是通过在 config 类中通过 RabbitListener 注解来监听队列那么我们如何显示的调用方法来监听队列呢
Spring amqp 为我们提供了一个 MessageListener 接口我们需要实现这个接口中的 onMessage() 方法 当通过 MessageListener 接口实现了消费者的主要消费逻辑之后我们就需要设置监听器设置监听器依靠于 SimpleMessageListenerContainer 类中的 setMessageListener() 方法然后具体监听哪个队列就通过 addQueueNames() 方法来指定需要消费的队列
Component
public class ThreadPoolUtil {Resource(name taskExecutor)private Executor taskExecutor;Autowiredprivate SimpleMessageListenerContainer simpleMessageListenerContainer;Autowiredprivate RabbitMessageQueueListener rabbitMessageQueueListener;PostConstructpublic void init() {taskExecutor.execute(() - {simpleMessageListenerContainer.setMessageListener(rabbitMessageQueueListener);simpleMessageListenerContainer.addQueueNames(message.queue);});}
}结论
感谢各位朋友们能够看到结尾找不到工作某直聘已读不回不妨看看这里超快回复助力每一位程序员早日找到理想的工作
