RabbitMQ之业务场景（四）：动态创建，删除队列工具类，拿来即用

目前有整合RabbitMQ到项目中，有个需求就是：需要根据不同的门店创建不同的队列，而在启动项目初始化的时候，是不知到有哪些门店在使用，所以创建了也就浪费了资源。所以就有了动态创建队列的需求。
然后在网上疯狂的搜罗了一波。现总结如下：
RabbitConfig.java 配置类

import java.util.HashMap;
import java.util.Map;import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.CustomExchange;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 配置rabbitMQ* @author Rayson517**/
@Configuration
public class RabbitConfig {@Beanpublic RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){return new RabbitAdmin(connectionFactory);}@Beanpublic RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){RabbitTemplate rabbitTemplate=new RabbitTemplate(connectionFactory);//数据转换为json存入消息队列rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());return rabbitTemplate;}
}

RabbitUtil.java工具类

import java.util.Date;
import java.util.UUID;import javax.annotation.Resource;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.AbstractExchange;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.CustomExchange;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Exchange;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessagePostProcessor;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.SerializationUtils;@Configuration
public class RabbitUtil {private static final Logger logger = LoggerFactory.getLogger(RabbitUtil.class);private final RabbitAdmin rabbitAdmin;private final RabbitTemplate rabbitTemplate;@Autowiredpublic RabbitUtil(RabbitAdmin rabbitAdmin, RabbitTemplate rabbitTemplate){this.rabbitAdmin = rabbitAdmin;this.rabbitTemplate = rabbitTemplate;}/*** 转换Message对象* @param messageType 返回消息类型 MessageProperties类中常量* @param msg* @return*/public Message getMessage(String messageType, Object msg){MessageProperties messageProperties = new MessageProperties();messageProperties.setContentType(messageType);Message message = new Message(msg.toString().getBytes(),messageProperties);return message;}/*** 有绑定Key的Exchange发送* @param routingKey* @param msg*/public void sendMessageToExchange(TopicExchange topicExchange, String routingKey, Object msg){Message message = getMessage(MessageProperties.CONTENT_TYPE_JSON,msg);rabbitTemplate.send(topicExchange.getName(), routingKey, message);}/*** 没有绑定KEY的Exchange发送* @param exchange* @param msg*/public void sendMessageToExchange(TopicExchange topicExchange, AbstractExchange exchange, String msg){addExchange(exchange);logger.info("RabbitMQ send "+exchange.getName()+"->"+msg);rabbitTemplate.convertAndSend(topicExchange.getName(),msg);}/*** 给queue发送消息* @param queueName* @param msg*/public void sendToQueue(String queueName, String msg){sendToQueue(DirectExchange.DEFAULT, queueName, msg);}/*** 给direct交换机指定queue发送消息* @param directExchange* @param queueName* @param msg*/public void sendToQueue(DirectExchange directExchange, String queueName, String msg){Queue queue = new Queue(queueName);addQueue(queue);Binding binding = BindingBuilder.bind(queue).to(directExchange).withQueueName();rabbitAdmin.declareBinding(binding);//设置消息内容的类型，默认是 application/octet-stream 会是 ASCII 码值rabbitTemplate.convertAndSend(directExchange.getName(), queueName, msg);}/*** 给queue发送消息* @param queueName* @param msg*/public String receiveFromQueue(String queueName){return receiveFromQueue(DirectExchange.DEFAULT, queueName);}/*** 给direct交换机指定queue发送消息* @param directExchange* @param queueName* @param msg*/public String receiveFromQueue(DirectExchange directExchange, String queueName){Queue queue = new Queue(queueName);addQueue(queue);Binding binding = BindingBuilder.bind(queue).to(directExchange).withQueueName();rabbitAdmin.declareBinding(binding);String messages = (String)rabbitTemplate.receiveAndConvert(queueName);System.out.println("Receive:"+messages);return messages;}/*** 创建Exchange* @param exchange*/public void addExchange(AbstractExchange exchange){rabbitAdmin.declareExchange(exchange);}/*** 删除一个Exchange* @param exchangeName*/public boolean deleteExchange(String exchangeName){return rabbitAdmin.deleteExchange(exchangeName);}/*** Declare a queue whose name is automatically named. It is created with exclusive = true, autoDelete=true, and* durable = false.* @return Queue*/public Queue addQueue(){return rabbitAdmin.declareQueue();}/*** 创建一个指定的Queue* @param queue* @return queueName*/public String addQueue(Queue queue){return rabbitAdmin.declareQueue(queue);}/*** Delete a queue.* @param queueName the name of the queue.* @param unused true if the queue should be deleted only if not in use.* @param empty true if the queue should be deleted only if empty.*/public void deleteQueue(String queueName, boolean unused, boolean empty){rabbitAdmin.deleteQueue(queueName,unused,empty);}/*** 删除一个queue* @return true if the queue existed and was deleted.* @param queueName*/public boolean deleteQueue(String queueName){return rabbitAdmin.deleteQueue(queueName);}/*** 绑定一个队列到一个匹配型交换器使用一个routingKey* @param queue* @param exchange* @param routingKey*/public void addBinding(Queue queue ,TopicExchange exchange,String routingKey){Binding binding = BindingBuilder.bind(queue).to(exchange).with(routingKey);rabbitAdmin.declareBinding(binding);}/*** 绑定一个Exchange到一个匹配型Exchange 使用一个routingKey* @param exchange* @param topicExchange* @param routingKey*/public void addBinding(Exchange exchange,TopicExchange topicExchange,String routingKey){Binding binding = BindingBuilder.bind(exchange).to(topicExchange).with(routingKey);rabbitAdmin.declareBinding(binding);}/*** 去掉一个binding* @param binding*/public void removeBinding(Binding binding){rabbitAdmin.removeBinding(binding);}
}

然后在需要的地方注入这个RabbitUtil工具类就可以使用了

RabbitMQ之业务场景（四）：动态创建，删除队列工具类，拿来即用相关推荐

安卓创建第一个工具类
安卓创建工具类 1.运用IOC框架简化代码注解 (Annotation):@Class 给代码看的处理代码逻辑 2. 创建自己的注解 @Target() ElementType.FIELD 放在属性 ...
Mybatis的动态创建删除表
Mybatis中可以使用JSTL标签动态删除表 Mapper void deleteTable(@Param("tableName") String tableName); Ma ...
Pygame飞机大战（四）——创建己方飞机的类，并添加子弹吧
我们接下来要基于pygame.sprite.Sprite创建自己的类,首先必须是主角的,创建一个己方飞机的类,并且给飞机加上子弹哈! 首先我们还是先分析一下,己方飞机需要有哪些部分构成: 自身的图片加 ...
JUC（3）List、Set、Map集合线程安全Callable创建线程三大工具类：CountDownLatch减法计数器、CyclicBarrier加法计数器、Semaphore计数信号量
1. List集合线程安全 CopyOnWriteArrayList是线程安全的集合: ArrayList是线程不安全的集合: Vector是线程安全的集合(不推荐使用) 1.1 解决ArrarLis ...
JUC系列(四) callable与常用的工具类
一个字稳，云原生产品家族支撑冬奥会九大业务场景，打造云上奥运新体验
北京冬奥会已经成为收视最高的一届冬奥会,在转播时长.技术.内容制作方式等多方面都书写了新记录.云技术的应用,是本届北京冬奥会赛事转播的一大特色. 而云原生作为云计算的新界面,如何稳定支撑北京冬奥会多个 ...
php业务的适用场景,根据业务场景寻找合适解决方案（PHP）?
系统环境: Linux PHP 7.3 ThinkPHP 6 先说一下业务场景: 订单创建成功之后,每一笔订单都需要进行统计及其他业务处理. 如何及时发现处理失败的订单,然后进行补单处理. 订单所产生 ...
throwable四参构造_深入分析Java反射(四)-动态代理
动态代理的简介 Java动态代理机制的出现,使得Java开发人员不用手工编写代理类,只要简单地指定一组接口及委托类对象,便能动态地获得代理类.代理类会负责将所有的方法调用分派到委托对象上反射执行,在分 ...
Drools动态创建规则文件并动态调用
目录 1.编写规则内容,如下图 2.创建KieSession 3.根据规则名称货主匹配规则进行执行 3.1.根据规则名称完全匹配方式执行 3.2.根据规则名称前缀匹配方式执行 1.编写规则内容,如下图 ...
Android动态加载黑科技动态创建Activity模式
基本信息 Author:kaedea GitHub:android-dynamical-loading 代理Activity模式的限制还记得我们在代理Activity模式里谈到启动插件APK里的Ac ...

RabbitMQ之业务场景（四）：动态创建，删除队列工具类，拿来即用

RabbitMQ之业务场景（四）：动态创建，删除队列工具类，拿来即用相关推荐

最新文章

热门文章