Java 기반 직렬 통신 도구 작성

최근 강좌에서는 호스트 컴퓨터 직렬 통신 도구를 작성해야 했습니다. Java 기반 그래픽 인터페이스를 사용하여 간단한 직렬 통신 도구를 작성했습니다. 참고할 수 있도록 프로세스가 아래에 자세히 설명되어 있습니다. :

먼저 Java 직렬 통신 작업을 지원하는 추가 jar 패키지를 다운로드해야 합니다. java.comm은 상대적으로 오래되었고 64비트 시스템을 지원하지 않으므로 여기서는 Rxtx jar 패키지를 권장합니다(32- 비트/64비트 지원).

공식 다운로드 주소: http://fizzed.com/oss/rxtx-for-java (참고: 다운로드 시 FQ가 필요할 수 있음)

FQ가 불가능한 아동용 신발은 다운로드 가능 여기:

http://xiazai.jb51.net/201612/yuanma/javamfzrxtx(jb51.net).rar(32비트)

http://xiazai.jb51.net /201612/ yuanma/javamfzrxtx(jb51.net).rar (64비트)

둘:

jar 패키지를 다운로드하고 압축을 풀고 Java 빌드 경로에 도입합니다:

캡처

참고: 작업 중에 java.lang.UnsatisfiedLinkError 오류가 발생하는 경우 rxtx 압축 풀기 패키지에 있는 rxtxParallel.dll 및 rxtxSerial.dll 파일을 다음 위치에 복사하세요. C:WindowsSystem32 이 오류는 해당 디렉터리로 이동하여 해결할 수 있습니다.

세:

이 jar 패키지의 사용과 관련하여 직렬 포트 통신과 관련된 간단한 서비스를 제공하는 SerialTool.java 클래스를 작성했습니다. (이 클래스에 유의하십시오.) 는 serialPort 패키지에 있습니다.

참고: 이 메서드 클래스에서 발생하는 예외는 모두 내 사용자 정의 예외입니다. 이렇게 하는 이유는 다음 중 하나에서 해당 처리를 용이하게 하기 위한 것입니다. 예외는 아래에 게시되어 있습니다.

package serialPort;
 
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.TooManyListenersException;
 
import gnu.io.CommPort;
import gnu.io.CommPortIdentifier;
import gnu.io.NoSuchPortException;
import gnu.io.PortInUseException;
import gnu.io.SerialPort;
import gnu.io.SerialPortEventListener;
import gnu.io.UnsupportedCommOperationException;
import serialException.*;
 
/**
 * 串口服务类，提供打开、关闭串口，读取、发送串口数据等服务（采用单例设计模式）
 * @author zhong
 *
 */
public class SerialTool {
  
 private static SerialTool serialTool = null;
  
 static {
 //在该类被ClassLoader加载时就初始化一个SerialTool对象
 if (serialTool == null) {
  serialTool = new SerialTool();
 }
 }
  
 //私有化SerialTool类的构造方法，不允许其他类生成SerialTool对象
 private SerialTool() {} 
  
 /**
 * 获取提供服务的SerialTool对象
 * @return serialTool
 */
 public static SerialTool getSerialTool() {
 if (serialTool == null) {
  serialTool = new SerialTool();
 }
 return serialTool;
 }
 
 
 /**
 * 查找所有可用端口
 * @return 可用端口名称列表
 */
 public static final ArrayList<String> findPort() {
 
 //获得当前所有可用串口
 Enumeration<CommPortIdentifier> portList = CommPortIdentifier.getPortIdentifiers(); 
  
 ArrayList<String> portNameList = new ArrayList<>();
 
 //将可用串口名添加到List并返回该List
 while (portList.hasMoreElements()) {
  String portName = portList.nextElement().getName();
  portNameList.add(portName);
 }
 
 return portNameList;
 
 }
  
