| | |
| | |
|
| | | public static final String CACHEKEY_PREFIX = "VMP_channel_";
|
| | |
|
| | | public static final String KEEPLIVEKEY_PREFIX = "VMP_keeplive_";
|
| | | public static final String KEEPLIVEKEY_PREFIX = "VMP_KEEPLIVE_";
|
| | |
|
| | | public static final String PLAYER_PREFIX = "VMP_player_";
|
| | |
|
| | |
| | | public void run(String... args) throws Exception { |
| | | // 设置所有设备离线 |
| | | storager.outlineForAll(); |
| | | // 设置所有设备离线 |
| | | redisCatchStorage.outlineForAll(); |
| | | } |
| | | } |
| | |
| | | * @param deviceId 设备ID |
| | | */ |
| | | void clearCatchByDeviceId(String deviceId); |
| | | |
| | | /** |
| | | * 设置所有设备离线 |
| | | */ |
| | | void outlineForAll(); |
| | | } |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void outlineForAll() { |
| | | List<Object> onlineDevices = redis.scan(String.format("%S*", VideoManagerConstants.KEEPLIVEKEY_PREFIX)); |
| | | for (int i = 0; i < onlineDevices.size(); i++) { |
| | | String key = (String) onlineDevices.get(i); |
| | | redis.del(key); |
| | | } |
| | | } |
| | | } |