启动时清除先前注册上级平台的缓存

lawrencehj

2021-03-26 c5a05c15df6c01602f259a49ff470fa996579b0b

 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMRunner.java

@@ -4,8 +4,8 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.genersoft.iot.vmp.conf.MediaServerConfig;
import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
import okhttp3.*;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
//import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -15,9 +15,6 @@
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;

@@ -27,8 +24,11 @@

    private final static Logger logger = LoggerFactory.getLogger(ZLMRunner.class);

    // @Autowired
    // private IVideoManagerStorager storager;

    @Autowired
    private IVideoManagerStorager storager;
    private IRedisCatchStorage redisCatchStorage;

    @Value("${media.ip}")
    private String mediaIp;
@@ -60,6 +60,9 @@
    @Autowired
    private ZLMRESTfulUtils zlmresTfulUtils;

    @Autowired
    private ZLMMediaListManager zlmMediaListManager;

    @Override
    public void run(String... strings) throws Exception {
        // 获取zlm信息
@@ -69,7 +72,9 @@
            logger.info("zlm接入成功...");
            if (autoConfig) saveZLMConfig();
            mediaServerConfig = getMediaServerConfig();
            storager.updateMediaInfo(mediaServerConfig);
            redisCatchStorage.updateMediaInfo(mediaServerConfig);
            // 更新流列表
            zlmMediaListManager.updateMediaList();
        }
    }

@@ -130,4 +135,5 @@
            logger.info("设置zlm失败: " + responseJSON.getString("msg"));
        }
    }

}