 /**
 * 打开串口
 * @param portName 端口名称
 * @param baudrate 波特率
 * @return 串口对象
 * @throws SerialPortParameterFailure 设置串口参数失败
 * @throws NotASerialPort 端口指向设备不是串口类型
 * @throws NoSuchPort 没有该端口对应的串口设备
 * @throws PortInUse 端口已被占用
 */
 public static final SerialPort openPort(String portName, int baudrate) throws SerialPortParameterFailure, NotASerialPort, NoSuchPort, PortInUse {
 
 try {
 
  //通过端口名识别端口
  CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(portName);
 
  //打开端口，并给端口名字和一个timeout（打开操作的超时时间）
  CommPort commPort = portIdentifier.open(portName, 2000);
 
  //判断是不是串口
  if (commPort instanceof SerialPort) {
   
  SerialPort serialPort = (SerialPort) commPort;
   
  try {   
   //设置一下串口的波特率等参数
   serialPort.setSerialPortParams(baudrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);    
  } catch (UnsupportedCommOperationException e) { 
   throw new SerialPortParameterFailure();
  }
   
  //System.out.println("Open " + portName + " sucessfully !");
  return serialPort;
   
  } 
  else {
  //不是串口
  throw new NotASerialPort();
  }
 } catch (NoSuchPortException e1) {
  throw new NoSuchPort();
 } catch (PortInUseException e2) {
  throw new PortInUse();
 }
 }
  
 /**
 * 关闭串口
 * @param serialport 待关闭的串口对象
 */
 public static void closePort(SerialPort serialPort) {
 if (serialPort != null) {
  serialPort.close();
  serialPort = null;
 }
 }
  
 /**
 * 往串口发送数据
 * @param serialPort 串口对象
 * @param order 待发送数据
 * @throws SendDataToSerialPortFailure 向串口发送数据失败
 * @throws SerialPortOutputStreamCloseFailure 关闭串口对象的输出流出错
 */
 public static void sendToPort(SerialPort serialPort, byte[] order) throws SendDataToSerialPortFailure, SerialPortOutputStreamCloseFailure {
 
 OutputStream out = null;
  
 try {
   
  out = serialPort.getOutputStream();
  out.write(order);
  out.flush();
   
 } catch (IOException e) {
  throw new SendDataToSerialPortFailure();
 } finally {
  try {
  if (out != null) {
   out.close();
   out = null;
  }  
  } catch (IOException e) {
  throw new SerialPortOutputStreamCloseFailure();
  }
 }
  
 }
  
 /**
 * 从串口读取数据
 * @param serialPort 当前已建立连接的SerialPort对象
 * @return 读取到的数据
 * @throws ReadDataFromSerialPortFailure 从串口读取数据时出错
 * @throws SerialPortInputStreamCloseFailure 关闭串口对象输入流出错
 */
 public static byte[] readFromPort(SerialPort serialPort) throws ReadDataFromSerialPortFailure, SerialPortInputStreamCloseFailure {
 
 InputStream in = null;
 byte[] bytes = null;
 
 try {
   
  in = serialPort.getInputStream();
  int bufflenth = in.available(); //获取buffer里的数据长度
   
  while (bufflenth != 0) {    
  bytes = new byte[bufflenth]; //初始化byte数组为buffer中数据的长度
  in.read(bytes);
  bufflenth = in.available();
  } 
 } catch (IOException e) {
  throw new ReadDataFromSerialPortFailure();
 } finally {
  try {
  if (in != null) {
   in.close();
   in = null;
  }
  } catch(IOException e) {
  throw new SerialPortInputStreamCloseFailure();
  }
 
 }
 
 return bytes;
 
 }
  
 /**
 * 添加监听器
 * @param port 串口对象
 * @param listener 串口监听器
 * @throws TooManyListeners 监听类对象过多
 */
 public static void addListener(SerialPort port, SerialPortEventListener listener) throws TooManyListeners {
 
 try {
   
  //给串口添加监听器
  port.addEventListener(listener);
  //设置当有数据到达时唤醒监听接收线程
  port.notifyOnDataAvailable(true);
  //设置当通信中断时唤醒中断线程
  port.notifyOnBreakInterrupt(true);
 
 } catch (TooManyListenersException e) {
  throw new TooManyListeners();
 }
 }
  
  
}

