RS232 - JSSC 2.8.0 串行端口 Reader - 歧义阅读
RS232 - JSSC 2.8.0 Serial Port Reader - Ambiguous reading
package deviceintegration;
import jssc.SerialPort;
import jssc.SerialPortEvent;
import jssc.SerialPortEventListener;
import jssc.SerialPortException;
/**
*
*
*/
public class SerialScaleDevice implements SerialPortEventListener {
private String m_sPortScale;
private SerialPort m_CommSerialPort;
private static final int SCALE_READY = 0;
private String m_dWeight;
private int m_iStatusScale;
/**
* Creates a new instance of SerialScaleDevice
*
* @param sPortPrinter
*/
public SerialScaleDevice(String sPortPrinter) {
m_sPortScale = sPortPrinter;
m_CommSerialPort = new SerialPort(m_sPortScale);
//
m_iStatusScale = SCALE_READY;
m_dWeight = "";
}
/**
*
* @return
*/
public String readWeight() {
synchronized (this) {
if (m_iStatusScale != SCALE_READY) {
try {
wait(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
if (m_iStatusScale != SCALE_READY) {
m_iStatusScale = SCALE_READY;
}
}
m_dWeight = "0.0";
read();
try {
wait(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return m_dWeight;
}
}
private void read() {
try {
m_CommSerialPort.openPort();
m_CommSerialPort.setEventsMask(SerialPort.MASK_RXCHAR);
m_CommSerialPort.setFlowControlMode(SerialPort.FLOWCONTROL_NONE);
m_CommSerialPort.setParams(SerialPort.BAUDRATE_9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
m_CommSerialPort.addEventListener(this);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* @param e
*/
public void serialEvent(SerialPortEvent event) {
// Determine type of event.
switch (event.getEventType()) {
case SerialPortEvent.BREAK:
case SerialPortEvent.CTS:
case SerialPortEvent.DSR:
case SerialPortEvent.ERR:
case SerialPortEvent.RING:
case SerialPortEvent.RLSD:
case SerialPortEvent.RXFLAG:
case SerialPortEvent.TXEMPTY:
break;
case SerialPortEvent.RXCHAR:
try {
Thread.sleep(200);
m_dWeight = new String (m_CommSerialPort.readBytes());
System.out.println("readBytes: " + m_dWeight);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (SerialPortException e) {
e.printStackTrace();
}
break;
}
}
}
我得到的示例:
我不知道您使用的设备的协议,但它似乎每条消息发送 12 个字节。 <STX><+-><9 digit hex><ETX>
。因此,一次读取 12 个字节,并将十六进制转换为十进制。
所以,先改
m_dWeight = new String (m_CommSerialPort.readBytes());
到
m_dWeight = new String(m_CommSerialPort.readBytes(12));
然后,解析消息:
// ☻+00000001B♥
char stx = m_dWeight.charAt(0);
char etx = m_dWeight.charAt(11);
if (stx == 2 && etx == 3) {
long actualValue = Long.parseLong(m_dWeight.substring(1, 11), 16);
System.out.println(actualValue);
}
package deviceintegration;
import jssc.SerialPort;
import jssc.SerialPortEvent;
import jssc.SerialPortEventListener;
import jssc.SerialPortException;
/**
*
*
*/
public class SerialScaleDevice implements SerialPortEventListener {
private String m_sPortScale;
private SerialPort m_CommSerialPort;
private static final int SCALE_READY = 0;
private String m_dWeight;
private int m_iStatusScale;
/**
* Creates a new instance of SerialScaleDevice
*
* @param sPortPrinter
*/
public SerialScaleDevice(String sPortPrinter) {
m_sPortScale = sPortPrinter;
m_CommSerialPort = new SerialPort(m_sPortScale);
//
m_iStatusScale = SCALE_READY;
m_dWeight = "";
}
/**
*
* @return
*/
public String readWeight() {
synchronized (this) {
if (m_iStatusScale != SCALE_READY) {
try {
wait(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
if (m_iStatusScale != SCALE_READY) {
m_iStatusScale = SCALE_READY;
}
}
m_dWeight = "0.0";
read();
try {
wait(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return m_dWeight;
}
}
private void read() {
try {
m_CommSerialPort.openPort();
m_CommSerialPort.setEventsMask(SerialPort.MASK_RXCHAR);
m_CommSerialPort.setFlowControlMode(SerialPort.FLOWCONTROL_NONE);
m_CommSerialPort.setParams(SerialPort.BAUDRATE_9600, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
m_CommSerialPort.addEventListener(this);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* @param e
*/
public void serialEvent(SerialPortEvent event) {
// Determine type of event.
switch (event.getEventType()) {
case SerialPortEvent.BREAK:
case SerialPortEvent.CTS:
case SerialPortEvent.DSR:
case SerialPortEvent.ERR:
case SerialPortEvent.RING:
case SerialPortEvent.RLSD:
case SerialPortEvent.RXFLAG:
case SerialPortEvent.TXEMPTY:
break;
case SerialPortEvent.RXCHAR:
try {
Thread.sleep(200);
m_dWeight = new String (m_CommSerialPort.readBytes());
System.out.println("readBytes: " + m_dWeight);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (SerialPortException e) {
e.printStackTrace();
}
break;
}
}
}
我得到的示例:
我不知道您使用的设备的协议,但它似乎每条消息发送 12 个字节。 <STX><+-><9 digit hex><ETX>
。因此,一次读取 12 个字节,并将十六进制转换为十进制。
所以,先改
m_dWeight = new String (m_CommSerialPort.readBytes());
到
m_dWeight = new String(m_CommSerialPort.readBytes(12));
然后,解析消息:
// ☻+00000001B♥
char stx = m_dWeight.charAt(0);
char etx = m_dWeight.charAt(11);
if (stx == 2 && etx == 3) {
long actualValue = Long.parseLong(m_dWeight.substring(1, 11), 16);
System.out.println(actualValue);
}