Modifier and Type | Method and Description |
---|---|
Packet |
ClientAioHandler.heartbeatPacket(ChannelContext channelContext)
创建心跳包
|
Modifier and Type | Field and Description |
---|---|
MapWithLock<Integer,Packet> |
TioConfig.waitingResps |
Modifier and Type | Method and Description |
---|---|
Packet |
PacketConverter.convert(Packet packet,
ChannelContext channelContext) |
Modifier and Type | Method and Description |
---|---|
MapWithLock<Integer,Packet> |
TioConfig.getWaitingResps() |
Modifier and Type | Method and Description |
---|---|
static Boolean |
Tio.bSend(ChannelContext channelContext,
Packet packet)
阻塞发送消息到指定ChannelContext
|
static Boolean |
Tio.bSend(TioConfig tioConfig,
String ip,
int port,
Packet packet)
发送到指定的ip和port
|
static Boolean |
Tio.bSendToAll(TioConfig tioConfig,
Packet packet,
ChannelContextFilter channelContextFilter)
发消息到所有连接
|
static Boolean |
Tio.bSendToBsId(TioConfig tioConfig,
String bsId,
Packet packet)
阻塞发消息给指定业务ID
|
static Boolean |
Tio.bSendToGroup(TioConfig tioConfig,
String group,
Packet packet)
发消息到组
|
static Boolean |
Tio.bSendToGroup(TioConfig tioConfig,
String group,
Packet packet,
ChannelContextFilter channelContextFilter)
发消息到组
|
static Boolean |
Tio.bSendToId(TioConfig tioConfig,
String channelContextId,
Packet packet)
发消息给指定ChannelContext id
|
static Boolean |
Tio.bSendToIp(TioConfig tioConfig,
String ip,
Packet packet)
阻塞发送到指定ip对应的集合
|
static Boolean |
Tio.bSendToIp(TioConfig tioConfig,
String ip,
Packet packet,
ChannelContextFilter channelContextFilter)
阻塞发送到指定ip对应的集合
|
static Boolean |
Tio.bSendToSet(TioConfig tioConfig,
SetWithLock<ChannelContext> setWithLock,
Packet packet,
ChannelContextFilter channelContextFilter)
发消息到指定集合
|
static Boolean |
Tio.bSendToToken(TioConfig tioConfig,
String token,
Packet packet)
阻塞发消息到指定token
|
static Boolean |
Tio.bSendToUser(TioConfig tioConfig,
String userid,
Packet packet)
阻塞发消息给指定用户
|
Packet |
PacketConverter.convert(Packet packet,
ChannelContext channelContext) |
void |
WriteCompletionHandler.handleOne(Integer result,
Throwable throwable,
Packet packet,
Boolean isSentSuccess) |
void |
DefaultAioListener.onAfterDecoded(ChannelContext channelContext,
Packet packet,
int packetSize) |
void |
DefaultAioListener.onAfterHandled(ChannelContext channelContext,
Packet packet,
long cost) |
void |
DefaultAioListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess) |
void |
ChannelContext.processAfterSent(Packet packet,
Boolean isSentSuccess) |
static Boolean |
Tio.send(ChannelContext channelContext,
Packet packet)
发送消息到指定ChannelContext
|
static Boolean |
Tio.send(TioConfig tioConfig,
String ip,
int port,
Packet packet)
发送到指定的ip和port
|
static void |
Tio.sendToAll(TioConfig tioConfig,
Packet packet) |
static void |
Tio.sendToAll(TioConfig tioConfig,
Packet packet,
ChannelContextFilter channelContextFilter)
发消息到所有连接
|
static Boolean |
Tio.sendToBsId(TioConfig tioConfig,
String bsId,
Packet packet)
发消息给指定业务ID
|
static void |
Tio.sendToGroup(TioConfig tioConfig,
String group,
Packet packet)
发消息到组
|
static void |
Tio.sendToGroup(TioConfig tioConfig,
String group,
Packet packet,
ChannelContextFilter channelContextFilter)
发消息到组
|
static Boolean |
Tio.sendToId(TioConfig tioConfig,
String channelContextId,
Packet packet)
发消息给指定ChannelContext id
|
static void |
Tio.sendToIp(TioConfig tioConfig,
String ip,
Packet packet)
发送到指定ip对应的集合
|
static void |
Tio.sendToIp(TioConfig tioConfig,
String ip,
Packet packet,
ChannelContextFilter channelContextFilter)
发送到指定ip对应的集合
|
static void |
Tio.sendToSet(TioConfig tioConfig,
SetWithLock<ChannelContext> setWithLock,
Packet packet,
ChannelContextFilter channelContextFilter)
发消息到指定集合
|
static Boolean |
Tio.sendToToken(TioConfig tioConfig,
String token,
Packet packet)
发消息到指定token
|
static Boolean |
Tio.sendToUser(TioConfig tioConfig,
String userid,
Packet packet)
发消息给指定用户
|
Modifier and Type | Class and Description |
---|---|
class |
EncodedPacket |
Modifier and Type | Method and Description |
---|---|
Packet |
Packet.clone() |
Packet |
AioHandler.decode(ByteBuffer buffer,
int limit,
int position,
int readableLength,
ChannelContext channelContext)
根据ByteBuffer解码成业务需要的Packet对象.
|
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
AioHandler.encode(Packet packet,
TioConfig tioConfig,
ChannelContext channelContext)
编码
|
void |
AioHandler.handler(Packet packet,
ChannelContext channelContext)
处理消息包
|
void |
AioListener.onAfterDecoded(ChannelContext channelContext,
Packet packet,
int packetSize)
原方法名:onAfterDecoded
解码成功后触发本方法
|
void |
AioListener.onAfterHandled(ChannelContext channelContext,
Packet packet,
long cost)
处理一个消息包后
|
void |
PacketListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess) |
void |
AioListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess)
消息包发送之后触发本方法
|
Modifier and Type | Method and Description |
---|---|
static boolean |
SslUtils.needSslEncrypt(Packet packet,
TioConfig tioConfig)
是否需要对这个packet进行SSL加密
|
Modifier and Type | Method and Description |
---|---|
void |
IpStatListener.onAfterDecoded(ChannelContext channelContext,
Packet packet,
int packetSize,
IpStat ipStat)
解码成功后
|
void |
DefaultIpStatListener.onAfterDecoded(ChannelContext channelContext,
Packet packet,
int packetSize,
IpStat ipStat) |
void |
IpStatListener.onAfterHandled(ChannelContext channelContext,
Packet packet,
IpStat ipStat,
long cost)
处理一个消息包后
|
void |
DefaultIpStatListener.onAfterHandled(ChannelContext channelContext,
Packet packet,
IpStat ipStat,
long cost) |
void |
IpStatListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess,
IpStat ipStat)
发送后(注:不一定会发送成功)
|
void |
DefaultIpStatListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess,
IpStat ipStat) |
Modifier and Type | Method and Description |
---|---|
ConcurrentLinkedQueue<Packet> |
SendRunnable.getForSendAfterSslHandshakeCompleted(boolean forceCreate) |
FullWaitQueue<Packet> |
SendRunnable.getMsgQueue() |
FullWaitQueue<Packet> |
HandlerRunnable.getMsgQueue() |
Modifier and Type | Method and Description |
---|---|
boolean |
SendRunnable.addMsg(Packet packet) |
void |
HandlerRunnable.handler(Packet packet)
处理packet
|
void |
DecodeRunnable.handler(Packet packet,
int byteCount) |
boolean |
SendRunnable.sendPacket(Packet packet) |
Modifier and Type | Class and Description |
---|---|
class |
FlashPolicyPacket |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
FlashPolicyServerAioHandler.encode(Packet packet,
TioConfig tioConfig,
ChannelContext channelContext) |
void |
FlashPolicyServerAioHandler.handler(Packet packet,
ChannelContext channelContext)
处理消息
|
Modifier and Type | Class and Description |
---|---|
class |
HttpPacket |
class |
HttpRequest |
class |
HttpResponse |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
HttpServerAioHandler.encode(Packet packet,
TioConfig tioConfig,
ChannelContext channelContext) |
void |
HttpServerAioHandler.handler(Packet packet,
ChannelContext channelContext) |
void |
HttpServerAioListener.onAfterDecoded(ChannelContext channelContext,
Packet packet,
int packetSize) |
void |
HttpServerAioListener.onAfterHandled(ChannelContext channelContext,
Packet packet,
long cost) |
void |
HttpServerAioListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess) |
Modifier and Type | Method and Description |
---|---|
Packet |
WsClientAioHander.decode(ByteBuffer buffer,
int limit,
int position,
int readableLength,
ChannelContext ctx) |
Packet |
WsClientAioHander.heartbeatPacket(ChannelContext ctx) |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
WsClientAioHander.encode(Packet packet,
TioConfig tioConfig,
ChannelContext ctx) |
void |
WsClientAioHander.handler(Packet packet,
ChannelContext ctx) |
void |
WsClientAioListener.onAfterDecoded(ChannelContext channelContext,
Packet packet,
int packetSize) |
void |
WsClientAioListener.onAfterHandled(ChannelContext channelContext,
Packet packet,
long cost) |
void |
WsClientAioListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess) |
Modifier and Type | Class and Description |
---|---|
class |
ClientHttpRequest
临时写的httpclient,用于性能测试
|
Modifier and Type | Method and Description |
---|---|
static Boolean |
TioKit.bSend(ChannelContext channelContext,
Packet packet,
int timeout,
TimeUnit timeUnit) |
Modifier and Type | Class and Description |
---|---|
class |
WsPacket |
class |
WsRequest |
class |
WsResponse |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
WsServerAioHandler.encode(Packet packet,
TioConfig tioConfig,
ChannelContext channelContext) |
void |
WsServerAioHandler.handler(Packet packet,
ChannelContext channelContext) |
void |
WsServerAioListener.onAfterDecoded(ChannelContext channelContext,
Packet packet,
int packetSize) |
void |
WsServerAioListener.onAfterHandled(ChannelContext channelContext,
Packet packet,
long cost) |
void |
WsServerAioListener.onAfterSent(ChannelContext channelContext,
Packet packet,
boolean isSentSuccess) |
Copyright © 2021. All rights reserved.