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)
     {

    }
});