Android端末 BLE受信 同じ値を受信し続けてしまう問題[java]

Question

ご覧いただきありがとうございます。
ラズパイ3からandroid(google pixel 6)に数値を10秒おきに増加させ、10秒おきにその数値を送るシステムを作っています。
同じ数値は一度のみしか送りません。
しかし、現在android側の受信で、同じ数字が10秒の間に何度も受信が確認できています。
10秒後、数字は1個増加しますが、また次の数字も10秒間に何度も受信しています。

現在原因分からず、質問させていただきます。
送信側はコメントに掲載しています。

現時点で、一度もonCharacteristicChangedが実行できていないのが問題なのかなと
個人的に考えています...

前提条件

セントラル: Android(google Pixel 6)
ペリフェラル: ラズパイ3

ラズパイ側のプログラムは字数制限で掲載できておりません。
また、java側のプログラムも長文のため、importは省略しております。

public class MainActivity extends Activity {
    private final static String TAG = MainActivity.class.getSimpleName();
    private static final int REQUEST_PERMISSION_CODE = 2;

    private BluetoothAdapter mBluetoothAdapter;
    private BluetoothLeScanner mBluetoothLeScanner;
    private BluetoothGatt mBluetoothGatt;
    private boolean mScanning;

    private static final UUID MY_SERVICE_UUID = UUID.fromString("00001111-0000-1000-8000-00805F9B34FB");
    private static final UUID MY_CHARACTERISTIC_UUID = UUID.fromString("00002211-0000-1000-8000-00805F9B34FB");

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        // BluetoothManagerを取得し、アダプターを取得する。
        final BluetoothManager bluetoothManager = (BluetoothManager) getSystemService(Context.BLUETOOTH_SERVICE);
        mBluetoothAdapter = bluetoothManager.getAdapter();
        Log.d(TAG, "111");
        // BLEがサポートされているか確認する。
        if (!getPackageManager().hasSystemFeature(PackageManager.FEATURE_BLUETOOTH_LE)) {
            finish();
        }

        mBluetoothLeScanner = mBluetoothAdapter.getBluetoothLeScanner();
        requestPermissions();

    }

    private void requestPermissions() {
        List<String> permissionsNeeded = new ArrayList<>();
        if (ContextCompat.checkSelfPermission(this, Manifest.permission.ACCESS_FINE_LOCATION) != PackageManager.PERMISSION_GRANTED) {
            permissionsNeeded.add(Manifest.permission.ACCESS_FINE_LOCATION);
        }
        if (ContextCompat.checkSelfPermission(this, Manifest.permission.BLUETOOTH_SCAN) != PackageManager.PERMISSION_GRANTED) {
            permissionsNeeded.add(Manifest.permission.BLUETOOTH_SCAN);
        }
        if (ContextCompat.checkSelfPermission(this, Manifest.permission.BLUETOOTH_CONNECT) != PackageManager.PERMISSION_GRANTED) {
            permissionsNeeded.add(Manifest.permission.BLUETOOTH_CONNECT);
        }

        if (!permissionsNeeded.isEmpty()) {
            ActivityCompat.requestPermissions(this, permissionsNeeded.toArray(new String[0]), REQUEST_PERMISSION_CODE);
        } else {
            scanLeDevice(true);
        }
    }


    private void scanLeDevice(final boolean enable) {
        if (enable) {

            if (ActivityCompat.checkSelfPermission(this, android.Manifest.permission.BLUETOOTH_SCAN) != PackageManager.PERMISSION_GRANTED) {

                return;
            }
            Log.d(TAG, "222");
            mBluetoothLeScanner.startScan(mLeScanCallback);
            mScanning = true;
        } else {
            mBluetoothLeScanner.stopScan(mLeScanCallback);
            mScanning = false;
        }
    }

    // スキャンのコールバック。
    private ScanCallback mLeScanCallback = new ScanCallback() {
        @Override
        public void onScanResult(int callbackType, ScanResult result) {
            super.onScanResult(callbackType, result);
            // スキャン結果から、デバイスを取得し、Gattサーバーへ接続する。
            BluetoothDevice device = result.getDevice();
            if (String.valueOf(device).equals("B8:27:EB:F1:9C:71")) { // 指定されたMACアドレスと比較 研究室用
            //if (String.valueOf(device).equals("B8:27:EB:98:26:06")) { // 指定されたMACアドレスと比較 家用
                if (ActivityCompat.checkSelfPermission(MainActivity.this, Manifest.permission.BLUETOOTH_CONNECT) != PackageManager.PERMISSION_GRANTED) {
                    return;
                }
                Log.d(TAG, device.getName());
                Log.d(TAG, "find!!!");
                if (ActivityCompat.checkSelfPermission(MainActivity.this, android.Manifest.permission.BLUETOOTH_CONNECT) != PackageManager.PERMISSION_GRANTED) {
                    Log.d(TAG, "許可がないよ1");
                    return;
                }
                Log.d(TAG, "333");
                mBluetoothGatt = device.connectGatt(MainActivity.this, false, mGattCallback);
            }
        }
    };

    // Gattコールバック。
    private final BluetoothGattCallback mGattCallback = new BluetoothGattCallback() {
        @Override
        public void onConnectionStateChange(BluetoothGatt gatt, int status, int newState) {
            Log.d(TAG, "444");
            if (status == BluetoothGatt.GATT_SUCCESS && newState == BluetoothGatt.STATE_CONNECTED) {
                Log.d(TAG, "555");
                // GATTサーバーに接続成功。サービスを探索する。
                if (ActivityCompat.checkSelfPermission(MainActivity.this, android.Manifest.permission.BLUETOOTH_CONNECT) != PackageManager.PERMISSION_GRANTED) {
                    return;
                }

                gatt.discoverServices();
                Log.d(TAG, "666");
            } else {
                // GATTサーバーへの接続が切断または失敗。スキャンを再開する。
                Log.d(TAG,"切れちゃった");
                scanLeDevice(true);
            }

        }

        @Override
        public void onServicesDiscovered(BluetoothGatt gatt, int status) {
            Log.d(TAG, "1111111");
            // 対象のサービスとキャラクタリスティックを見つけ、Notificationをセットする。
            if (status == BluetoothGatt.GATT_SUCCESS) {
                Log.d(TAG, "777");
                BluetoothGattService service = gatt.getService(MY_SERVICE_UUID);
                Log.d(TAG, "888");
                if (service != null) {
                    BluetoothGattCharacteristic characteristic = service.getCharacteristic(MY_CHARACTERISTIC_UUID);
                    Log.d(TAG, "999");
                    if (characteristic != null) {
                        // Characteristicのプロパティを確認し、必要な処理を実装する
                        int properties = characteristic.getProperties();
                        if ((properties & BluetoothGattCharacteristic.PROPERTY_READ) != 0) {
                            if (ActivityCompat.checkSelfPermission(MainActivity.this, Manifest.permission.BLUETOOTH_CONNECT) != PackageManager.PERMISSION_GRANTED) {
                                return;
                            }
                            gatt.readCharacteristic(characteristic);
                        }
                        if ((properties & BluetoothGattCharacteristic.PROPERTY_NOTIFY) != 0) {
                            gatt.setCharacteristicNotification(characteristic, true);
                            BluetoothGattDescriptor descriptor = characteristic.getDescriptor(UUID.fromString("00002902-0000-1000-8000-00805f9b34fb"));
				descriptor.setValue(BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE);
				gatt.writeDescriptor(descriptor);

                        }
                    }
                }
            }
        }

        @Override
        public void onCharacteristicRead(BluetoothGatt gatt, BluetoothGattCharacteristic characteristic, int status) {
            Log.d(TAG, "101010");
            Log.d(TAG, String.valueOf(characteristic.getUuid()));
            if (status == BluetoothGatt.GATT_SUCCESS) {
                // キャラクタリスティックが読まれた場合、データを取得する。
                byte[] data = characteristic.getValue();
                if (data != null && data.length > 0) {
                    String textData = new String(data, Charset.forName("UTF-8"));
                    Log.i(TAG, "Received data: " + textData);
                }
		gatt.readCharacteristic(characteristic);

            }
        };
@Override
public void onCharacteristicChanged(BluetoothGatt gatt, BluetoothGattCharacteristic characteristic) {
    Log.d(TAG, "Characteristic Changed: " + characteristic.getUuid().toString());
    byte[] data = characteristic.getValue();
    if (data != null && data.length > 0) {
        String textData = new String(data, Charset.forName("UTF-8"));
        Log.i(TAG, "Received data: " + textData);
        }
     }
  };
}

