Непрерывное и одновременное чтение и запись данных

Question

Я не могу прочитать данные с любого устройства на Android-приложение. Если я выполняю непрерывную и одновременную передачу данных, любой из способов отсоединения, хотя Bluetooth подключен.

Я пытаюсь получить 30 байтов данных от любого устройства непрерывно. Я пытался с изменением размера mtu, но бесполезно. Если я начну отправлять 30 байтов данных из приложения, получение данных с любого устройства в приложение будет остановлено. Я не могу сделать одновременную передачу данных. Может кто-нибудь, пожалуйста, помогите мне сделать одновременную передачу данных непрерывно. Я отправляю 30 байт данных на устройство ble со скоростью 300 мс, и мне необходимо получить 30 байт данных с устройства ble со скоростью 1 сек. Я успешно могу читать или записывать одновременно. Но не оба одновременно.

Если я исправлю размер mtu на 20, я смогу одновременно прочитать 20 байтов с устройства ble. Но я должен прочитать 30 байтов данных с устройства ble.

Я также хотел знать, есть ли возможность непрерывного чтения и записи одновременно поверх данных без потери данных?

Я выполняю gatt.requestMtu (512) во время успешного подключения к gatt.

 public void onConnectionStateChange(BluetoothGatt gatt, int status, int newState) {
            String intentAction;
            if (newState == BluetoothProfile.STATE_CONNECTED) {
                intentAction = ACTION_GATT_CONNECTED;
                mConnectionState = STATE_CONNECTED;
                broadcastUpdate(intentAction);
                gatt.requestMtu(512);
                Intent i = new Intent("status").putExtra("status",staticConnectionStatus);
                sendBroadcast(i);
            } else if (newState == BluetoothProfile.STATE_DISCONNECTED) {
                intentAction = ACTION_GATT_DISCONNECTED;
                mConnectionState = STATE_DISCONNECTED;
                Intent intent = new Intent("status");
                intent.putExtra("status", staticConnectionStatus);
                sendBroadcast(intent);
                Log.d(TAG, "Disconnected from GATT server.");
                broadcastUpdate(intentAction);
            }
        }

    @Override
    public void onCharacteristicRead(BluetoothGatt gatt,
                                     BluetoothGattCharacteristic characteristic,
                                     int status) {


        if (status == BluetoothGatt.GATT_SUCCESS) {
            Log.d(TAG, "ACTION_DATA_AVAILABLE" + ACTION_DATA_AVAILABLE);
            broadcastUpdate(ACTION_DATA_AVAILABLE, characteristic);

            byte[] charValue = characteristic.getValue();
            byte flag = charValue[0];


        } else if (status == BluetoothGatt.GATT_FAILURE) {
            Log.d(TAG, "failed");
        }

        byte[] charValue = characteristic.getValue();
        byte flag = charValue[0];
    }
    @Override
    public void onCharacteristicChanged(BluetoothGatt gatt, BluetoothGattCharacteristic characteristic) {
        //gatt.requestMtu(185);
        broadcastUpdate(ACTION_DATA_AVAILABLE, characteristic);
        byte[] charValue = characteristic.getValue();
        byte flag = charValue[0];

    }
};



  public void writeRXCharacteristic(byte[] value) {


        if (mBluetoothGatt != null) {


//            try {
//                Thread.sleep(200);
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }

            BluetoothGattService RxService = mBluetoothGatt.getService(UUID.fromString("0000FEFB-0000-1000-8000-00805F9B34FB"));

            if (RxService == null) {
//                showMessage("Rx service not found!");
                broadcastUpdate(DEVICE_DOES_NOT_SUPPORT_UART);
                return;
            }
            BluetoothGattCharacteristic RxChar = RxService.getCharacteristic(UUID.fromString("00000001-0000-1000-8000-008025000000"));

            if (RxChar == null) {
//                showMessage("Rx charateristic not found!");
                broadcastUpdate(DEVICE_DOES_NOT_SUPPORT_UART);
                return;
            }

            RxChar.setWriteType(BluetoothGattCharacteristic.WRITE_TYPE_DEFAULT);
            RxChar.setValue(value);

            if (mBluetoothGatt != null) {
                boolean status = mBluetoothGatt.writeCharacteristic(RxChar);
            } else {
                broadcastUpdate(DEVICE_DOES_NOT_SUPPORT_UART);
            }


        } else {
            broadcastUpdate(DEVICE_DOES_NOT_SUPPORT_UART);
        }

    }


