跳过导航链接
com.supermap.messagequeue

类 MQTTClient


  • public class MQTTClient
extends InternalHandle
    MQTT客户端类，基于MQTT协议的消息总线客户端方案

    采用主题订阅方式实现消息收发的机制，

    • 构造器概要

      构造器 
      构造器和说明
      MQTTClient()
      构造函数

    • 方法概要

      所有方法 实例方法 具体方法 
      限定符和类型 方法和说明
      boolean create(java.lang.String uri, java.lang.String userName, java.lang.String password, java.lang.String clientID)
      创建连接
      void dispose()
      析构函数，释放资源
      MQTTReturnMessage receiveMessage()
      接收消息 需在子线程执行该操作
      void resume()
      唤醒
      boolean sendMessage(java.lang.String topic, java.lang.String message)
      发送消息
      boolean subscribe(java.lang.String topicName, int qos)
      订阅某一主题
      void suspend()
      挂起
      boolean unsubscribe(java.lang.String topicName)
      取消某一主题的订阅

      • 从类继承的方法 java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • 构造器详细资料

      • MQTTClient

        public MQTTClient()
        构造函数

    • 方法详细资料

      • create

        public boolean create(java.lang.String uri,
                      java.lang.String userName,
                      java.lang.String password,
                      java.lang.String clientID)
        创建连接
        参数:
        uri - 服务地址
        userName - 用户名
        password - 用户密码
        clientID - 客户端ID
        返回:
        创建成功返回true,否则返回false

      • dispose

        public void dispose()
        析构函数，释放资源

      • subscribe

        public boolean subscribe(java.lang.String topicName,
                         int qos)
        订阅某一主题
        参数:
        topicName - 主题名
        qos - 消息质量
        返回:
        订阅成功返回true,否则返回false

      • unsubscribe

        public boolean unsubscribe(java.lang.String topicName)
        取消某一主题的订阅
        参数:
        topicName - 主题名
        返回:
        返回是否取消成功

      • sendMessage

        public boolean sendMessage(java.lang.String topic,
                           java.lang.String message)
        发送消息
        参数:
        topic - 主题名
        message - 消息内容
        返回:
        发送成功返回true,否则返回false

      • receiveMessage

        public MQTTReturnMessage receiveMessage()
        接收消息

        需在子线程执行该操作

        返回:
        接收到的消息

      • resume

        public void resume()
        唤醒

      • suspend

        public void suspend()
        挂起
跳过导航链接