diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml index 3e2fe8ca..dbe426b2 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml @@ -30,11 +30,11 @@ jeecg-boot-module-system - + org.jeecgframework.boot diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java index 2e455426..ece0f420 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java @@ -1,27 +1,27 @@ -package org.jeecg.modules.cloud.ebus; - -import cn.hutool.core.util.ObjectUtil; -import lombok.extern.slf4j.Slf4j; -import org.jeecg.boot.starter.rabbitmq.event.EventObj; -import org.jeecg.boot.starter.rabbitmq.event.JeecgBusEventHandler; -import org.jeecg.common.base.BaseMap; -import org.jeecg.modules.cloud.constant.CloudConstant; -import org.springframework.stereotype.Component; - -/** - * 消息处理器【发布订阅】 - */ -@Slf4j -@Component(CloudConstant.MQ_DEMO_BUS_EVENT) -public class DemoBusEvent implements JeecgBusEventHandler { - - - @Override - public void onMessage(EventObj obj) { - if (ObjectUtil.isNotEmpty(obj)) { - BaseMap baseMap = obj.getBaseMap(); - String orderId = baseMap.get("orderId"); - log.info("业务处理----订单ID:" + orderId); - } - } -} +//package org.jeecg.modules.cloud.ebus; +// +//import cn.hutool.core.util.ObjectUtil; +//import lombok.extern.slf4j.Slf4j; +//import org.jeecg.boot.starter.rabbitmq.event.EventObj; +//import org.jeecg.boot.starter.rabbitmq.event.JeecgBusEventHandler; +//import org.jeecg.common.base.BaseMap; +//import org.jeecg.modules.cloud.constant.CloudConstant; +//import org.springframework.stereotype.Component; +// +///** +// * 消息处理器【发布订阅】 +// */ +//@Slf4j +//@Component(CloudConstant.MQ_DEMO_BUS_EVENT) +//public class DemoBusEvent implements JeecgBusEventHandler { +// +// +// @Override +// public void onMessage(EventObj obj) { +// if (ObjectUtil.isNotEmpty(obj)) { +// BaseMap baseMap = obj.getBaseMap(); +// String orderId = baseMap.get("orderId"); +// log.info("业务处理----订单ID:" + orderId); +// } +// } +//} diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java index 1f34c9ed..8713efbb 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java @@ -1,12 +1,9 @@ package org.jeecg.modules.cloud.feign.controller; -import cn.hutool.core.util.RandomUtil; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; -import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient; import org.jeecg.common.api.vo.Result; -import org.jeecg.common.base.BaseMap; import org.jeecg.modules.cloud.constant.CloudConstant; import org.jeecg.modules.cloud.feign.feign.JeecgTestClient; import org.jeecg.modules.cloud.feign.feign.JeecgTestClientDyn; @@ -16,8 +13,6 @@ import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; -import javax.servlet.http.HttpServletRequest; - @RestController @RequestMapping("/sys/test") @Api(tags = "【微服务】单元测试") @@ -27,8 +22,8 @@ public class JeecgTestFeignController { private JeecgFeignService jeecgFeignService; @Autowired private JeecgTestClient jeecgTestClient; - @Autowired - private RabbitMqClient rabbitMqClient; +// @Autowired +// private RabbitMqClient rabbitMqClient; @GetMapping("getMessage") @ApiOperation(value = "测试feign", notes = "测试feign") @@ -43,19 +38,19 @@ public class JeecgTestFeignController { return myClientDyn.getMessage("动态fegin——jeecg-boot2"); } - @GetMapping(value = "/rabbitmq") - @ApiOperation(value = "测试rabbitmq", notes = "测试rabbitmq") - public Result rabbitMqClientTest(HttpServletRequest req) { - //rabbitmq消息队列测试 - BaseMap map = new BaseMap(); - map.put("orderId", RandomUtil.randomNumbers(10)); - rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map); - rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER_TIME, map,10); - - //rabbitmq消息总线测试 - BaseMap params = new BaseMap(); - params.put("orderId", "123456"); - rabbitMqClient.publishEvent(CloudConstant.MQ_DEMO_BUS_EVENT, params); - return Result.OK("MQ发送消息成功"); - } +// @GetMapping(value = "/rabbitmq") +// @ApiOperation(value = "测试rabbitmq", notes = "测试rabbitmq") +// public Result rabbitMqClientTest(HttpServletRequest req) { +// //rabbitmq消息队列测试 +// BaseMap map = new BaseMap(); +// map.put("orderId", RandomUtil.randomNumbers(10)); +// rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map); +// rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER_TIME, map,10); +// +// //rabbitmq消息总线测试 +// BaseMap params = new BaseMap(); +// params.put("orderId", "123456"); +// rabbitMqClient.publishEvent(CloudConstant.MQ_DEMO_BUS_EVENT, params); +// return Result.OK("MQ发送消息成功"); +// } } diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java index 1792c737..032d6ba0 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java @@ -1,17 +1,11 @@ package org.jeecg.modules.cloud.lock; import lombok.extern.slf4j.Slf4j; -import org.jeecg.boot.starter.lock.annotation.JLock; import org.jeecg.boot.starter.lock.client.RedissonLockClient; -import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient; -import org.jeecg.common.base.BaseMap; import org.jeecg.modules.cloud.constant.CloudConstant; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; -import java.util.Map; - /** * 分布式锁测试demo */ @@ -20,26 +14,26 @@ import java.util.Map; public class DemoLockTest { @Autowired RedissonLockClient redissonLock; - @Autowired - RabbitMqClient rabbitMqClient; +// @Autowired +// RabbitMqClient rabbitMqClient; - /** - * 测试分布式锁【注解方式】 - */ - @Scheduled(cron = "0/5 * * * * ?") - @JLock(lockKey = CloudConstant.REDISSON_DEMO_LOCK_KEY1) - public void execute() throws InterruptedException { - log.info("执行execute任务开始,休眠三秒"); - Thread.sleep(3000); - System.out.println("=======================业务逻辑1============================="); - Map map = new BaseMap(); - map.put("orderId", "BJ0001"); - rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map); - //延迟10秒发送 - map.put("orderId", "NJ0002"); - rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map, 10000); - log.info("execute任务结束,休眠三秒"); - } +// /** +// * 测试分布式锁【注解方式】 +// */ +// @Scheduled(cron = "0/5 * * * * ?") +// @JLock(lockKey = CloudConstant.REDISSON_DEMO_LOCK_KEY1) +// public void execute() throws InterruptedException { +// log.info("执行execute任务开始,休眠三秒"); +// Thread.sleep(3000); +// System.out.println("=======================业务逻辑1============================="); +// Map map = new BaseMap(); +// map.put("orderId", "BJ0001"); +// rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map); +// //延迟10秒发送 +// map.put("orderId", "NJ0002"); +// rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map, 10000); +// log.info("execute任务结束,休眠三秒"); +// } public DemoLockTest() { } diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java index 29de6ef4..6d769e5d 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java @@ -1,36 +1,36 @@ -package org.jeecg.modules.cloud.rabbitmq; - -import com.rabbitmq.client.Channel; -import lombok.extern.slf4j.Slf4j; -import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; -import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; -import org.jeecg.common.annotation.RabbitComponent; -import org.jeecg.common.base.BaseMap; -import org.jeecg.modules.cloud.constant.CloudConstant; -import org.springframework.amqp.rabbit.annotation.RabbitHandler; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.amqp.support.AmqpHeaders; -import org.springframework.messaging.handler.annotation.Header; - -/** - * RabbitMq接受者1 - * (@RabbitListener声明类上,一个类只能监听一个队列) - */ -@Slf4j -@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER) -@RabbitComponent(value = "helloReceiver1") -public class HelloReceiver1 extends BaseRabbiMqHandler { - - @RabbitHandler - public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { - super.onMessage(baseMap, deliveryTag, channel, new MqListener() { - @Override - public void handler(BaseMap map, Channel channel) { - //业务处理 - String orderId = map.get("orderId").toString(); - log.info("MQ Receiver1,orderId : " + orderId); - } - }); - } - -} \ No newline at end of file +//package org.jeecg.modules.cloud.rabbitmq; +// +//import com.rabbitmq.client.Channel; +//import lombok.extern.slf4j.Slf4j; +//import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; +//import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; +//import org.jeecg.common.annotation.RabbitComponent; +//import org.jeecg.common.base.BaseMap; +//import org.jeecg.modules.cloud.constant.CloudConstant; +//import org.springframework.amqp.rabbit.annotation.RabbitHandler; +//import org.springframework.amqp.rabbit.annotation.RabbitListener; +//import org.springframework.amqp.support.AmqpHeaders; +//import org.springframework.messaging.handler.annotation.Header; +// +///** +// * RabbitMq接受者1 +// * (@RabbitListener声明类上,一个类只能监听一个队列) +// */ +//@Slf4j +//@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER) +//@RabbitComponent(value = "helloReceiver1") +//public class HelloReceiver1 extends BaseRabbiMqHandler { +// +// @RabbitHandler +// public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { +// super.onMessage(baseMap, deliveryTag, channel, new MqListener() { +// @Override +// public void handler(BaseMap map, Channel channel) { +// //业务处理 +// String orderId = map.get("orderId").toString(); +// log.info("MQ Receiver1,orderId : " + orderId); +// } +// }); +// } +// +//} \ No newline at end of file diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java index abc83910..14fb9ddb 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java @@ -1,36 +1,36 @@ -package org.jeecg.modules.cloud.rabbitmq; - -import com.rabbitmq.client.Channel; -import lombok.extern.slf4j.Slf4j; -import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; -import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; -import org.jeecg.common.annotation.RabbitComponent; -import org.jeecg.common.base.BaseMap; -import org.jeecg.modules.cloud.constant.CloudConstant; -import org.springframework.amqp.rabbit.annotation.RabbitHandler; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.amqp.support.AmqpHeaders; -import org.springframework.messaging.handler.annotation.Header; - -/** - * RabbitMq接受者2 - * (@RabbitListener声明类上,一个类只能监听一个队列) - */ -@Slf4j -@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER) -@RabbitComponent(value = "helloReceiver2") -public class HelloReceiver2 extends BaseRabbiMqHandler { - - @RabbitHandler - public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { - super.onMessage(baseMap, deliveryTag, channel, new MqListener() { - @Override - public void handler(BaseMap map, Channel channel) { - //业务处理 - String orderId = map.get("orderId").toString(); - log.info("MQ Receiver2,orderId : " + orderId); - } - }); - } - -} \ No newline at end of file +//package org.jeecg.modules.cloud.rabbitmq; +// +//import com.rabbitmq.client.Channel; +//import lombok.extern.slf4j.Slf4j; +//import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; +//import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; +//import org.jeecg.common.annotation.RabbitComponent; +//import org.jeecg.common.base.BaseMap; +//import org.jeecg.modules.cloud.constant.CloudConstant; +//import org.springframework.amqp.rabbit.annotation.RabbitHandler; +//import org.springframework.amqp.rabbit.annotation.RabbitListener; +//import org.springframework.amqp.support.AmqpHeaders; +//import org.springframework.messaging.handler.annotation.Header; +// +///** +// * RabbitMq接受者2 +// * (@RabbitListener声明类上,一个类只能监听一个队列) +// */ +//@Slf4j +//@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER) +//@RabbitComponent(value = "helloReceiver2") +//public class HelloReceiver2 extends BaseRabbiMqHandler { +// +// @RabbitHandler +// public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { +// super.onMessage(baseMap, deliveryTag, channel, new MqListener() { +// @Override +// public void handler(BaseMap map, Channel channel) { +// //业务处理 +// String orderId = map.get("orderId").toString(); +// log.info("MQ Receiver2,orderId : " + orderId); +// } +// }); +// } +// +//} \ No newline at end of file diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java index 5289c3aa..2be891c6 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java @@ -1,35 +1,35 @@ -package org.jeecg.modules.cloud.rabbitmq; - -import com.rabbitmq.client.Channel; -import lombok.extern.slf4j.Slf4j; -import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; -import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; -import org.jeecg.common.annotation.RabbitComponent; -import org.jeecg.common.base.BaseMap; -import org.jeecg.modules.cloud.constant.CloudConstant; -import org.springframework.amqp.rabbit.annotation.RabbitHandler; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.amqp.support.AmqpHeaders; -import org.springframework.messaging.handler.annotation.Header; - -/** - * RabbitMq接受者3 - * (@RabbitListener声明类方法上,一个类可以多监听多个队列) - */ -@Slf4j -@RabbitComponent(value = "helloReceiver3") -public class HelloReceiver3 extends BaseRabbiMqHandler { - - @RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER) - public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { - super.onMessage(baseMap, deliveryTag, channel, new MqListener() { - @Override - public void handler(BaseMap map, Channel channel) { - //业务处理 - String orderId = map.get("orderId").toString(); - log.info("MQ Receiver3,orderId : " + orderId); - } - }); - } - -} \ No newline at end of file +//package org.jeecg.modules.cloud.rabbitmq; +// +//import com.rabbitmq.client.Channel; +//import lombok.extern.slf4j.Slf4j; +//import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; +//import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; +//import org.jeecg.common.annotation.RabbitComponent; +//import org.jeecg.common.base.BaseMap; +//import org.jeecg.modules.cloud.constant.CloudConstant; +//import org.springframework.amqp.rabbit.annotation.RabbitHandler; +//import org.springframework.amqp.rabbit.annotation.RabbitListener; +//import org.springframework.amqp.support.AmqpHeaders; +//import org.springframework.messaging.handler.annotation.Header; +// +///** +// * RabbitMq接受者3 +// * (@RabbitListener声明类方法上,一个类可以多监听多个队列) +// */ +//@Slf4j +//@RabbitComponent(value = "helloReceiver3") +//public class HelloReceiver3 extends BaseRabbiMqHandler { +// +// @RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER) +// public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { +// super.onMessage(baseMap, deliveryTag, channel, new MqListener() { +// @Override +// public void handler(BaseMap map, Channel channel) { +// //业务处理 +// String orderId = map.get("orderId").toString(); +// log.info("MQ Receiver3,orderId : " + orderId); +// } +// }); +// } +// +//} \ No newline at end of file diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java index 649c9cc3..38e9131c 100644 --- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java +++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java @@ -1,32 +1,32 @@ -package org.jeecg.modules.cloud.rabbitmq; - -import com.rabbitmq.client.Channel; -import lombok.extern.slf4j.Slf4j; -import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; -import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; -import org.jeecg.common.annotation.RabbitComponent; -import org.jeecg.common.base.BaseMap; -import org.jeecg.modules.cloud.constant.CloudConstant; -import org.springframework.amqp.rabbit.annotation.RabbitHandler; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.amqp.support.AmqpHeaders; -import org.springframework.messaging.handler.annotation.Header; - -@Slf4j -@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER_TIME) -@RabbitComponent(value = "helloTimeReceiver") -public class HelloTimeReceiver extends BaseRabbiMqHandler { - - @RabbitHandler - public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { - super.onMessage(baseMap, deliveryTag, channel, new MqListener() { - @Override - public void handler(BaseMap map, Channel channel) { - //业务处理 - String orderId = map.get("orderId").toString(); - log.info("Time Receiver1,orderId : " + orderId); - } - }); - } - -} \ No newline at end of file +//package org.jeecg.modules.cloud.rabbitmq; +// +//import com.rabbitmq.client.Channel; +//import lombok.extern.slf4j.Slf4j; +//import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler; +//import org.jeecg.boot.starter.rabbitmq.listenter.MqListener; +//import org.jeecg.common.annotation.RabbitComponent; +//import org.jeecg.common.base.BaseMap; +//import org.jeecg.modules.cloud.constant.CloudConstant; +//import org.springframework.amqp.rabbit.annotation.RabbitHandler; +//import org.springframework.amqp.rabbit.annotation.RabbitListener; +//import org.springframework.amqp.support.AmqpHeaders; +//import org.springframework.messaging.handler.annotation.Header; +// +//@Slf4j +//@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER_TIME) +//@RabbitComponent(value = "helloTimeReceiver") +//public class HelloTimeReceiver extends BaseRabbiMqHandler { +// +// @RabbitHandler +// public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) { +// super.onMessage(baseMap, deliveryTag, channel, new MqListener() { +// @Override +// public void handler(BaseMap map, Channel channel) { +// //业务处理 +// String orderId = map.get("orderId").toString(); +// log.info("Time Receiver1,orderId : " + orderId); +// } +// }); +// } +// +//} \ No newline at end of file diff --git a/jeecg-boot/pom.xml b/jeecg-boot/pom.xml index 7dd48293..94336697 100644 --- a/jeecg-boot/pom.xml +++ b/jeecg-boot/pom.xml @@ -363,7 +363,7 @@ jeecg - 127.0.0.1:8848 + jeecg-boot-nacos:8848 @@ -373,7 +373,7 @@ DEFAULT_GROUP - 127.0.0.1:8848 + jeecg-boot-nacos:8848 @@ -385,7 +385,7 @@ jeecg - 127.0.0.1:8848 + jeecg-boot-nacos:8848 @@ -395,7 +395,7 @@ DEFAULT_GROUP - 127.0.0.1:8848 + jeecg-boot-nacos:8848 @@ -407,7 +407,7 @@ jeecg - 127.0.0.1:8848 + jeecg-boot-nacos:8848 @@ -417,7 +417,7 @@ DEFAULT_GROUP - 127.0.0.1:8848 + jeecg-boot-nacos:8848