point io是适合于不同应用场景的物联网数据采集与交互的通信框架

package com.point.iot.base.tools; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.lang.reflect.Field; import java.net.InetAddress; import java.net.NetworkInterface; import java.net.SocketException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.text.ParseException; import java.text.ParsePosition; import java.text.SimpleDateFormat; import java.util.Arrays; import java.util.Calendar; import java.util.Date; import java.util.Enumeration; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Random; import java.util.StringTokenizer; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.HttpStatus; import org.apache.http.HttpVersion; import org.apache.http.client.HttpClient; import org.apache.http.client.methods.HttpPost; import org.apache.http.entity.ByteArrayEntity; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.params.BasicHttpParams; import org.apache.http.params.CoreConnectionPNames; import org.apache.http.params.CoreProtocolPNames; import org.apache.http.params.HttpParams; import org.apache.log4j.Logger; import org.apache.mina.core.session.IoSession; import com.point.iot.base.mysql.jdbc.DBConnectionManager; public class CommUtils { static Logger logger = Logger.getLogger(CommUtils.class); public static final boolean DEPLOY_SERVER = !((System.getProperties().getProperty("os.name")).indexOf("Windows")>=0); /** * int转byte * @param value * @return */ public static byte[] intToBytes(int value) { byte[] byte_src = new byte[4]; byte_src[3] = (byte) ((value & 0xFF000000)>>24); byte_src[2] = (byte) ((value & 0x00FF0000)>>16); byte_src[1] = (byte) ((value & 0x0000FF00)>>8); byte_src[0] = (byte) ((value & 0x000000FF)); return byte_src; } /** * 将short转成byte[2] * @param a * @param b * @param offset b中的偏移量 */ public static byte[] short2Byte(short a){ byte[] b = new byte[2]; b[0] = (byte) (a >> 8); b[1] = (byte) (a); return b; } /** * 把低位在前的int转换为高位在前，低位在后 如ABCD 解析为DCBA * @param a * @return */ public static int highAndLowAddressSwap(int a){ int b = (a & 0x000000ff)<<24; int c = (a & 0x0000ff00)<<8; int d = (a & 0x00ff0000)>>8; int e = (a & 0xff000000)>>24; return b + c + d + e; } public static String formatDouble(double i){ String result = String .format("%.3f",i); return result; } public static void main(String args[]){// int a = highAndLowAddressSwap(0x1C000000); System.out.println(a); } /** * 替换参数{:key} * @param pattern * @param arguments * @return */ public static String format(String pattern, Map<String, Object> arguments) { String formatedStr = pattern; for (String key : arguments.keySet()) { String replacement = "\\{:" + key + "\\}"; formatedStr = formatedStr.replaceAll(replacement, arguments.get(key) .toString()); System.out.println(replacement + arguments.get(key) .toString()); } return formatedStr; } public synchronized static String getTimeStamp() { SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMddHHmmssSSS"); Date date = new Date(); return formatter.format(date); } public static void printStacktrace(StackTraceElement[] stackTrackElements) { logger.error(Arrays.toString(stackTrackElements)); } public static String getSessionAddress(IoSession session){ if ( session == null ){ return "" ; } if ( session.getRemoteAddress() == null || "".equals(session.getRemoteAddress())){ return "" ; } String sessionAddress = session.getRemoteAddress().toString(); sessionAddress = sessionAddress.substring(0, sessionAddress .indexOf(":")); return sessionAddress ; } /** * 读取/proc/stat 获取cpu占用率 ; Linux * * @return float efficiency * @throws IOException * @throws InterruptedException */ public static float getCpuInfo() { File file = new File("/proc/stat"); BufferedReader br = null; try { br = new BufferedReader(new InputStreamReader(new FileInputStream(file))); StringTokenizer token = new StringTokenizer(br.readLine()); token.nextToken(); long user1 = Long.parseLong(token.nextToken()); long nice1 = Long.parseLong(token.nextToken()); long sys1 = Long.parseLong(token.nextToken()); long idle1 = Long.parseLong(token.nextToken()); Thread.sleep(1000); br = new BufferedReader(new InputStreamReader(new FileInputStream(file))); token = new StringTokenizer(br.readLine()); token.nextToken(); long user2 = Long.parseLong(token.nextToken()); long nice2 = Long.parseLong(token.nextToken()); long sys2 = Long.parseLong(token.nextToken()); long idle2 = Long.parseLong(token.nextToken()); return (float) ((user2 + sys2 + nice2) - (user1 + sys1 + nice1)) / (float) ((user2 + nice2 + sys2 + idle2) - (user1 + nice1 + sys1 + idle1)); } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { try { if(br != null) br.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } return 0; } /** * 根据网卡取本机配置的IP 如果是双网卡的，则取出外网IP * * @return */ public static String getLocalIp() { String localip = null;// 返回它 try { Enumeration<NetworkInterface> netInterfaces = NetworkInterface.getNetworkInterfaces(); InetAddress ip = null; boolean finded = false;// 是否找到外网IP while (netInterfaces.hasMoreElements() && !finded) { NetworkInterface ni = netInterfaces.nextElement(); Enumeration<InetAddress> address = ni.getInetAddresses(); while (address.hasMoreElements()) { ip = address.nextElement(); if (ip.isSiteLocalAddress() && !ip.isLoopbackAddress() && ip.getHostAddress().indexOf(":") == -1) {// 内网IP localip = ip.getHostAddress(); } } } } catch (SocketException e) { e.printStackTrace(); } return localip; } public static Date dateMulti(Date date, int milliseconds ){ Date newdate = new Date(date.getTime() + milliseconds) ; return newdate ; } /** * 根据日期获得星期 * * @param date * @return */ public static int getWeekOfDate(Date date) { int[] weekDaysCode = { 1, 2, 3, 4, 5, 6, 7 }; Calendar calendar = Calendar.getInstance(); calendar.setTime(date); int intWeek = calendar.get(Calendar.DAY_OF_WEEK) - 1; return weekDaysCode[intWeek]; } /** * 根据日期获得星期 * * @param date * @return */ public static String getWeekNameOfDate(Date date) { String[] weekDaysName = { "周日", "周一", "周二", "周三", "周四", "周五", "周六" }; Calendar calendar = Calendar.getInstance(); calendar.setTime(date); int intWeek = calendar.get(Calendar.DAY_OF_WEEK) - 1; return weekDaysName[intWeek]; } /** * 获取下一个月的timestamp时间 * @param timestamp 时间戳 * @return */ public static long getNextDateOfMonth(long timestamp) { Calendar calendar = Calendar.getInstance(); Date date = new Date(timestamp); calendar.setTime(date); c