概念

描述

MQTT

MQTT是基于二进制消息的发布/订阅（Publish/Subscribe）模式的协议，
最早由IBM提出的，如今已经成为OASIS规范，
更符合M2M大规模沟通。

endpoint

IoT Hub 的服务实例，代表一个完整的IoT Hub 服务。

thing

表示IoT Hub 设备，
用户可以在每个endpoint中创建一个或多个thing。

principal

principal是一个抽象概念，表示设备(thing)的身份。
每个thing可以绑定一个principal，
每个principal拥有一个policy权限。

policy

为身份principal设置对应的策略policy，一个principal对应一个policy。

permission

为每一个policy设置一组权限permission，其中包括主题topic，和对该主题的操作权限operation。

topic

每一个policy都需要指定一个主题项目（topic），在进行使用IoT Hub 服务之前，
需要先为我们即将开展的订阅发布信息创建一个主题名称，
该主题应用于MQTT客户端。topic规则允许字符串可以带一个通配符"#"，
例如"temperature/#"就是匹配前缀是temperature的所有topic；单独的"#"表示匹配所有topic。

operation

对topic的操作权限。目前基于MQTT协议，IoT Hub 支持创建发布PUBLISH和订阅SUBSCRIBE两种权限。

package com.baidu.iot;

import java.io.InputStream;

import java.security.KeyStore;

import java.security.cert.Certificate;

import java.security.cert.CertificateFactory;

import javax.net.ssl.SSLContext;

import javax.net.ssl.TrustManager;

import javax.net.ssl.TrustManagerFactory;

import org.eclipse.paho.client.mqttv3.MqttClient;

import org.eclipse.paho.client.mqttv3.MqttConnectOptions;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public class Thermometer {

public static void main(String[] args) throws Exception {

String endpoint = "hostname"; //输入创建实例endpoint返回的hostname

String username = "yourendpoint/yourthing"; //输入创建thing返回的username

String password = "Dm3yyvOHb7zt/uRWsPgsfsgbnj7CxuVMc+uDbf4j960="; //输入创建principal返回的password

String topic = "building-b/floor-5/temperature-1"; //订阅的消息主题，本例是指订阅b号楼第五层的温度

TrustManagerFactory tmf = TrustManagerFactory.getInstance("X509");

tmf.init((KeyStore)null);

TrustManager[] trustManagers = tmf.getTrustManagers();

SSLContext ctx = SSLContext.getInstance("TLS");

ctx.init(null, trustManagers, null);

MqttConnectOptions options = new MqttConnectOptions();

options.setCleanSession(true);

options.setUserName(username);

options.setPassword(password.toCharArray());

options.setSocketFactory(ctx.getSocketFactory());

MqttClient client = new MqttClient(endpoint, "java-client");

client.connect(options);

MqttMessage message = new MqttMessage();

message.setPayload("15".getBytes());

client.publish(topic, message);

client.disconnect();

}

}