(모든 사용자 정의 예외는 serialException 패키지에 배치됩니다.)

각 사용자 정의 Exception 클래스를 다시 작성했습니다. () 메소드를 사용하여 메인 프로그램이 Exception

package serialException;
 
public class SerialPortParameterFailure extends Exception {
 /**
 * 
 */
 private static final long serialVersionUID = 1L;
 
 public SerialPortParameterFailure() {}
 
 @Override
 public String toString() {
 return "设置串口参数失败！打开串口操作未完成！";
 }
  
}

을 포착한 후 해당 오류 메시지를 인쇄할 수 있도록 합니다. 그 중 serialException 패키지에는 수신된 Exception 객체에서 오류 정보를 추출하고 변환하는 특수한 것도 있습니다. 반환된 클래스의 코드는 다음과 같습니다.

4:

package serialException;
 
import java.io.IOException;
import java.io.PrintWriter;
import java.io.StringWriter;
 
/**
 * 负责将传入的Exception中的错误信息提取出来并转换成字符串；
 * @author zhong
 *
 */
public class ExceptionWriter {
 
 /**
 * 将Exception中的错误信息封装到字符串中并返回该字符串
 * @param e 包含错误的Exception
 * @return 错误信息字符串
 */
 public static String getErrorInfoFromException(Exception e) { 
   
  StringWriter sw = null;
  PrintWriter pw = null;
   
  try { 
  sw = new StringWriter(); 
  pw = new PrintWriter(sw); 
  e.printStackTrace(pw); 
  return "\r\n" + sw.toString() + "\r\n"; 
   
  } catch (Exception e2) { 
  return "出错啦！未获取到错误信息，请检查后重试!"; 
  } finally {
  try {
   if (pw != null) {
   pw.close();
   }
   if (sw != null) {
   sw.close();
   }
  } catch (IOException e1) {
   e1.printStackTrace();
  }
  }
 }
}

주 프로그램 클래스의 사용법은 프로그램의 항목 주소( main 메소드), 해당 기능은 Welcome 인터페이스를 표시하고 실제 직렬 포트 데이터 표시를 위해 DataView.java 클래스를 호출하는 것입니다.

Client.java 코드는 다음과 같습니다.

실행 스크린샷:

package serialPort;
 
import java.awt.Color;
import java.awt.FlowLayout;
import java.awt.Font;
import java.awt.Frame;
import java.awt.Graphics;
import java.awt.GridLayout;
import java.awt.Image;
import java.awt.Label;
import java.awt.Panel;
import java.awt.Toolkit;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
 
import javax.swing.JOptionPane;
 
import serialException.ExceptionWriter;
 
/**
 * 主程序
 * @author zhong
 *
 */
public class Client extends Frame{
  
 /**
 * 
 */
 private static final long serialVersionUID = 1L;
 
 /**
 * 程序界面宽度
 */
 public static final int WIDTH = 800;
  
 /**
 * 程序界面高度
 */
 public static final int HEIGHT = 620;
  
 /**
 * 程序界面出现位置（横坐标）
 */
 public static final int LOC_X = 200;
  
 /**
 * 程序界面出现位置（纵坐标）
 */
 public static final int LOC_Y = 70;
 
 Color color = Color.WHITE; 
 Image offScreen = null; //用于双缓冲
  
 //设置window的icon（这里我自定义了一下Windows窗口的icon图标，因为实在觉得哪个小咖啡图标不好看 = =）
 Toolkit toolKit = getToolkit();
 Image icon = toolKit.getImage(Client.class.getResource("computer.png"));
  
 //持有其他类
 DataView dataview = new DataView(this); //主界面类（显示监控数据主面板）
 
