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

目录[+]


DMS Java API

导入Jar包

org.eclipse.paho.client.mqttv3_1.0.2_dms.jar

初始化

String clientId = "JavaSample1";
//默认地址是 "tcp://mqttdms.aodianyun.com:1883"
DMS.init(clientId, new MqttCallback() {
    @Override
    public void connectionLost(Throwable cause) {
        System.out.println("connectionLost");
    }
    @Override
    public void messageArrived(String topic, MqttMessage message)
            throws Exception {
        System.out.println("messageArrived: " + message);
    }
    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        System.out.println("deliveryComplete");
    }
});

连接服务器

String pub_key = "demo";
String sub_key = "demo";
IMqttToken token = null;
token = DMS.connect(pub_key,sub_key, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        System.out.println("connect-->onSuccess");
    }
    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
        System.out.println("connect-->onFailure");
    }
});
//等待连接成功
token.waitForCompletion();

关注话题

String topic = "test";
token = DMS.subscribe(topic, null,new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        System.out.println("subscribe-->onSuccess");
    }
    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
        System.out.println("subscribe-->onFailure");
    }
});
//等待关注动作完成
token.waitForCompletion();

推送消息

String topic = "test";
String content = "Message from JavaClient1";
token = DMS.publish(topic, content, null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        System.out.println("publish-->onSuccess");
    }
    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
        System.out.println("publish-->onFailure");
    }
});
//等待推送消息完毕
token.waitForCompletion();

取消关注

String topic = "test";
//也可以注册监听器
token = DMS.unsubscribe(topic);
//等待取消完成
token.waitForCompletion();

断开连接

token = DMS.disconnect(null, new IMqttActionListener() {
    @Override
    public void onSuccess(IMqttToken asyncActionToken) {
        System.out.println("disconnect-->onSuccess");
    }
    @Override
    public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
        System.out.println("disconnect-->onFailure");
    }
});
token.waitForCompletion();

释放资源

DMS.close();



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

  • 电话

    X

    售前咨询:

    400-663-6063

    售后服务:

    400-663-6063

  • 客服

  • 建议

    咨询留言 X
    提  交

在线QQ

售前咨询400-663-6063

售后服务400-663-6063