Android平台接入OneNET

1. OneNET簡介

中國移動物聯網開放平台是由中國移動打造的PaaS物聯網開放平台。
平台能夠幫助開發者輕松實現設備接入與設備連接，提供綜合性的物聯網解決方案，實現物聯網設備的數據獲取，數據存儲，數據展現。

中移物聯網官方網址

https://open.iot.10086.cn/

安卓平台接入OneNET方法：

①注冊一個中移物聯網的賬號

②接下來開始創建產品與產品下的設備

③點擊右上角新建產品

④接下來開始創建設備，點擊提交之后出現

記住設備id，之后程序里會用到

為設備添加APIKey，這也是之后程序里要用到的

保存設備APIKey

接下來為設備創建數據流，所有的數據都是被上傳到數據流的
這里進行查看數據流

這里添加數據流

接下來就是程序方面的實現
使用http協議，具體的協議內容可以查看

https://open.iot.10086.cn/doc/art/id/190#43

具體二進制文件的傳輸看這個網址
https://open.iot.10086.cn/doc/art258.html#68

以下http協議代碼的實現都是基於這個規定的，一定要打開對照來看

(1) 以POST實現文本數據的上傳

public class OneNETUrlConnectionPost extends Thread {

	private int SHOW_REQUEST = 0;
	private Handler handler;
	// 首先聲明設備ID及apikey
	private static final String DeviceID = "25857699";
	// 個人使用就建議填產品key,設備key在二進制獲取那里會權限不足
	private static final String ApiKey = "QMrXbErb2t8h=E1mHORgxX20QVM=";

	public OneNETUrlConnectionPost(Handler handler) {
		this.handler = handler;
	}

	@Override
	public void run() {

		URL url;
		HttpURLConnection connection;
		try {
			//data1代表雲端的數據流是data1
			String s1 = new String(",;" + "data1" + "," + "哈哈哈，終於成功了");
			byte[] data = s1.getBytes();
			// 先new出一個URL對象，傳入網絡地址
			// 調用openConnection()方法獲取到HttpURLConnection對象
			// 自己創建的中移物聯網的地址http://api.heclouds.com/devices/25857699/datapoints?type=5
			url = new URL("http://api.heclouds.com/devices/" + DeviceID
					+ "/datapoints?type=5");
			connection = (HttpURLConnection) url.openConnection();
			// 下面使一些自由的定制，比如設置連接超時，讀取超時的毫秒數，以及服務器希望得到的一些消息頭
			connection.setConnectTimeout(8000);
			connection.setReadTimeout(8000);
			connection.setDoOutput(true);
			connection.setDoInput(true);
			connection.setRequestMethod("POST");
			connection.setRequestProperty("api-key", ApiKey);
			connection.setRequestProperty("Content-Length",
					String.valueOf(data.length));
			connection.setChunkedStreamingMode(5);
			// 設置打開輸出流
			connection.setDoOutput(true);
			// 拿到輸出流
			OutputStream os = connection.getOutputStream();
			// 使用輸出流往服務器提交數據
			os.write(data);
			os.flush();
			os.close();
			// //如果請求發送成功
			if (connection.getResponseCode() == 200) {

				// 接下來利用輸入流對數據進行讀取
				InputStream is = connection.getInputStream();
				BufferedReader br = new BufferedReader(
						new InputStreamReader(is));
				StringBuilder response = new StringBuilder();
				String line;
				while ((line = br.readLine()) != null) {
					response.append(line);
				}// 正常則返回{"errno":0,"error":"succ"}，此函數為void，用不上這個

				// 發送數據完畢，接下來用Handler進行提交成功顯示
				Message message = new Message();
				message.what = SHOW_REQUEST;
				message.obj = response.toString();
				handler.sendMessage(message);
			}

			// 最后關閉HTTP連接
			connection.disconnect();

		} catch (Exception e) {
			e.printStackTrace();
		}

	}

}

(2) 以POST實現字節數據的上傳（包括圖片視頻等二進制文件）

public class OneNETUrlConnectionPostByte extends Thread {

	private int SHOW_REQUEST = 0;
	private Handler handler;

	// 首先聲明設備ID及apikey
	private static final String DeviceID = "25857699";
	// 個人使用就建議填產品key,設備key在二進制獲取那里會權限不足
	private static final String ApiKey = "QMrXbErb2t8h=E1mHORgxX20QVM=";

	public OneNETUrlConnectionPostByte(Handler handler) {
		this.handler = handler;
	}

