支持使用abl接收国标流

648540858

2024-04-02 8b90fade9eb3a62b428f23f2306cb1911c98d355

 src/main/java/com/genersoft/iot/vmp/media/event/hook/HookSubscribe.java

@@ -22,7 +22,7 @@
    /**
     * 订阅数据过期时间
     */
    private final long subscribeExpire = 5 * 1000;
    private final long subscribeExpire = 5 * 60 * 1000;

    @FunctionalInterface
    public interface Event{
@@ -35,11 +35,7 @@
    @Async("taskExecutor")
    @EventListener
    public void onApplicationEvent(MediaArrivalEvent event) {
        if ("rtsp".equals(event.getSchema())) {
            System.out.println("流到来的处理: " + allSubscribes.size());
            for (String s : allSubscribes.keySet()) {
                System.out.println("key: " + s);
            }
        if (event.getSchema() == null || "rtsp".equals(event.getSchema())) {
            sendNotify(HookType.on_media_arrival, event);
        }

@@ -51,7 +47,7 @@
    @Async("taskExecutor")
    @EventListener
    public void onApplicationEvent(MediaDepartureEvent event) {
        if ("rtsp".equals(event.getSchema())) {
        if (event.getSchema() == null || "rtsp".equals(event.getSchema())) {
            sendNotify(HookType.on_media_departure, event);
        }

@@ -70,7 +66,6 @@

    private void sendNotify(HookType hookType, MediaEvent event) {
        Hook paramHook = Hook.getInstance(hookType, event.getApp(), event.getStream(), event.getMediaServer().getId());
        System.out.println("sendNotify: " + paramHook.toString());
        Event hookSubscribeEvent = allSubscribes.get(paramHook.toString());
        if (hookSubscribeEvent != null) {
            HookData data = HookData.getInstance(event);
@@ -87,7 +82,6 @@
    }

    public void removeSubscribe(Hook hook) {
        System.out.println("removeSubscribe: " + hook.toString());
        allSubscribes.remove(hook.toString());
        allHook.remove(hook.toString());
    }
@@ -100,7 +94,6 @@
        long expireTime = System.currentTimeMillis() - subscribeExpire;
        for (Hook hook : allHook.values()) {
            if (hook.getCreateTime() < expireTime) {
                System.out.println("execute removeSubscribe: " + hook.toString());
                allSubscribes.remove(hook.toString());
                allHook.remove(hook.toString());
            }