优化录像列表获取算法

Lawrence

2021-01-11 dc1d9646a97ac07d20a911c0daf5bae361964717

优化录像列表获取算法

 .gitignore

@@ -9,7 +9,7 @@

# Mobile Tools for Java (J2ME)
.mtj.tmp/

src/main/resources/application-*.yml
# Package Files #
#*.jar
*.war
@@ -18,7 +18,7 @@
*.zip
*.tar.gz
*.rar

*.iml
# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
hs_err_pid*
/.idea/*

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/MessageRequestProcessor.java

@@ -342,6 +342,7 @@
        try {

            // 回复200 OK

            responseAck(evt);

            String seqNo = String.valueOf(System.currentTimeMillis());

            RecordInfo recordInfo = new RecordInfo();

            Element rootElement = getRootElement(evt);

            Element deviceIdElement = rootElement.element("DeviceID");

@@ -396,31 +397,21 @@
                if (recordInfo.getSumNum() > 0 && recordList.size() > 0 && recordList.size() < recordInfo.getSumNum()) {

                    // 为防止连续请求该设备的录像数据，返回数据错乱，特增加sn进行区分

                    String cacheKey = CACHE_RECORDINFO_KEY + deviceId + sn;

                    // TODO 暂时直接操作redis存储，后续封装专用缓存接口，改为本地内存缓存

                    if (redis.hasKey(cacheKey)) {

                        List<RecordItem> previousList = (List<RecordItem>) redis.get(cacheKey);

                        if (previousList != null && previousList.size() > 0) {

                            recordList.addAll(previousList);

                        }

                        // 本分支表示录像列表被拆包，且加上之前的数据还是不够,保存缓存返回，等待下个包再处理

                        if (recordList.size() < recordInfo.getSumNum()) {

                            logger.info("已获取" + recordList.size() + "项录像数据，共" + recordInfo.getSumNum() + "项");

                            redis.set(cacheKey, recordList, 90);

                            return;

                        } else {

                            // 本分支表示录像被拆包，但加上之前的数据够足够，返回响应

                            // 因设备心跳有监听redis过期机制，为提高性能，此处手动删除

                            logger.info("录像数据已全部获取");

                            redis.del(cacheKey);

                        }

                    } else {

                        // 本分支有两种可能：1、录像列表被拆包，且是第一个包,直接保存缓存返回，等待下个包再处理

                        // 2、之前有包，但超时清空了，那么这次sn批次的响应数据已经不完整，等待过期时间后redis自动清空数据

                        logger.info("已获取" + recordList.size() + "项录像数据，共" + recordInfo.getSumNum() + "项");

                        logger.info("等待后续的包...");



                        redis.set(cacheKey, recordList, 90);

                    redis.set(cacheKey + "_" + seqNo, recordList, 90);

                    List<Object> cacheKeys = redis.scan(cacheKey + "_*");

                    List<RecordItem> totalRecordList = new ArrayList<RecordItem>();

                    for (int i = 0; i < cacheKeys.size(); i++) {

                        totalRecordList.addAll((List<RecordItem>) redis.get(cacheKeys.get(i).toString()));

                    }

                    if (totalRecordList.size() < recordInfo.getSumNum()) {

                        logger.info("已获取" + totalRecordList.size() + "项录像数据，共" + recordInfo.getSumNum() + "项");

                        return;

                    }

                    logger.info("录像数据已全部获取，共" + recordInfo.getSumNum() + "项");

                    recordInfo.setRecordList(totalRecordList);

                    for (int i = 0; i < cacheKeys.size(); i++) {

                        redis.del(cacheKeys.get(i).toString());

                    }

                }

                // 自然顺序排序, 元素进行升序排列

@@ -460,7 +451,6 @@
                    cmder.streamByeCmd(streamInfo.getStreamId());

                }

            }



        } catch (ParseException | SipException | InvalidArgumentException | DocumentException e) {

            e.printStackTrace();

        }