cn.orionsec.kit.http.ok.ws

Class OkWebSocketClient

java.lang.Object

okhttp3.WebSocketListener

cn.orionsec.kit.http.ok.ws.OkWebSocketClient

public class OkWebSocketClient
extends okhttp3.WebSocketListener

OkHttp WebSocket 客户端

Since:

2020/4/9 15:58

Version:

1.0.0

Author:

Jiahang Li

Constructor Summary

Constructors

Constructor and Description
OkWebSocketClient(String url)

Method Summary

Modifier and Type	Method and Description
void	close() 关闭 client 连接
void	close(int code, String reason) 关闭 client 连接
OkWebSocketClient	closeHandler(CloseHandler closeHandler)
OkWebSocketClient	failureHandler(FailureHandler failureHandler)
int	getCloseCode()
String	getCloseReason()
int	getConnectionState()
int	getErrorReconnectionInterval()
int	getErrorReconnectionTimes()
int	getNowReconnectionTimes()
String	getSessionId()
Throwable	getThrowable()
String	getUrl()
okhttp3.WebSocket	getWebSocket()
OkWebSocketClient	messageByteHandler(MessageByteHandler messageByteHandler)
OkWebSocketClient	messageHandler(MessageHandler messageHandler)
void	onClosed(okhttp3.WebSocket webSocket, int code, String reason)
void	onClosing(okhttp3.WebSocket webSocket, int code, String reason)
void	onFailure(okhttp3.WebSocket failWebSocket, Throwable t, okhttp3.Response response)
void	onMessage(okhttp3.WebSocket webSocket, okio.ByteString bytes)
void	onMessage(okhttp3.WebSocket webSocket, String text)
void	onOpen(okhttp3.WebSocket webSocket, okhttp3.Response response)
OkWebSocketClient	openHandler(OpenHandler openHandler)
OkWebSocketClient	reconnection(int times) 异常关闭重连
OkWebSocketClient	reconnection(int times, int interval) 异常关闭重连
void	send(byte[] bs)
void	send(byte[] bs, int offset, int len)
void	send(okio.ByteString byteString) 发送消息
void	send(String text) 发送消息
OkWebSocketClient	sendMessageByteHandler(SendMessageByteHandler sendMessageByteHandler)
OkWebSocketClient	sendMessageHandler(SendMessageHandler sendMessageHandler)
void	start() 启动 client

Methods inherited from class java.lang.Object

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

Constructor Detail

OkWebSocketClient

public OkWebSocketClient(String url)

Method Detail

start

public void start()

启动 client

send

public void send(String text)

发送消息

Parameters:

text - text

send

public void send(byte[] bs)

send

public void send(byte[] bs,
                 int offset,
                 int len)

send

public void send(okio.ByteString byteString)

发送消息

Parameters:

byteString - byteString

close

public void close()

关闭 client 连接

close

public void close(int code,
                  String reason)

关闭 client 连接

Parameters:

code - code

reason - reason

reconnection

public OkWebSocketClient reconnection(int times)

异常关闭重连

Parameters:

times - 重试次数

Returns:

this

reconnection

public OkWebSocketClient reconnection(int times,
                                      int interval)

异常关闭重连

Parameters:

times - 重试次数

interval - 重试间隔ms

Returns:

this

onOpen

public void onOpen(okhttp3.WebSocket webSocket,
                   okhttp3.Response response)

Overrides:

onOpen in class okhttp3.WebSocketListener

onMessage

public void onMessage(okhttp3.WebSocket webSocket,
                      String text)

Overrides:

onMessage in class okhttp3.WebSocketListener

onMessage

public void onMessage(okhttp3.WebSocket webSocket,
                      okio.ByteString bytes)

Overrides:

onMessage in class okhttp3.WebSocketListener

onClosing

public void onClosing(okhttp3.WebSocket webSocket,
                      int code,
                      String reason)

Overrides:

onClosing in class okhttp3.WebSocketListener

onClosed

public void onClosed(okhttp3.WebSocket webSocket,
                     int code,
                     String reason)

Overrides:

onClosed in class okhttp3.WebSocketListener

onFailure

public void onFailure(okhttp3.WebSocket failWebSocket,
                      Throwable t,
                      okhttp3.Response response)

Overrides:

onFailure in class okhttp3.WebSocketListener

openHandler

public OkWebSocketClient openHandler(OpenHandler openHandler)

messageHandler

public OkWebSocketClient messageHandler(MessageHandler messageHandler)

messageByteHandler

public OkWebSocketClient messageByteHandler(MessageByteHandler messageByteHandler)

closeHandler

public OkWebSocketClient closeHandler(CloseHandler closeHandler)

failureHandler

public OkWebSocketClient failureHandler(FailureHandler failureHandler)

sendMessageHandler

public OkWebSocketClient sendMessageHandler(SendMessageHandler sendMessageHandler)

sendMessageByteHandler

public OkWebSocketClient sendMessageByteHandler(SendMessageByteHandler sendMessageByteHandler)

getUrl

public String getUrl()

getWebSocket

public okhttp3.WebSocket getWebSocket()

getSessionId

public String getSessionId()

getErrorReconnectionTimes

public int getErrorReconnectionTimes()

getErrorReconnectionInterval

public int getErrorReconnectionInterval()

getCloseCode

public int getCloseCode()

getCloseReason

public String getCloseReason()

getThrowable

public Throwable getThrowable()

getNowReconnectionTimes

public int getNowReconnectionTimes()

getConnectionState

public int getConnectionState()