io.jpom.socket

Class BaseProxyHandler

java.lang.Object

org.springframework.web.socket.handler.AbstractWebSocketHandler

org.springframework.web.socket.handler.TextWebSocketHandler

io.jpom.socket.BaseHandler

io.jpom.socket.BaseProxyHandler

All Implemented Interfaces:

org.springframework.web.socket.WebSocketHandler

Direct Known Subclasses:

ConsoleHandler, DockerLogHandler, NodeScriptHandler, NodeUpdateHandler, ServerScriptHandler, TomcatHandler

public abstract class BaseProxyHandler
extends BaseHandler

服务端socket 基本类

Since:

2019/4/25

Author:

jiangzeyin

Constructor Summary

Constructors

Constructor and Description
BaseProxyHandler(NodeUrl nodeUrl)

Method Summary

Modifier and Type	Method and Description
void	afterConnectionEstablishedImpl(org.springframework.web.socket.WebSocketSession session) 建立会话后
void	destroy(org.springframework.web.socket.WebSocketSession session) 关闭连接
protected abstract Object[]	getParameters(Map<String,Object> attributes) 连接参数
protected String	handleTextMessage(Map<String,Object> attributes, ProxySession proxySession, com.alibaba.fastjson.JSONObject json, ConsoleCommandOp consoleCommandOp) 消息处理方法
protected String	handleTextMessage(Map<String,Object> attributes, org.springframework.web.socket.WebSocketSession session, com.alibaba.fastjson.JSONObject json, ConsoleCommandOp consoleCommandOp) 消息处理方法
protected void	handleTextMessage(org.springframework.web.socket.WebSocketSession session, org.springframework.web.socket.TextMessage message)
protected void	init(org.springframework.web.socket.WebSocketSession session, Map<String,Object> attributes) 连接成功 初始化

Methods inherited from class io.jpom.socket.BaseHandler

afterConnectionClosed, afterConnectionEstablished, handleTransportError, logOpt, sendMsg, showHelloMsg

Methods inherited from class org.springframework.web.socket.handler.TextWebSocketHandler

handleBinaryMessage

Methods inherited from class org.springframework.web.socket.handler.AbstractWebSocketHandler

handleMessage, handlePongMessage, supportsPartialMessages

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseProxyHandler

public BaseProxyHandler(NodeUrl nodeUrl)

Method Detail

getParameters

protected abstract Object[] getParameters(Map<String,Object> attributes)

连接参数

Parameters:

attributes - 属性

Returns:

key, value, key, value.....

afterConnectionEstablishedImpl

public void afterConnectionEstablishedImpl(org.springframework.web.socket.WebSocketSession session)
                                    throws Exception

Description copied from class: BaseHandler

建立会话后

Overrides:

afterConnectionEstablishedImpl in class BaseHandler

Parameters:

session - 会话

Throws:

Exception - 异常

init

protected void init(org.springframework.web.socket.WebSocketSession session,
                    Map<String,Object> attributes)
             throws Exception

连接成功 初始化

Parameters:

session - 会话

attributes - 属性

Throws:

URISyntaxException - 异常

IOException - IO

Exception

handleTextMessage

protected void handleTextMessage(org.springframework.web.socket.WebSocketSession session,
                                 org.springframework.web.socket.TextMessage message)
                          throws Exception

Overrides:

handleTextMessage in class org.springframework.web.socket.handler.AbstractWebSocketHandler

Throws:

Exception

handleTextMessage

protected String handleTextMessage(Map<String,Object> attributes,
                                   org.springframework.web.socket.WebSocketSession session,
                                   com.alibaba.fastjson.JSONObject json,
                                   ConsoleCommandOp consoleCommandOp)
                            throws IOException

消息处理方法

Parameters:

attributes - 属性

session - 当前回话

json - 数据

consoleCommandOp - 操作类型

Throws:

IOException

handleTextMessage

protected String handleTextMessage(Map<String,Object> attributes,
                                   ProxySession proxySession,
                                   com.alibaba.fastjson.JSONObject json,
                                   ConsoleCommandOp consoleCommandOp)

消息处理方法

Parameters:

attributes - 属性

proxySession - 代理回话

json - 数据

consoleCommandOp - 操作类型

destroy

public void destroy(org.springframework.web.socket.WebSocketSession session)

Description copied from class: BaseHandler

关闭连接

Specified by:

destroy in class BaseHandler

Parameters:

session - session