Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/FreddyChen/NettyChat
/ functions
Functions
437 in github.com/FreddyChen/NettyChat
⨍
Functions
437
◇
Types & classes
66
↓ 2 callers
Method
newBuilder
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:1494
↓ 2 callers
Method
onCEvent
事件回调函数<br /> <b>注意:</b><br /> 如果 obj 使用了对象池(如 socket 事件的对象),<br /> 那么事件完成后,obj 即自动回收到对象池,请不要在其它线程继续使用,否则可能会导致数据不正常 @param topic 事件名称 @pa
app/src/main/java/com/freddy/chat/event/I_CEventListener.java:26
↓ 2 callers
Method
parsePartialFrom
( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite ex
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:809
↓ 2 callers
Method
receivedMsg
接收消息,并通过OnEventListener转发消息到应用层 @param msg
im_lib/src/main/java/com/freddy/im/MsgDispatcher.java:33
↓ 2 callers
Method
registerEventListener
注册监听器 @param listener 监听器 @param topic 主题
app/src/main/java/com/freddy/chat/event/CEventCenter.java:60
↓ 2 callers
Method
removeChannelIfConnectNoActive
(Channel channel)
im_lib/src/main/java/com/freddy/im/NettyServerDemo.java:210
↓ 2 callers
Method
sendMsg
(AppMessage message)
app/src/main/java/com/freddy/chat/im/IMessageProcessor.java:21
↓ 2 callers
Method
setContent
(String content)
app/src/main/java/com/freddy/chat/bean/BaseMessage.java:96
↓ 2 callers
Method
setExtend
<pre> 扩展字段,以key/value形式存放的json </pre> <code>string extend = 8;</code>
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:2155
↓ 2 callers
Method
setStatusReport
(int statusReport)
app/src/main/java/com/freddy/chat/bean/Head.java:77
↓ 2 callers
Method
unregisterEventListener
注销监听器 @param listener 监听器 @param topic 注销对该主题的监听
app/src/main/java/com/freddy/chat/event/CEventCenter.java:116
↓ 1 callers
Method
action
(AppMessage message)
app/src/main/java/com/freddy/chat/im/handler/AbstractMessageHandler.java:23
↓ 1 callers
Method
addRepeatedField
( com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:492
↓ 1 callers
Method
buildReceivedReportMsg
构建客户端消息接收状态报告 @param msgId @return
im_lib/src/main/java/com/freddy/im/netty/TCPReadHandler.java:98
↓ 1 callers
Method
clearField
( com.google.protobuf.Descriptors.FieldDescriptor field)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:479
↓ 1 callers
Method
clearOneof
( com.google.protobuf.Descriptors.OneofDescriptor oneof)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:483
↓ 1 callers
Method
close
关闭连接,同时释放资源
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:159
↓ 1 callers
Method
connectServer
连接服务器 @return
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:701
↓ 1 callers
Method
convertHosts
(String hosts)
app/src/main/java/com/freddy/chat/im/IMSClientBootstrap.java:79
↓ 1 callers
Method
createNewObj
创建一个新的对象 @return 创建成功的对象
app/src/main/java/com/freddy/chat/event/ObjectPool.java:40
↓ 1 callers
Method
createObjPool
创建对象池 @param capacity 最大限度容量 @return 对象池
app/src/main/java/com/freddy/chat/event/ObjectPool.java:33
↓ 1 callers
Method
destroy
释放所有线程池
im_lib/src/main/java/com/freddy/im/ExecutorServiceFactory.java:115
↓ 1 callers
Method
dispatchEvent
同步分发事件 @param topic 主题 @param msgCode 消息类型 @param resultCode 预留参数 @param obj 回调返回数据
app/src/main/java/com/freddy/chat/event/CEventCenter.java:166
↓ 1 callers
Method
dispatchMsg
分发消息到应用层 @param msg
im_lib/src/main/java/com/freddy/im/listener/OnEventListener.java:23
↓ 1 callers
Method
execBossTask
执行boss任务 @param r
im_lib/src/main/java/com/freddy/im/ExecutorServiceFactory.java:63
↓ 1 callers
Method
execWorkTask
执行work任务 @param r
im_lib/src/main/java/com/freddy/im/ExecutorServiceFactory.java:75
↓ 1 callers
Method
findFreeObject
从池中找到空闲的对象 @return 空闲的对象
app/src/main/java/com/freddy/chat/event/ObjectPool.java:79
↓ 1 callers
Method
getChannelId
()
im_lib/src/main/java/com/freddy/im/NettyServerDemo.java:260
↓ 1 callers
Method
getConnectTimeout
获取连接超时时长 @return
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:275
↓ 1 callers
Method
getDescriptor
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:142
↓ 1 callers
Method
getDescriptor
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:1054
↓ 1 callers
Method
getHandlerByMsgType
根据消息类型获取对应的处理handler @param msgType @return
app/src/main/java/com/freddy/chat/im/handler/MessageHandlerFactory.java:41
↓ 1 callers
Method
getHandshakeMsg
获取由应用层构造的握手消息 @return
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:334
↓ 1 callers
Method
getHead
<pre> 消息头 </pre> <code>.Head head = 1;</code>
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:562
↓ 1 callers
Method
getHeadFieldBuilder
<pre> 消息头 </pre> <code>.Head head = 1;</code>
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:681
↓ 1 callers
Method
getIMSClient
()
im_lib/src/main/java/com/freddy/im/IMSClientFactory.java:19
↓ 1 callers
Method
getInstance
()
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:78
↓ 1 callers
Method
getLoopGroup
获取线程池 @return
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:427
↓ 1 callers
Method
getMessageByProtobuf
通过protobuf消息对象获取业务消息对象 @param protobufMessage @return
app/src/main/java/com/freddy/chat/im/MessageBuilder.java:129
↓ 1 callers
Method
getMsg
()
im_lib/src/main/java/com/freddy/im/MsgTimeoutTimer.java:82
↓ 1 callers
Method
getProtoBufMessageBuilderByAppMessage
根据业务消息对象获取protoBuf消息对应的builder @param message @return
app/src/main/java/com/freddy/chat/im/MessageBuilder.java:101
↓ 1 callers
Method
getSerializedSize
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:250
↓ 1 callers
Method
hasHead
<pre> 消息头 </pre> <code>.Head head = 1;</code>
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:28
↓ 1 callers
Method
init
(String userId, String token, String hosts, int appStatus)
app/src/main/java/com/freddy/chat/im/IMSClientBootstrap.java:45
↓ 1 callers
Method
initBootstrap
初始化bootstrap
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:454
↓ 1 callers
Method
initWorkLoopGroup
初始化work线程池
im_lib/src/main/java/com/freddy/im/ExecutorServiceFactory.java:43
↓ 1 callers
Method
isClosed
标识ims是否已关闭 @return
im_lib/src/main/java/com/freddy/im/interf/IMSClientInterface.java:58
↓ 1 callers
Method
isInitialized
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:230
↓ 1 callers
Method
isInitialized
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:1287
↓ 1 callers
Method
isOnMainThread
()
app/src/main/java/com/freddy/chat/utils/CThreadPoolExecutor.java:227
↓ 1 callers
Method
logAllThreadStackTrace
()
app/src/main/java/com/freddy/chat/utils/CThreadPoolExecutor.java:295
↓ 1 callers
Method
mergeHead
<pre> 消息头 </pre> <code>.Head head = 1;</code>
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:614
↓ 1 callers
Method
newThread
(Runnable r)
app/src/main/java/com/freddy/chat/utils/CThreadPoolExecutor.java:120
↓ 1 callers
Method
onConnectFailed
ims连接失败
im_lib/src/main/java/com/freddy/im/listener/IMSConnectStatusCallback.java:29
↓ 1 callers
Method
onConnected
ims连接成功
im_lib/src/main/java/com/freddy/im/listener/IMSConnectStatusCallback.java:24
↓ 1 callers
Method
onConnecting
ims连接中
im_lib/src/main/java/com/freddy/im/listener/IMSConnectStatusCallback.java:19
↓ 1 callers
Method
onResetConnected
重连成功回调,重连并握手成功时,重发消息发送超时管理器中所有的消息
im_lib/src/main/java/com/freddy/im/MsgTimeoutTimerManager.java:93
↓ 1 callers
Method
parser
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:2230
↓ 1 callers
Method
reConnect
重连,首次连接也认为是第一次重连 @return
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:677
↓ 1 callers
Method
receiveMsg
(AppMessage message)
app/src/main/java/com/freddy/chat/im/IMessageProcessor.java:20
↓ 1 callers
Method
reset
恢复到默认状态
app/src/main/java/com/freddy/chat/event/PoolableObject.java:14
↓ 1 callers
Method
resetConnect
重置连接,也就是重连 首次连接也可认为是重连
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:117
↓ 1 callers
Method
returnObj
把对象放回池里面 @param obj 需要放回对象池的对象
app/src/main/java/com/freddy/chat/event/ObjectPool.java:64
↓ 1 callers
Method
run
()
app/src/main/java/com/freddy/chat/utils/CThreadPoolExecutor.java:157
↓ 1 callers
Method
runOnMainThread
(Runnable r)
app/src/main/java/com/freddy/chat/utils/CThreadPoolExecutor.java:231
↓ 1 callers
Method
saveChannel
(NettyChannel channel)
im_lib/src/main/java/com/freddy/im/NettyServerDemo.java:203
↓ 1 callers
Method
sendMessage
发送消息 @param msg
app/src/main/java/com/freddy/chat/im/IMSClientBootstrap.java:73
↓ 1 callers
Method
sendMsg
发送消息 @param msg
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:220
↓ 1 callers
Method
setAppStatus
设置app前后台状态 @param appStatus
im_lib/src/main/java/com/freddy/im/interf/IMSClientInterface.java:109
↓ 1 callers
Method
setField
( com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:474
↓ 1 callers
Method
setMsgContentType
<pre> 消息内容类型 </pre> <code>int32 msgContentType = 3;</code>
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:1834
↓ 1 callers
Method
setOnEventListener
(OnEventListener listener)
im_lib/src/main/java/com/freddy/im/MsgDispatcher.java:25
↓ 1 callers
Method
setRepeatedField
( com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:487
↓ 1 callers
Method
sharedInstance
()
app/src/main/java/com/freddy/chat/NettyChatApp.java:20
↓ 1 callers
Method
toServer
真正连接服务器的地方
im_lib/src/main/java/com/freddy/im/netty/NettyTcpClient.java:603
↓ 1 callers
Method
updateAppStatus
(int appStatus)
app/src/main/java/com/freddy/chat/im/IMSClientBootstrap.java:96
↓ 1 callers
Method
writeTo
(com.google.protobuf.CodedOutputStream output)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:239
Method
Builder
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:415
Method
Builder
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:1531
Method
CEvenObjPool
(int capacity)
app/src/main/java/com/freddy/chat/event/CEvenObjPool.java:11
Method
CEvent
()
app/src/main/java/com/freddy/chat/event/CEvent.java:31
Method
CThreadFactory
(String prefix, int priority)
app/src/main/java/com/freddy/chat/utils/CThreadPoolExecutor.java:111
Method
ChannelContainer
()
im_lib/src/main/java/com/freddy/im/NettyServerDemo.java:191
Method
ContentMessage
()
app/src/main/java/com/freddy/chat/bean/ContentMessage.java:22
Method
Head
(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:953
Method
HeartbeatHandler
(NettyTcpClient imsClient)
im_lib/src/main/java/com/freddy/im/HeartbeatHandler.java:25
Method
HeartbeatRespHandler
(NettyTcpClient imsClient)
im_lib/src/main/java/com/freddy/im/HeartbeatRespHandler.java:24
Method
HeartbeatTask
(ChannelHandlerContext ctx)
im_lib/src/main/java/com/freddy/im/HeartbeatHandler.java:59
Method
IMSClientBootstrap
()
app/src/main/java/com/freddy/chat/im/IMSClientBootstrap.java:29
Method
IMSEventListener
(String userId, String token)
app/src/main/java/com/freddy/chat/im/IMSEventListener.java:30
Method
LoginAuthRespHandler
(NettyTcpClient imsClient)
im_lib/src/main/java/com/freddy/im/LoginAuthRespHandler.java:29
Method
MessageContentType
(int msgContentType)
app/src/main/java/com/freddy/chat/im/MessageType.java:75
Method
MessageHandlerFactory
()
app/src/main/java/com/freddy/chat/im/handler/MessageHandlerFactory.java:20
Method
MessageProcessor
()
app/src/main/java/com/freddy/chat/im/MessageProcessor.java:27
Method
MessageProtobuf
()
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:7
Method
MessageType
(int msgType)
app/src/main/java/com/freddy/chat/im/MessageType.java:48
Method
Msg
(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)
im_lib/src/main/java/com/freddy/im/protobuf/MessageProtobuf.java:73
Method
MsgDispatcher
()
im_lib/src/main/java/com/freddy/im/MsgDispatcher.java:21
Method
MsgTimeoutTimer
(IMSClientInterface imsClient, MessageProtobuf.Msg msg)
im_lib/src/main/java/com/freddy/im/MsgTimeoutTimer.java:27
Method
MsgTimeoutTimerManager
(IMSClientInterface imsClient)
im_lib/src/main/java/com/freddy/im/MsgTimeoutTimerManager.java:28
← previous
next →
101–200 of 437, ranked by callers