org.tio.websocket.client

Class WsClientAioHander

java.lang.Object

org.tio.websocket.client.WsClientAioHander

All Implemented Interfaces:

ClientAioHandler, AioHandler

public class WsClientAioHander
extends Object
implements ClientAioHandler

Constructor Summary

Constructors

Constructor and Description
WsClientAioHander()

Method Summary

Modifier and Type	Method and Description
Packet	decode(ByteBuffer buffer, int limit, int position, int readableLength, ChannelContext ctx) 根据ByteBuffer解码成业务需要的Packet对象.
ByteBuffer	encode(Packet packet, TioConfig tioConfig, ChannelContext ctx) 编码
void	handler(Packet packet, ChannelContext ctx) 处理消息包
Packet	heartbeatPacket(ChannelContext ctx) 创建心跳包

Methods inherited from class java.lang.Object

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

Constructor Detail

WsClientAioHander

public WsClientAioHander()

Method Detail

heartbeatPacket

public Packet heartbeatPacket(ChannelContext ctx)

Description copied from interface: ClientAioHandler

创建心跳包

Specified by:

heartbeatPacket in interface ClientAioHandler

Returns:

decode

public Packet decode(ByteBuffer buffer,
                     int limit,
                     int position,
                     int readableLength,
                     ChannelContext ctx)
              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 ctx)

Description copied from interface: AioHandler

编码

Specified by:

encode in interface AioHandler

Returns:

handler

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

Description copied from interface: AioHandler

处理消息包

Specified by:

handler in interface AioHandler

Throws:

Exception