在app 项目的 build.gradle 中引入一下依赖 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: implementation 'no.nordicsemi.android:log:2.1.1' implementation 'com.madgag.spongycastle:core:1.56.0.0' implementation 'com.madgag.spongycastle:prov:1.56.0.0' implementation 'com.google.code.gson:gson:2.8.5' implementation 'no.nordicsemi.android.support.v18:scanner:1.1.0' implementation "android.arch.lifecycle:extensions:1.1.1" implementation 'android.arch.persistence.room:runtime:1.1.1' annotationProcessor "android.arch.persistence.room:compiler:1.1.1" androidTestImplementation 'android.arch.persistence.room:testing:1.1.1' mesh sdk 初始化 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: MeshManagerApi mMeshManagerApi = new MeshManagerApi(context); mMeshManagerApi.setMeshManagerCallbacks(this); mMeshManagerApi.setProvisioningStatusCallbacks(this); mMeshManagerApi.setMeshStatusCallbacks(this); BleMeshManager bleMeshManager = new BleMeshManager(context) NetworkInformation networkInformation=new NetworkInformation(context) NrfMeshRepository mMeshRepository=NrfMeshRepository(mMeshManagerApi, networkInformation, bleMeshManager); 以上是初始化流程 扫描未入网设备 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: ScannerRepository mScannerRepository=new ScannerRepository(context,meshManagerApi) mScannerRepository.getScannerState().startScanning(); //扫描前建议判断下蓝牙是否可用，定位是否打开（Android sdk>= 6.0） mScannerRepository.startScan(BleMeshManager.MESH_PROVISIONING_UUID) //扫描结果回调 mScannerRepository.getScannerState().observe(this, state -> { mDevices = scannerLiveData.getDevices(); final Integer i = devices.getUpdatedDeviceIndex(); if (i != null) notifyItemChanged(i); else notifyDataSetChanged(); }); 扫描已经入网设备 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: ScannerRepository mScannerRepository=new ScannerRepository(context,meshManagerApi) mScannerRepository.getScannerState().startScanning(); //扫描前建议判断下蓝牙是否可用，定位是否打开（Android sdk>= 6.0） mScannerRepository.startScan(BleMeshManager.MESH_PROXY_UUID) //扫描结果回调 mScannerRepository.getScannerState().observe(this, state -> { mDevices = scannerLiveData.getDevices(); final Integer i = devices.getUpdatedDeviceIndex(); if (i != null) notifyItemChanged(i); else notifyDataSetChanged(); }); 点击设备开始连接,入网开始 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" 1 设备连接成功后，mesh SDK 进行发现服务，使能通知(接收硬件端发送的数据) :: final UnprovisionedBeacon beacon = (UnprovisionedBeacon) device.getBeacon(); //private static final int ATTENTION_TIMER = 5; if (beacon != null) { mMeshManagerApi.identifyNode(beacon.getUuid(), device.getName(), device.getAddress(), ATTENTION_TIMER); } else { final byte[] serviceData = getServiceData(device.getScanResult(), BleMeshManager.MESH_PROVISIONING_UUID); if (serviceData != null) { final UUID uuid = mMeshManagerApi.getDeviceUuid(serviceData); //第一步 发送invite 消息 mMeshManagerApi.identifyNode(uuid, device.getName(), device.getAddress(), ATTENTION_TIMER); } } // 入网回调 mNrfMeshRepository.getUnprovisionedMeshNode().observe(this, meshNode -> { if (meshNode != null) { if (meshNode.getDeviceAddress() == null) { meshNode.setDeviceAddress(device.getAddress()); } // 第二步 收到设备端回复Capabilities if (meshNode.getProvisioningCapabilities() != null) { //此处可以进行界面刷新 // 第三步 发送provision start 消息 有三种方式 final UnprovisionedMeshNode node = mMeshRepository.getUnProvisionedMeshNode().getValue(); //mMeshRepository.getMeshManagerApi().startProvisioning(node); //mMeshRepository.getMeshManagerApi().startProvisioningWithStaticOOB(node); //mMeshRepository.getMeshManagerApi().startProvisioningWithOutputOOB(node, action); //调用 startProvision 后,sdk会自动完成入网 } } }); // provision state callback mNrfMeshRepository.getProvisioningStatus().observe(this, provisioningStateLiveData -> { if (provisioningStateLiveData != null) { final ProvisionerProgress provisionerProgress = provisioningStateLiveData.getProvisionerProgress(); if (provisionerProgress != null) { final ProvisioningStatusLiveData.ProvisioningLiveDataState state = provisionerProgress.getState(); switch (state) { case PROVISIONING_INVITE: // step 1 break; case PROVISIONING_CAPABILITIES: // step 2 break; case PROVISIONING_START: //step 3 break; case PROVISIONING_FAILED: // 入网失败 break; case PROVISIONING_AUTHENTICATION_STATIC_OOB_WAITING: //step 4 break; case PROVISIONING_AUTHENTICATION_OUTPUT_OOB_WAITING: //step 4 break; case PROVISIONING_AUTHENTICATION_INPUT_OOB_WAITING: //step 4 break; case PROVISIONING_AUTHENTICATION_INPUT_ENTERED: //step 4 break; case COMPOSITION_DATA_STATUS_RECEIVED: break; case PROVISIONING_PUBLIC_KEY_SENT: //step 5 break; case PROVISIONING_PUBLIC_KEY_RECEIVED: //step 6 break; case PROVISIONING_RANDOM_SENT: //step 7 break; case PROVISIONING_RANDOM_RECEIVED: //step 8 break; case PROVISIONING_DATA_SENT: //step 9 break; case PROVISIONING_COMPLETE: // 入网完成 //received break case APP_KEY_STATUS_RECEIVED: break; } } } }); 入网成功后手机数据库中会插入一条该设备数据 在MeshManagerApi.java中 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: private final InternalMeshManagerCallbacks internalMeshMgrCallbacks = new InternalMeshManagerCallbacks() { @Override public void onNodeProvisioned(final ProvisionedMeshNode meshNode) { updateProvisionedNodeList(meshNode); incrementUnicastAddress(meshNode.getUnicastAddress(), meshNode.getNumberOfElements()); //Set the mesh network uuid to the node so we can identify nodes belonging to a network meshNode.setMeshUuid(mMeshNetwork.getMeshUUID()); //插入节点数据 mMeshNetworkDb.insertNode(mProvisionedNodeDao, meshNode); mMeshNetworkDb.updateProvisioner(mProvisionerDao, mMeshNetwork.getSelectedProvisioner()); mTransportCallbacks.onNetworkUpdated(mMeshNetwork); } private void updateProvisionedNodeList(final ProvisionedMeshNode meshNode) { Log.d(TAG, "updateProvisionedNodeList: " + meshNode.getUuid()); for (int i = 0; i < mMeshNetwork.nodes.size(); i++) { final ProvisionedMeshNode node = mMeshNetwork.nodes.get(i); Log.d(TAG, "updateProvisionedNodeList: " + node.getUuid()); if (meshNode.getUuid().equals(node.getUuid())) { mMeshNetwork.nodes.remove(i); break; } } mMeshNetwork.nodes.add(meshNode); } }; 发送消息注意事项 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" ConfigMessage 地址必须是：unicastAddress（mMeshRepository.getSelectedMeshNode().value().getUnicastAddress()） GenericMessage 地址必须是：节点元素地址 elementAddress ConfigMessage 属于配置信息主要目的是给相应的model 添加通信能力的字段信息 例如：ConfigAppkeyAdd 添加节点通信加解密appkey（16byte） 例如：ConfigModelAppBind 用于model通信加解密绑定 例如：ConfigModelSubscriptionAdd 订阅分组 :: public ConfigModelSubscriptionAdd(@NonNull final byte[] elementAddress, @NonNull final byte[] subscriptionAddress, final int modelIdentifier) throws IllegalArgumentException { //subscriptionAddress 分组地址 0xc000~0xFFEF this(AddressUtils.getUnicastAddressInt(elementAddress), AddressUtils.getUnicastAddressInt(subscriptionAddress), modelIdentifier); } 发送消息 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: //example 入网完成后需要获取设备配置信息 final ConfigCompositionDataGet compositionDataGet = new ConfigCompositionDataGet(); ProvisionedMeshNode provisionedMeshNode = mMeshRepository.getProvisionedMeshNode().getValue(); int dst = provisionedMeshNode.getUnicastAddress();//代表目的地址(elementAddress,groupAddress) 手机发送消息用到的地址 mMeshRepository.getMeshManagerApi().sendMeshMessage(dst, meshMessage); mMeshRepository.getNrfMeshRepository().getMeshMessageLiveData().observe(this, new Observer() { @Override public void onChanged(@Nullable MeshMessage meshMessage) { if(meshMessage instanceof ConfigCompositionDataStatus){ //收到设备端回复的配置信息 //ConfigCompositionDataStatus 解析得到List :elements ,list:models }else{ // more status need to catch } }); 移除节点 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: final ConfigNodeReset configNodeReset = new ConfigNodeReset(); ProvisionedMeshNode provisionedMeshNode = mMeshRepository.getSelectedMeshNode().getValue();//get之前先set 不然会报错 int dst = provisionedMeshNode.getUnicastAddress(); mMeshRepository.getMeshManagerApi().sendMeshMessage(dst, meshMessage); mMeshRepository.getNrfMeshRepository().getMeshMessageLiveData().observe(this, new Observer() { @Override public void onChanged(@Nullable MeshMessage meshMessage) { if(meshMessage instanceof ConfigNodeResetStatus){ //节点已经移除，该设备已经变成未入网设备，可以进行入网操作 }else{ // more status need to catch } }); 在手机数据库中添加分组信息 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: //地址范围 0xc000~0xFEFF //(例如手机中现有两个节点，并且都订阅了改地址(以下代码中的地址是0xc000),那么现在可以向0xc000 发送一条分组消息，那么这两个节点都会处理该消息 mMeshRepository.getMeshNetworkLiveData().getMeshNetwork().addGroup(0xc000,"randomName") 从手机数据库中获取分组列表 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: mMeshRepository.getGroups().observe(this, groups -> { //refresh UI }); 导出手机入网数据 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: final File f = new File(EXPORT_PATH); if (!f.exists()) { f.mkdirs(); } mMeshRepository.getMeshManagerApi().exportMeshNetwork(EXPORT_PATH); 导入数据到手机 """"""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""""" :: final Intent intent; if (Utils.isKitkatOrAbove()) { intent = new Intent(Intent.ACTION_OPEN_DOCUMENT); } else { intent = new Intent(Intent.ACTION_GET_CONTENT); } intent.addCategory(Intent.CATEGORY_OPENABLE); intent.setType("*/*"); startActivityForResult(intent, READ_FILE_REQUEST_CODE); public void onActivityResult(final int requestCode, final int resultCode, final Intent data) { super.onActivityResult(requestCode, resultCode, data); switch (requestCode) { case READ_FILE_REQUEST_CODE: if (resultCode == RESULT_OK) { if (data != null) { final Uri uri = data.getData(); mMeshRepository.importMeshNetwork(uri); } } else { Log.e(TAG, "Error while opening file browser"); } break; } }