计数线程处理调整

src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java

@@ -77,10 +77,10 @@ public class IotMessageListener implements MessageListener {
             String content = new String(body);
             String topic = message.getStringProperty("topic");
             String messageId = message.getStringProperty("messageId");
-//            log.info("receive message"
-//                    + ", topic = " + topic
-//                    + ", messageId = " + messageId
-//                    + ", content = " + content);
+            log.info("receive message"
+                    + ", topic = " + topic
+                    + ", messageId = " + messageId
+                    + ", content = " + content);
             count.getAndIncrement();
 
         } catch (Exception e) {

src/main/java/com/telpo/iotgateway/server/IotSubscribe.java

@@ -51,8 +51,8 @@ public class IotSubscribe {
 
     // 执行单元线程池
     private final static ExecutorService executorService = new ThreadPoolExecutor(
-            Runtime.getRuntime().availableProcessors(),
-            Runtime.getRuntime().availableProcessors() * 2, 60, TimeUnit.SECONDS,
+            Runtime.getRuntime().availableProcessors() - 1,
+            (Runtime.getRuntime().availableProcessors() -1)* 2, 60, TimeUnit.SECONDS,
             new LinkedBlockingQueue<>(50000));
     // Jms连接侦听
     private static JmsConnectionListener myJmsConnectionListener = new IotJmsConnectionListener();