创建路由器、队列

src/main/java/com/fjhx/rabbitmq/JsRabbitMQListener.java

@@ -35,11 +35,12 @@ public class JsRabbitMQListener implements ChannelAwareMessageListener {
     @Retryable(value = {Exception.class}, backoff = @Backoff(delay = 3000, multiplier = 1))
     @Override
     public void onMessage(Message message, Channel channel) throws Exception {
+
+
         try {
             String msg = new String(message.getBody(), StandardCharsets.UTF_8);
-            JSONObject jsonObject = JSONObject.parseObject(msg);
 
-            System.err.println(msg);
+            JSONObject jsonObject = JSONObject.parseObject(msg);
 
             rfidService.receiveInstructions(jsonObject);
 

src/main/java/com/fjhx/rfid/r2000/common/service/impl/RFIDServiceImpl.java

@@ -25,7 +25,7 @@ import java.util.stream.Collectors;
 @Service
 public class RFIDServiceImpl implements IRFIDService {
 
-    
+
     @Autowired
     private TcpServiceV2 tcpServiceV2;
 

src/main/java/com/fjhx/rfid/r2000/tcp/service/impl/TcpServiceImplV2.java

@@ -25,6 +25,7 @@ import org.springframework.stereotype.Service;
 
 import java.text.MessageFormat;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.CountDownLatch;
@@ -134,6 +135,15 @@ public class TcpServiceImplV2 implements TcpServiceV2 {
      */
     @Override
     public AjaxResult openAndReturnGoHeavyData(List<String> ips, String busUuid, String userId) {
+        // TODO test
+//        JSONObject testData = new JSONObject();
+//        testData.put("messageId", IdUtils.fastSimpleUUID());
+//        testData.put("msgSource", MsgSourceEnum.MSG_SOURCE_2.getKey());
+//        testData.put("userId", userId);
+//        testData.put("notices", Arrays.asList("fsds2137862138","dsadsa21346218"));
+//        rabbitmqService.send(testData);
+
+
         Integer count = 0;
         try {
             CountDownLatch countDownLatch = new CountDownLatch(ips.size());