上記のコードを実行すると、以下のようなログが出ます。

Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 0
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1
Received data: 1

Comments

[AGLAAGLA]

送信側(ラズパイ)は文字オーバで入りきらなかったので、以下に示します。

```
from pybleno import *
import time

bleno = Bleno()

# サービスとキャラクタリスティックのためのUUID
APPROACH_SERVICE_UUID = '00001101-0000-1000-8000-00805F9B34FB'
APPROACH_CHARACTERISTIC_UUID = '00002201-0000-1000-8000-00805f9b34fb'

counter = 0 # グローバル変数として初期化

class ApproachCharacteristic(Characteristic):

def __init__(self):
Characteristic.__init__(self, {
'uuid': APPROACH_CHARACTERISTIC_UUID,
'properties': ['read', 'notify'],
'value': None
})

self._value = str(0).encode()
self._updateValueCallback = None

def onReadRequest(self, offset, callback):
print('ApproachCharacteristic - onReadRequest')
callback(result=Characteristic.RESULT_SUCCESS, data=self._value)

def onSubscribe(self, maxValueSize, updateValueCallback):
print('ApproachCharacteristic - onSubscribe')

self._updateValueCallback = updateValueCallback

def onUnsubscribe(self):
print('ApproachCharacteristic - onUnsubscribe')

self._updateValueCallback = None

def onStateChange(state):
print('on -> stateChange: ' + state)

if state == 'poweredOn':
bleno.startAdvertising(name='Approach', service_uuids=[APPROACH_SERVICE_UUID])
else:
bleno.stopAdvertising()

bleno.on('stateChange', onStateChange)

approachCharacteristic = ApproachCharacteristic()

def onAdvertisingStart(error):
print('on -> advertisingStart: ' + ('error ' + error if error else 'success'))

if not error:
bleno.setServices([
BlenoPrimaryService({
'uuid': APPROACH_SERVICE_UUID,
'characteristics': [
approachCharacteristic
]
})
])

bleno.on('advertisingStart', onAdvertisingStart)

bleno.start()

def task():
global counter
counter = counter + 1
approachCharacteristic._value = str(counter).encode()

if approachCharacteristic._updateValueCallback:
print('Sending notification with value: ' + str(approachCharacteristic._value))
approachCharacteristic._updateValueCallback(data=approachCharacteristic._value)

print(counter) # 各反復でカウンターの値を表示します

while True:
task()
time.sleep(10)
```

Answer 1

自己解決しました。
キャラスタリスティックを有効化し、
ディスクリプタを書き込んだらいけました。