try {
        SerialPortListener.statListen("/dev/ttyS3", 9600, 0)
                .subscribeOn(Schedulers.io())
                .subscribe(new Consumer<byte[]>() {
                    @Override
                    public void accept(byte[] bytes) throws Exception {
                        //todo 实现业务逻辑
                    }
                }, new Consumer<Throwable>() {
                    @Override
                    public void accept(Throwable throwable) throws Exception {

                    }
                });
    } catch (Exception e) {
        e.printStackTrace();
    }

SerialPortSender.send(serialPortFileName,bytes);

SerialPortListener.stop(serialPortFileName);