程序包 com.sh.wf.util

类 IMServerUtil

java.lang.Object
com.sh.wf.util.IMServerUtil

public class IMServerUtil extends Object

Description: 发送推送消息

Title:首亨软件 - TSS/CRM等

从以下版本开始:
2018年1月17日
  • 字段详细资料

  • 构造器详细资料

    • IMServerUtil

      public IMServerUtil()
  • 方法详细资料

    • initAndStartupTask

      public static void initAndStartupTask()
      初始化并启动任务,只能调用一次
    • addSendTask

      public static void addSendTask(IMServerUtil.SendMsgBuilder builder)
      添加异步发送任务
      参数:
      builder - SendMsgBuilder消息实体
    • addSendTask

      public static void addSendTask(IMServerUtil.SendMsgBuilder builder, int milliseconds)
      添加异步发送任务
      参数:
      builder - SendMsgBuilder消息实体
      milliseconds - 延迟发送毫秒
    • addSendTask

      public static void addSendTask(IMServerUtil.SendMsgBuilder builder, int duration, TimeUnit timeUnit)
      添加异步发送任务
      参数:
      builder - SendMsgBuilder消息实体
      duration - 延迟发送时间
      timeUnit - 时间单位,默认毫秒
    • sendMsgBySourceWithActiveMQ

      public static void sendMsgBySourceWithActiveMQ(String topicId, String source, JSONObject param)
      通过来源发送消息 使用ActiveMQ
      参数:
      topicId - 主题
      source - 源
      param - 自定义参数
    • sendMsgBySourceWithRabbitMQ

      public static void sendMsgBySourceWithRabbitMQ(String topicId, String source, JSONObject param)
      通过来源发送消息 使用RabbitMQ
      参数:
      topicId - 主题
      source - 源
      param - 自定义参数
    • sendMsg

      public static boolean sendMsg(String msg, String toUserId)
      通过客户端连接,要求必须连上客户端
      参数:
      msg - String
      toUserId - String
      返回:
      boolean
    • sendMsg

      public static int sendMsg(String topicId, String toUserId, JSONObject param)
      推送数据到前台
      参数:
      topicId - 主题
      toUserId - 接收用户
      param - 接收参数,配合前台开发
      返回:
      大于0 推送人用户数 0 表示无人在线 -1 失败
    • sendMsgByConn

      public static int sendMsgByConn(String connId, String topicId, String toUserId, JSONObject param)
      推送数据到前台
      参数:
      topicId - 主题
      toUserId - 接收用户
      param - 接收参数,配合前台开发
      返回:
      大于0 推送人用户数 0 表示无人在线 -1 失败
    • sendServerMonitor

      public static int sendServerMonitor(String topicId, String source, JSONObject param)
      通知服务器发送监控信息
      参数:
      topicId - String
      source - String
      param - JSONObject
      返回:
      int
    • sendMsgByConn

      public static JSONObject sendMsgByConn(IMServerUtil.SendMsgBuilder builder)
      发送通用消息
      参数:
      builder -
      返回:
    • sendCommonMsg

      public static JSONObject sendCommonMsg(IMServerUtil.SendMsgBuilder builder)
      发送通用消息
      参数:
      builder -
      返回:
    • isUserOnline

      public static boolean isUserOnline(String userId)
      判断用户是否在线
      参数:
      userId - 用户编号
      返回:
      true|false
    • isUserOnlineBySource

      public static boolean isUserOnlineBySource(String userId, String source)
      能过source来源判断是否在线
      参数:
      userId -
      source -
      返回:
      boolean
    • isUserOnline

      public static boolean isUserOnline(String topicId, String userId)
      判断用户是否在线
      参数:
      topicId - 主题
      userId - 用户编号
      返回:
      true|false
    • isUserOnline

      public static boolean isUserOnline(String topicId, String userId, String source)
      检测用户是否在线
      参数:
      topicId -
      userId -
      source -
      返回:
      boolean
    • queryUserInfo

      public static JSONObject queryUserInfo(String userId)
      查询用户连接信息
      参数:
      userId - 用户编号
      返回:
    • queryUserInfo

      public static JSONObject queryUserInfo(String topicId, String userId)
      查询用户连接信息
      参数:
      topicId - 主题
      userId - 用户编号
      返回:
    • rtcRoomUser

      public static JSONObject rtcRoomUser(String room)
      查询会议室的用户信息
      参数:
      room - 会议室编号
      返回:
    • rtcRoomUser

      public static JSONObject rtcRoomUser(String topicId, String room)
      查询会议室的用户信息
      参数:
      topicId - 主题
      room - 会议室编号
      返回:
    • rtcRoomUserCount

      public static int rtcRoomUserCount(String room)
      当前会议室中的数量
      参数:
      room - 会议室编号
      返回:
      -1 房间不存在
    • createBuilder

      public static IMServerUtil.SendMsgBuilder createBuilder(String type)
    • sendMsgBuilder

      public static IMServerUtil.SendMsgBuilder sendMsgBuilder()
    • sendMsgBySourceBuilder

      public static IMServerUtil.SendMsgBuilder sendMsgBySourceBuilder()
    • sendMsgByConnIdBuilder

      public static IMServerUtil.SendMsgBuilder sendMsgByConnIdBuilder()
    • sendMsgByConditionBuilder

      public static IMServerUtil.SendMsgBuilder sendMsgByConditionBuilder()
    • sendMsgAllBuilder

      public static IMServerUtil.SendMsgBuilder sendMsgAllBuilder()
    • isConnectedBuilder

      public static IMServerUtil.SendMsgBuilder isConnectedBuilder()
    • queryUserInfoBuilder

      public static IMServerUtil.SendMsgBuilder queryUserInfoBuilder()
    • countByTopicIdBuilder

      public static IMServerUtil.SendMsgBuilder countByTopicIdBuilder()
    • countBySourceBuilder

      public static IMServerUtil.SendMsgBuilder countBySourceBuilder()
    • rtcRoomUserBuilder

      public static IMServerUtil.SendMsgBuilder rtcRoomUserBuilder()
    • rtcRoomUserCountBuilder

      public static IMServerUtil.SendMsgBuilder rtcRoomUserCountBuilder()