From 2151a5efbac31c1f6a1b2563ccb352170aa48c9c Mon Sep 17 00:00:00 2001 From: 935090232@qq.com <ak473600000> Date: Mon, 25 Oct 2021 14:14:16 +0800 Subject: [PATCH] 新增本地缓存 --- zq-erp/src/main/java/com/matrix/config/RabbitMqConfig.java | 36 ++++++++++++++++-------------------- 1 files changed, 16 insertions(+), 20 deletions(-) diff --git a/zq-erp/src/main/java/com/matrix/config/RabbitMqConfig.java b/zq-erp/src/main/java/com/matrix/config/RabbitMqConfig.java index ce1ff16..f93d94d 100644 --- a/zq-erp/src/main/java/com/matrix/config/RabbitMqConfig.java +++ b/zq-erp/src/main/java/com/matrix/config/RabbitMqConfig.java @@ -5,7 +5,10 @@ import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.rabbitmq.RabiitMqTemplateFactory; import com.matrix.core.tools.LogUtil; -import com.matrix.system.shopXcx.mqTask.*; +import com.matrix.system.shopXcx.mqTask.OrderOutSotoreTask; +import com.matrix.system.shopXcx.mqTask.SalesOrderRefundTask; +import com.matrix.system.shopXcx.mqTask.SalesOrderTask; +import com.matrix.system.shopXcx.mqTask.TemplateMsgTask; import com.matrix.system.wechart.templateMsg.Task.UniformMsgSentTask; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; @@ -15,7 +18,10 @@ import java.util.ArrayList; import java.util.List; -@Configuration +/** + * 小型应用弃用rabbitmq,直接通过观察者模式对消息进行同步消费 参考 AsyncMessageManager + */ +//@Configuration public class RabbitMqConfig { @Value("${rabbitmq.host}") @@ -38,18 +44,17 @@ //订阅模式 public static final String MQ_EXCHANGE_TOPIC = "hive_exchange_fanout"; - @Bean - VipCreateTask VipCreateTask() { - return new VipCreateTask(); - } - @Bean - OrderTask OrderrCreateTask() { - return new OrderTask(); - } + + + @Bean SalesOrderTask SalesOrderTask() { return new SalesOrderTask(); + } + @Bean + SalesOrderRefundTask SalesOrderRefundTask() { + return new SalesOrderRefundTask(); } @Bean @@ -80,17 +85,7 @@ List<MqTask> taskList = new ArrayList<>(); //注册RabbitMq任务 - taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.CREATE_VIP + evn, MQTaskRouting.CREATE_VIP + evn, VipCreateTask())); - //订阅模式 - - taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.SEND_TEMPLATE_MSG + evn,MQTaskRouting.SEND_TEMPLATE_MSG + evn, TemplateMsgTask())); - taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.ORDER_OUT_SOTORE + evn,MQTaskRouting.ORDER_OUT_SOTORE + evn, OrderOutSotoreTask())); - taskList.add(new MqTask(MQ_EXCHANGE_A + evn, MQTaskRouting.SEND_UNIFORM_TEMPLATE_MSG + evn,MQTaskRouting.SEND_UNIFORM_TEMPLATE_MSG + evn, UniformMsgSentTask())); - - //不同任务在不同的队列,但是routingKey一样则可以收到生产者消息 - taskList.add(new MqTask(MQ_EXCHANGE_TOPIC + evn, MQTaskRouting.CREATE_ORDER + evn,MQTaskRouting.CREATE_ORDER + evn,SalesOrderTask())); - taskList.add(new MqTask(MQ_EXCHANGE_TOPIC + evn, MQTaskRouting.SALES_ORDER + evn,MQTaskRouting.CREATE_ORDER + evn,OrderrCreateTask())); rabiitMqTemplate.binding(taskList); @@ -99,4 +94,5 @@ } + } -- Gitblit v1.9.1