org.tio.websocket.server

Class WsServerAioHandler

java.lang.Object

org.tio.websocket.server.WsServerAioHandler

All Implemented Interfaces:

AioHandler, ServerAioHandler

public class WsServerAioHandler
extends Object
implements ServerAioHandler

Author:

tanyaowu

Constructor Summary

Constructors

Constructor and Description
WsServerAioHandler(WsServerConfig wsServerConfig, IWsMsgHandler wsMsgHandler)

Method Summary

Modifier and Type	Method and Description
WsRequest	decode(ByteBuffer buffer, int limit, int position, int readableLength, ChannelContext channelContext) 根据ByteBuffer解码成业务需要的Packet对象.
ByteBuffer	encode(Packet packet, TioConfig tioConfig, ChannelContext channelContext) 编码
WsServerConfig	getHttpConfig()
void	handler(Packet packet, ChannelContext channelContext) 处理消息包
void	setHttpConfig(WsServerConfig httpConfig)
static HttpResponse	updateWebSocketProtocol(HttpRequest request, ChannelContext channelContext) 本方法改编自baseio: https://gitee.com/generallycloud/baseio 感谢开源作者的付出

Methods inherited from class java.lang.Object

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

Constructor Detail

WsServerAioHandler

public WsServerAioHandler(WsServerConfig wsServerConfig,
                          IWsMsgHandler wsMsgHandler)

Parameters:

wsServerConfig -

wsMsgHandler -

Method Detail

decode

public WsRequest decode(ByteBuffer buffer,
                        int limit,
                        int position,
                        int readableLength,
                        ChannelContext channelContext)
                 throws TioDecodeException

Description copied from interface: AioHandler

根据ByteBuffer解码成业务需要的Packet对象. 如果收到的数据不全，导致解码失败，请返回null，在下次消息来时框架层会自动续上前面的收到的数据

Specified by:

decode in interface AioHandler

Parameters:

buffer - 参与本次希望解码的ByteBuffer

limit - ByteBuffer的limit

position - ByteBuffer的position，不一定是0哦

readableLength - ByteBuffer参与本次解码的有效数据（= limit - position）

Returns:

Throws:

AioDecodeException

TioDecodeException

encode

public ByteBuffer encode(Packet packet,
                         TioConfig tioConfig,
                         ChannelContext channelContext)

Description copied from interface: AioHandler

编码

Specified by:

encode in interface AioHandler

Returns:

getHttpConfig

public WsServerConfig getHttpConfig()

Returns:

the httpConfig

handler

public void handler(Packet packet,
                    ChannelContext channelContext)
             throws Exception

Description copied from interface: AioHandler

处理消息包

Specified by:

handler in interface AioHandler

Throws:

Exception

setHttpConfig

public void setHttpConfig(WsServerConfig httpConfig)

Parameters:

httpConfig - the httpConfig to set

updateWebSocketProtocol

public static HttpResponse updateWebSocketProtocol(HttpRequest request,
                                                   ChannelContext channelContext)

本方法改编自baseio: https://gitee.com/generallycloud/baseio
感谢开源作者的付出

Parameters:

request -

channelContext -

Returns: