使用冒号分隔redis的key

648540858

2024-03-28 1de344674afd6bb35b51b165bbad76dbe6299b7e

 src/main/java/com/genersoft/iot/vmp/jt1078/session/SessionManager.java

@@ -76,13 +76,13 @@
        Session session = this.get(cmd.getDevId());
        if (session == null) {
            log.error("DevId: {} not online!", cmd.getDevId());
            return "-1";
            return null;
        }
        String requestKey = requestKey(cmd.getDevId(), cmd.getRespId(), cmd.getPackageNo());
        SynchronousQueue<String> subscribe = subscribe(requestKey);
        if (subscribe == null) {
            log.error("DevId: {} key:{} send repaid", cmd.getDevId(), requestKey);
            return "-1";
            return null;
        }
        session.writeObject(cmd);
        try {
@@ -105,7 +105,7 @@
                log.error("{}", e.getMessage(), e);
            }
        }
        log.warn("未找到对应回复指令,key:{} 消息:{} ", requestKey, data);
        log.warn("Not find response,key:{} data:{} ", requestKey, data);
        return false;
    }