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

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

@@ -14,6 +14,7 @@ import com.fdkankan.platform.api.feign.PlatformUserClient;
 import com.fdkankan.platform.api.vo.Camera;
 import com.fdkankan.platform.api.vo.Company;
 import com.fdkankan.platform.api.vo.User;
+import com.fdkankan.redis.constant.RedisLockKey;
 import com.fdkankan.redis.util.RedisUtil;
 import com.fdkankan.scene.service.IFolderService;
 import com.fdkankan.scene.service.ISceneService;
@@ -68,9 +69,8 @@ public class TestController {
 //        for (int i = 0; i< 10; i++){
 //            rocketMQProducer.syncSend("qwe",i+"",  "消息体"+i);
 //        }
-        redisUtil.incr("gggg", 1);
-        System.out.println(redisUtil.get("gggg"));
-        return redisUtil.get("gggg") + "";
+        Long loading =  redisUtil.incr(RedisLockKey.LOCK_FDKANKAN_SCENE_NUMS, 1);
+        return loading + "";
 
     }