 /**
 * 主方法
 * @param args //
 */
 public static void main(String[] args) {
 new Client().launchFrame(); 
 }
  
 /**
 * 显示主界面
 */
 public void launchFrame() {
 this.setBounds(LOC_X, LOC_Y, WIDTH, HEIGHT); //设定程序在桌面出现的位置
 this.setTitle("CDIO工程项目"); //设置程序标题
 this.setIconImage(icon);
 this.setBackground(Color.white); //设置背景色
  
 this.addWindowListener(new WindowAdapter() {
  //添加对窗口状态的监听
  public void windowClosing(WindowEvent arg0) {
  //当窗口关闭时
  System.exit(0); //退出程序
  }
   
 });
 
 this.addKeyListener(new KeyMonitor()); //添加键盘监听器
 this.setResizable(false); //窗口大小不可更改
 this.setVisible(true); //显示窗口
   
 new Thread(new RepaintThread()).start(); //开启重画线程
 }
  
 /**
 * 画出程序界面各组件元素
 */
 public void paint(Graphics g) {
 Color c = g.getColor();
  
 g.setFont(new Font("微软雅黑", Font.BOLD, 40));
 g.setColor(Color.black);
 g.drawString("欢迎使用上位机实时监控系统", 45, 190);
  
 g.setFont(new Font("微软雅黑", Font.ITALIC, 26));
 g.setColor(Color.BLACK);
 g.drawString("Version：1.0 Powered By：ZhongLei", 280, 260);
  
 g.setFont(new Font("微软雅黑", Font.BOLD, 30));
 g.setColor(color);
 g.drawString("————点击Enter键进入主界面————", 100, 480);
 //使文字 "————点击Enter键进入主界面————" 黑白闪烁
 if (color == Color.WHITE) color = Color.black;
 else if (color == color.BLACK) color = Color.white;
  
  
 }
  
 /**
 * 双缓冲方式重画界面各元素组件
 */
 public void update(Graphics g) {
 if (offScreen == null) offScreen = this.createImage(WIDTH, HEIGHT);
 Graphics gOffScreen = offScreen.getGraphics();
 Color c = gOffScreen.getColor();
 gOffScreen.setColor(Color.white);
 gOffScreen.fillRect(0, 0, WIDTH, HEIGHT); //重画背景画布
 this.paint(gOffScreen); //重画界面元素
 gOffScreen.setColor(c);
 g.drawImage(offScreen, 0, 0, null); //将新画好的画布“贴”在原画布上
 }
  
 /*
 * 内部类形式实现对键盘事件的监听
 */
 private class KeyMonitor extends KeyAdapter {
 
 public void keyReleased(KeyEvent e) {
  int keyCode = e.getKeyCode();
  if (keyCode == KeyEvent.VK_ENTER) { //当监听到用户敲击键盘enter键后执行下面的操作
  setVisible(false); //隐去欢迎界面
  dataview.setVisible(true); //显示监测界面
  dataview.dataFrame(); //初始化监测界面
  }
 }
  
 }
  
  
 /*
 * 重画线程（每隔250毫秒重画一次）
 */
 private class RepaintThread implements Runnable {
 public void run() {
  while(true) {
  repaint();
  try {
   Thread.sleep(250);
  } catch (InterruptedException e) {
   //重画线程出错抛出异常时创建一个Dialog并显示异常详细信息
   String err = ExceptionWriter.getErrorInfoFromException(e);
   JOptionPane.showMessageDialog(null, err, "错误", JOptionPane.INFORMATION_MESSAGE);
   System.exit(0);
  }
  }
 }
  
 }
  
}

