王通 / jtt1078-video-server · Files

package cn.org.hentai.jtt1078.rtsp;

import io.netty.channel.Channel;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * Rtsp会话
 */
public class RtspSessionManager {

    private static Map<String, Object> channel2register = new ConcurrentHashMap<>();

    private static Map<String, Channel> channel2push = new ConcurrentHashMap<>();

    public static void register(String channel) {
        channel2register.put(channel, System.currentTimeMillis());
    }

    public static void unregister(String channel) {
        channel2register.remove(channel);
    }

    public static boolean isRegistered(String channel) {
        return channel2register.containsKey(channel);
    }

    public static void setPush(String channel, Channel push) {
        channel2push.put(channel, push);
    }

    public static Channel getPush(String channel) {
        return channel2push.get(channel);
    }
}