cn.orionsec.kit.http.ok.ws

Class OkWebSocketServer

java.lang.Object

okhttp3.WebSocketListener

cn.orionsec.kit.http.ok.ws.OkWebSocketServer

public class OkWebSocketServer
extends okhttp3.WebSocketListener

OkHttp WebSocket 服务端

Since:

2020/4/9 15:35

Version:

1.0.0

Author:

Jiahang Li

Constructor Summary

Constructors

Constructor and Description
OkWebSocketServer(InetAddress address, int port)
OkWebSocketServer(int port)

Method Summary

Modifier and Type	Method and Description
void	broadcast(byte[] bs)
void	broadcast(byte[] bs, int offset, int len)
void	broadcast(okio.ByteString bs)
void	broadcast(String text) 广播
OkWebSocketServer	closeHandler(CloseHandler closeHandler)
OkWebSocketServer	failureHandler(FailureHandler failureHandler)
InetAddress	getAddress()
int	getClientCount()
int	getPort()
OkWebSocketServer	maxClientCount(int maxCount) 设置最大连接数
OkWebSocketServer	messageByteHandler(MessageByteHandler messageByteHandler)
OkWebSocketServer	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 webSocket, 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)
OkWebSocketServer	openHandler(OpenHandler openHandler)
OkWebSocketServer	sendMessageByteHandler(SendMessageByteHandler sendMessageByteHandler)
OkWebSocketServer	sendTextHandler(SendMessageHandler sendTextHandler)
void	shutdown() 停止 server
OkWebSocketServer	shutdownHandler(ShutdownHandler shutdownHandler)
OkWebSocketServer	shutDownWaitClientTime(int timeout) 关闭连接最大等待时长
void	spread(String sessionId, byte[] bs)
void	spread(String sessionId, byte[] bs, int offset, int len)
void	spread(String sessionId, okio.ByteString bs)
void	spread(String sessionId, String text) 点播
void	spread(okhttp3.WebSocket webSocket, byte[] bs)
void	spread(okhttp3.WebSocket webSocket, byte[] bs, int offset, int len)
void	spread(okhttp3.WebSocket webSocket, okio.ByteString bs)
void	spread(okhttp3.WebSocket webSocket, String text)
void	start() 启动server

Methods inherited from class java.lang.Object

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

Constructor Detail

OkWebSocketServer

public OkWebSocketServer(int port)

OkWebSocketServer

public OkWebSocketServer(InetAddress address,
                         int port)

Method Detail

start

public void start()
           throws IOException

启动server

Throws:

IOException - IOException

shutdown

public void shutdown()
              throws IOException

停止 server

Throws:

IOException - IOException

shutDownWaitClientTime

public OkWebSocketServer shutDownWaitClientTime(int timeout)

关闭连接最大等待时长

Parameters:

timeout - timeout

Returns:

this

maxClientCount

public OkWebSocketServer maxClientCount(int maxCount)

设置最大连接数

Parameters:

maxCount - 最大连接数

Returns:

this

broadcast

public void broadcast(String text)

广播

broadcast

public void broadcast(byte[] bs)

broadcast

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

broadcast

public void broadcast(okio.ByteString bs)

spread

public void spread(String sessionId,
                   String text)

点播

spread

public void spread(String sessionId,
                   byte[] bs)

spread

public void spread(String sessionId,
                   byte[] bs,
                   int offset,
                   int len)

spread

public void spread(String sessionId,
                   okio.ByteString bs)

spread

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

spread

public void spread(okhttp3.WebSocket webSocket,
                   byte[] bs)

spread

public void spread(okhttp3.WebSocket webSocket,
                   byte[] bs,
                   int offset,
                   int len)

spread

public void spread(okhttp3.WebSocket webSocket,
                   okio.ByteString bs)

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 webSocket,
                      Throwable t,
                      okhttp3.Response response)

Overrides:

onFailure in class okhttp3.WebSocketListener

openHandler

public OkWebSocketServer openHandler(OpenHandler openHandler)

messageHandler

public OkWebSocketServer messageHandler(MessageHandler messageHandler)

messageByteHandler

public OkWebSocketServer messageByteHandler(MessageByteHandler messageByteHandler)

sendMessageByteHandler

public OkWebSocketServer sendMessageByteHandler(SendMessageByteHandler sendMessageByteHandler)

sendTextHandler

public OkWebSocketServer sendTextHandler(SendMessageHandler sendTextHandler)

closeHandler

public OkWebSocketServer closeHandler(CloseHandler closeHandler)

failureHandler

public OkWebSocketServer failureHandler(FailureHandler failureHandler)

shutdownHandler

public OkWebSocketServer shutdownHandler(ShutdownHandler shutdownHandler)

getAddress

public InetAddress getAddress()

getPort

public int getPort()

getClientCount

public int getClientCount()