添加RedisRpcResponse的toString

648540858

2024-04-18 2a765a93ebb30534c60a19adf58469e317c382cd

 src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java

@@ -79,6 +79,7 @@
        if (userSetting.getServerId().equals(response.getToId())) {
            return;
        }
        logger.info("[redis-rpc] << {}", response);
        response(response);
    }

@@ -87,6 +88,7 @@
            if (userSetting.getServerId().equals(request.getFromId())) {
                return;
            }
            logger.info("[redis-rpc] >> {}", request);
            Method method = getMethod(request.getUri());
            // 没有携带目标ID的可以理解为哪个wvp有结果就哪个回复，携带目标ID，但是如果是不存在的uri则直接回复404
            if (userSetting.getServerId().equals(request.getToId())) {
@@ -193,10 +195,8 @@
    }

    private void setCallback(long key, CommonCallback<RedisRpcResponse> callback)  {
        if (!callbacks.containsKey(key)) {
            callbacks.put(key, callback);
        }

        // TODO 如果多个上级点播同一个通道会有问题
        callbacks.put(key, callback);
    }

    public void removeCallback(long key)  {