程序包 org.ssssssss.magicapi.core.config

类 WebSocketSessionManager

java.lang.Object

org.ssssssss.magicapi.core.config.WebSocketSessionManager

所有已实现的接口:

org.springframework.beans.factory.DisposableBean, org.springframework.boot.CommandLineRunner

@Component
public class WebSocketSessionManager
extends Object
implements org.springframework.boot.CommandLineRunner, org.springframework.beans.factory.DisposableBean

字段概要

字段

修饰符和类型	字段	说明
private static final int	CHECK_INTERVAL
private static final Map<String,org.ssssssss.script.MagicScriptDebugContext>	CONTEXTS
private static String	instanceId
private static final int	KEEPALIVE_TIMEOUT
private ScheduledThreadPoolExecutor	logExecutor
private static final org.slf4j.Logger	logger
private static MagicNotifyService	magicNotifyService
private static final List<Pair<String,String>>	MESSAGE_CACHE
private static final Map<String,MagicConsoleSession>	SESSIONS
private ScheduledThreadPoolExecutor	wsExecutor

构造器概要

构造器

构造器	说明
WebSocketSessionManager()

方法概要

修饰符和类型	方法	说明
static void	add(MagicConsoleSession session)
static void	addMagicScriptContext(String sessionAndScriptId, org.ssssssss.script.MagicScriptDebugContext context)
static String	buildMessage(MessageType messageType, Object... values)
private static void	checkSession()
void	destroy()
static org.ssssssss.script.MagicScriptDebugContext	findMagicScriptContext(String sessionAndScriptId)
static MagicConsoleSession	findSession(String clientId)
static void	flushLog()
static MagicConsoleSession	getConsoleSession(String clientId)
static Collection<MagicConsoleSession>	getSessions()
static void	remove(String sessionId)
static void	remove(MagicConsoleSession session)
static void	removeMagicScriptContext(String sessionAndScriptId)
void	run(String... args)
static void	sendByClientId(String clientId, String content)
static void	sendByClientId(String clientId, MessageType messageType, Object... values)
static void	sendBySession(MagicConsoleSession session, String content)
static void	sendLogs(String sessionId, String message)
private static void	sendToAll(String content)
static void	sendToAll(MessageType messageType, Object... values)
static void	sendToMachine(MessageType messageType, Object... args)
static void	sendToMachineByClientId(String clientId, String content)
static void	sendToOther(String excludeClientId, MessageType messageType, Object... values)
static void	setInstanceId(String instanceId)
static void	setMagicNotifyService(MagicNotifyService magicNotifyService)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

logger

private static final org.slf4j.Logger logger

SESSIONS

private static final Map<String,MagicConsoleSession> SESSIONS

magicNotifyService

private static MagicNotifyService magicNotifyService

CONTEXTS

private static final Map<String,org.ssssssss.script.MagicScriptDebugContext> CONTEXTS

instanceId

private static String instanceId

CHECK_INTERVAL

private static final int CHECK_INTERVAL

另请参阅:

• 常量字段值

KEEPALIVE_TIMEOUT

private static final int KEEPALIVE_TIMEOUT

另请参阅:

• 常量字段值

MESSAGE_CACHE

private static final List<Pair<String,String>> MESSAGE_CACHE

logExecutor

private ScheduledThreadPoolExecutor logExecutor

wsExecutor

private ScheduledThreadPoolExecutor wsExecutor

构造器详细资料

WebSocketSessionManager

public WebSocketSessionManager()

方法详细资料

add

public static void add(MagicConsoleSession session)

getConsoleSession

public static MagicConsoleSession getConsoleSession(String clientId)

destroy

public void destroy()

指定者:

destroy 在接口中 org.springframework.beans.factory.DisposableBean

run

public void run(String... args)
         throws Exception

指定者:

run 在接口中 org.springframework.boot.CommandLineRunner

抛出:

Exception

getSessions

public static Collection<MagicConsoleSession> getSessions()

remove

public static void remove(MagicConsoleSession session)

remove

public static void remove(String sessionId)

sendToAll

public static void sendToAll(MessageType messageType,
 Object... values)

sendToAll

private static void sendToAll(String content)

sendLogs

public static void sendLogs(String sessionId,
 String message)

flushLog

public static void flushLog()

sendByClientId

public static void sendByClientId(String clientId,
 MessageType messageType,
 Object... values)

sendToOther

public static void sendToOther(String excludeClientId,
 MessageType messageType,
 Object... values)

sendToMachineByClientId

public static void sendToMachineByClientId(String clientId,
 String content)

sendToMachine

public static void sendToMachine(MessageType messageType,
 Object... args)

buildMessage

public static String buildMessage(MessageType messageType,
 Object... values)

sendByClientId

public static void sendByClientId(String clientId,
 String content)

sendBySession

public static void sendBySession(MagicConsoleSession session,
 String content)

findSession

public static MagicConsoleSession findSession(String clientId)

setMagicNotifyService

public static void setMagicNotifyService(MagicNotifyService magicNotifyService)

setInstanceId

public static void setInstanceId(String instanceId)

addMagicScriptContext

public static void addMagicScriptContext(String sessionAndScriptId,
 org.ssssssss.script.MagicScriptDebugContext context)

findMagicScriptContext

public static org.ssssssss.script.MagicScriptDebugContext findMagicScriptContext(String sessionAndScriptId)

removeMagicScriptContext

public static void removeMagicScriptContext(String sessionAndScriptId)

checkSession

private static void checkSession()