onServices在連接到GATT服務器時從未被調用

Question

我有一個與我的Nexus 5X（運行Android 7.1）配對的藍牙耳機，並且我想連接到耳機的GATT服務器。我用下面的代碼試了一下：

private BluetoothGattCallback btleGattCallback = new BluetoothGattCallback() { 
    @Override 
    public void onConnectionStateChange(BluetoothGatt gatt, int status, int newState) { 
     Log.d(TAG, "onConnectionStateChange: " + status + ", " + newState); 

     if(newState == STATE_CONNECTED) { 
      Log.d(TAG, "Device connected"); 
      boolean ans = gatt.discoverServices(); 
      Log.d(TAG, "Discover Services started: " + ans); 
     } 
    } 

    @Override 
    public void onServicesDiscovered(BluetoothGatt gatt, int status) { 
      Log.d(TAG, "Number of Services: " + gatt.getServices().size()); 
    } 
}; 

public void onDeviceClicked(BluetoothDevice device) { 
    BluetoothGatt gatt = device.connectGatt(this, false, btleGattCallback); 
    Log.d(TAG, "Connected to GATT: " + gatt.connect()); 
} 

如果我點擊我的UI onDeviceClicked耳機打電話，談到這個日誌輸出：

<!-- language: lang-none --> 
Connected to GATT: true 
onConnectionStateChange: 0, 2 // GATT_SUCCESS, STATE_CONNECTED 
Device connected 
Discover Services started: true 

正如你可以看到onServicesDiscovered是從來沒有發射。我試圖撥打connectGatt與TRANSPORT_LE（ref），但後來我得到一個onConnectionStateChange: 133, 0。我還發現this question這就是爲什麼我加入了回答二中提到的gatt.connect()方法的原因。

你有什麼想法，爲什麼我沒有得到onServicesDiscovered回調？

Answer 1

東西已經非常有用，我是等待大約600毫秒的連接建立後，然後啓動該服務發現。

Answer 2

Android上的BLE可能會有點挑剔。

確保您在UI線程上調用mBluetoothGatt.discoverServices（）。

if(newState == STATE_CONNECTED) { 
    Log.d(TAG, "Device connected"); 
    new Handler(Looper.getMainLooper()).post(new Runnable() { 
     @Override 
     public void run() { 
      boolean ans = mBluetoothGatt.discoverServices(); 
      Log.d(TAG, "Discover Services started: " + ans); 
     } 
    }); 
} 

也可以嘗試做BluetoothGatt gatt一個字段變量而不是局部變量。

如果您正在做任何重要的工作，請嘗試使用一個掩蓋所有特質的庫，以便您可以專注於高級邏輯。 https://github.com/Polidea/RxAndroidBle。

以下是如何讀取特徵的示例。

 connectionObservable 
       .flatMap(rxBleConnection -> rxBleConnection.readCharacteristic(characteristicUuid)) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(bytes -> { 
        readOutputView.setText(new String(bytes)); 
        readHexOutputView.setText(HexString.bytesToHex(bytes)); 
        writeInput.setText(HexString.bytesToHex(bytes)); 
       }, this::onReadFailure); 

或者與Java 7的語法

 connectionObservable 
       .flatMap(new Func1<RxBleConnection, Observable<byte[]>>() { 
        @Override 
        public Observable<byte[]> call(RxBleConnection rxBleConnection) { 
         return rxBleConnection.readCharacteristic(characteristicUuid); 
        } 
       }) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Subscriber<byte[]>() { 
        @Override 
        public void onCompleted() { 

        } 

        @Override 
        public void onError(Throwable e) { 
         onReadFailure(e); 
        } 

        @Override 
        public void onNext(byte[] bytes) { 
         readOutputView.setText(new String(bytes)); 
         readHexOutputView.setText(HexString.bytesToHex(bytes)); 
         writeInput.setText(HexString.bytesToHex(bytes)); 
        } 
       }); 

Answer 3

這可能有助於

我將分兩個步驟說明：連接和發現服務

連接： 從mainthread連接，如果版本更大

設置的自動重新連接到假

大於或等於M，設置Tranposrt類型

其他直接用反思和妥善處理

Handler(applicationContext.mainLooper).post { 
        Log.d(TAG, " Post is called inside mainlooper") 
        mBluetoothGatt = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) { 
         Log.d(TAG, " Is Or Greater than M $mBluetoothDevice") 
         mBluetoothDevice!!.connectGatt(this, false, 
           onGhattListener, TRANSPORT_LE) 
        } else { 
         Log.d(TAG, " Less than M") 
         try { 
          Log.d(TAG, " Trying TRANPORT LE with reflection") 
          val m = mBluetoothDevice!!.javaClass.getDeclaredMethod("connectGatt", Context::class.java, Boolean::class.javaPrimitiveType, BluetoothGattCallback::class.java, Int::class.javaPrimitiveType) 
          m.isAccessible = true 
          val transport = mBluetoothDevice!!.javaClass.getDeclaredField("TRANSPORT_LE").getInt(null) 
          m.invoke(mBluetoothDevice, this, false, onGhattListener, transport) as BluetoothGatt 
         } catch (e: Exception) { 
          e.printStackTrace() 
          Log.d(TAG, " Catch to call normal connection") 
          mBluetoothDevice!!.connectGatt(this, false, 
            onGhattListener) 
         } 
        } 
        Log.d(TAG, "mBluetooth gatt is $mBluetoothGatt") 
        mBluetoothGatt?.let { 
         refreshDeviceCache(mBluetoothGatt!!) 
        } 
       } 

disover服務：在onGhattListener，如果設備是從主線程

override fun onConnectionStateChange(gatt: BluetoothGatt, status: Int, 
             newState: Int) { 
     Log.d(TAG, "onConnectionStateChange $gatt and status $status and newstate $newState") 
     when (newState) { 
      BluetoothGatt.STATE_CONNECTED -> { 
       Handler(Looper.getMainLooper()).post { 
        gatt.discoverServices() 
       } 
      } 
      BluetoothGatt.STATE_DISCONNECTED -> { 

      } 
      BluetoothGatt.STATE_CONNECTING -> { 

      } 
      BluetoothGatt.STATE_DISCONNECTING -> { 

      } 
     } 
    } 

連接消防discoverServices()這可能會解決你的問題

帶反射的呼叫刷新方法

fun refreshDeviceCache(gatt: BluetoothGatt): Boolean { 
    try { 
     val localMethod = gatt.javaClass.getMethod("refresh") 
     if (localMethod != null) { 
      return localMethod.invoke(gatt) as Boolean 
     } 
    } catch (localException: Exception) { 
     Log.e(TAG, "An exception occured while refreshing device") 
     localException.printStackTrace() 
    } 
    return false 
}