本文实例为大家分享了Java使用开源Rxtx实现串口通讯的具体代码，供大家参考，具体内容如下

使用方法：

windows平台：

1、把rxtxParallel.dll、rxtxSerial.dll拷贝到：C:\WINDOWS\system32下。

2、如果是在开发的时候(JDK),需要把RXTXcomm.jar、rxtxParallel.dll、rxtxSerial.dll拷贝到..\jre...\lib\ext下；如：D:\Program Files\Java\jre1.6.0_02\lib\ext

3、而且需要把项目1.右键->2.Preperties(首选项)->3.Java Build Path->4.Libraries->5.展开RXTXcomm.jar->6.Native library location:(None)->7.浏览External Folder(选择至该项目的lib文件夹，如：E:/Item/MyItem/WebRoot/WEB-INF/lib).

import gnu.io.*;

import java.io.*;

import java.util.*;

import com.call.dao.*;

public class SerialReader extends Observable implements Runnable,SerialPortEventListener

{

static CommPortIdentifier portId;

int delayRead = 100;

int numBytes; // buffer中的实际数据字节数

private static byte[] readBuffer = new byte[1024]; // 4k的buffer空间,缓存串口读入的数据

static Enumeration portList;

InputStream inputStream;

OutputStream outputStream;

static SerialPort serialPort;

HashMap serialParams;

Thread readThread;//本来是static类型的

//端口是否打开了

boolean isOpen = false;

// 端口读入数据事件触发后,等待n毫秒后再读取,以便让数据一次性读完

public static final String PARAMS_DELAY = "delay read"; // 延时等待端口数据准备的时间

public static final String PARAMS_TIMEOUT = "timeout"; // 超时时间

public static final String PARAMS_PORT = "port name"; // 端口名称

public static final String PARAMS_DATABITS = "data bits"; // 数据位

public static final String PARAMS_STOPBITS = "stop bits"; // 停止位

public static final String PARAMS_PARITY = "parity"; // 奇偶校验

public static final String PARAMS_RATE = "rate"; // 波特率

public boolean isOpen(){

return isOpen;

}

/**

* 初始化端口操作的参数.

* @throws SerialPortException

*

* @see

*/

public SerialReader()

{

isOpen = false;

}

public void open(HashMap params)

{

serialParams = params;

if(isOpen){

close();

}

try

{

// 参数初始化

int timeout = Integer.parseInt( serialParams.get( PARAMS_TIMEOUT )

.toString() );

int rate = Integer.parseInt( serialParams.get( PARAMS_RATE )

.toString() );

int dataBits = Integer.parseInt( serialParams.get( PARAMS_DATABITS )

.toString() );

int stopBits = Integer.parseInt( serialParams.get( PARAMS_STOPBITS )

.toString() );

int parity = Integer.parseInt( serialParams.get( PARAMS_PARITY )

.toString() );

delayRead = Integer.parseInt( serialParams.get( PARAMS_DELAY )

.toString() );

String port = serialParams.get( PARAMS_PORT ).toString();

// 打开端口

portId = CommPortIdentifier.getPortIdentifier( port );

serialPort = ( SerialPort ) portId.open( "SerialReader", timeout );

inputStream = serialPort.getInputStream();

serialPort.addEventListener( this );

serialPort.notifyOnDataAvailable( true );

serialPort.setSerialPortParams( rate, dataBits, stopBits, parity );

isOpen = true;

}

catch ( PortInUseException e )

{

// 端口"+serialParams.get( PARAMS_PORT ).toString()+"已经被占用";

}

catch ( TooManyListenersException e )

{

//"端口"+serialParams.get( PARAMS_PORT ).toString()+"监听者过多";

}

catch ( UnsupportedCommOperationException e )

{

//"端口操作命令不支持";

}

catch ( NoSuchPortException e )

{

//"端口"+serialParams.get( PARAMS_PORT ).toString()+"不存在";

}

catch ( IOException e )

{

//"打开端口"+serialParams.get( PARAMS_PORT ).toString()+"失败";

}

serialParams.clear();

Thread readThread = new Thread( this );

readThread.start();

}

public void run()

{

try

{

Thread.sleep(50);

}

catch ( InterruptedException e )

{

}

}

public void start(){

try {

outputStream = serialPort.getOutputStream();

}

catch (IOException e) {}

try{

readThread = new Thread(this);

readThread.start();

}

catch (Exception e) { }

} //start() end

public void run(String message) {

try {

Thread.sleep(4);

}

catch (InterruptedException e) { }

try {

if(message!=null&&message.length()!=0)

{

System.out.println("run message:"+message);

outputStream.write(message.getBytes());

}

} catch (IOException e) {}

}

public void close()

{

if (isOpen)

{

try

{

serialPort.notifyOnDataAvailable(false);

serialPort.removeEventListener();

inputStream.close();

serialPort.close();

isOpen = false;

} catch (IOException ex)

{

//"关闭串口失败";

}

}

}

public void serialEvent( SerialPortEvent event )

{

try

{

Thread.sleep( delayRead );

}

catch ( InterruptedException e )

{

e.printStackTrace();

}

switch ( event.getEventType() )

{

case SerialPortEvent.BI: // 10

case SerialPortEvent.OE: // 7

case SerialPortEvent.FE: // 9

case SerialPortEvent.PE: // 8

case SerialPortEvent.CD: // 6

case SerialPortEvent.CTS: // 3

case SerialPortEvent.DSR: // 4

case SerialPortEvent.RI: // 5

case SerialPortEvent.OUTPUT_BUFFER_EMPTY: // 2

break;

case SerialPortEvent.DATA_AVAILABLE: // 1

try

{

// 多次读取,将所有数据读入

while (inputStream.available() > 0) {

numBytes = inputStream.read(readBuffer);

}

//打印接收到的字节数据的ASCII码

for(int i=0;i

// System.out.println("msg[" + numBytes + "]: [" +readBuffer[i] + "]:"+(char)readBuffer[i]);

}

// numBytes = inputStream.read( readBuffer );

changeMessage( readBuffer, numBytes );

}

catch ( IOException e )

{

e.printStackTrace();

}

break;

}

}

// 通过observer pattern将收到的数据发送给observer

// 将buffer中的空字节删除后再发送更新消息,通知观察者

public void changeMessage( byte[] message, int length )

{

setChanged();

byte[] temp = new byte[length];

System.arraycopy( message, 0, temp, 0, length );

notifyObservers( temp );

}

static void listPorts()

{

Enumeration portEnum = CommPortIdentifier.getPortIdentifiers();

while ( portEnum.hasMoreElements() )

{

CommPortIdentifier portIdentifier = ( CommPortIdentifier ) portEnum

.nextElement();

}

}

public void openSerialPort(String message)

{

HashMap params = new HashMap();

otherDAO odao=new otherDAO();

String port=odao.selectNumberById(15);

String rate = "9600";

String dataBit = ""+SerialPort.DATABITS_8;

String stopBit = ""+SerialPort.STOPBITS_1;

String parity = ""+SerialPort.PARITY_NONE;

int parityInt = SerialPort.PARITY_NONE;

params.put( SerialReader.PARAMS_PORT, port ); // 端口名称

params.put( SerialReader.PARAMS_RATE, rate ); // 波特率

params.put( SerialReader.PARAMS_DATABITS,dataBit ); // 数据位

params.put( SerialReader.PARAMS_STOPBITS, stopBit ); // 停止位

params.put( SerialReader.PARAMS_PARITY, parityInt ); // 无奇偶校验

params.put( SerialReader.PARAMS_TIMEOUT, 100 ); // 设备超时时间 1秒

params.put( SerialReader.PARAMS_DELAY, 100 ); // 端口数据准备时间 1秒

try {

open(params);//打开串口

LoginFrame cf=new LoginFrame();

addObserver(cf);

if(message!=null&&message.length()!=0)

{

String str="";

for(int i=0;i<10;i++)

{

str+=message;

}

start();

run(str);

}

} catch (Exception e) {

}

}

static String getPortTypeName( int portType )

{

switch ( portType )

{

case CommPortIdentifier.PORT_I2C:

return "I2C";

case CommPortIdentifier.PORT_PARALLEL:

return "Parallel";

case CommPortIdentifier.PORT_RAW:

return "Raw";

case CommPortIdentifier.PORT_RS485:

return "RS485";

case CommPortIdentifier.PORT_SERIAL:

return "Serial";

default:

return "unknown type";

}

}

public HashSet getAvailableSerialPorts()//本来static

{

HashSet h = new HashSet();

Enumeration thePorts = CommPortIdentifier.getPortIdentifiers();

while ( thePorts.hasMoreElements() )

{

CommPortIdentifier com = ( CommPortIdentifier ) thePorts

.nextElement();

switch ( com.getPortType() )

{

case CommPortIdentifier.PORT_SERIAL:

try

{

CommPort thePort = com.open( "CommUtil", 50 );

thePort.close();

h.add( com );

}

catch ( PortInUseException e )

{

System.out.println( "Port, " + com.getName()

+ ", is in use." );

}

catch ( Exception e )

{

System.out.println( "Failed to open port "

+ com.getName() + e );

}

}

}

return h;

}

}