//Im notifying the service UUID on services discovered
        BluetoothGattCharacteristic TxChar = RxService.getCharacteristic(UUID.fromString("00000002-0000-1000-8000-008025000000"));
    mBluetoothGatt.setCharacteristicNotification(TxChar, true);

Answer 1

Вот некоторый сопоставимый код Kotlin, который работает с последовательным соединением и увеличенным размером MTU. Я удалил обработку ошибок, ведение журнала и некоторый код приложения.

Он использует две характеристики: - Характеристика command используется для отправки данных с телефона на устройство. - Характеристика обратная связь используется для получения данных, отправляемых устройством.

Обратите внимание на то, как это работает:

• Создание рабочего соединения проходит через несколько этапов иожидает завершения каждой фазы перед началом следующей фазы: подключение, обнаружение служб, увеличение MTU.
• Характеристики сохраняются в переменных экземпляра после обнаружения служб.
• Соединение готово послеобратный вызов изменения MTU.
• Уведомления включаются после изменения MTU.
• Включение уведомлений выполняется с помощью setCharacteristicNotification . Не нужно возиться с дескрипторами.

import android.bluetooth.BluetoothGatt
import android.bluetooth.BluetoothGattCallback
import android.bluetooth.BluetoothGattCharacteristic
import android.bluetooth.BluetoothProfile

class BleConnection(private val device: BluetoothDevice) : Connection {

    private var deviceGatt: BluetoothGatt? = null
    private var commandCharacteristic: BluetoothGattCharacteristic? = null
    private var feedbackCharacteristic: BluetoothGattCharacteristic? = null

    private val gattCallback = object: BluetoothGattCallback() {    
        override fun onConnectionStateChange(gatt: BluetoothGatt?, status: Int, newState: Int) {
            this@BleConnection.onConnectionStateChange(gatt, newState)
        }
        override fun onServicesDiscovered(gatt: BluetoothGatt?, status: Int) {
            this@BleConnection.onServicesDiscovered(gatt)
        }
        override fun onCharacteristicChanged(gatt: BluetoothGatt?, characteristic: BluetoothGattCharacteristic?) {
            this@BleConnection.onCharacteristicChanged(characteristic)
        }
        override fun onMtuChanged(gatt: BluetoothGatt?, mtu: Int, status: Int) {
            this@BleConnection.onMtuChange(gatt)
        }
    }

    // Start to connect
    override fun connect() {
        deviceGatt = device.connectGatt(null, false, gattCallback)
    }

    // The connection state has changed
    private fun onConnectionStateChange(gatt: BluetoothGatt?, newState: Int) {
        when (newState) {
            BluetoothProfile.STATE_CONNECTED -> {
                gatt!!.discoverServices()
            }
            BluetoothProfile.STATE_DISCONNECTED -> {
                ...
            }
        }
    }

    // GATT services have been discovered
    fun onServicesDiscovered(gatt: BluetoothGatt?) {    
        for (service in gatt!!.services) {  
            if (service.uuid == Constants.SERVICE_UUID) {
                feedbackCharacteristic = service.getCharacteristic(Constants.FEEDBACK_CHAR_UUID)
                commandCharacteristic = service.getCharacteristic(Constants.COMMAND_CHAR_UUID)
                 // Increase the MTU
                 gatt.requestMtu(256)
            }
        }
    }

    // The MTU has successfully been changed
    fun onMtuChange(gatt: BluetoothGatt?) {
        gatt!!.setCharacteristicNotification(feedbackCharacteristic, true)
        // ... notify that connection is fully established and ready
    } 

    // Characteristic has been changed (i.e. new data has been received)
    fun onCharacteristicChanged(characteristic: BluetoothGattCharacteristic?) {
        val data = characteristic!!.value
        // ... process the received data
    }

    // may only be called after the connection has been fully established
    // (see onMtuChange() )
    override fun sendData(command: ByteArray) {
        commandCharacteristic!!.value = command
        deviceGatt!!.writeCharacteristic(commandCharacteristic!!)
    }    
}