OneNet设备云平台javaAPI

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
 * 为OneNet平台操作提供的java方法
 * 
 * @author lixu
 * 
 */
public class OneNetAPI {

	public static void main（String[] args） {
		// System.out.println（OneNetAPI.getDataStreams（“10000“ “apikey“  “userCount“））;
	}

	/**
	 * 向OneNet请求创建新的数据流
	 * 
	 * @param apiKey 
	 * @param datastreamsId:数据流id
	 * @param deviceId:设备ID
	 * @param unit:单位
	 * @param symbol:符号
	 * @return
	 */
	public static String createStreamsInOneNet（String apiKey String datastreamsId
			String deviceId String unit String symbol） {
		PrintWriter out = null;
		BufferedReader in = null;
		String url = “http://api.heclouds.com/devices/“ + deviceId
				+ “/datastreams“;
		String result = ““;
		// 组织数据格式
		String query = “{\“id\“:\““ + datastreamsId + “\“\“unit\“:\““ + unit
				+ “\“\“unit_symbol\“:\““ + symbol + “\“}“;
		try {
			URL realUrl = new URL（url）;
			// 打开和URL之间的连接
			URLConnection conn = realUrl.openConnection（）;

			conn.setRequestProperty（“connection“ “Keep-Alive“）;
			conn.setRequestProperty（“api-key“ apiKey）;
			// 发送POST请求必须设置如下两行
			conn.setDoOutput（true）;
			conn.setDoInput（true）;
			// 发送请求参数
			out = new PrintWriter（conn.getOutputStream（））;
			out.write（query）;
			out.flush（）;
			in = new BufferedReader（
					new InputStreamReader（conn.getInputStream（）））;
			String line;
			while （（line = in.readLine（）） != null） {
				result += line;
			}
		} catch （Exception e） {
			System.out.println（“创建数据流 发送 POST请求出现异常！“）;
		} finally {
			try {
				if （out != null） {
					out.close（）;
				}
				if （in != null） {
					in.close（）;
				}
			} catch （IOException ex） {
				System.out.println（“IO关闭异常“）;
			}
		}
		return result;
	}

	/**
	 * 删除数据流
	 * 
	 * @param deviceId：设备ID
	 * @param apiKey
	 * @param datastreamId：数据流ID
	 * @return
	 */
	public static String deleteDataStreams（String deviceId String apiKey
			String datastreamId） {
		String result = ““;
		BufferedReader in = null;
		try {
			String url = “http://api.heclouds.com/devices/“ + deviceId
					+ “/datastreams/“ + datastreamId;
			URL realUrl = new URL（url）;
			// 打开和URL之间的连接
			HttpURLConnection connection = （HttpURLConnection） realUrl
					.openConnection（）;
			// 设置通用的请求属性
			connection.setRequestProperty（“Content-Type“
					“application/x-www-form-urlencoded“）;
			connection.setRequestMethod（“DELETE“）;
			connection.setRequestProperty（“api-key“ apiKey）;
			// 建立实际的连接
			connection.connect（）;
			// 定义 BufferedReader输入流来读取URL的响应
			in = new BufferedReader（new InputStreamReader（
					connection.getInputStream（）））;
			String line;
			while （（line = in.readLine（）） != null） {
				result += line;
			}

		} catch （Exception e） {
			System.ou