//ASCII表

//-------------------------------------------------------------

// ASCII Characters

//

//Dec Hex Char Code Dec Hex Char

//

//0 0 NUL 64 40 @

//1 1 SOH 65 41 A

//2 2 STX 66 42 B

//3 3 ETX 67 43 C

//4 4 EOT 68 44 D

//5 5 ENQ 69 45 E

//6 6 ACK 70 46 F

//7 7 BEL 71 47 G

//8 8 BS 72 48 H

//9 9 HT 73 49 I

//10 0A LF 74 4A J

//11 0B VT 75 4B K

//12 0C FF 76 4C L

//13 0D CR 77 4D M

//14 0E SO 78 4E N

//15 0F SI 79 4F O

//16 10 SLE 80 50 P

//17 11 CS1 81 51 Q

//18 12 DC2 82 52 R

//19 13 DC3 83 53 S

//20 14 DC4 84 54 T

//21 15 NAK 85 55 U

//22 16 SYN 86 56 V

//23 17 ETB 87 57 W

//24 18 CAN 88 58 X

//25 19 EM 89 59 Y

//26 1A SIB 90 5A Z

//27 1B ESC 91 5B [

// 92 5C \

//28 1C FS 93 5D ]

//29 1D GS 94 5E ^

//30 1E RS 95 5F _