참고: 실제 실행 과정에서 "클릭" 하단에 하나가 있습니다. 메인 인터페이스로 들어가려면 Enter 키를 누르세요." 깜박이는 효과(이 문장이 흰색과 검은색으로 번갈아 나타나도록 인터페이스를 가끔씩 다시 그려서 얻을 수 있음), 이중 버퍼링 방법은 다음과 같은 경우 인터페이스 깜박임 문제를 해결하는 데 도움이 됩니다. 다시 그리기(이중 버퍼링을 사용하지 않는 경우 버퍼링 방법은 다시 그릴 때마다 이전 인터페이스에 새로운 것을 조금씩 그리는 것과 같습니다. 이중 버퍼링은 기본적으로 먼저 메모리에 직접 새 인터페이스 다이어그램을 그린 다음 직접 사용합니다. 인터페이스가 이전 인터페이스를 덮어씁니다.)

DataView.java 코드는 다음과 같습니다. (이 클래스는 직렬 포트 데이터를 실제로 표시하는 데 사용됩니다. 시간)

간단한 설명:

하드웨어 장치는 직렬 포트 도구가 하드웨어 장치에 성공적으로 연결되고 모니터링을 추가한 후 가끔씩 직렬 포트를 통해 컴퓨터로 데이터를 보냅니다. , 데이터를 수신할 때마다 데이터를 구문 분석하고 인터페이스를 업데이트합니다.

사용 시 요구 사항이 나와 다를 수 있습니다. 실제 사용 시 다시 필요할 수 있습니다. -데이터 표시 인터페이스 및 데이터 분석 방법 생성

작업 스크린샷:

package serialPort;
 
import java.awt.Button;
import java.awt.Choice;
import java.awt.Color;
import java.awt.Font;
import java.awt.Frame;
import java.awt.Graphics;
import java.awt.Image;
import java.awt.Label;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.util.List;
import java.util.TooManyListenersException;
 
import javax.swing.JOptionPane;
 
import gnu.io.SerialPort;
import gnu.io.SerialPortEvent;
import gnu.io.SerialPortEventListener;
import serialException.*;
 
/**
 * 监测数据显示类
 * @author Zhong
 *
 */
public class DataView extends Frame {
  
 /**
 * 
 */
 private static final long serialVersionUID = 1L;
 
 Client client = null;
 
 private List<String> commList = null; //保存可用端口号
 private SerialPort serialPort = null; //保存串口对象
  
 private Font font = new Font("微软雅黑", Font.BOLD, 25);
  
 private Label tem = new Label("暂无数据", Label.CENTER); //温度
 private Label hum = new Label("暂无数据", Label.CENTER); //湿度
 private Label pa = new Label("暂无数据", Label.CENTER); //压强
 private Label rain = new Label("暂无数据", Label.CENTER); //雨量
 private Label win_sp = new Label("暂无数据", Label.CENTER); //风速
 private Label win_dir = new Label("暂无数据", Label.CENTER); //风向
  
 private Choice commChoice = new Choice(); //串口选择（下拉框）
 private Choice bpsChoice = new Choice(); //波特率选择
  
 private Button openSerialButton = new Button("打开串口");
  
 Image offScreen = null; //重画时的画布
  
 //设置window的icon
 Toolkit toolKit = getToolkit();
 Image icon = toolKit.getImage(DataView.class.getResource("computer.png"));
 
 /**
 * 类的构造方法
 * @param client
 */
 public DataView(Client client) {
 this.client = client;
 commList = SerialTool.findPort(); //程序初始化时就扫描一次有效串口
 }
  
