帮助列表
帮助列表
DMS Android API 文档

目录[+]


DMS ANDROID API

设置androdManifest.xml

<uses-permission android:name="android.permission.WAKE_LOCK" />
<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>

<service android:name="org.eclipse.paho.android.service.MqttService" >
    </service> 设置再<application></application>里面

初始化

static public void init(Context ctx,String pubKey ,
String subKey,MqttCallback callback )

    使用DMS的pubkey 和subkey 进行初始化
    DMS.init(getApplicationContext(), "demo", "demo",new MqttCallback() {
        @Override
        public void messageArrived(String topic, MqttMessage msg) 
        throws Exception
         {
           //收到话题消息
        }

        @Override
        public void deliveryComplete(IMqttDeliveryToken token) {

        }

        @Override
        public void connectionLost(Throwable t) {
         //连接中断
        }
    });

使用DMS的pubkey 和subkey 以及自定义 client_id 进行初始化
static public void init(Context ctx,String pubKey ,String subKey,String clientId,
MqttCallback callback )
DMS.init2(getApplicationContext(), "demo", "demo","you_client_id",new MqttCallback() {
    @Override
    public void messageArrived(String topic, MqttMessage msg) throws Exception {
       //收到话题消息
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {

    }

    @Override
    public void connectionLost(Throwable t) {
     //连接中断

    }
});

连接

static public IMqttToken connect(IMqttActionListener callback) throws MqttException
连接到DMS服务器,连接成功后才能关注和推送消息
DMS.connect(new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {


    }

    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception)
     {

    }
});

推送消息

static public IMqttDeliveryToken publish(String topic, byte[] payload,  
IMqttActionListener callback)throws MqttException, MqttPersistenceException

推送消息到对应话题

DMS.publish("go", "test".getBytes(), new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {

    }

    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) 
    {

    }
});

关注话题

static public IMqttToken subscribe(String topic,IMqttActionListener callback) 
throws MqttException 
static public IMqttToken subscribe(String[] topic,IMqttActionListener callback) 
throws MqttException 
关注某个话题的消息和批量关注
将从init设置的callback中收到pubish到这个话题的消息
DMS.subscribe("go", new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {


    }
    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) {

    }
});

取消关注话题

static public IMqttToken unsubscribe(String topic, IMqttActionListener callback) 
throws MqttException 
static public IMqttToken unsubscribe(String[] topic, IMqttActionListener callback)
 throws MqttException 
取消关注的话题,将不会收到该话题的消息
  DMS.unsubscribe("go", new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {


    }
    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) {

    }
});

断开连接

static public IMqttToken disconnect(IMqttActionListener callback) 
throws MqttException

 DMS.disconnect( new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {


    }
    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception)
     {

    }
});



2006 - 2023 aodianyun.com, All Rights Reserved. 奥点科技 版权所有 增值电信业务经营许可证:浙B2-20110306 浙ICP备07500424号 |

  • 电话

    X

    售前咨询:

    400-663-6063

    售后服务:

    400-663-6063

  • 客服

  • 建议

    咨询留言 X
    提  交

在线QQ

售前咨询400-663-6063

售后服务400-663-6063