diff --git a/pom.xml b/pom.xml index 0d06f53..b3f8446 100644 --- a/pom.xml +++ b/pom.xml @@ -100,9 +100,9 @@ provided - van.cn - jd-jdk - 1.0 + com.jd + jdk + 2.0 diff --git a/src/main/java/cn/van/business/controller/jd/OrderController.java b/src/main/java/cn/van/business/controller/jd/OrderController.java index d109da2..d18bba9 100644 --- a/src/main/java/cn/van/business/controller/jd/OrderController.java +++ b/src/main/java/cn/van/business/controller/jd/OrderController.java @@ -16,7 +16,7 @@ import javax.annotation.Resource; * @description: */ @RestController -@RequestMapping("order") +@RequestMapping("/order") public class OrderController { public static String TOKEN = "cc0313"; diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 767b807..9ce7719 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -14,7 +14,6 @@ import org.springframework.stereotype.Service; import java.nio.charset.StandardCharsets; import java.util.Base64; -import static cn.hutool.core.thread.ThreadUtil.sleep; import static cn.van.business.util.WXUtil.WX_BASE_URL; /** @@ -24,13 +23,14 @@ import static cn.van.business.util.WXUtil.WX_BASE_URL; * @description: */ @Service -@RocketMQMessageListener(topic = "wx-message", consumerGroup = "${rocketmq.consumer.group}",nameServer = "${rocketmq.name-server}") +@RocketMQMessageListener(topic = "wx-message", consumerGroup = "${rocketmq.consumer.group}", nameServer = "${rocketmq.name-server}") public class MessageConsumerService implements RocketMQListener { private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class); // create a rate limiter of 1 qps RateLimiter rateLimiter = RateLimiter.create(0.5); + @Override public void onMessage(JSONObject jsonObject) { // 处理消息 diff --git a/src/main/java/cn/van/business/mq/MessageProducerService.java b/src/main/java/cn/van/business/mq/MessageProducerService.java index 20d4380..85f1e3b 100644 --- a/src/main/java/cn/van/business/mq/MessageProducerService.java +++ b/src/main/java/cn/van/business/mq/MessageProducerService.java @@ -6,7 +6,6 @@ import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; /**