	@Override
	public void run() {

		URL url;
		// 自定義的字符數組將它上傳到雲端
		byte[] my_data = { '8', '8', '6' };
		HttpURLConnection connection;
		try {

			// 先new出一個URL對象，傳入網絡地址
			// 調用openConnection()方法獲取到HttpURLConnection對象
			// 自己創建的中移物聯網的地址http://api.heclouds.com/devices/25857699/datapoints?type=5
			url = new URL("http://api.heclouds.com/bindata?device_id="
					+ DeviceID + "&datastream_id=" + "data123");
			connection = (HttpURLConnection) url.openConnection();
			// 下面使一些自由的定制，比如設置連接超時，讀取超時的毫秒數，以及服務器希望得到的一些消息頭
			connection.setConnectTimeout(8000);
			connection.setReadTimeout(8000);
			connection.setDoOutput(true);
			connection.setDoInput(true);
			connection.setRequestMethod("POST");
			connection.setRequestProperty("api-key", ApiKey);
			connection.setRequestProperty("Content-Length",
					String.valueOf(my_data.length));
			connection.setChunkedStreamingMode(5);
			// 設置打開輸出流
			connection.setDoOutput(true);
			// 拿到輸出流
			OutputStream os = connection.getOutputStream();
			// 使用輸出流往服務器提交數據
			os.write(my_data);
			os.flush();
			os.close();
			// //如果請求發送成功
			if (connection.getResponseCode() == 200) {

				// 接下來利用輸入流對數據進行讀取
				InputStream is = connection.getInputStream();
				BufferedReader br = new BufferedReader(
						new InputStreamReader(is));
				StringBuilder response = new StringBuilder();
				String line;
				while ((line = br.readLine()) != null) {
					response.append(line);
				}// 正常則返回{"errno":0,"error":"succ"}，此函數為void，用不上這個

				// 發送數據完畢，接下來用Handler進行提交成功顯示
				Message message = new Message();
				message.what = SHOW_REQUEST;
				message.obj = response.toString();
				handler.sendMessage(message);
			}

			// 最后關閉HTTP連接
			connection.disconnect();

		} catch (Exception e) {
			e.printStackTrace();
		}

	}

}

(3) 以GET實現文本數據的獲取

public class OneNETHttpRequestGET extends Thread {

	private int SHOW_REQUEST = 0;
	private Handler handler;
	// 首先聲明設備ID及apikey
	private static final String DeviceID = "25857699";
	// 個人使用就建議填產品key,設備key在二進制獲取那里會權限不足
	private static final String ApiKey = "QMrXbErb2t8h=E1mHORgxX20QVM=";

	public OneNETHttpRequestGET(Handler handler) {
		this.handler = handler;
	}

	@Override
	public void run() {

		URL url;
		HttpURLConnection connection;
		try {
			// 先new出一個URL對象，傳入網絡地址
			// 調用openConnection()方法獲取到HttpURLConnection對象
			url = new URL("http://api.heclouds.com/devices/" + DeviceID
					+ "/datastreams/" + "data1");
			connection = (HttpURLConnection) url.openConnection();
			// 下面使一些自由的定制，比如設置連接超時，讀取超時的毫秒數，以及服務器希望得到的一些消息頭
			connection.setConnectTimeout(15000);
			connection.setReadTimeout(15000);
			connection.setRequestMethod("GET");
			connection.setRequestProperty("api-key", ApiKey);

			// 如果網頁正確響應
			if (connection.getResponseCode() == 200) {
				// 接下來利用輸入流對數據進行讀取
				InputStream is = connection.getInputStream();
				BufferedReader br = new BufferedReader(
						new InputStreamReader(is));
				StringBuilder response = new StringBuilder();
				String line;
				while ((line = br.readLine()) != null) {
					response.append(line);
				}
				// 讀取數據完畢，接下來將數據傳送到Handler進行顯示
				Message message = new Message();
				message.what = SHOW_REQUEST;
				message.obj = response.toString();
				handler.sendMessage(message);
				// 最后關閉HTTP連接
				connection.disconnect();
			}

		} catch (Exception e) {
			e.printStackTrace();
		}

	}
}

(4) 以GET實現字節數據的獲取，但是存在小bug還未成功

public class OneNETHttpRequestGETByte extends Thread {

	private int SHOW_REQUEST = 0;
	private Handler handler;
	// 首先聲明設備ID及apikey
	private static final String DeviceID = "25857699";
	// 個人使用就建議填產品key,設備key在二進制獲取那里會權限不足
	private static final String ApiKey = "QMrXbErb2t8h=E1mHORgxX20QVM=";

	public OneNETHttpRequestGETByte(Handler handler) {
		this.handler = handler;
	}

	@Override
	public void run() {

		URL url;
		HttpURLConnection connection;
		try {
			// 先new出一個URL對象，傳入網絡地址
			// 調用openConnection()方法獲取到HttpURLConnection對象
			url = new URL("http://api.heclouds.com/bindata/"
					+ "25857699_15201013688560_data123");
			connection = (HttpURLConnection) url.openConnection();
			// 下面使一些自由的定制，比如設置連接超時，讀取超時的毫秒數，以及服務器希望得到的一些消息頭
			connection.setConnectTimeout(15000);
			connection.setReadTimeout(15000);
			connection.setRequestMethod("GET");
			connection.setRequestProperty("api-key", ApiKey);

			// 如果網頁正確響應
			if (connection.getResponseCode() == 200) {
				// 接下來利用輸入流對數據進行讀取
				InputStream is = connection.getInputStream();
				BufferedReader br = new BufferedReader(
						new InputStreamReader(is));
				StringBuilder response = new StringBuilder();
				String line;
				while ((line = br.readLine()) != null) {
					response.append(line);
				}
				// 讀取數據完畢，接下來將數據傳送到Handler進行顯示
				Message message = new Message();
				message.what = SHOW_REQUEST;
				message.obj = response.toString();
				handler.sendMessage(message);
				// 最后關閉HTTP連接
				connection.disconnect();
			}

		} catch (Exception e) {
			e.printStackTrace();
		}

	}
}

了解更多技術文章，歡迎關注我的個人公眾號