xin.alum.aim.handler

类 AimReceiver

java.lang.Object

xin.alum.aim.handler.AimReceiver

所有已实现的接口:

AimServerReceiver, SocksHandShake, WebSocketHandShake

public class AimReceiver
extends Object
implements AimServerReceiver

此类为源码测试接受者 正式业务请重写此服务类

字段概要

字段

限定符和类型	字段和说明
protected SessionGroups	groups
protected static io.netty.util.internal.logging.InternalLogger	logger
protected Sessions	sessions

构造器概要

构造器

构造器和说明
AimReceiver()

方法概要

限定符和类型	方法和说明
void	onByte(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf buf) 处理WebSocket binary请求 测试方法，正式业务请重写
void	onClose(io.netty.channel.Channel ch, ChannelClose heartbeat) 关闭连接通道
boolean	onHandShake(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf in) Socks握手处理逻辑，绑定用户信息到会话系统
boolean	onHandShake(io.netty.channel.Channel ch, io.netty.handler.codec.http.FullHttpRequest req, io.netty.handler.codec.http.FullHttpResponse res) WebSocket握手处理逻辑，绑定用户信息到会话系统
void	onHandShaked(io.netty.channel.Channel ch)
Reply	onKick(io.netty.channel.Channel ch, Session session) 处理互踢业务逻辑
void	onPing(io.netty.channel.Channel ch) 收到客户端的Ping操作
void	onRecive(io.netty.channel.Channel ch, Sent msg) 测试方法，正式业务请重写
void	onText(io.netty.channel.Channel ch, String text) Text类型数据处理，测试用，正式业务请重写

从类继承的方法 java.lang.Object

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

字段详细资料

sessions

@Autowired
protected Sessions sessions

groups

@Autowired
protected SessionGroups groups

logger

protected static final io.netty.util.internal.logging.InternalLogger logger

构造器详细资料

AimReceiver

public AimReceiver()

方法详细资料

onHandShake

public boolean onHandShake(io.netty.channel.Channel ch,
                           io.netty.handler.codec.http.FullHttpRequest req,
                           io.netty.handler.codec.http.FullHttpResponse res)

WebSocket握手处理逻辑，绑定用户信息到会话系统

指定者:

onHandShake 在接口中 WebSocketHandShake

参数:

ch - 当前连接通道

req - 当前上行请求,URL参数已经放入ch中

res - 握手失败 return false 输出给客户端的对象

返回:

onHandShake

public boolean onHandShake(io.netty.channel.Channel ch,
                           io.netty.buffer.ByteBuf in)

Socks握手处理逻辑，绑定用户信息到会话系统

指定者:

onHandShake 在接口中 SocksHandShake

参数:

ch - 通道

in - 握手数据包

返回:

onHandShaked

public void onHandShaked(io.netty.channel.Channel ch)

指定者:

onHandShaked 在接口中 AimServerReceiver

onPing

public void onPing(io.netty.channel.Channel ch)

从接口复制的说明: AimServerReceiver

收到客户端的Ping操作

指定者:

onPing 在接口中 AimServerReceiver

onText

public void onText(io.netty.channel.Channel ch,
                   String text)

Text类型数据处理，测试用，正式业务请重写

指定者:

onText 在接口中 AimServerReceiver

参数:

ch -

text -

onByte

public void onByte(io.netty.channel.Channel ch,
                   io.netty.buffer.ByteBuf buf)

处理WebSocket binary请求 测试方法，正式业务请重写

指定者:

onByte 在接口中 AimServerReceiver

参数:

ch -

buf -

抛出:

com.google.protobuf.InvalidProtocolBufferException

onRecive

public void onRecive(io.netty.channel.Channel ch,
                     Sent msg)

测试方法，正式业务请重写

指定者:

onRecive 在接口中 AimServerReceiver

参数:

ch -

msg -

onKick

public Reply onKick(io.netty.channel.Channel ch,
                    Session session)

从接口复制的说明: AimServerReceiver

处理互踢业务逻辑

指定者:

onKick 在接口中 AimServerReceiver

onClose

public void onClose(io.netty.channel.Channel ch,
                    ChannelClose heartbeat)

从接口复制的说明: AimServerReceiver

关闭连接通道

指定者:

onClose 在接口中 AimServerReceiver