xin.alum.aim.handler

类 AimReceiver

java.lang.Object

xin.alum.aim.handler.AimReceiver

所有已实现的接口:

AimReceive, SocksHandShake, WebSocketHandShake

public class AimReceiver
extends Object
implements AimReceive

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

字段概要

字段

限定符和类型	字段和说明
protected SessionGroups	groups 所有群组
protected io.netty.util.internal.logging.InternalLogger	logger 日志对象
protected Sessions	sessions 所有会话

构造器概要

构造器

构造器和说明
AimReceiver()

方法概要

限定符和类型	方法和说明
void	onByte(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf in) 处理WebSocket binary请求 测试方法，正式业务请重写
void	onClose(io.netty.channel.Channel ch, ChannelClose close) 关闭连接通道
boolean	onHandShake(io.netty.channel.Channel ch, io.netty.buffer.ByteBuf in) Socks基于自定义Bing握手处理逻辑，绑定用户信息到会话系统
boolean	onHandShake(io.netty.channel.Channel ch, io.netty.handler.codec.http.FullHttpRequest req, io.netty.handler.codec.http.FullHttpResponse res) WebSocket握手处理逻辑，绑定用户信息到会话系统
boolean	onHandShake(io.netty.channel.Channel ch, String user, String token) Socks基于ProtoBuf-Login的握手处理逻辑
void	onHandShaked(io.netty.channel.Channel ch) 握手成功业务处理类，此方法支持Async异步处理
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 s) 测试方法，正式业务请重写
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 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基于自定义Bing握手处理逻辑，绑定用户信息到会话系统

指定者:

onHandShake 在接口中 SocksHandShake

参数:

ch - 通道

in - 握手数据包

返回:

onHandShake

public boolean onHandShake(io.netty.channel.Channel ch,
                           String user,
                           String token)

Socks基于ProtoBuf-Login的握手处理逻辑

指定者:

onHandShake 在接口中 SocksHandShake

参数:

ch -

user -

token -

返回:

onHandShaked

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

从接口复制的说明: AimReceive

握手成功业务处理类，此方法支持Async异步处理

指定者:

onHandShaked 在接口中 AimReceive

onPing

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

从接口复制的说明: AimReceive

收到客户端的Ping操作

指定者:

onPing 在接口中 AimReceive

onText

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

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

指定者:

onText 在接口中 AimReceive

参数:

ch -

text -

onByte

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

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

指定者:

onByte 在接口中 AimReceive

参数:

ch -

in -

抛出:

com.google.protobuf.InvalidProtocolBufferException

onRecive

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

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

指定者:

onRecive 在接口中 AimReceive

参数:

ch -

s -

onKick

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

从接口复制的说明: AimReceive

处理互踢业务逻辑

指定者:

onKick 在接口中 AimReceive

onClose

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

从接口复制的说明: AimReceive

关闭连接通道

指定者:

onClose 在接口中 AimReceive