基于java平台的与无线远程测控终端的串口通信
2016-12-22 16:02
513 查看
package ChuanKouTongXin;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
//import java.io.UnsupportedEncodingException;
import java.util.Enumeration;
import java.util.TooManyListenersException;
import gnu.io.CommPortIdentifier;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;
import gnu.io.UnsupportedCommOperationException;
public class ReadSerialPort implements Runnable, SerialPortEventListener {
private String appName = "串口通信";
private int timeout = 2000;//open 端口时的等待时间
private int threadTime = 0;
private String sport;
private CommPortIdentifier commPort;
private SerialPort serialPort;
private InputStream inputStream;
private OutputStream outputStream;
public Object ReadSerialPort;
@SuppressWarnings("rawtypes")
public void listPort(){
CommPortIdentifier cpid;
Enumeration en = CommPortIdentifier.getPortIdentifiers();
System.out.println("now to list all Port of this PC：" +en);
while(en.hasMoreElements()){
cpid = (CommPortIdentifier)en.nextElement();
if(cpid.getPortType() == CommPortIdentifier.PORT_SERIAL){
System.out.println(cpid.getName() + ", " + cpid.getCurrentOwner());
}
}
}
public ReadSerialPort() {
}
/**
* @方法名称 :selectPort
* @功能描述 :选择一个端口，比如：COM1
* @返回值类型 :void
* @param portName
*/
@SuppressWarnings("rawtypes")
public void selectPort(String portName){
this.commPort = null;
CommPortIdentifier cpid;
Enumeration en = CommPortIdentifier.getPortIdentifiers();
while(en.hasMoreElements()){
cpid = (CommPortIdentifier)en.nextElement();
if(cpid.getPortType() == CommPortIdentifier.PORT_SERIAL
&& cpid.getName().equals(portName)){
this.commPort = cpid;
break;
}
}
/*try {
serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);
} catch (UnsupportedCommOperationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
openPort();
}
/**
* @方法名称 :openPort
* @功能描述 :打开SerialPort
* @返回值类型 :void
*/
private void openPort(){
if(commPort == null)
log(String.format("无法找到名字为'%1$s'的串口！", commPort.getName()));
else{
log("端口选择成功，当前端口："+commPort.getName()+",现在实例化 SerialPort:");
try{
serialPort = (SerialPort)commPort.open(appName, timeout);
log("实例 SerialPort 成功！");
}catch(PortInUseException e){
throw new RuntimeException(String.format("端口'%1$s'正在使用中！",
commPort.getName()));
}
}
}
/**
* @方法名称 :checkPort
* @功能描述 :检查端口是否正确连接
* @返回值类型 :void
*/
private void checkPort(){
if(commPort == null)
throw new RuntimeException("没有选择端口，请使用 " +
"selectPort(String portName) 方法选择端口");
if(serialPort == null){
throw new RuntimeException("SerialPort 对象无效！");
}
}
/**
* @方法名称 :write
* @功能描述 :向端口发送数据，请在调用此方法前 先选择端口，并确定SerialPort正常打开！
* @返回值类型 :void
* @param message
*/
public void write(String message) {
checkPort();
try{
outputStream = new BufferedOutputStream(serialPort.getOutputStream());
}catch(IOException e){
throw new RuntimeException("获取端口的OutputStream出错："+e.getMessage());
}
try{
outputStream.write(message.getBytes());
log("信息发送成功！");
}catch(IOException e){
throw new RuntimeException("向端口发送信息时出错："+e.getMessage());
}finally{
try{
outputStream.close();
}catch(Exception e){
}
}
}
/**
* @方法名称 :startRead
* @功能描述 :开始监听从端口中接收的数据
* @返回值类型 :void
* @param time 监听程序的存活时间，单位为秒，0 则是一直监听
*/
public void startRead(int time){
checkPort();
try{
inputStream = new BufferedInputStream(serialPort.getInputStream());
}catch(IOException e){
throw new RuntimeException("获取端口的InputStream出错："+e.getMessage());
}
try{
serialPort.addEventListener(this);
}catch(TooManyListenersException e){
throw new RuntimeException(e.getMessage());
}
serialPort.notifyOnDataAvailable(true);
log(String.format("开始监听来自'%1$s'的数据--------------", commPort.getName()));
if(time > 0){
this.threadTime = time*1000;
Thread t = new Thread(this);
t.start();
log(String.format("监听程序将在%1$d秒后关闭。。。。", threadTime));
}
try {
serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);
} catch (UnsupportedCommOperationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void startRead(){
checkPort();
try{
inputStream = new BufferedInputStream(serialPort.getInputStream
4000
());
}catch(IOException e){
throw new RuntimeException("获取端口的InputStream出错："+e.getMessage());
}
try{
serialPort.addEventListener(this);
}catch(TooManyListenersException e){
throw new RuntimeException(e.getMessage());
}
serialPort.notifyOnDataAvailable(true);
log(String.format("开始监听来自'%1$s'的数据--------------", commPort.getName()));
}
/**
* @方法名称 :close
* @功能描述 :关闭 SerialPort
* @返回值类型 :void
*/
public void close(){
serialPort.close();
serialPort = null;
commPort = null;
}
public void log(String msg){
System.out.println(appName+" --> "+msg);
}
/**
* 数据接收的监听处理函数
* @return
*/
@Override
public void serialEvent(SerialPortEvent arg0) {
switch(arg0.getEventType()){
case SerialPortEvent.BI:/*Break interrupt,通讯中断*/
case SerialPortEvent.OE:/*Overrun error，溢位错误*/
case SerialPortEvent.FE:/*Framing error，传帧错误*/
case SerialPortEvent.PE:/*Parity error，校验错误*/
case SerialPortEvent.CD:/*Carrier detect，载波检测*/
case SerialPortEvent.CTS:/*Clear to send，清除发送*/
case SerialPortEvent.DSR:/*Data set ready，数据设备就绪*/
case SerialPortEvent.RI:/*Ring indicator，响铃指示*/
case SerialPortEvent.OUTPUT_BUFFER_EMPTY:/*Output buffer is empty，输出缓冲区清空*/
break;
case SerialPortEvent.DATA_AVAILABLE:/*Data available at the serial port，端口有可用数据。读到缓冲数组，输出到终端*/
byte[] readBuffer = new byte[1024];
String readStr="";
String s2 = "";
try {
while (inputStream.available() > 0) {
inputStream.read(readBuffer);
for (int i = 0; i < readBuffer.length; i++) { /*数据转换成16进制*/
int v = readBuffer[i] & 0xFF;
String hv = Integer.toHexString(v);
readStr += new String(hv).trim() ;
}
s2 = new String(readBuffer).trim();
log("接收到端口返回数据(长度为"+readStr.length()+")："+readStr);
log(s2);
//service.addRecord(s2);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void run() {
try{
Thread.sleep(threadTime);
serialPort.close();
log(String.format("端口''监听关闭了！", commPort.getName()));
}catch(Exception e){
e.printStackTrace();
}
}
public String getSport() {
return sport;
}
public void setSport(String sport) {
this.sport = sport;
}
}
package ChuanKouTongXin;
public class ceshi {
public static void main(String[] args) {
ReadSerialPort sp = new ReadSerialPort();
sp.listPort();
sp.selectPort("COM4");
//sp.write("123456");
sp.startRead(12);
}
}
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
//import java.io.UnsupportedEncodingException;
import java.util.Enumeration;
import java.util.TooManyListenersException;
import gnu.io.CommPortIdentifier;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;
import gnu.io.UnsupportedCommOperationException;
public class ReadSerialPort implements Runnable, SerialPortEventListener {
private String appName = "串口通信";
private int timeout = 2000;//open 端口时的等待时间
private int threadTime = 0;
private String sport;
private CommPortIdentifier commPort;
private SerialPort serialPort;
private InputStream inputStream;
private OutputStream outputStream;
public Object ReadSerialPort;
@SuppressWarnings("rawtypes")
public void listPort(){
CommPortIdentifier cpid;
Enumeration en = CommPortIdentifier.getPortIdentifiers();
System.out.println("now to list all Port of this PC：" +en);
while(en.hasMoreElements()){
cpid = (CommPortIdentifier)en.nextElement();
if(cpid.getPortType() == CommPortIdentifier.PORT_SERIAL){
System.out.println(cpid.getName() + ", " + cpid.getCurrentOwner());
}
}
}
public ReadSerialPort() {
}
/**
* @方法名称 :selectPort
* @功能描述 :选择一个端口，比如：COM1
* @返回值类型 :void
* @param portName
*/
@SuppressWarnings("rawtypes")
public void selectPort(String portName){
this.commPort = null;
CommPortIdentifier cpid;
Enumeration en = CommPortIdentifier.getPortIdentifiers();
while(en.hasMoreElements()){
cpid = (CommPortIdentifier)en.nextElement();
if(cpid.getPortType() == CommPortIdentifier.PORT_SERIAL
&& cpid.getName().equals(portName)){
this.commPort = cpid;
break;
}
}
/*try {
serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);
} catch (UnsupportedCommOperationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
openPort();
}
/**
* @方法名称 :openPort
* @功能描述 :打开SerialPort
* @返回值类型 :void
*/
private void openPort(){
if(commPort == null)
log(String.format("无法找到名字为'%1$s'的串口！", commPort.getName()));
else{
log("端口选择成功，当前端口："+commPort.getName()+",现在实例化 SerialPort:");
try{
serialPort = (SerialPort)commPort.open(appName, timeout);
log("实例 SerialPort 成功！");
}catch(PortInUseException e){
throw new RuntimeException(String.format("端口'%1$s'正在使用中！",
commPort.getName()));
}
}
}
/**
* @方法名称 :checkPort
* @功能描述 :检查端口是否正确连接
* @返回值类型 :void
*/
private void checkPort(){
if(commPort == null)
throw new RuntimeException("没有选择端口，请使用 " +
"selectPort(String portName) 方法选择端口");
if(serialPort == null){
throw new RuntimeException("SerialPort 对象无效！");
}
}
/**
* @方法名称 :write
* @功能描述 :向端口发送数据，请在调用此方法前 先选择端口，并确定SerialPort正常打开！
* @返回值类型 :void
* @param message
*/
public void write(String message) {
checkPort();
try{
outputStream = new BufferedOutputStream(serialPort.getOutputStream());
}catch(IOException e){
throw new RuntimeException("获取端口的OutputStream出错："+e.getMessage());
}
try{
outputStream.write(message.getBytes());
log("信息发送成功！");
}catch(IOException e){
throw new RuntimeException("向端口发送信息时出错："+e.getMessage());
}finally{
try{
outputStream.close();
}catch(Exception e){
}
}
}
/**
* @方法名称 :startRead
* @功能描述 :开始监听从端口中接收的数据
* @返回值类型 :void
* @param time 监听程序的存活时间，单位为秒，0 则是一直监听
*/
public void startRead(int time){
checkPort();
try{
inputStream = new BufferedInputStream(serialPort.getInputStream());
}catch(IOException e){
throw new RuntimeException("获取端口的InputStream出错："+e.getMessage());
}
try{
serialPort.addEventListener(this);
}catch(TooManyListenersException e){
throw new RuntimeException(e.getMessage());
}
serialPort.notifyOnDataAvailable(true);
log(String.format("开始监听来自'%1$s'的数据--------------", commPort.getName()));
if(time > 0){
this.threadTime = time*1000;
Thread t = new Thread(this);
t.start();
log(String.format("监听程序将在%1$d秒后关闭。。。。", threadTime));
}
try {
serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);
} catch (UnsupportedCommOperationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void startRead(){
checkPort();
try{
inputStream = new BufferedInputStream(serialPort.getInputStream
4000
());
}catch(IOException e){
throw new RuntimeException("获取端口的InputStream出错："+e.getMessage());
}
try{
serialPort.addEventListener(this);
}catch(TooManyListenersException e){
throw new RuntimeException(e.getMessage());
}
serialPort.notifyOnDataAvailable(true);
log(String.format("开始监听来自'%1$s'的数据--------------", commPort.getName()));
}
/**
* @方法名称 :close
* @功能描述 :关闭 SerialPort
* @返回值类型 :void
*/
public void close(){
serialPort.close();
serialPort = null;
commPort = null;
}
public void log(String msg){
System.out.println(appName+" --> "+msg);
}
/**
* 数据接收的监听处理函数
* @return
*/
@Override
public void serialEvent(SerialPortEvent arg0) {
switch(arg0.getEventType()){
case SerialPortEvent.BI:/*Break interrupt,通讯中断*/
case SerialPortEvent.OE:/*Overrun error，溢位错误*/
case SerialPortEvent.FE:/*Framing error，传帧错误*/
case SerialPortEvent.PE:/*Parity error，校验错误*/
case SerialPortEvent.CD:/*Carrier detect，载波检测*/
case SerialPortEvent.CTS:/*Clear to send，清除发送*/
case SerialPortEvent.DSR:/*Data set ready，数据设备就绪*/
case SerialPortEvent.RI:/*Ring indicator，响铃指示*/
case SerialPortEvent.OUTPUT_BUFFER_EMPTY:/*Output buffer is empty，输出缓冲区清空*/
break;
case SerialPortEvent.DATA_AVAILABLE:/*Data available at the serial port，端口有可用数据。读到缓冲数组，输出到终端*/
byte[] readBuffer = new byte[1024];
String readStr="";
String s2 = "";
try {
while (inputStream.available() > 0) {
inputStream.read(readBuffer);
for (int i = 0; i < readBuffer.length; i++) { /*数据转换成16进制*/
int v = readBuffer[i] & 0xFF;
String hv = Integer.toHexString(v);
readStr += new String(hv).trim() ;
}
s2 = new String(readBuffer).trim();
log("接收到端口返回数据(长度为"+readStr.length()+")："+readStr);
log(s2);
//service.addRecord(s2);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
@Override
public void run() {
try{
Thread.sleep(threadTime);
serialPort.close();
log(String.format("端口''监听关闭了！", commPort.getName()));
}catch(Exception e){
e.printStackTrace();
}
}
public String getSport() {
return sport;
}
public void setSport(String sport) {
this.sport = sport;
}
}
package ChuanKouTongXin;
public class ceshi {
public static void main(String[] args) {
ReadSerialPort sp = new ReadSerialPort();
sp.listPort();
sp.selectPort("COM4");
//sp.write("123456");
sp.startRead(12);
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- [远程测控通信]基于DataSocket的电台网络化远程测控系统
- 基于Android平台的串口通信实现
- DTU(用于将串口数据转换为IP数据或将IP数据转换为串口数据通过无线通信网络进行传送的无线终端设备)
- 基于TMS320C6455、XC5VSX95T 的6U CPCI无线通信处理平台
- 基于Java的串口通信环境配置
- 基于Android平台的串口通信实现
- 64-基于TMS320C6455、XC5VSX95T 的6U CPCI无线通信处理平台
- java语言基于万准衡器(吊钩秤)的串口通信案例
- 分布式Java--基于远程调用实现系统间通信
- 基于Java编写串口通信工具
- 基于VxWorks和MPC860T平台的嵌入式串口通信服务器的解决方案
- Android中实现java与PHP服务器（基于新浪云免费云平台）http通信详解
- 基于cocos2dx3.1引擎C++编写的android平台串口通信接口
- 基于Android平台的串口通信实现
- RTU——远程测控终端介绍
- 基于win平台的高性能服务器底层通信模型设计(1)
- 基于局域网络应用Java语言实现远程智能终端的控制
- Java回归嵌入式无线通信
- 在CB6下基于api函数编写串口通信程序简介
- 基于win平台的高性能服务器底层通信模型设计(1)