1

pom.xml

@@ -100,9 +100,9 @@
             <scope>provided</scope>
         </dependency>
         <dependency>
-            <groupId>van.cn</groupId>
-            <artifactId>jd-jdk</artifactId>
-            <version>1.0</version>
+            <groupId>com.jd</groupId>
+            <artifactId>jdk</artifactId>
+            <version>2.0</version>
         </dependency>
     </dependencies>
 

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";

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<JSONObject> {
 
     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) {
         // 处理消息

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;
 
 /**