Java版DLT645-2007电能表协议解析源码(串口协议解析)

import javax.comm.*; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.util.*; /** * Created by WuSong * 2017-05-04 */ public class Dlt645Test implements SerialPortEventListener{ private ArrayList<String> portList; private CommPortIdentifier portId; private SerialPort serialPort; private OutputStream outputStream; private InputStream inputStream; private int packetlength; static final char[] HEX_CHAR_TABLE = { '0','1','2','3','4','5','6','7','8','9','A','B','C','D','E','F' }; public void scanPorts(){ portList = new ArrayList<String>(); Enumeration<?> en = CommPortIdentifier.getPortIdentifiers(); CommPortIdentifier portId; while(en.hasMoreElements()){ portId = (CommPortIdentifier)en.nextElement(); if(portId.getPortType() == CommPortIdentifier.PORT_SERIAL){ String name = portId.getName(); if(!portList.contains(name)){ portList.add(name); } } } if(null == portList || portList.isEmpty()){ System.out.println("未找到可用的串行端口号，程序无法启动！"); } } public void openSerialPort(String portname){ try{ portId = CommPortIdentifier.getPortIdentifier(portname); }catch (NoSuchPortException e){ System.out.println("抱歉，没有找到" + portname + "串行端口号！"); return; } } public void setSerialPortParam(int rate,int data,int stop,int parity){ try{ serialPort = (SerialPort)portId.open("test",2000); }catch (PortInUseException e){ System.out.println(serialPort.getName() +"端口已被占用"); return; } try { serialPort.setSerialPortParams(rate,data,stop,parity); } catch (UnsupportedCommOperationException e) { e.printStackTrace(); } try{ outputStream = serialPort.getOutputStream(); inputStream = serialPort.getInputStream(); }catch (IOException e){ e.printStackTrace(); } try { serialPort.addEventListener(this); } catch (TooManyListenersException e) { e.printStackTrace(); } serialPort.notifyOnDataAvailable(true); } public void sendDataToSerialPort(byte[] b){ try { outputStream.write(b); outputStream.flush(); } catch (IOException e) { e.printStackTrace(); } } public void serialEvent(SerialPortEvent e){ switch (e.getEventType()) { case SerialPortEvent.BI: case SerialPortEvent.OE: case SerialPortEvent.FE: case SerialPortEvent.PE: case SerialPortEvent.CD: case SerialPortEvent.CTS: case SerialPortEvent.DSR: case SerialPortEvent.RI: case SerialPortEvent.OUTPUT_BUFFER_EMPTY: break; case SerialPortEvent.DATA_AVAILABLE: // String data = toHexString(getPack()); byte[] msgPack=this.getPack(); System.out.println("**********************************************************"); List list = new ArrayList(); for (int i = 0; i < msgPack.length; i++) { //System.out.println(msgPack[i]<0?msgPack[i]+256:msgPack[i]); list.add(Integer.toHexString(msgPack[i]<0?msgPack[i]+256:msgPack[i])); /*for (int j = i; j <= i; j++) { if ((list.get(j).toString()).length()==1){ ((String) list.get(j)).replace((String)list.get(j),String.format("%02d",Integer.parseInt((String)list.get(j)))); } }*/ } Object[] msg=list.toArray(new String[list.size()]); list=new ArrayList(); for (int i = 0; i < msg.length; i++) { if (msg[i].toString().length()==1){ list.add(String.format("%02d",Integer.parseInt((String) msg[i]))); }else { list.add(msg[i]); } } System.out.println("返回数据:" + list.toString().replace(",","").replaceAll("\\[|\\]","")); AgreementDemo ad=new AgreementDemo(); try { System.out.println("*************************解析结果*************************"); ad.analysis(list.toString().replace(",","").replaceAll("\\[|\\]","")); } catch (Exception e1) { e1.printStackTrace(); System.out.println("解析出错！"); } } } public byte[] getPack(){ byte[] pack1 = new byte[10]; for(int i=0;i<10;i++){ int newData = 0; try{ if((newData = inputStream.read()) != -1){ // System.out.println("数据:" + newData); pack1[i] = (byte) newData; } }catch (IOException e){ e.printStackTrace(); } } int packetLength=Integer.parseInt(String.valueOf(pack1[pack1.length-1])); byte[] pack2 = new byte[packetLength+2]; //System.out.println(pack2.length); for(int i=0;i<pack2.length;i++){ int newData = 0; try{ if((newData = inputStream.read()) != -1){ pack2[i] = (byte) newData; } }catch (IOException e){ e.printStackTrace(); } } byte[] msgPack = new byte[pack1.length+pack2.length]; System.arraycopy(pack1,0,msgPack,0,pack1.length); System.arraycopy(pack2,0,msgPack,pack1.length,pack2.length); System.out.println("数据长度:" + msgPack.length); return msgPack; } public String toHexString(byte[] data){ if(data == null || data.length == 0) return null; byte[] hex = new byte[data.length * 2]; int index = 0; for(byte b : data){ int v = b & 0xFF; hex[index++] = (byte) HEX_CHAR_TABLE[v >>> 4]; hex[index++] = (byte) HEX_CHAR_TABLE[v & 0xF]; } return new String(hex); } public String toHexString(Byte[] data){ byte[] resultBytes = new byte[data.length]; for(int i =0 ;i<data.length;i++){ resultBytes[i] = data[i]; } return toHexString(resultBytes); } public byte[] hexStringToBytes(String data){ if(data == null || "".equals(data)) return null; data = data.toUpperCase(); int length = data.length()/2; char[] dataChars = data.toCharArray(); byte[] byteData = new byte[length]; for (int i = 0;i<length;i++){ int pos = i * 2; byteData[i] = (byte)(charToByte(dataChars[pos]) << 4 | charToByte(dataChars[pos + 1])); } return byteData; } public byte charToByte(char c){ return (byte)"0123456789ABCDEF".indexOf(c); } /* public int getPacketlength() { return packetlength; } public void setPacketlength(int packetlength) { this.packetlength = packetlength; }*/ public static void main(String[] args){ Dlt645Test dlt645 = new Dlt645Test();