JAVA操作串口有感
http://blog.csdn.net/linghao00/article/details/6852739在做过一年多的RXTX操作串口项目有现在把一些平时遇到的问题在这里写写:RXTX是一个开源包,主要是在COMM开源包中做扩张,以前的COMM包只能在WINDOWS下面对串口或并口做操作,扩充后的RXTX可以在LINUX和MAC下对串口和并口做操作。 现在跨平台:在
http://blog.csdn.net/linghao00/article/details/6852739
在做过一年多的RXTX操作串口项目有现在把一些平时遇到的问题在这里写写:
RXTX是一个开源包,主要是在COMM开源包中做扩张,以前的COMM包只能在WINDOWS下面对串口或并口做操作,扩充后的RXTX可以在LINUX和MAC下对串口和并口做操作。 现在跨平台:
在RXTX网站下载JAR包和动态库
http://users.frii.com/jarvi/rxtx/download.html
下载后配置环境
Windows
拷贝RXTXcomm.jar 文件到 \jre\lib\ext 目录下
拷贝rxtxSerial.dll文件到 \jre\bin目录下
Mac OS X (x86 and ppc) (there is an Installer with the source)
MAC下面我自己没有配置环境成功,后来找一个MAC下RXTX的安装把环境配置好的。
http://www.jdivelog.org/how-to/mac-os-x/下载安装环境配置文件RXTX_Tiger.pkg
Linux (only x86, x86_64, ia64 here but more in the ToyBox)
拷贝RXTXcomm.jar 文件到 /jre/lib/ext 目录下
拷贝librxtxSerial.so 文件到 /jre/lib/[machine type] (i386 for instance)目录下
并将拷贝文件释放权限给所有用户
Solaris (sparc only so far)
拷贝RXTXcomm.jar 文件到 /jre/lib/ext 目录下
拷贝librxtxSerial.so 文件到 /jre/lib/[machine type]目录下
并将拷贝文件释放权限给所有用户
环境搭建好后开始写代码实现
- import java.io.*;
- import java.text.SimpleDateFormat;
- import java.util.Date;
- import java.util.TooManyListenersException;
- import gnu.io.CommPortIdentifier;
- import gnu.io.NoSuchPortException;
- import gnu.io.PortInUseException;
- import gnu.io.SerialPort;
- import gnu.io.SerialPortEvent;
- import gnu.io.SerialPortEventListener;
- public class SerialComm implements SerialPortEventListener, Runnable
- {
- public final static String PORT_OWER = "MonitorApp";
- private boolean isOpen;
- private boolean isStart;
- private boolean isSave;
- private boolean isPrint;
- private Thread readThread;
- private String portName;
- private String portAddress;
- private CommPortIdentifier portId;
- private SerialPort serialPort;
- private DataInputStream inputStream;
- private OutputStream outputStream;
- private SimpleDateFormat formatter;
- // prase data with process
- private String dataProtocol;
- private Object readWriteLock = new Object();
- public SerialComm() {
- isOpen = false;
- isStart = false;
- isSave = true;
- isPrint = false;
- formatter = new SimpleDateFormat("[yyyy-MM-dd hh:mm:ss,SSS]");
- portName = "COM1";
- portAddress = "LOCAL";
- dataProtocol = "Gooseli";
- }
- public void init(String port, String protocol) throws Exception
- {
- portName = port;
- portAddress = portName;
- dataProtocol = protocol;
- init();
- }
- public void init(String port, String address, String protocol) throws Exception
- {
- portName = port;
- portAddress = address;
- dataProtocol = protocol;
- init();
- }
- public void init() throws IOException, Exception, Exception
- {
- if (isOpen)
- {
- close();
- }
- try
- {
- //传送串口名创建CommPortIdentifier对象服务。
- portId = CommPortIdentifier.getPortIdentifier(portName);
- //使用portId对象服务打开串口,并获得串口对象
- serialPort = (SerialPort) portId.open(PORT_OWER, 2000);
- //通过串口对象获得读串口流对象
- inputStream = new DataInputStream(serialPort.getInputStream());
- //通过串口对象获得写串口流对象
- outputStream = serialPort.getOutputStream();
- isOpen = true;
- } catch (NoSuchPortException ex)
- {
- throw new Exception(ex.toString());
- } catch (PortInUseException ex)
- {
- throw new Exception(ex.toString());
- }
- }
- public void start() throws Exception
- {
- if (!isOpen)
- {
- throw new Exception(portName + " has not been opened.");
- }
- try
- {
- //创建对象线程
- readThread = new Thread(this);
- readThread.start();
- //设置串口数据时间有效
- serialPort.notifyOnDataAvailable(true);
- //增加监听
- serialPort.addEventListener(this);
- isStart = true;
- } catch (TooManyListenersException ex)
- {
- throw new Exception(ex.toString());
- }
- }
- public void run()
- {
- String at = "at^hcmgr=1\r";
- String strTemp = at + (char) Integer.parseInt("1a", 16) + "z";
- writeComm(strTemp);
- isPrint = true;
- }
- public void stop()
- {
- if (isStart)
- {
- serialPort.notifyOnDataAvailable(false);
- serialPort.removeEventListener();
- isStart = false;
- }
- }
- public void close()
- {
- stop();
- if (isOpen)
- {
- try
- {
- inputStream.close();
- outputStream.close();
- serialPort.close();
- isOpen = false;
- } catch (IOException ex)
- {
- }
- }
- }
- //如果串口有数据上报则主动调用此方法
- public void serialEvent(SerialPortEvent event)
- {
- switch (event.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:
- readComm();
- break;
- default:
- break;
- }
- }
- public void readComm()
- {
- StringBuffer readBuffer = new StringBuffer();
- String scannedInput = "";
- Date currentTime = null;
- String TimeStamp = "";
- int c;
- char a;
- try
- {
- InputStreamReader fis = new InputStreamReader(inputStream, "utf-8");
- while ((c = fis.read()) != -1)
- {
- readBuffer.append((char) c);
- }
- scannedInput = readBuffer.toString().trim();
- currentTime = new Date();
- TimeStamp = formatter.format(currentTime);
- } catch (IOException ex)
- {
- ex.printStackTrace();
- } catch (Exception ex)
- {
- ex.printStackTrace();
- }
- }
- public void writeComm(String outString)
- {
- synchronized (readWriteLock)
- {
- try
- {
- outputStream.write(outString.getBytes());
- } catch (IOException ex)
- {
- }
- }
- }
- public static void main(String[] args)
- {
- SerialComm serialcomm = new SerialComm();
- try
- {
- serialcomm.init("COM3", "Air");// windows下测试端口
- // serialcomm.init("/dev/ttyUSB0", "Air");//linux下测试端口
- serialcomm.start();
- } catch (Exception ex)
- {
- }
- }
- }
更多推荐
所有评论(0)