 /**
 * 主菜单窗口显示；
 * 添加Label、按钮、下拉条及相关事件监听；
 */
 public void dataFrame() {
 this.setBounds(client.LOC_X, client.LOC_Y, client.WIDTH, client.HEIGHT);
 this.setTitle("CDIO工程项目");
 this.setIconImage(icon);
 this.setBackground(Color.white);
 this.setLayout(null);
  
 this.addWindowListener(new WindowAdapter() {
  public void windowClosing(WindowEvent arg0) {
  if (serialPort != null) {
   //程序退出时关闭串口释放资源
   SerialTool.closePort(serialPort);
  }
  System.exit(0);
  }
   
 });
  
 tem.setBounds(140, 103, 225, 50);
 tem.setBackground(Color.black);
 tem.setFont(font);
 tem.setForeground(Color.white);
 add(tem);
  
 hum.setBounds(520, 103, 225, 50);
 hum.setBackground(Color.black);
 hum.setFont(font);
 hum.setForeground(Color.white);
 add(hum);
  
 pa.setBounds(140, 193, 225, 50);
 pa.setBackground(Color.black);
 pa.setFont(font);
 pa.setForeground(Color.white);
 add(pa);
 
 rain.setBounds(520, 193, 225, 50);
 rain.setBackground(Color.black);
 rain.setFont(font);
 rain.setForeground(Color.white);
 add(rain);
  
 win_sp.setBounds(140, 283, 225, 50);
 win_sp.setBackground(Color.black);
 win_sp.setFont(font);
 win_sp.setForeground(Color.white);
 add(win_sp);
  
 win_dir.setBounds(520, 283, 225, 50);
 win_dir.setBackground(Color.black);
 win_dir.setFont(font);
 win_dir.setForeground(Color.white);
 add(win_dir);
  
 //添加串口选择选项
 commChoice.setBounds(160, 397, 200, 200);
 //检查是否有可用串口，有则加入选项中
 if (commList == null || commList.size()<1) {
  JOptionPane.showMessageDialog(null, "没有搜索到有效串口！", "错误", JOptionPane.INFORMATION_MESSAGE);
 }
 else {
  for (String s : commList) {
  commChoice.add(s);
  }
 }
 add(commChoice);
  
 //添加波特率选项
 bpsChoice.setBounds(526, 396, 200, 200);
 bpsChoice.add("1200");
 bpsChoice.add("2400");
 bpsChoice.add("4800");
 bpsChoice.add("9600");
 bpsChoice.add("14400");
 bpsChoice.add("19200");
 bpsChoice.add("115200");
 add(bpsChoice);
  
 //添加打开串口按钮
 openSerialButton.setBounds(250, 490, 300, 50);
 openSerialButton.setBackground(Color.lightGray);
 openSerialButton.setFont(new Font("微软雅黑", Font.BOLD, 20));
 openSerialButton.setForeground(Color.darkGray);
 add(openSerialButton);
 //添加打开串口按钮的事件监听
 openSerialButton.addActionListener(new ActionListener() {
 
  public void actionPerformed(ActionEvent e) {
   
  //获取串口名称
  String commName = commChoice.getSelectedItem();  
  //获取波特率
  String bpsStr = bpsChoice.getSelectedItem();
   
  //检查串口名称是否获取正确
  if (commName == null || commName.equals("")) {
   JOptionPane.showMessageDialog(null, "没有搜索到有效串口！", "错误", JOptionPane.INFORMATION_MESSAGE);  
  }
  else {
   //检查波特率是否获取正确
   if (bpsStr == null || bpsStr.equals("")) {
   JOptionPane.showMessageDialog(null, "波特率获取错误！", "错误", JOptionPane.INFORMATION_MESSAGE);
   }
   else {
   //串口名、波特率均获取正确时
   int bps = Integer.parseInt(bpsStr);
   try {
     
    //获取指定端口名及波特率的串口对象
    serialPort = SerialTool.openPort(commName, bps);
    //在该串口对象上添加监听器
    SerialTool.addListener(serialPort, new SerialListener());
    //监听成功进行提示
    JOptionPane.showMessageDialog(null, "监听成功，稍后将显示监测数据！", "提示", JOptionPane.INFORMATION_MESSAGE);
     
   } catch (SerialPortParameterFailure | NotASerialPort | NoSuchPort | PortInUse | TooManyListeners e1) {
    //发生错误时使用一个Dialog提示具体的错误信息
    JOptionPane.showMessageDialog(null, e1, "错误", JOptionPane.INFORMATION_MESSAGE);
   }
   }
  }
   
  }
 });
  
  
 this.setResizable(false);
  
 new Thread(new RepaintThread()).start(); //启动重画线程
  
 }
  
