| | |
|---|
| | | package com.genersoft.iot.vmp.media.zlm; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.genersoft.iot.vmp.media.zlm.dto.HookType; |
|---|
| | | import com.genersoft.iot.vmp.media.zlm.dto.IHookSubscribe; |
|---|
| | | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 对订阅数据进行过期清理 |
|---|
| | | */ |
|---|
| | | @Scheduled(cron="0 0/5 * * * ?") //每5分钟执行一次 |
|---|
| | | // @Scheduled(cron="0 0/5 * * * ?") //每5分钟执行一次 |
|---|
| | | @Scheduled(fixedRate = 2 * 1000) |
|---|
| | | public void execute(){ |
|---|
| | | |
|---|
| | | System.out.println(allSubscribes.size()); |
|---|
| | | Instant instant = Instant.now().minusMillis(TimeUnit.MINUTES.toMillis(5)); |
|---|
| | | int total = 0; |
|---|
| | | for (HookType hookType : allSubscribes.keySet()) { |
|---|
