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

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

@@ -17,6 +17,7 @@ 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.IScene3dNumService;
 import com.fdkankan.scene.service.ISceneService;
 import com.fdkankan.scene.vo.SceneVO;
 import com.google.common.collect.Lists;
@@ -63,14 +64,18 @@ public class TestController {
     @Autowired
     private RocketMQProducer rocketMQProducer;
 
+    @Autowired
+    private IScene3dNumService scene3dNumService;
+
 
     @GetMapping("/test")
     public String test() throws Exception {
 //        for (int i = 0; i< 10; i++){
 //            rocketMQProducer.syncSend("qwe",i+"",  "消息体"+i);
 //        }
-        Long loading =  redisUtil.incr(RedisLockKey.LOCK_FDKANKAN_SCENE_NUMS, 1);
-        return loading + "";
+//        Long loading =  redisUtil.incr(RedisLockKey.LOCK_FDKANKAN_SCENE_NUMS, 1);
+        String sceneNum = scene3dNumService.generateSceneNum();
+        return sceneNum;
 
     }