private static final String UUIDString = "00001101-0000-1000-8000-00805F9B34FB";
//開啟服務(wù)器
private class ServerThread extends Thread {
    @Override
    public void run() {
        try {
                /* 創(chuàng)建一個(gè)藍(lán)牙服務(wù)器
                 * 參數(shù)分別：服務(wù)器名稱、UUID   */
            mServerSocket = bluetoothAdapter.listenUsingRfcommWithServiceRecord(PROTOCOL_SCHEME_RFCOMM, UUID.fromString(UUIDString));
            while (true){
                Log.d("server", "wait cilent connect...");
                Message msg = new Message();
                msg.obj = "請稍候，正在等待客戶端的連接...";
                msg.what = WAITING_FOR_CLIENT;
                linkDetectedHandler.sendMessage(msg);
                /* 接受客戶端的連接請求 */
                BluetoothSocket socket = mServerSocket.accept();
                socketMap.put(socket.getRemoteDevice().getAddress(), socket);
//                  remoteDeviceMap.put(socket.getRemoteDevice().getAddress(),socket.getRemoteDevice());
                Log.d("server", "accept success !");
                Message msg2 = new Message();
                String info = "客戶端已經(jīng)連接上！可以發(fā)送信息。";
                msg2.obj = info;
                msg.what = CONNECTED_CLIENT;
                linkDetectedHandler.sendMessage(msg2);
                //啟動(dòng)接受數(shù)據(jù)
                ReadThread mreadThread = new ReadThread(socket.getRemoteDevice().getAddress());
                readThreadMap.put(socket.getRemoteDevice().getAddress(),mreadThread);
                mreadThread.start();
            }

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

//開啟客戶端
private class ClientThread extends Thread {
    private String remoteAddress;
    public ClientThread(String remoteAddress) {
        this.remoteAddress = remoteAddress;
    }
    @Override
    public void run() {
        try {
            //創(chuàng)建一個(gè)Socket連接：只需要服務(wù)器在注冊時(shí)的UUID號(hào)
            BluetoothDevice device = bluetoothAdapter.getRemoteDevice(remoteAddress);
            BluetoothSocket socket = device.createRfcommSocketToServiceRecord(UUID.fromString(UUIDString));
            //連接
            Message msg2 = new Message();
            msg2.obj = "請稍候，正在連接服務(wù)器:" + remoteAddress;
            msg2.what = IS_CONNECTING_SERVER;
            linkDetectedHandler.sendMessage(msg2);
            socket.connect();
            socketMap.put(remoteAddress, socket);
            Message msg = new Message();
            msg.obj = remoteAddress;
            msg.what = CONNECTED_SERVER;
            linkDetectedHandler.sendMessage(msg);
            //啟動(dòng)接受數(shù)據(jù)
            ReadThread mreadThread = new ReadThread(remoteAddress);
            readThreadMap.put(remoteAddress,mreadThread);
            mreadThread.start();
        } catch (IOException e) {
            e.printStackTrace();
            socketMap.remove(remoteAddress);
            Log.e("connect", e.getMessage(), e);
            Message msg = new Message();
            msg.obj = "連接服務(wù)端異常！斷開連接重新試一試。"+e.getMessage();
            msg.what = CONNECT_SERVER_ERROR;
            linkDetectedHandler.sendMessage(msg);
        }
    }
}

private fun setupServer() {
    val gattService = BluetoothGattService(Constants.BLE_SERVICE_UUID, BluetoothGattService.SERVICE_TYPE_PRIMARY)
    val characteristicRead = BluetoothGattCharacteristic(Constants.BLE_READ_UUID, BluetoothGattCharacteristic.PROPERTY_READ, BluetoothGattCharacteristic.PERMISSION_READ)
    val descriptor = BluetoothGattDescriptor(Constants.BLE_DESC_UUID, BluetoothGattCharacteristic.PERMISSION_WRITE)
    characteristicRead.addDescriptor(descriptor)
    gattService.addCharacteristic(characteristicRead)
    val characteristicWrite = BluetoothGattCharacteristic(Constants.BLE_WRITE_UUID, BluetoothGattCharacteristic.PROPERTY_WRITE or
            BluetoothGattCharacteristic.PROPERTY_READ or BluetoothGattCharacteristic.PROPERTY_NOTIFY,
            BluetoothGattCharacteristic.PERMISSION_WRITE)
    gattService.addCharacteristic(characteristicWrite)
    Log.d("wenpd", "startGattServer:stagattServicetus=$gattService")
    mGattServer.addService(gattService)
}

private class GattClientCallback extends BluetoothGattCallback {
    @Override
    public void onConnectionStateChange(BluetoothGatt gatt, int status, int newState) {
        super.onConnectionStateChange(gatt, status, newState);
        if (status == BluetoothGatt.GATT_FAILURE) {
            disconnectGattServer();
            return;
        } else if (status != BluetoothGatt.GATT_SUCCESS) {
            disconnectGattServer();
            return;
        }
        if (newState == BluetoothProfile.STATE_CONNECTED) {
            mConnected = true;
            gatt.discoverServices();
        } else if (newState == BluetoothProfile.STATE_DISCONNECTED) {
            disconnectGattServer();
        }
    }

    @Override
    public void onServicesDiscovered(BluetoothGatt gatt, int status) {
        super.onServicesDiscovered(gatt, status);
        Log.d(TAG, "onServicesDiscovered status:" + status);
        if (status != BluetoothGatt.GATT_SUCCESS) {
            return;
        }
        BluetoothGattService service = gatt.getService(Constants.SERVICE_UUID);
        BluetoothGattCharacteristic characteristic = service.getCharacteristic(Constants.CHARACTERISTIC_UUID);
        characteristic.setWriteType(BluetoothGattCharacteristic.WRITE_TYPE_DEFAULT);
        mInitialized = gatt.setCharacteristicNotification(characteristic, true);
    }

    @Override
    public void onCharacteristicChanged(BluetoothGatt gatt, BluetoothGattCharacteristic characteristic) {
        super.onCharacteristicChanged(gatt, characteristic);
        byte[] messageBytes = characteristic.getValue();
        /*for(int i = 0, j = messageBytes.length -1; i < j; ++i, --j) {
            byte temp = messageBytes[i];
            messageBytes[i] = messageBytes[j];
            messageBytes[j] = temp;
        }*/
        String messageString = new String(messageBytes, StandardCharsets.UTF_8);
        Log.d(TAG,"Received message: " + messageString);
        setReceivedData(messageString);
    }
}