JavaFx, простой терминал COM порта

в 23:32, , рубрики: java, javafx, Программирование, разработка под windows

В жизни embedded разработчика, часто возникает потребность взаимодействия с серийным портом
И пускай RS-232 почти полностью вытеснен современными интерфейсами, UART похоже никуда не собирается уходить

Большинство модулей (WI-FI, IoT и др.), демоплат/одноплатников работают или имеют на борту UART

JavaFx, простой терминал COM порта - 1

Терминальных программ огромное множество, самые заметные — Putty и termianl v1.9b
Они отлично справляются с задачами, но сложности начинаются, когда открытых соединений больше одного
На переключение и поиск нужного окна уходит много времени

Тогда возникла идея, почему бы не написать терминал, где каждое соединение будет в отдельной вкладке, и каждый пришедший пакет будет на ней сигнализировать
Уверен, это удобнее 4-ех терминалов разбросанных по разным экранам

Выбор был между node webkit, Qt и javaFx
Node webkit испугал возможной прожорливостью, Qt имхо долгий в разработке/отладке

JavaFx, простой терминал COM порта - 2
JavaFx, простой терминал COM порта - 3
JavaFx, простой терминал COM порта - 4

Первым делом была набросана блок схема
JavaFx, простой терминал COM порта - 5
И уже к вечеру был относительно рабочий проект

Наверно нет смысла выкладывать здесь весь код
Проект есть на гите

Представлю наиболее интересную на мой взгляд часть:

public class ConnectionData {
    @FXML
    public TextArea receiveData;
    @FXML
    public TextField sendData;
    @FXML
    public Button sendButton;

    private StringProperty sendDataProperty = new SimpleStringProperty("");
    BlockingQueue<String> rxDataQueue = new LinkedBlockingQueue<>();

    @FXML
    public void initialize() {
        sendData.textProperty().bindBidirectional(sendDataProperty);
        sendButton.disableProperty().bind(sendDataProperty.isEmpty());

        Task<Void> task = new Task<Void>() {
            @Override
            public Void call() throws Exception {
                Platform.runLater(() -> new MessageConsumer(rxDataQueue, receiveData, rxDataQueue.size()).start());
                while(true) {
                    if(rxDataQueue.size() != 0) {
                        rxDataQueue.put(rxDataQueue.take().toString());
                        rxDataQueue.remove(0);
                    }
                    Thread.sleep(100);
                }
            }
        };
        new Thread(task).start();
    }

    public class MessageConsumer extends AnimationTimer {
        private final BlockingQueue<String> messageQueue ;
        private final TextArea textArea ;
        private int messagesReceived = 0 ;
        public MessageConsumer(BlockingQueue<String> messageQueue, TextArea textArea, int numMessages) {
            this.messageQueue = messageQueue ;
            this.textArea = textArea ;
        }
        @Override
        public void handle(long now) {
            List<String> messages = new ArrayList<>();
            messagesReceived += messageQueue.drainTo(messages);
            messages.forEach(msg -> textArea.appendText(msg));
        }
    }

    public Button getPropertySendButton() {
        return sendButton;
    }

    public String getSendDataProperty() {
        String sendBuff = sendDataProperty.get();
        sendDataProperty.set("");
        return sendBuff;
    }

    public void clearReceiveData() {
        receiveData.textProperty().setValue("");
    }

    public void setReceiveData(byte[] buffer) {
        try {
            rxDataQueue.add(new String(buffer, "UTF-8"));
        } catch (UnsupportedEncodingException ex) {
            System.err.print(ex);
        }
    }
}

Класс формы для вывода принятого — TextField (sendData)

Если напрямую писать данные в буфер и отправлять сразу в TextField, очень скоро возникнет nullException, т.к. они в разных потоках

Для этого, как не сложно догадаться, используется очередь — BlockingQueue rxDataQueue

Данные принимаются с SerialPort (jssc) и помещаются в очередь через вызов setReceiveData
Как только они помещаются, rxDataQueue.size() — становится (!=isEmpty)
Task task заберет первый элемент и после отправки удалит его из очереди

Что хочется получить дальше и что планируется из функционала:
— наверно требуется сохранение конфигов по портам
— ssh клиент (гибкий и интуитивно понятный!)
— добавление настраиваемого цвета к вкладкам
— довести интерфейс до приятного вида, css, JFoenix

Гит
github.com/khomin/Terminal_Serial_Java
Собранная сборка
yadi.sk/d/zbennIV53VPFct

Автор: Khomin

Источник

* - обязательные к заполнению поля


https://ajax.googleapis.com/ajax/libs/jquery/3.4.1/jquery.min.js