#

luxiaotao1123

2024-08-12 1560f3063ca90d41c0717f8ed6e1fb00fde64776

 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,6 +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);
@@ -96,6 +98,8 @@
        } else {
            Log.d(TAG, "Client " + clientId + " is not connected");
        }

        Log.d(TAG, "Client " + clientId + " is not connected");
    }

    @Override