临时提交

648540858

2024-04-18 3639d2224d423ccfd937a302af62b71a7cad925f

 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())) {
@@ -200,4 +202,9 @@
    public void removeCallback(long key)  {
        callbacks.remove(key);
    }


    public int getCallbackCount(){
        return callbacks.size();
    }
}