在测试环节中

JSONObject jsonObject = JSONObject();
jsonObject.put(, userId);
jsonObject.put(,objectId);
jsonObject.put(,content);
bizBody.setData(JSON.(jsonObject));

这个objectId  在后面调用到的RouterHandlerServiceImpl中的sendMsgToClient方法，里面并没有做userid的校验，也就是说 每次发送 都是给userId发送，也就是自己给自己发送数据，并没有真正给objectId发送数据 这个是测试数据的过程中的bug吧，老师你的实例 是怎么做到userId  给objectId客户端发送数据 objectId又能收到数据的？

(ImMsgBody imMsgBody) {
    Long userId = imMsgBody.getUserId();
    ChannelHandlerContext ctx = ChannelHandlerContextCache.(userId);
    (ctx != )
    {
        String msgId = UUID.().toString();
        imMsgBody.setUserId(userId);
        ImMsg respMsg = ImMsg.(ImMsgCodeEnum..getCode(), JSON.(imMsgBody));
        ctx.writeAndFlush(respMsg);
        ;
    }
    ;
}

这里的userId  永远都是发送者的Id啊  并没有从这个data中获取objectId这个动作 我不知道你的代码是怎么实现userId 给objectId 发送数据的

System..println();
String content = scanner.next();
ImMsgBody bizBody = ImMsgBody();
bizBody.setAppId(AppIdEnum..getCode());
bizBody.setUserId(userId);
bizBody.setBizCode();
JSONObject jsonObject = JSONObject();
jsonObject.put(, userId);
jsonObject.put(,objectId);
jsonObject.put(,content);
bizBody.setData(JSON.(jsonObject));
ImMsg heartBeatMsg = ImMsg.(ImMsgCodeEnum..getCode(), JSON.(bizBody));
userIdChannelMap.get(userId).writeAndFlush(heartBeatMsg);