 /**
 * 画出主界面组件元素
 */
 public void paint(Graphics g) {
 Color c = g.getColor();
  
 g.setColor(Color.black);
 g.setFont(new Font("微软雅黑", Font.BOLD, 25));
 g.drawString(" 温度： ", 45, 130);
 
 g.setColor(Color.black);
 g.setFont(new Font("微软雅黑", Font.BOLD, 25));
 g.drawString(" 湿度： ", 425, 130);
  
 g.setColor(Color.black);
 g.setFont(new Font("微软雅黑", Font.BOLD, 25));
 g.drawString(" 压强： ", 45, 220);
  
 g.setColor(Color.black);
 g.setFont(new Font("微软雅黑", Font.BOLD, 25));
 g.drawString(" 雨量： ", 425, 220);
  
 g.setColor(Color.black);
 g.setFont(new Font("微软雅黑", Font.BOLD, 25));
 g.drawString(" 风速： ", 45, 310);
  
 g.setColor(Color.black);
 g.setFont(new Font("微软雅黑", Font.BOLD, 25));
 g.drawString(" 风向： ", 425, 310);
  
 g.setColor(Color.gray);
 g.setFont(new Font("微软雅黑", Font.BOLD, 20));
 g.drawString(" 串口选择： ", 45, 410);
  
 g.setColor(Color.gray);
 g.setFont(new Font("微软雅黑", Font.BOLD, 20));
 g.drawString(" 波特率： ", 425, 410);
  
 }
  
 /**
 * 双缓冲方式重画界面各元素组件
 */
 public void update(Graphics g) {
 if (offScreen == null) offScreen = this.createImage(Client.WIDTH, Client.HEIGHT);
 Graphics gOffScreen = offScreen.getGraphics();
 Color c = gOffScreen.getColor();
 gOffScreen.setColor(Color.white);
 gOffScreen.fillRect(0, 0, Client.WIDTH, Client.HEIGHT); //重画背景画布
 this.paint(gOffScreen); //重画界面元素
 gOffScreen.setColor(c);
 g.drawImage(offScreen, 0, 0, null); //将新画好的画布“贴”在原画布上
 }
  
 /*
 * 重画线程（每隔30毫秒重画一次）
 */
 private class RepaintThread implements Runnable {
 public void run() {
  while(true) {
  //调用重画方法
  repaint();
   
   
   
  //扫描可用串口
  commList = SerialTool.findPort();
  if (commList != null && commList.size()>0) {
    
   //添加新扫描到的可用串口
   for (String s : commList) {
    
   //该串口名是否已存在，初始默认为不存在（在commList里存在但在commChoice里不存在，则新添加）
   boolean commExist = false; 
    
   for (int i=0; i<commChoice.getItemCount(); i++) {
    if (s.equals(commChoice.getItem(i))) {
    //当前扫描到的串口名已经在初始扫描时存在
    commExist = true;
    break;
    }   
   }
    
   if (commExist) {
    //当前扫描到的串口名已经在初始扫描时存在，直接进入下一次循环
    continue;
   }
   else {
    //若不存在则添加新串口名至可用串口下拉列表
    commChoice.add(s);
   }
   }
    
   //移除已经不可用的串口
   for (int i=0; i<commChoice.getItemCount(); i++) {
    
   //该串口是否已失效，初始默认为已经失效（在commChoice里存在但在commList里不存在，则已经失效）
   boolean commNotExist = true; 
    
   for (String s : commList) {
    if (s.equals(commChoice.getItem(i))) {
    commNotExist = false; 
    break;
    }
   }
    
   if (commNotExist) {
    //System.out.println("remove" + commChoice.getItem(i));
    commChoice.remove(i);
   }
   else {
    continue;
   }
   }
    
  }
  else {
   //如果扫描到的commList为空，则移除所有已有串口
   commChoice.removeAll();
  }
 
  try {
   Thread.sleep(30);
  } catch (InterruptedException e) {
   String err = ExceptionWriter.getErrorInfoFromException(e);
   JOptionPane.showMessageDialog(null, err, "错误", JOptionPane.INFORMATION_MESSAGE);
   System.exit(0);
  }
  }
 }
  
 }
  
