20201209游戏测试（wps有问题）

game/src/main/java/com/ccsens/game/api/DebugController.java

@@ -38,12 +38,6 @@ public class DebugController {
     })
     @RequestMapping(value="/game",method = RequestMethod.GET,produces = {"application/json;charset=UTF-8"})
     public JsonResponse testGameMq(HttpServletRequest request) throws Exception {
-            ServerMessage serverMessage = new ServerMessage();
-            serverMessage.setType("Ping");
-            InMessage inMessage = InMessage.newToServerMessage(MessageConstant.DomainType.Server,serverMessage);
-            String j = JacksonUtil.beanToJson(inMessage);
-            //FixMe 发送到消息队列
-            rabbitTemplate.convertAndSend("fanoutExchange","",j);
 
         return JsonResponse.newInstance().ok("测试");
     }

game/src/main/java/com/ccsens/game/service/RabbitMQListenerGameTest.java

@@ -1,27 +1,27 @@
-package com.ccsens.game.service;
-
-import com.ccsens.util.config.RabbitMQConfig;
-import lombok.extern.slf4j.Slf4j;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.stereotype.Component;
-
-import java.io.IOException;
-
-@Slf4j
-@Component
-@RabbitListener(queues = RabbitMQConfig.GAME_MQ_A)
-public class RabbitMQListenerGameTest {
-    private Logger logger = LoggerFactory.getLogger(RabbitMQListener.class);
-
-
-    @RabbitHandler
-    public void gameTest(String gameTest) throws IOException {
-        System.out.println("============================="+gameTest);
-//        List<GameMessageWithChangeStatusOut> gameMessageList = JacksonUtil.jsonToBean(messageJson,
-//                GameMessageWithChangeStatusOut.class, true);
-        log.info("测试游戏MQ消息 {}",gameTest);
-    }
-}
+//package com.ccsens.game.service;
+//
+//import com.ccsens.util.config.RabbitMQConfig;
+//import lombok.extern.slf4j.Slf4j;
+//import org.slf4j.Logger;
+//import org.slf4j.LoggerFactory;
+//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+//import org.springframework.amqp.rabbit.annotation.RabbitListener;
+//import org.springframework.stereotype.Component;
+//
+//import java.io.IOException;
+//
+//@Slf4j
+//@Component
+//@RabbitListener(queues = RabbitMQConfig.GAME_MQ_A)
+//public class RabbitMQListenerGameTest {
+//    private Logger logger = LoggerFactory.getLogger(RabbitMQListener.class);
+//
+//
+//    @RabbitHandler
+//    public void gameTest(String gameTest) throws IOException {
+//        System.out.println("============================="+gameTest);
+////        List<GameMessageWithChangeStatusOut> gameMessageList = JacksonUtil.jsonToBean(messageJson,
+////                GameMessageWithChangeStatusOut.class, true);
+//        log.info("测试游戏MQ消息 {}",gameTest);
+//    }
+//}

game/src/main/java/com/ccsens/game/util/SendMsg.java

@@ -69,7 +69,7 @@ public class SendMsg {
 
         });
         if (CollectionUtil.isNotEmpty(outs)) {
-            rabbitTemplate.convertAndSend(RabbitMQConfig.GAME_STATUS, JacksonUtil.beanToJson(outs));
+            rabbitTemplate.convertAndSend("fanoutExchange", "",JacksonUtil.beanToJson(outs));
             log.info("发送成功:{}", JacksonUtil.beanToJson(outs));
         }
 

game/src/main/resources/application.yml

@@ -1,4 +1,4 @@
 spring:
   profiles:
-    active: prod
-    include: common, util-prod
+    active: dev
+    include: common, util-dev

util/src/main/java/com/ccsens/util/config/RabbitMQConfig.java

@@ -19,7 +19,7 @@ public class RabbitMQConfig {
     private static final String GAME_STATUS_DELAY_SEND_EXCHANGE = "gameStatusDelaySendExchange";
     private static final String GAME_STATUS_DELAY_SEND_ROUTING_KEY = "gameStatusDelaySendRoutingKey";
 
-    public static final String GAME_MQ_A = "gameMqB";
+    public static final String GAME_MQ_A = "gameMqA";
 
 
     /**消息队列发送*/