From 35deea0e6f314b4e3ecf47d7efe247a746c42c43 Mon Sep 17 00:00:00 2001
From: whycq <10027870+whycq@user.noreply.gitee.com>
Date: 星期一, 12 八月 2024 14:23:43 +0800
Subject: [PATCH] #
---
app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java | 9 +++++++++
1 files changed, 9 insertions(+), 0 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 0076379..2d2c049 100644
--- a/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
+++ b/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
@@ -90,6 +90,15 @@
}
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");
}
--
Gitblit v1.9.1