 /**
 * 以内部类形式创建一个串口监听类
 * @author zhong
 *
 */
 private class SerialListener implements SerialPortEventListener {
  
 /**
  * 处理监控到的串口事件
  */
 public void serialEvent(SerialPortEvent serialPortEvent) {
   
  switch (serialPortEvent.getEventType()) {
 
  case SerialPortEvent.BI: // 10 通讯中断
   JOptionPane.showMessageDialog(null, "与串口设备通讯中断", "错误", JOptionPane.INFORMATION_MESSAGE);
   break;
 
  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 串口存在可用数据
    
   //System.out.println("found data");
   byte[] data = null;
    
   try {
   if (serialPort == null) {
    JOptionPane.showMessageDialog(null, "串口对象为空！监听失败！", "错误", JOptionPane.INFORMATION_MESSAGE);
   }
   else {
    data = SerialTool.readFromPort(serialPort); //读取数据，存入字节数组
    //System.out.println(new String(data));
     
   // 自定义解析过程，你在实际使用过程中可以按照自己的需求在接收到数据后对数据进行解析
    if (data == null || data.length < 1) { //检查数据是否读取正确 
    JOptionPane.showMessageDialog(null, "读取数据过程中未获取到有效数据！请检查设备或程序！", "错误", JOptionPane.INFORMATION_MESSAGE);
    System.exit(0);
    }
    else {
    String dataOriginal = new String(data); //将字节数组数据转换位为保存了原始数据的字符串
    String dataValid = ""; //有效数据（用来保存原始数据字符串去除最开头*号以后的字符串）
    String[] elements = null; //用来保存按空格拆分原始字符串后得到的字符串数组 
    //解析数据
    if (dataOriginal.charAt(0) == &#39;*&#39;) { //当数据的第一个字符是*号时表示数据接收完成，开始解析    
     dataValid = dataOriginal.substring(1);
     elements = dataValid.split(" ");
     if (elements == null || elements.length < 1) { //检查数据是否解析正确
     JOptionPane.showMessageDialog(null, "数据解析过程出错，请检查设备或程序！", "错误", JOptionPane.INFORMATION_MESSAGE);
     System.exit(0);
     }
     else {
     try {
      //更新界面Label值
      /*for (int i=0; i<elements.length; i++) {
      System.out.println(elements[i]);
      }*/
      //System.out.println("win_dir: " + elements[5]);
      tem.setText(elements[0] + " ℃");
      hum.setText(elements[1] + " %");
      pa.setText(elements[2] + " hPa");
      rain.setText(elements[3] + " mm");
      win_sp.setText(elements[4] + " m/s");
      win_dir.setText(elements[5] + " °");
     } catch (ArrayIndexOutOfBoundsException e) {
      JOptionPane.showMessageDialog(null, "数据解析过程出错，更新界面数据失败！请检查设备或程序！", "错误", JOptionPane.INFORMATION_MESSAGE);
      System.exit(0);
     }
     } 
    }
    }
     
   }   
    
   } catch (ReadDataFromSerialPortFailure | SerialPortInputStreamCloseFailure e) {
   JOptionPane.showMessageDialog(null, e, "错误", JOptionPane.INFORMATION_MESSAGE);
   System.exit(0); //发生读取错误时显示错误信息后退出系统
   } 
    
   break;
  
  }
 
 }
 
 }
  
  
}

위는 이 기사의 전체 내용이 모든 사람의 학습에 도움이 되기를 바랍니다. 또한 모든 사람이 PHP 중국어 웹사이트를 지원하기를 바랍니다.

Java 기반 직렬 통신 도구 작성과 관련된 더 많은 기사를 보려면 PHP 중국어 웹사이트를 주목하세요!