//31 1F US 96 60 `

//32 20 (space) 97 61 a

//33 21 ! 98 62 b

//34 22 "

// 99 63 c

//35 23 # 100 64 d

//36 24 $

//37 25 % 101 65 e

//38 26 & 102 66 f

//39 27 ' 103 67 g

//40 28 ( 104 68 h

//41 29 ) 105 69 i

//42 2A * 106 6A j

//43 2B + 107 6B k

//44 2C , 108 6C l

//45 2D - 109 6D m

//46 2E . 110 6E n

//47 2F / 111 6F o

//48 30 0 112 70 p

//49 31 1 113 72 q

//50 32 2 114 72 r

//51 33 3 115 73 s

//52 34 4 116 74 t

//53 35 5 117 75 u

//54 36 6 118 76 v

//55 37 7 119 77 w

//56 38 8 120 78 x

//57 39 9 121 79 y

//58 3A : 122 7A z

//59 3B ; 123 7B {

//60 3C < 124 7C |

//61 3D = 125 7D }

//62 3E > 126 7E ~

//63 3F ? 127 7F

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

java rxtx_Java使用开源Rxtx实现串口通讯相关推荐

  1. JAVA通信编程（五）——串口通讯的补充说明

    欢迎支持笔者新作:<深入理解Kafka:核心设计与实践原理>和<RabbitMQ实战指南>,同时欢迎关注笔者的微信公众号:朱小厮的博客. 在<JAVA通讯编程(一)--串 ...

  2. JAVA通信编程（一）——串口通讯

    欢迎支持笔者新作:<深入理解Kafka:核心设计与实践原理>和<RabbitMQ实战指南>,同时欢迎关注笔者的微信公众号:朱小厮的博客. 欢迎跳转到本文的原文链接:https: ...

  3. springboot + mina 实现串口通讯

    记一次串口开发,以下代码只能调用本机的串口发送指令. 下载mfz-rxtx-2.2-20081207-win-x64压缩包,将以下三个文件放入指定文件夹内. Copy RXTXcomm.jar --- ...

  4. Java使用RXTX进行串口SerialPort通讯

    RXTX简介 (https://www.jianshu.com/p/cb61f797ffc1 RXTX是一个提供串口和并口通信的开源java类库,由该项目发布的文件均遵循LGPL协议. RXTX项目提 ...

  5. JAVA使用RXTX编写串口调试工具-代码分析

    本程序是基于下面博客修改而来,添加了更多的代码注释和一些功能,具体环境安装看下面的微博 https://blog.csdn.net/kong_gu_you_lan/article/details/80 ...

  6. 银河麒麟龙芯mips64架构集成RXTX串口通讯兼容问题

    前言 应用涉及到串口通讯,用到的是RXTX.一直部署在win环境,项目要求用国产服务器.银河麒麟操作系统.龙芯处理器.国产中间件.国产数据库.因此出现rxtx在以上环境中兼容问题,下面记录下我遇到的问 ...

  7. java串口通讯包_java串口通讯

    Java进行串口通讯,一般需要相关的开源jar包,比较通用的为RXTXComm.jar和comm.jar,其中RXTXComm.jar为在comm.jar基础上进行了封装,对操作系统等一些底层做了适配 ...

  8. java串口通讯，可实现javaWeb页面同时控制多个串口，有demo

    java串口通讯,可实现javaWeb页面控制串口,调用串口数据,发送串口指令 前言 关于java实现串口通讯网上有很多例子,但是都是做客户端的demo,实际集成到javaWeb系统中会遇到很多问题. ...

  9. Java 串口 mysql_java串口通讯

    使用java进行串口通信确实不是串口通讯操作的主流方法,另外写好的的java程序无法随意的迁移.不过对熟悉java的同学确实挺有帮助,下面是我使用java语言进行串口通讯的过程. 1 usb转串口安装 ...

  10. java天平数据,java RS232串口通讯（电子天平数据抓取）

    写这篇文章是为了记录RS232串口通讯,当时有个央企项目里需要实现自动抓取RS232串口数据,需要支持主要浏览器:Chrome,Firefox,IE8以上等.看了很多有关rs232的资料和也找了很多方 ...

最新文章

  1. 【C++】利用构造函数对类对象进行初始化
  2. python用户名和密码登录函数_基于Python构建用户ID和密码存储查询系统,python,建立,一个,用户名,UserID,Password,的...
  3. C++学习笔记第二天：几个知识点
  4. C# 对Outlook联系人的增、删、查
  5. C++的安全类型转换的讨论
  6. 10 3 java_10.3 UiPath如何调用Java
  7. js鼠标禁止右键、复制粘贴代码
  8. 对流式计算模型的理解
  9. 【二分答案】【中位数】codeforces 394 bun
  10. MSDEV.EXE-应用程序错误解决办法
  11. tecplot批量导出图片_科研画图工具Tecplot使用教程
  12. dpdk-pktgen快速发包工具踩坑日记
  13. 软考（软件设计师）考点总结 -- 信息安全分析与设计
  14. 计算机科学技术学报官网convex,计算机学报chin
  15. Hibernate2 参考文档
  16. 如何理解会议中控系统
  17. win10中conda activate激活环境出错的解决办法
  18. TYPEC转HDMI+PD3.0 分辨率4K60Hz拓展坞方案：CS5269
  19. 搭建文字转语音(TTS)服务器
  20. VMware安装VMwareTolls

热门文章

  1. 将图片转为CAD的方法
  2. 智慧供应链的学习笔记（库存管理、配补货、仓间调拨、控制塔等）
  3. PCL ——最小包围盒
  4. element-ui对话框fullscreen.lock使用
  5. Python实现给qq自动发消息 终于有人来和我说早安晚安了吗...
  6. 寻迹pid算法 c语言,基于STC12C5A60S2单片机及PID控制算法的气味循迹车设计
  7. 集成电路的设计 —— 晶体管
  8. 几个小图像处理工具网址
  9. java合并2个txt文本,Java实现多个文档合并输出到一个文档
  10. UE编辑器加入鼠标右键