JSSC-断开连接会导致阻塞串行端口



我正在使用JSSC串行端口软件包在我的应用程序和连接到串行端口的设备之间交换数据。我制作了一个简单的应用程序,可以将标识消息发送到设备并打印响应。我希望它能抵抗连接错误(例如,在通信过程中拔下电缆后(。

动作序列init-> open-> idn->关闭完美工作。打开端口后拔下电缆时,我无法发送消息(对我来说似乎是合乎逻辑的(并关闭端口(没有什么可关闭的,所以我也明白这一点(。

在一开始,我很惊讶地再次插入电缆后无法关闭端口,但是我发现,在设备的每次连接后,OS给出了JSSC库来处理端口的不同数字。幸运的是,事实证明,重新连接后仅打开端口解决所有问题,因为该应用程序可以再次发送消息。

不幸的是,当端口打开时有更多尝试断开/连接电缆的尝试时,问题就开始了。每次尝试之后,应用程序的工作速度较慢,结束时,当无法发送消息时,该应用程序在该州结束。另一件事是,在这种状态下,所有串行端口(不仅是我尝试与之通信的端口(都被阻止了,我什至无法通过类似终端的应用程序访问它们。

所以问题是:

如何使该应用程序能够抵抗连接断裂,而不会阻止端口并失去性能?

我想这可能是关于某种资源,内存管理或这样的知识,但是我对这些事情的了解不足以解决问题。

交流的实现:

import jssc.SerialPort;
import jssc.SerialPortEvent;
import jssc.SerialPortEventListener;
import jssc.SerialPortException;
class Connection implements SerialPortEventListener {
  private static final int SERIAL_PORT_BAUD_RATE = 9600;
  private static final int SERIAL_PORT_DATA_BITS_NUMBER = 8;
  private static final int SERIAL_PORT_STOP_BITS_NUMBER = 1;
  private static final int SERIAL_PORT_PARITY = 0;
  private SerialPort serialPort;
  private String portName;
  public Connection(String portName) {
    this.portName = portName;
  }
  public void open() throws SerialPortException {
    serialPort = new SerialPort(portName);
    serialPort.openPort();
    serialPort.setParams(SERIAL_PORT_BAUD_RATE,
            SERIAL_PORT_DATA_BITS_NUMBER,
            SERIAL_PORT_STOP_BITS_NUMBER,
            SERIAL_PORT_PARITY);
    serialPort.addEventListener(this);
  }
  public void close() throws SerialPortException {
    if (serialPort != null) {
      serialPort.closePort();
    }
  }
  public void simpleMessage() throws SerialPortException {
    if (serialPort != null) {
      serialPort.writeString("IDN");
    }
  }
  @Override
  public void serialEvent(SerialPortEvent serialPortEvent) {
    if (serialPortEvent.getEventType() == SerialPortEvent.RXCHAR) {
      try {
        System.out.println(serialPort.readString());
      } catch (SerialPortException e) {
        System.out.println("Error while reading a string.");
      }
    }
  }
}

主类:

import javafx.application.Application;
import javafx.application.Platform;
import javafx.fxml.FXMLLoader;
import javafx.scene.Scene;
import javafx.scene.layout.Pane;
import javafx.stage.Stage;
import java.io.IOException;
public class MainApplication extends Application{
  public static void main(String [] args) {
    Application.launch();
  }
  @Override
  public void start(Stage primaryStage) throws Exception {
    Pane rootPane = null;
    FXMLLoader loader = new FXMLLoader();
    loader.setLocation(MainApplication.class.getResource("front.fxml"));
    try{
      rootPane = loader.load();
    } catch (IOException exception) {
      exception.printStackTrace();
    }
    Scene scene = new Scene(rootPane);
    primaryStage.setScene(scene);
    primaryStage.show();
    primaryStage.setOnCloseRequest(event -> {
      Platform.exit();
      System.exit(0);
    });
  }
}

FXML代码:

<?xml version="1.0" encoding="UTF-8"?>
<?import javafx.scene.layout.StackPane?>
<?import javafx.scene.control.Button?>
<?import javafx.scene.layout.VBox?>
<StackPane fx:id="rootPane"
           xmlns="http://javafx.com/javafx/8.0.60"
           xmlns:fx="http://javafx.com/fxml/1"
           fx:controller="FrontController">
    <VBox>
        <Button text="Init" onAction="#init"/>
        <Button text="Open" onAction="#openPort"/>
        <Button text="Close" onAction="#closePort"/>
        <Button text="IDN" onAction="#idn"/>
        <Button text="Get Ports" onAction="#getPorts"/>
        <Button text="Is opened?" onAction="#isPortOpen"/>
    </VBox>
</StackPane>

控制器:

import javafx.fxml.FXML;
import jssc.SerialPortException;
import jssc.SerialPortList;
import java.util.Arrays;
public class FrontController {
  private Connection connection;
  @FXML
  private void init() {
    String portName = "COM4";
    connection = new Connection(portName);
  }
  @FXML
  private void openPort() {
    try {
      connection.open();
    } catch (SerialPortException e) {
      e.printStackTrace();
    }
  }
  @FXML
  private void closePort() {
    try {
      connection.close();
    } catch (SerialPortException e) {
      e.printStackTrace();
    }
  }
  @FXML
  private void idn() {
    try {
      connection.idnMessage();
    } catch (SerialPortException e) {
      e.printStackTrace();
    }
  }
  @FXML
  private void getPorts() {
    System.out.println(Arrays.toString(SerialPortList.getPortNames()));
  }
  @FXML
  private void isPortOpen() {
    System.out.println(connection.getSerialPort().isOpened());
  }
}

基本上是在不关闭的情况下(在Windows OS中大多数情况下实际上(将操作系统留下不一致的状态。卸下设备时,您需要进行清理。请注意,即使卸下设备,关闭端口也非常重要。我们可能会留下关闭的回报值。这给出了OS的提示,该应用程序也对设备不感兴趣,因此OS具有发布我们也想要的资源的自由。因此,简而言之,我们需要创建一个线程,该线程将监视我们的设备是否连接到系统。

相关内容

  • 没有找到相关文章

最新更新