Package com.github.theword.queqiao.tool.websocket

Class WsClient

java.lang.Object

org.java_websocket.WebSocketAdapter

org.java_websocket.AbstractWebSocket

org.java_websocket.client.WebSocketClient

com.github.theword.queqiao.tool.websocket.WsClient

All Implemented Interfaces:

Runnable, org.java_websocket.WebSocket, org.java_websocket.WebSocketListener

public class WsClient
extends org.java_websocket.client.WebSocketClient

WebSocket 客户端

Field Summary

Fields inherited from class org.java_websocket.client.WebSocketClient

uri

Constructor Summary

Constructors

Constructor	Description
WsClient(URI uri, org.slf4j.Logger logger, com.google.gson.Gson gson, String serverName, String accessToken, int reconnectMaxTimes, int reconnectInterval, boolean enabled)

Method Summary

Modifier and Type	Method	Description
void	onClose(int code, String reason, boolean remote)
void	onError(Exception exception)
void	onMessage(String message)
void	onOpen(org.java_websocket.handshake.ServerHandshake serverHandshake)
void	reconnectNow()	主动立即重连（适用于 reload 等场景）
void	stopWithoutReconnect(int code, String reason)	停止并不再重连

Methods inherited from class org.java_websocket.client.WebSocketClient

addHeader, clearHeaders, close, close, close, closeBlocking, closeConnection, connect, connectBlocking, connectBlocking, getAttachment, getConnection, getConnections, getDraft, getLocalSocketAddress, getLocalSocketAddress, getProtocol, getReadyState, getRemoteSocketAddress, getRemoteSocketAddress, getResourceDescriptor, getSocket, getSSLSession, getURI, hasBufferedData, hasSSLSupport, isClosed, isClosing, isFlushAndClose, isOpen, onCloseInitiated, onClosing, onMessage, onSetSSLParameters, onWebsocketClose, onWebsocketCloseInitiated, onWebsocketClosing, onWebsocketError, onWebsocketMessage, onWebsocketMessage, onWebsocketOpen, onWriteDemand, reconnect, reconnectBlocking, removeHeader, run, send, send, send, sendFragmentedFrame, sendFrame, sendFrame, sendPing, setAttachment, setDnsResolver, setProxy, setSocket, setSocketFactory

Methods inherited from class org.java_websocket.AbstractWebSocket

getConnectionLostTimeout, isReuseAddr, isTcpNoDelay, setConnectionLostTimeout, setReuseAddr, setTcpNoDelay, startConnectionLostTimer, stopConnectionLostTimer

Methods inherited from class org.java_websocket.WebSocketAdapter

onPreparePing, onWebsocketHandshakeReceivedAsClient, onWebsocketHandshakeReceivedAsServer, onWebsocketHandshakeSentAsClient, onWebsocketPing, onWebsocketPong

Methods inherited from class java.lang.Object

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

Constructor Details

WsClient

public WsClient(URI uri,
 org.slf4j.Logger logger,
 com.google.gson.Gson gson,
 String serverName,
 String accessToken,
 int reconnectMaxTimes,
 int reconnectInterval,
 boolean enabled)

Method Details

onOpen

public void onOpen(org.java_websocket.handshake.ServerHandshake serverHandshake)

Specified by:

onOpen in class org.java_websocket.client.WebSocketClient

onMessage

public void onMessage(String message)

Specified by:

onMessage in class org.java_websocket.client.WebSocketClient

onClose

public void onClose(int code,
 String reason,
 boolean remote)

Specified by:

onClose in class org.java_websocket.client.WebSocketClient

onError

public void onError(Exception exception)

Specified by:

onError in class org.java_websocket.client.WebSocketClient

reconnectNow

public void reconnectNow()

主动立即重连（适用于 reload 等场景）

stopWithoutReconnect

public void stopWithoutReconnect(int code,
 String reason)

停止并不再重连

Parameters:

code - 关闭代码

reason - 关闭原因