配置
Windows ---------------------------------------------------- Choose your binary build - x64 or x86 (based on which version of the JVM you are installing to) NOTE: You MUST match your architecture. You can't install the i386 version on a 64-bit version of the JDK and vice-versa. For a JDK installation: Copy RXTXcomm.jar ---> <JAVA_HOME>jrelibext Copy rxtxSerial.dll ---> <JAVA_HOME>jrein Copy rxtxParallel.dll ---> <JAVA_HOME>jrein Linux ---------------------------------------------------- Choose your binary build - x86_64 or i386 (based on which version of the JVM you are installing to) NOTE: You MUST match your architecture. You can't install the i386 version on a 64-bit version of the JDK and vice-versa. For a JDK installation on architecture=i386 Copy RXTXcomm.jar ---> <JAVA_HOME>/jre/lib/ext Copy librxtxSerial.so ---> <JAVA_HOME>/jre/lib/i386/ Copy librxtxParallel.so ---> <JAVA_HOME>/jre/lib/i386/ NOTE: For a JDK installation on architecture=x86_64, just change the i386 to x86_64 above.
线程
package com.dartfar.rfid.server; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.UnsupportedEncodingException; import java.math.BigInteger; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.Enumeration; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.ResourceBundle; import java.util.TooManyListenersException; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.struts2.interceptor.ServletRequestAware; import org.apache.struts2.interceptor.ServletResponseAware; import org.apache.struts2.interceptor.SessionAware; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import com.dafu.action.testRXTX; import com.dafu.model.game.ChengJi; import com.dafu.service.game.GameService; import com.dafu.vo.ChengJiVo; import gnu.io.CommPort; import gnu.io.CommPortIdentifier; import gnu.io.NoSuchPortException; import gnu.io.PortInUseException; import gnu.io.SerialPort; import gnu.io.SerialPortEvent; import gnu.io.SerialPortEventListener; import gnu.io.UnsupportedCommOperationException; import net.sf.json.JSONObject; /** * 处理自动出入库线程 */ public class AutoOutInStoreHandler implements Runnable, SessionAware, ServletResponseAware, ServletRequestAware { public static String aa = ""; /** * session对象 */ private Map<String, Object> session; /** * request对象 */ private HttpServletRequest request; /** * response对象 */ private HttpServletResponse response; private GameService gameservice; //全局定义端口 public static SerialPort serialPort; private String startTime; @SuppressWarnings("static-access") public void run() { // 获得系统端口列表 getSystemPort(); ResourceBundle resource = ResourceBundle.getBundle("port");//test为属性文件名，放在包com.mmq下，如果是放在src下，直接用test即可 String port = resource.getString("endPort"); // System.out.println(">>>>>>>>>><<<<<<<<<<<"+port); // 开启端口COM6，波特率57600. serialPort = openSerialPort(port, 57600); // 启动一个线程每2s向串口发送数据，发送1000次hello new Thread(new Runnable() { @Override public void run() { int i = 1; while (i < 1000) { String s = "hello"; byte[] bytes = s.getBytes(); testRXTX.sendData(serialPort, bytes);// 发送数据 i++; try { Thread.sleep(2000); if(serialPort == null) break; } catch (InterruptedException e) { e.printStackTrace(); } } } }).start(); // 设置串口的listener testRXTX.setListenerToSerialPort(serialPort, new SerialPortEventListener() { @Override public void serialEvent(SerialPortEvent arg0) { if (arg0.getEventType() == SerialPortEvent.DATA_AVAILABLE) {// 数据通知 byte[] bytes = testRXTX.readData(serialPort); System.out.println("收到的数据长度：" + bytes.length); try { System.out.println("收到的数据：" + new String(bytes, "utf-8") + "===,==" +new SimpleDateFormat("mm分ss秒SSS毫秒").format(new Date())); //bytes转回十六进制 StringBuilder hex = new StringBuilder(); for (int i = 0; i < bytes.length; i++) { byte b = bytes[i]; boolean flag = false; if (b < 0) flag = true; int absB = Math.abs(b); if (flag) absB = absB | 0x80; //System.out.println(absB & 0xFF); String tmp = Integer.toHexString(absB & 0xFF); if (tmp.length() == 1) { //转化的十六进制不足两位，需要补0 hex.append("0"); } hex.append(tmp.toLowerCase()); } startTime=AutoOrderStoreHandler.getStartTime(); System.out.println("<><><><><><><><><><><><><><>"+startTime); //String codestr=new BigInteger(hex.toString(), 16).toString(); // System.out.println(">>>>>>>>>>"+hex.toString()+"==========="+codestr); // List<ChengJi> list=gameservice.getList(); // // System.out.println(list.size()+"<<<<<<<<<<<<<<<<<<"); //String beginTime=startTime; // // System.out.println(">>>>>>>>"+startTime+"0000000000000"); // String endTime=new SimpleDateFormat("mm:ss.SSS").format(new Date()); // // System.out.println(">>>>>>>>"+endTime+"<<<<<<<<<<"); // SimpleDateFormat dfs = new SimpleDateFormat("mm:ss.SSS"); long between = 0; try { java.util.Date begin = dfs.parse(startTime); java.util.Date end = dfs.parse(endTime); between = (end.getTime() - begin.getTime());// 得到两者的毫秒数 } catch (Exception ex) { ex.printStackTrace(); } long day = between / (24 * 60 * 60 * 1000); long hour = (between / (60 * 60 * 1000) - day * 24); long min = ((between / (60 * 1000)) - day * 24 * 60 - hour * 60); long s = (between / 1000 - day * 24 * 60 * 60 - hour * 60 * 60 - min * 60); long ms = (between - day * 24 * 60 * 60 * 1000 - hour * 60 * 60 * 1000 - min * 60 * 1000 - s * 1000); // System.out.println(hour + ":" + min + ":" + s + "." + ms); // String chengjiTime= min + ":" + s + "." + ms; System.out.println("收到的数据：" + hex.toString() + "===,==" +new SimpleDateFormat("mm:ss.SSS").format(new Date())); //打开驱动，存入数据，关闭 Connection con = null; PreparedStatement pstm = null; try { Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://47.105.242.156:3306/partner?characterEncoding=utf-8"; String user = "root"; String password = "Abc123!_"; con = DriverManager.getConnection(url, user, password); String sql = "insert into chengji(code,time) value(?,?)"; pstm = con.prepareStatement(sql); pstm.setString(1, hex.toString()); pstm.setString(2, chengjiTime); // if (list!=null&&list.size()>0) //{ //return; //}else{ int row = pstm.executeUpdate(); System.out.println("新增数据为:" + row + "条"); // } } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); }finally{ if(con != null){ try { con.close(); } catch (SQLException e) { e.printStackTrace(); } } if(pstm != null){ try { pstm.close(); } catch (SQLException e) { e.printStackTrace(); } } } // } catch (UnsupportedEncodingException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } } }); } /** * 获得系统可用的端口名称列表 * * @return 可用端口名称列表 */ @SuppressWarnings("unchecked") public static List<String> getSystemPort() { List<String> systemPorts = new ArrayList<>(); // 获得系统可用的端口 Enumeration<CommPortIdentifier> portList = CommPortIdentifier.getPortIdentifiers(); while (portList.hasMoreElements()) { String portName = portList.nextElement().getName();// 获得端口的名字 systemPorts.add(portName); } System.out.println("系统可用端口列表：" + systemPorts); return systemPorts; } // /** * 开启串口 * * @param serialPortName 串口名称 * @param baudRate 波特率 * @return 串口对象 */ public static SerialPort openSerialPort(String serialPortName, int baudRate) { try { // 通过端口名称得到端口 CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(serialPortName); // 打开端口，（自定义名字，打开超时时间） CommPort commPort = portIdentifier.open(serialPortName, 2222); // 判断是不是串口 if (commPort instanceof SerialPort) { SerialPort serialPort = (SerialPort)commPort; // 设置串口参数（波特率，数据位8，停止位1，校验位无） serialPort.setSerialPortParams(baudRate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE); System.out.println("开启串口成功，串口名称：" + serialPortName); return serialPort; } else { // 是其他类型的端口 throw new NoSuchPortException(); } } catch (NoSuchPortException e) { e.printStackTrace(); } catch (PortInUseException e) { e.printStackTrace(); } catch (UnsupportedCommOperationException e) { e.printStackTrace(); } return null; } // /** * 关闭串口 * * @param serialPort 要关闭的串口对象 */ public static void closeSerialPort() { if (serialPort != null) { serialPort.close(); System.out.println("关闭了串口：" + serialPort.getName()); serialPort = null; } } // /** * 向串口发送数据 * * @param serialPort 串口对象 * @param data 发送的数据 */ public static void sendData(SerialPort serialPort, byte[] data) { OutputStream os = null; try { os = serialPort.getOutputStream();// 获得串口的输出流 os.write(data); os.flush(); } catch (IOException e) { e.printStackTrace(); } finally { try { if (os != null) { os.close(); os = null; } } catch (IOException e) { e.printStackTrace(); } } } // /** * 从串口读取数据 * * @param serialPort 要读取的串口 * @return 读取的数据 */ public static byte[] readData(SerialPort serialPort) { InputStream is = null; byte[] bytes = null; try { is = serialPort.getInputStream();// 获得串口的输入流 int bufflenth = is.available();// 获得数据长度 while (bufflenth != 0) { bytes = new byte[bufflenth];// 初始化byte数组 is.read(bytes); bufflenth = is.available(); } } catch (IOException e) { e.printStackTrace(); } finally { try { if (is != null) { is.close(); is = null; } } catch (IOException e) { e.printStackTrace(); } } return bytes; } // /** * 给串口设置监听 * * @param serialPort * @param listener */ public static void setListenerToSerialPort(SerialPort serialPort, SerialPortEventListener listener) { try { // 给串口添加事件监听 serialPort.addEventListener(listener); } catch (TooManyListenersException e) { e.printStackTrace(); } serialPort.notifyOnDataAvailable(true);// 串口有数据监听 serialPort.notifyOnBreakInterrupt(true);// 中断事件监听 } @Override public void setServletResponse(HttpServletResponse response) { this.response = response; } @Override public void setSession(Map<String, Object> session) { this.session = session; } @Override public void setServletRequest(HttpServletRequest request) { this.request = request; } @Resource public void setGameservice(GameService gameservice) { this.gameservice = gameservice; } }
调去线程
public String Start() { AutoOutInStoreHandler runner1 = new AutoOutInStoreHandler(); Thread thread1 = new Thread(runner1); thread1.start(); }
properties文件定义
startToendPort=COM7
endPort=COM6
//获取properties文件定义选择的端口号
ResourceBundle resource = ResourceBundle.getBundle("port");//port为属性文件名，放在包com.mmq下，如果是放在src下，直接用test即可 String port = resource.getString("startToendPort");