RTU example request

[DanielManjabacas]

Hi,

Could i have the RTU example?

Thanks in advance.
email: dmanjabacas@insece.es

[avcismail]

I can't connect to RTU. Please help. Where am I going wrong? I am getting the following error.
"Modbus master is not inited successfully..."

public void connect() {
        try {
            // Step 1: USB connection setup
            UsbManager manager = (UsbManager) getSystemService(Context.USB_SERVICE);
            List<UsbSerialDriver> availableDrivers = UsbSerialProber.getDefaultProber().findAllDrivers(manager);

            if (availableDrivers.isEmpty()) {
                Log.e("Modbus", "No USB device found.");
                Constants.isKerongActive = true;
                return;
            }

            // Choose the first available driver
            UsbSerialDriver driver = availableDrivers.get(0);
            UsbDeviceConnection connection = manager.openDevice(driver.getDevice());
            Constants._connection = connection;
            if (connection == null) {
                Log.e("Modbus", "Failed to open USB device.");
                return;
            }

            // Open the first port (typically port 0)
            Constants.usbSerialPort = driver.getPorts().get(0);
            Constants.usbSerialPort.open(connection);
            Constants.usbSerialPort.setParameters(57600, 8, 1, UsbSerialPort.PARITY_NONE);
            Log.d("Modbus", "USB Serial Port opened successfully.");

            // Step 2: Initialize Modbus RTU Master
            UsbSerialPortWrapper usbSerialPortWrapper = new UsbSerialPortWrapper(Constants.usbSerialPort);
            RtuMaster rtuMaster = new RtuMaster(usbSerialPortWrapper);
            rtuMaster.init();


            // Step 3: Send Modbus register write requests
            ModbusReq.getInstance().writeRegister(new OnRequestBack<String>() {
                @Override
                public void onSuccess(String s) {
                    Log.d("Modbus", "First write success: " + s);
                }

                @Override
                public void onFailed(String msg) {
                    Log.e("Modbus", "First write failed: " + msg);
                }
            }, 1, 10, 1);

            // Wait for the first request to complete
            Thread.sleep(1000);

            // Second Modbus register write request
            ModbusReq.getInstance().writeRegister(new OnRequestBack<String>() {
                @Override
                public void onSuccess(String s) {
                    Log.d("Modbus", "Second write success: " + s);
                }

                @Override
                public void onFailed(String msg) {
                    Log.e("Modbus", "Second write failed: " + msg);
                }
            }, 1, 13, 255);

        } catch (Exception ex) {
            Log.e("Modbus", "Error occurred: " + ex.getMessage(), ex);
            ex.printStackTrace();
        }
    }

public class UsbSerialPortWrapper implements SerialPortWrapper {
    private UsbSerialPort usbSerialPort;

    public UsbSerialPortWrapper(UsbSerialPort usbSerialPort) {
        this.usbSerialPort = usbSerialPort;
    }

    @Override
    public void open() throws IOException {
        //usbSerialPort.open(Constants._connection);
    }

    @Override
    public void close() throws IOException {
        usbSerialPort.close();
    }



    @Override
    public InputStream getInputStream() {
        return new InputStream() {
            @Override
            public int read() throws IOException {
                byte[] buffer = new byte[1];
                int size = usbSerialPort.read(buffer, 1000); // Timeout 1 saniye
                if (size > 0) {
                    return buffer[0] & 0xFF;
                }
                return -1; // Hiçbir veri okunamadı
            }

            @Override
            public int read(byte[] buffer, int offset, int length) throws IOException {
                byte[] tempBuffer = new byte[length];
                int size = usbSerialPort.read(tempBuffer, 1000); // Timeout 1 saniye
                if (size > 0) {
                    System.arraycopy(tempBuffer, 0, buffer, offset, size);
                }
                return size;
            }
        };
    }

    @Override
    public OutputStream getOutputStream() {
        return new OutputStream() {
            @Override
            public void write(int b) throws IOException {
                byte[] buffer = {(byte) b};
                usbSerialPort.write(buffer, 1000); // Timeout 1 saniye
            }

            @Override
            public void write(byte[] buffer, int offset, int length) throws IOException {
                byte[] tempBuffer = new byte[length];
                System.arraycopy(buffer, offset, tempBuffer, 0, length);
                usbSerialPort.write(tempBuffer, 1000); // Timeout 1 saniye
            }
        };
    }


    @Override
    public int getBaudRate() {
        return 57600;
    }

    @Override
    public int getFlowControlIn() {
        return 0;
    }

    @Override
    public int getFlowControlOut() {
        return 0;
    }

    @Override
    public int getDataBits() {
        return 8;
    }

    @Override
    public int getStopBits() {
        return 1;
    }

    @Override
    public int getParity() {
        return 0;
    }
}