mq一个消费者组订阅一个主题

4dkankan-center-scene/src/main/java/com/fdkankan/scene/controller/TestController.java

@@ -65,9 +65,11 @@ public class TestController {
 
     @GetMapping("/test")
     public String test() throws Exception {
-        for (int i = 0; i< 10; i++){
-            rocketMQProducer.syncSend("qwe",i+"",  "消息体"+i);
-        }
+//        for (int i = 0; i< 10; i++){
+//            rocketMQProducer.syncSend("qwe",i+"",  "消息体"+i);
+//        }
+        redisUtil.incr("gggg", 1);
+        System.out.println(redisUtil.get("gggg"));
         return "123";
 
     }

4dkankan-center-scene/src/main/java/com/fdkankan/scene/service/impl/SceneFileBuildServiceImpl.java

@@ -628,7 +628,7 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
         byte[] res = RSAEncrypt.decrypt(RSAEncrypt.loadPrivateKeyByStr(RSAEncrypt.loadPrivateKeyByFile()),
                 base64.decode(cipher));
         String restr = new String(res, "UTF-8");
-        log.debug("uploadSuccessBuild-params解密结果：" + restr);
+        log.info("uploadSuccessBuild-params解密结果：" + restr);
         String[] strArr = restr.split(SPLICE);
         if (strArr.length != 3) {
             throw new BusinessException(ErrorCode.PARAM_REQUIRED);