Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/wildfirechat/im-server
/ functions
Functions
9,418 in github.com/wildfirechat/im-server
⨍
Functions
9,418
◇
Types & classes
953
↓ 13 callers
Method
setOwner
(String owner)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:134
↓ 13 callers
Method
setType
<code>optional int32 type = 13;</code> <pre> 0 normal user; 1 robot </pre>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:29002
↓ 13 callers
Method
write
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java:100
↓ 12 callers
Method
getChannelId
<code>required string channel_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:13949
↓ 12 callers
Method
getClientID
()
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:232
↓ 12 callers
Method
getImBusinessScheduler
()
broker/src/main/java/io/moquette/server/Server.java:526
↓ 12 callers
Method
getMenuFieldBuilder
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:10634
↓ 12 callers
Method
getMqttVersion
(ChannelHandlerContext ctx)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttCodecUtil.java:30
↓ 12 callers
Method
getOperator
()
common/src/main/java/cn/wildfirechat/pojos/InputGetAlias.java:24
↓ 12 callers
Method
getUsername
()
broker/src/main/java/io/moquette/server/ConnectionDescriptor.java:92
↓ 12 callers
Method
hasType
<code>optional int32 type = 13;</code> <pre> 0 normal user; 1 robot </pre>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:28982
↓ 12 callers
Method
isGranted
漏桶算法,https://en.wikipedia.org/wiki/Leaky_bucket
broker/src/main/java/win/liyufan/im/RateLimiter.java:38
↓ 12 callers
Method
name
()
broker/src/main/java/io/moquette/spi/impl/subscriptions/Token.java:33
↓ 12 callers
Method
setDisplayName
(String displayName)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:70
↓ 12 callers
Method
setServerTimestamp
<code>optional int64 server_timestamp = 5;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26609
↓ 12 callers
Method
setTimestamp
(long timestamp)
broker/src/main/java/com/xiaoleilu/loServer/model/FriendData.java:88
↓ 12 callers
Method
strEqual
(String left, String right)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:1755
↓ 11 callers
Method
build
()
sdk/src/main/java/ikidou/reflect/TypeBuilder.java:96
↓ 11 callers
Method
checkSendMessageResult
检查消息发送结果 <p> 验证消息是否发送成功,如果失败则退出程序。 </p> @param resultSendMessage 消息发送结果
sdk/src/main/java/cn/wildfirechat/sdk/Main.java:1463
↓ 11 callers
Method
getAddress
<code>optional string address = 7;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26928
↓ 11 callers
Method
getAppName
<code>required string app_name = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:30997
↓ 11 callers
Method
getCreateDt
<code>optional int64 create_dt = 5;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:3611
↓ 11 callers
Method
getDesc
<code>optional string desc = 6;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:8529
↓ 11 callers
Method
getFixedHeaderByte1
(MqttFixedHeader header)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java:686
↓ 11 callers
Method
getID
Returns the identifier of this intercept handler. @return
broker/src/main/java/io/moquette/interception/InterceptHandler.java:41
↓ 11 callers
Method
getMemberCount
<code>optional int32 member_count = 6;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:1548
↓ 11 callers
Method
getMobile
()
common/src/main/java/cn/wildfirechat/pojos/InputGetUserInfo.java:33
↓ 11 callers
Method
getProcessor
()
broker/src/main/java/io/moquette/server/Server.java:518
↓ 11 callers
Method
getTargetId
()
common/src/main/java/cn/wildfirechat/pojos/InputCreateChannel.java:80
↓ 11 callers
Method
getTimestamp
<code>required int64 timestamp = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:66365
↓ 11 callers
Method
getUserId
<code>required string user_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:62476
↓ 11 callers
Method
printMissConfigLog
(String config, String defaultValue)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:731
↓ 11 callers
Method
qosLevel
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttFixedHeader.java:55
↓ 11 callers
Method
sendApiRequest
(Response response, String topic, byte[] message, Callback callback)
broker/src/main/java/com/xiaoleilu/loServer/action/robot/RobotAction.java:109
↓ 11 callers
Method
sendError
发送错误消息 @param status 错误状态码 @param msg 消息内容 @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:530
↓ 11 callers
Method
setContentType
设置Content-Type @param contentType Content-Type @return 自己
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:124
↓ 11 callers
Method
setCreateDt
(long createDt)
common/src/main/java/cn/wildfirechat/pojos/PojoGroupMember.java:76
↓ 11 callers
Method
setMobile
(String mobile)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:155
↓ 11 callers
Method
setName
(String name)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:123
↓ 11 callers
Method
setNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42615
↓ 11 callers
Method
start
(String[] args)
broker/src/main/java/io/moquette/server/Server.java:112
↓ 10 callers
Method
addToLine
<code>repeated int32 to_line = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42566
↓ 10 callers
Method
close
()
broker/src/main/java/io/moquette/server/ServerAcceptor.java:28
↓ 10 callers
Method
decode
(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java:73
↓ 10 callers
Method
decodeString
(ByteBuf buffer)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java:654
↓ 10 callers
Method
ensureToIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26725
↓ 10 callers
Method
getBlacked
<code>optional int32 blacked = 5;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:49798
↓ 10 callers
Method
getNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42605
↓ 10 callers
Method
getOwner
()
common/src/main/java/cn/wildfirechat/pojos/PojoGroupInfo.java:69
↓ 10 callers
Method
getParam
@param name 参数名 @return 获得请求参数
broker/src/main/java/com/xiaoleilu/loServer/handler/Request.java:198
↓ 10 callers
Method
getPhoneName
<code>optional string phone_name = 6;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:60159
↓ 10 callers
Method
getUserSessionSet
(String username)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:642
↓ 10 callers
Method
hasNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42599
↓ 10 callers
Method
hasUpdateDt
<code>optional int64 update_dt = 10;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26969
↓ 10 callers
Method
isAllowClientCustomGroupNotification
()
broker/src/main/java/io/moquette/spi/IMessagesStore.java:258
↓ 10 callers
Method
isAllowRobotCustomGroupNotification
()
broker/src/main/java/io/moquette/spi/IMessagesStore.java:259
↓ 10 callers
Method
isConnected
Determines wether a MQTT client is connected to the broker. @param clientID @return
broker/src/main/java/io/moquette/connections/IConnectionsManager.java:39
↓ 10 callers
Method
mergeNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42645
↓ 10 callers
Method
sendResponse
(Response response, ErrorCode errorCode, byte[] contents)
broker/src/main/java/com/xiaoleilu/loServer/action/IMAction.java:120
↓ 10 callers
Method
setAddress
(String address)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:102
↓ 10 callers
Method
setAlias
(String alias)
common/src/main/java/cn/wildfirechat/pojos/PojoGroupMember.java:44
↓ 10 callers
Method
setCode
(int code)
sdk/src/main/java/cn/wildfirechat/sdk/model/IMResult.java:23
↓ 10 callers
Method
setCompany
(String company)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:110
↓ 10 callers
Method
setEmail
(String email)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:94
↓ 10 callers
Method
setGender
(int gender)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:126
↓ 10 callers
Method
setHead
<code>required int64 head = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:35806
↓ 10 callers
Method
setSocial
(String social)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:30
↓ 10 callers
Method
setUpdateDt
<code>optional int64 update_dt = 10;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:28850
↓ 10 callers
Method
setUserId
(String userId)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:115
↓ 10 callers
Method
sha1Hex
(String input)
VerifyAdminSecretTool.java:105
↓ 9 callers
Method
AESDecrypt
(byte[] sSrc, String userKey, boolean checkTime)
broker/src/main/java/io/moquette/spi/impl/security/AES.java:114
↓ 9 callers
Method
addListener
<code>repeated string listener = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:13884
↓ 9 callers
Method
connAck
(MqttConnectReturnCode returnCode)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:299
↓ 9 callers
Method
ensureAddedMemberIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:18157
↓ 9 callers
Method
ensureChannelIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:15037
↓ 9 callers
Method
ensureInfoIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:37786
↓ 9 callers
Method
ensureMemberIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:39040
↓ 9 callers
Method
ensureMessageIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:37034
↓ 9 callers
Method
ensureRequestIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:40286
↓ 9 callers
Method
ensureResultIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:41584
↓ 9 callers
Method
ensureSubMenuIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:7358
↓ 9 callers
Method
generateId
ID = timestamp(43) + nodeId(6) + rotateId(15) 所以时间限制是到2157/5/15(2的42次幂代表的时间 + (2018-1970))。节点数限制是小于64,每台服务器每毫秒最多发送32768条消息 @return
broker/src/main/java/win/liyufan/im/MessageShardingUtil.java:38
↓ 9 callers
Method
getDeviceToken
<code>required string device_token = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:31012
↓ 9 callers
Method
getJoinType
<code>optional int32 join_type = 11;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:1603
↓ 9 callers
Method
getMessageTable
(long mid)
broker/src/main/java/win/liyufan/im/MessageShardingUtil.java:85
↓ 9 callers
Method
getMute
<code>optional int32 mute = 10;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:1593
↓ 9 callers
Method
getName
()
common/src/main/java/cn/wildfirechat/pojos/InputGetUserInfo.java:49
↓ 9 callers
Method
getPushType
<code>optional int32 push_type = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:60119
↓ 9 callers
Method
getRemoteMediaUrl
<code>optional string remoteMediaUrl = 7;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:15445
↓ 9 callers
Method
getTimestamp
()
broker/src/main/java/com/xiaoleilu/loServer/model/FriendData.java:84
↓ 9 callers
Method
getUserId
()
common/src/main/java/cn/wildfirechat/pojos/InputUserId.java:21
↓ 9 callers
Method
getUserStatus
(String userId)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:147
↓ 9 callers
Method
getVariableLengthInt
(int num)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java:746
↓ 9 callers
Method
hasGroupId
<code>required string group_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:41839
↓ 9 callers
Method
hasGroupId
<code>required string group_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42457
↓ 9 callers
Method
messagesStore
Factory method to instantiate the messages store. @return the create instance of IMessagesStore.
broker/src/main/java/io/moquette/spi/IStore.java:30
↓ 9 callers
Method
persistOrUpdateFriendData
(final FriendData request)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3637
↓ 9 callers
Method
sessionForUser
(String username)
broker/src/main/java/io/moquette/spi/ISessionsStore.java:68
↓ 9 callers
Method
setDeleted
(int deleted)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:72
↓ 9 callers
Method
setDisplayName
(String displayName)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:139
← previous
next →
201–300 of 9,418, ranked by callers