public class IMServerUtil
extends java.lang.Object
Description: 发送推送消息
Title:首亨软件 - TSS/CRM等
限定符和类型 | 类和说明 |
---|---|
static class |
IMServerUtil.SendMsgBuilder |
限定符和类型 | 字段和说明 |
---|---|
static java.lang.String |
MQ_TOPICID_IMSERVER |
static java.lang.String |
TYPE_countBySource |
static java.lang.String |
TYPE_countByTopicId |
static java.lang.String |
TYPE_isConnected |
static java.lang.String |
TYPE_queryUserInfo |
static java.lang.String |
TYPE_rtcRoomUser |
static java.lang.String |
TYPE_rtcRoomUserCount |
static java.lang.String |
TYPE_sendMsg |
static java.lang.String |
TYPE_sendMsgAll |
static java.lang.String |
TYPE_sendMsgByCondition |
static java.lang.String |
TYPE_sendMsgByConnId |
static java.lang.String |
TYPE_sendMsgBySource |
构造器和说明 |
---|
IMServerUtil() |
限定符和类型 | 方法和说明 |
---|---|
static void |
addSendTask(IMServerUtil.SendMsgBuilder builder)
添加异步发送任务
|
static void |
addSendTask(IMServerUtil.SendMsgBuilder builder,
int milliseconds)
添加异步发送任务
|
static void |
addSendTask(IMServerUtil.SendMsgBuilder builder,
int duration,
java.util.concurrent.TimeUnit timeUnit)
添加异步发送任务
|
static IMServerUtil.SendMsgBuilder |
countBySourceBuilder() |
static IMServerUtil.SendMsgBuilder |
countByTopicIdBuilder() |
static IMServerUtil.SendMsgBuilder |
createBuilder(java.lang.String type) |
static void |
initAndStartupTask()
初始化并启动任务,只能调用一次
|
static IMServerUtil.SendMsgBuilder |
isConnectedBuilder() |
static boolean |
isUserOnline(java.lang.String userId)
判断用户是否在线
|
static boolean |
isUserOnline(java.lang.String topicId,
java.lang.String userId)
判断用户是否在线
|
static com.alibaba.fastjson.JSONObject |
queryUserInfo(java.lang.String userId)
查询用户连接信息
|
static com.alibaba.fastjson.JSONObject |
queryUserInfo(java.lang.String topicId,
java.lang.String userId)
查询用户连接信息
|
static IMServerUtil.SendMsgBuilder |
queryUserInfoBuilder() |
static com.alibaba.fastjson.JSONObject |
rtcRoomUser(java.lang.String room)
查询会议室的用户信息
|
static com.alibaba.fastjson.JSONObject |
rtcRoomUser(java.lang.String topicId,
java.lang.String room)
查询会议室的用户信息
|
static IMServerUtil.SendMsgBuilder |
rtcRoomUserBuilder() |
static int |
rtcRoomUserCount(java.lang.String room)
当前会议室中的数量
|
static IMServerUtil.SendMsgBuilder |
rtcRoomUserCountBuilder() |
static com.alibaba.fastjson.JSONObject |
sendCommonMsg(IMServerUtil.SendMsgBuilder builder)
发送通用消息
|
static boolean |
sendMsg(java.lang.String msg,
java.lang.String toUserId)
通过客户端连接,要求必须连上客户端
|
static int |
sendMsg(java.lang.String topicId,
java.lang.String toUserId,
com.alibaba.fastjson.JSONObject param)
推送数据到前台
|
static IMServerUtil.SendMsgBuilder |
sendMsgAllBuilder() |
static IMServerUtil.SendMsgBuilder |
sendMsgBuilder() |
static com.alibaba.fastjson.JSONObject |
sendMsgByConn(IMServerUtil.SendMsgBuilder builder)
发送通用消息
|
static int |
sendMsgByConn(java.lang.String connId,
java.lang.String topicId,
java.lang.String toUserId,
com.alibaba.fastjson.JSONObject param)
推送数据到前台
|
static IMServerUtil.SendMsgBuilder |
sendMsgByConnIdBuilder() |
static IMServerUtil.SendMsgBuilder |
sendMsgBySourceBuilder() |
static void |
sendMsgBySourceWithActiveMQ(java.lang.String topicId,
java.lang.String source,
com.alibaba.fastjson.JSONObject param)
通过来源发送消息 使用ActiveMQ
|
static void |
sendMsgBySourceWithRabbitMQ(java.lang.String topicId,
java.lang.String source,
com.alibaba.fastjson.JSONObject param)
通过来源发送消息 使用RabbitMQ
|
static int |
sendServerMonitor(java.lang.String topicId,
java.lang.String source,
com.alibaba.fastjson.JSONObject param)
通知服务器发送监控信息
|
public static final java.lang.String MQ_TOPICID_IMSERVER
public static final java.lang.String TYPE_sendMsg
public static final java.lang.String TYPE_sendMsgBySource
public static final java.lang.String TYPE_sendMsgByConnId
public static final java.lang.String TYPE_sendMsgByCondition
public static final java.lang.String TYPE_sendMsgAll
public static final java.lang.String TYPE_isConnected
public static final java.lang.String TYPE_queryUserInfo
public static final java.lang.String TYPE_countByTopicId
public static final java.lang.String TYPE_countBySource
public static final java.lang.String TYPE_rtcRoomUser
public static final java.lang.String TYPE_rtcRoomUserCount
public static void initAndStartupTask()
public static void addSendTask(IMServerUtil.SendMsgBuilder builder)
builder
- SendMsgBuilder消息实体public static void addSendTask(IMServerUtil.SendMsgBuilder builder, int milliseconds)
builder
- SendMsgBuilder消息实体milliseconds
- 延迟发送毫秒public static void addSendTask(IMServerUtil.SendMsgBuilder builder, int duration, java.util.concurrent.TimeUnit timeUnit)
builder
- SendMsgBuilder消息实体duration
- 延迟发送时间timeUnit
- 时间单位,默认毫秒public static void sendMsgBySourceWithActiveMQ(java.lang.String topicId, java.lang.String source, com.alibaba.fastjson.JSONObject param)
topicId
- 主题source
- 源param
- 自定义参数public static void sendMsgBySourceWithRabbitMQ(java.lang.String topicId, java.lang.String source, com.alibaba.fastjson.JSONObject param)
topicId
- 主题source
- 源param
- 自定义参数public static boolean sendMsg(java.lang.String msg, java.lang.String toUserId)
msg
- StringtoUserId
- Stringpublic static int sendMsg(java.lang.String topicId, java.lang.String toUserId, com.alibaba.fastjson.JSONObject param)
topicId
- 主题toUserId
- 接收用户param
- 接收参数,配合前台开发public static int sendMsgByConn(java.lang.String connId, java.lang.String topicId, java.lang.String toUserId, com.alibaba.fastjson.JSONObject param)
topicId
- 主题toUserId
- 接收用户param
- 接收参数,配合前台开发public static int sendServerMonitor(java.lang.String topicId, java.lang.String source, com.alibaba.fastjson.JSONObject param)
topicId
- Stringsource
- Stringparam
- JSONObjectpublic static com.alibaba.fastjson.JSONObject sendMsgByConn(IMServerUtil.SendMsgBuilder builder)
builder
- public static com.alibaba.fastjson.JSONObject sendCommonMsg(IMServerUtil.SendMsgBuilder builder)
builder
- public static boolean isUserOnline(java.lang.String userId)
userId
- 用户编号public static boolean isUserOnline(java.lang.String topicId, java.lang.String userId)
topicId
- 主题userId
- 用户编号public static com.alibaba.fastjson.JSONObject queryUserInfo(java.lang.String userId)
userId
- 用户编号public static com.alibaba.fastjson.JSONObject queryUserInfo(java.lang.String topicId, java.lang.String userId)
topicId
- 主题userId
- 用户编号public static com.alibaba.fastjson.JSONObject rtcRoomUser(java.lang.String room)
room
- 会议室编号public static com.alibaba.fastjson.JSONObject rtcRoomUser(java.lang.String topicId, java.lang.String room)
topicId
- 主题room
- 会议室编号public static int rtcRoomUserCount(java.lang.String room)
room
- 会议室编号public static IMServerUtil.SendMsgBuilder createBuilder(java.lang.String type)
public static IMServerUtil.SendMsgBuilder sendMsgBuilder()
public static IMServerUtil.SendMsgBuilder sendMsgBySourceBuilder()
public static IMServerUtil.SendMsgBuilder sendMsgByConnIdBuilder()
public static IMServerUtil.SendMsgBuilder sendMsgAllBuilder()
public static IMServerUtil.SendMsgBuilder isConnectedBuilder()
public static IMServerUtil.SendMsgBuilder queryUserInfoBuilder()
public static IMServerUtil.SendMsgBuilder countByTopicIdBuilder()
public static IMServerUtil.SendMsgBuilder countBySourceBuilder()
public static IMServerUtil.SendMsgBuilder rtcRoomUserBuilder()
public static IMServerUtil.SendMsgBuilder rtcRoomUserCountBuilder()