From 6d13023b5737f331a541ed00de66f774a5315b4a Mon Sep 17 00:00:00 2001
From: whycq <10027870+whycq@user.noreply.gitee.com>
Date: 星期一, 12 八月 2024 14:19:37 +0800
Subject: [PATCH] #
---
app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java | 9 ++-------
1 files changed, 2 insertions(+), 7 deletions(-)
diff --git a/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java b/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
index 35c77b2..0076379 100644
--- a/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
+++ b/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
@@ -16,6 +16,7 @@
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;
+import java.util.Arrays;
import java.util.concurrent.ConcurrentHashMap;
public class NettyServerHandler extends ChannelInboundHandlerAdapter {
@@ -89,13 +90,7 @@
}
public static void sendMessageToClient(String clientId, byte[] message) {
- Channel channel = channelMap.get(clientId);
- if (channel != null && channel.isActive()) {
- ByteBuf buf = Unpooled.wrappedBuffer(message);
- channel.writeAndFlush(buf);
- } else {
- Log.d(TAG, "Client " + clientId + " is not connected");
- }
+ Log.d(TAG, "Client " + clientId + " is not connected");
}
@Override
--
Gitblit v1.9.1