Java使用开源Rxtx实现串口通讯-eolink官网

Java使用开源Rxtx实现串口通讯

本文实例为大家分享了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 FoMPCgwJClder(选择至该项目的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

{

Threadhttp://.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);

outputStrehttp://am.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

// 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

Flask接口签名sign原理与实例代码浅析

1106 2023-01-16

Java使用开源Rxtx实现串口通讯

Flask接口签名sign原理与实例代码浅析

java中的接口是类吗

vue项目接口域名动态的获取方法

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！