地址： http://fizzed.com/oss/rxtx-for-java
2.部署到Windows
下载完成后将 rxtxParallel.dll 、 rxtxSerial.dll 、文件拷贝到Java jdk的bin目录下（如图）
然后把RXTXcomm.jar包引入到项目中或者使用maven引入都可以，两种方式选一种就可以：
方式一： 本地jar包直接引入
在项目根目录下新建lib文件夹并导入RXTXcomm.jar，然后在pom中引入本地jar包即可
com.test rxtxcomm2.2 system ${basedir}/lib/RXTXcomm.jar
方式二 ： maven引入，在pom中写入如下内容即可
3.测试编码：org.bidib.jbidib.org.qbang.rxtx rxtxcomm2.2
import gnu.io.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Enumeration;
import java.util.TooManyListenersException;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
public class SerialPortDataHandle extends Thread implements SerialPortEventListener {
private static final Logger logger = LoggerFactory.getLogger(SerialPortDataHandle.class);
// 通讯端口管理，控制对通信端口的访问的中心类
static CommPortIdentifier portManager;
// 有效连接上的端口的枚举
static Enumeration portList;
// 串口输入流引用
static InputStream inputStream;
// 串口输出流引用
static OutputStream outputStream;
// 串口对象引用
static SerialPort serialPort;
// 堵塞队列：用来存放串口发送到服务端的数据
private BlockingQueue msgQueue = new LinkedBlockingQueue();
// 线程控制标识
private boolean flag = true;
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:
// 数据接收缓冲容器
byte[] readBuffer = new byte[0];
try {
readBuffer = new byte[inputStream.available()];
} catch (IOException e) {
e.printStackTrace();
}
try {
// 存储待接收读取字节数大小
int numBytes = 0;
while (inputStream.available() > 0) {
numBytes = inputStream.read(readBuffer);
if (numBytes > 0) {
msgQueue.add(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
.format(new Date()) + " 收到的串口发送数据为："+ new String(readBuffer));
// 数据接收缓冲容器清空初始化
readBuffer = new byte[0];
}
}
} catch (IOException e) {
logger.error("IO异常", e);
}
break;
}
}
public int init() {
// 通过串口通信管理类获得当前连接上的端口列表
//（获取一个枚举对象，该CommPortIdentifier对象包含系统中每个端口的对象集[串口、并口]）
portList = CommPortIdentifier.getPortIdentifiers();
while (portList.hasMoreElements()) {
// 获取相应串口对象
portManager = (CommPortIdentifier) portList.nextElement();
if (portManager.getPortType() == CommPortIdentifier.PORT_SERIAL) {
logger.info("串口设备名称：" + portManager.getName());
// 判断模拟COM4串口存在，就打开该串口
if (portManager.getName().equals("COM4")) {
logger.info("测试串口设备名称：" + portManager.getName());
try {
if (serialPort==null) {
// 打开串口，设置名字为COM_4(自定义),延迟阻塞时等待3000毫秒（赋值给预设的串口引用）
serialPort = (SerialPort)portManager.open("COM4", 3000);
logger.info("串口设备COM4已打开");
}
} catch (PortInUseException e) {
logger.error("串口使用异常", e);
return 0;
}
// 在串口引用不为空时进行下述操作
if (serialPort!=null) {
// 1. 设置串口的输入输出流引用
try {
inputStream = serialPort.getInputStream();
outputStream = serialPort.getOutputStream();
} catch (IOException e) {
logger.error("串口输入输出IO异常", e);
return 0;
}
// 2. 设置串口监听器
try {
serialPort.addEventListener(this);
} catch (TooManyListenersException e) {
logger.error("串口监听器添加异常", e);
return 0;
}
// 设置监听器在有数据时通知生效
serialPort.notifyOnDataAvailable(true);
// 3. 设置串口相关读写参数
try {
// 比特率、数据位、停止位、校验位
serialPort.setSerialPortParams(115200,
SerialPort.DATABITS_8,
SerialPort.STOPBITS_1,
SerialPort.PARITY_NONE);
} catch (UnsupportedCommOperationException e) {
logger.error("串口设置操作异常", e);
return 0;
}
return 1;
}
return 0;
}
}
}
return 0;
}
@Override
public void run() {
try {
logger.info("串口线程已运行");
while (flag) {
// 如果堵塞队列中存在数据就将其输出
if (msgQueue.size() > 0) {
// take() 取走BlockingQueue里排在首位的对象
// 若BlockingQueue为空，阻断进入等待状态直到Blocking有新的对象被加入为止
String msg = msgQueue.take();
logger.info(msg);
//echo数据
sendToPort(serialPort, msg.getBytes());
}
}
} catch (InterruptedException e) {
logger.error("线程执行异常", e);
}
}
public void stopGetDataBySerialPort() {
this.flag = false;
}
public static void sendToPort(SerialPort serialPort, byte[] data) {
OutputStream out = null;
try {
out = serialPort.getOutputStream();
out.write(data);
out.flush();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (out != null) {
try {
out.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
SerialPortDataHandle handle = new SerialPortDataHandle();
int i = handle.init();
if (i == 1) {
// 线程启动
handle.start();
}
}
}
4. 测试
需要下载两个调试工具：XCOM V2.0、vspd（Configure Virtual Serial Port Driver）
先在vspd中新增COMM4和COMM5端口如图，这里COMM4和COMM5是连接在一起的，也就是说如果我在COMM5发送数据后COMM4就能收到
然后我们打开 XCOM V2.0 ，然后配置 串口 参数如图（我选择的是COM5），这样我们在COM5发送消息后，COMM4应该就能收到了
