From 349cdbe3d30bb79c4fa9adae60fde67307fb63f2 Mon Sep 17 00:00:00 2001
From: zhou-hao <admin@hsweb.me>
Date: Wed, 5 Aug 2020 14:37:05 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96tcp=E7=BD=91=E5=85=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../community/network/tcp/device/TcpServerDeviceGateway.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java b/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java
index df0992c4..8df85036 100644
--- a/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java
+++ b/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java
@@ -151,10 +151,11 @@ class TcpServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGatew
             return client
                 .subscribe()
                 .filter(tcp -> started.get())
-                .doOnCancel(client::shutdown)
+                .publishOn(Schedulers.parallel())
                 .flatMap(this::handleTcpMessage)
                 .onErrorContinue((err, ignore) -> log.error(err.getMessage(), err))
-                .then();
+                .then()
+                .doOnCancel(client::shutdown);
         }
 
         Mono<Void> handleTcpMessage(TcpMessage message) {