From 1e2f58b5a373cc2d74d64cdbe278f1efcf07c4fe Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Mon, 28 Oct 2024 23:17:08 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=20=20=20=20=20=20//=20TODO=20=E6=B5=81?= =?UTF-8?q?=E9=87=8F=E5=B9=B6=E5=8F=91=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../heartbeat/common/adapter/ChannelFlowAdapter.java | 1 + .../src/main/resources/application.yml | 6 +++--- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java index 4d1f780..4615a8b 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java @@ -54,6 +54,7 @@ public class ChannelFlowAdapter { * @param channelFlow 通道数据 */ public void asyncHandler(Channel channel, ChannelFlow channelFlow) { + // TODO 流量并发异常 CHANNEL_FLOW_ADAPTER_EXECUTOR.submit(() -> handler(channel, channelFlow)); } diff --git a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application.yml b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application.yml index 2684ca9..d7fcc09 100644 --- a/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application.yml +++ b/wu-lazy-cloud-heartbeat-start/wu-lazy-cloud-heartbeat-client-start/src/main/resources/application.yml @@ -19,6 +19,6 @@ spring: # inet-port: 7101 --- -#logging: -# level: -# root: DEBUG \ No newline at end of file +logging1: + level: + root: DEBUG \ No newline at end of file