当前位置: 首页 > news >正文

技术先进的网站建设公aso优化推广

技术先进的网站建设公,aso优化推广,做一个网购网站需要备案吗,菜谱网站模版一,简介 蓝牙4.0以下称为传统蓝牙,4.0以上是低功耗蓝牙,5.0开始主打物联网 5.0协议蓝牙最重要的技术就是Mesh组网,实现1对多,多对多的无线通信。即从点对点传输发展为网络拓扑结构,主要领域如灯光控制等&…

一,简介

蓝牙4.0以下称为传统蓝牙,4.0以上是低功耗蓝牙,5.0开始主打物联网

5.0协议蓝牙最重要的技术就是Mesh组网,实现1对多,多对多的无线通信。即从点对点传输发展为网络拓扑结构,主要领域如灯光控制等,可以同时控制一组内的多个设备。

如下模型,把灯具分组,就可以同时控制一组或者多组内的多台设备

二 蓝牙组网步骤 

2.1 扫描,还是用BluetoothAdapter adapter = BluetoothAdapter.getDefaultAdapter();

/*** Start scanning for Bluetooth devices.** @param filterUuid UUID to filter scan results with*/
public void startScan(final UUID filterUuid, boolean auto) {mFilterUuid = filterUuid;Log.e(TAG, "mScannerStateLiveData: 6" );if (mScannerStateLiveData.isScanning()) {return;}if (mFilterUuid.equals(BleMeshManager.MESH_PROXY_UUID)) {final MeshNetwork network = mMeshManagerApi.getMeshNetwork();if (network != null) {if (!network.getNetKeys().isEmpty()) {mNetworkId = mMeshManagerApi.generateNetworkId(network.getNetKeys().get(0).getKey());}}}Log.e(TAG, "mScannerStateLiveData: 7" );mScannerStateLiveData.scanningStarted();//Scanning settingsfinal ScanSettings settings = new ScanSettings.Builder().setScanMode(ScanSettings.SCAN_MODE_LOW_LATENCY)// Refresh the devices list every second.setReportDelay(0)// Hardware filtering has some issues on selected devices.setUseHardwareFilteringIfSupported(false)// Samsung S6 and S6 Edge report equal value of RSSI for all devices. In this app we ignore the RSSI./*.setUseHardwareBatchingIfSupported(false)*/.build();//Let's use the filter to scan only for unprovisioned mesh nodes.final List<ScanFilter> filters = new ArrayList<>();filters.add(new ScanFilter.Builder().setServiceUuid(new ParcelUuid((filterUuid))).build());final BluetoothLeScannerCompat scanner = BluetoothLeScannerCompat.getScanner();Log.e(TAG, "startScan: 开始扫描" );scanner.startScan(filters, settings, mScanCallbacks);
}

2.2 扫描到设备后,连接并获取地址

@SuppressLint("RestrictedApi")
private void connect(final ExtendedBluetoothDevice extendedBluetoothDevice) {/*** 蓝牙     --根据UUID中的型号ID* DMX      --根据品牌-系列-模式* 2.4G     --单色温,双色温,全彩*/String uuid = ((UnprovisionedBeacon) selectedBluetoothDevice.getBeacon()).getUuid().toString().replace("-", "");String[] stringArray = OrderUtils.hexStringToStringArray(uuid);//型号byte 10 ~ 12	表示型号String modelFileName = stringArray[10] + stringArray[11] + stringArray[12];Log.e(TAG, "modelFileName: " + modelFileName);dataJson = dataJsonCommonDaoUtils.queryBykey(modelFileName);if (dataJson == null) {ConfirmDialog confirmDialog = new ConfirmDialog(mContext, R.style.dialog, "没有该型号的配置文件:\n" + modelFileName, getResources().getString(R.string.account_confirm));confirmDialog.show();hideCustomProgress();cancleHandlerProvisioning();return;}if (fromType == 1 || fromType == 2) {String json = dataJson.getDataJson();if (!json.contains("FUNCTION")) {ConfirmDialog confirmDialog = new ConfirmDialog(mContext, R.style.dialog, "请添加控制盒类型的配置文件\n", getResources().getString(R.string.account_confirm));confirmDialog.show();hideCustomProgress();cancleHandlerProvisioning();return;}}nextChBlue = getNextCHBlue();if (nextChBlue == -1) {//如果nextChBlue==-1,说明蓝牙地址1-512已将占完,直接return;cancleHandlerProvisioning();return;}showCustomProgress(getResources().getString(R.string.ble_provisioning) + (addIndex + 1) + "/" + mSelectCommonList.size());scannerViewModel.getScannerRepository().stopScan();provisioningViewModel.connect(this, extendedBluetoothDevice, false);//监听连接状态provisioningViewModel.getConnectionState().observe(this, new Observer<String>() {@Overridepublic void onChanged(@Nullable String s) {Log.e(TAG, "getConnectionState: " + s);}});//监听是否连接provisioningViewModel.isConnected().observe(this, connected -> {final boolean isComplete = provisioningViewModel.isProvisioningComplete();if (isComplete) {return;}if (connected != null) {if (connected) {Log.e(TAG, "isConnected: " + "连接成功");handlerProvisioning.sendEmptyMessageDelayed(1, 4000);} else {Log.e(TAG, "isConnected: " + "连接失败");}} else {Log.e(TAG, "isConnected: " + "未连接");}});//监听设备信息provisioningViewModel.isDeviceReady().observe(this, deviceReady -> {if (provisioningViewModel.getBleMeshManager().isDeviceReady()) {Log.e(TAG, "isDeviceReady:");final boolean isComplete = provisioningViewModel.isProvisioningComplete();if (isComplete) {setupProvisionerStateObservers();return;}}});//监听重连provisioningViewModel.isReconnecting().observe(this, isReconnecting -> {Log.e(TAG, "isReconnecting:");if (isReconnecting != null && isReconnecting) {provisioningViewModel.getUnprovisionedMeshNode().removeObservers(this);} else {setResultIntent();}});//监听keyprovisioningViewModel.getNetworkLiveData().observe(this, meshNetworkLiveData -> {final ApplicationKey applicationKey = meshNetworkLiveData.getSelectedAppKey();Log.e(TAG, "getNetworkLiveData:Key:" + MeshParserUtils.bytesToHex(applicationKey.getKey(), false));Log.e(TAG, "getNetworkLiveData: Address:" + getString(R.string.ble_hex_format, String.format(Locale.US, "%04X", meshNetworkLiveData.getMeshNetwork().getUnicastAddress())));// 获取已选择的app key//appKeyView.setText(MeshParserUtils.bytesToHex(applicationKey.getKey(), false));
//            Log.e("TAG", "onCreate: " + MeshParserUtils.bytesToHex(applicationKey.getKey(), false) );//            unicastAddressView.setText(getString(R.string.ble_hex_format,
//                    String.format(Locale.US, "%04X", meshNetworkLiveData.getMeshNetwork().getUnicastAddress())));});//监听设备识别provisioningViewModel.getUnprovisionedMeshNode().observe(this, meshNode -> {Log.e(TAG, "getUnprovisionedMeshNode:meshNode=" + (meshNode == null));if (meshNode != null) {final ProvisioningCapabilities capabilities = meshNode.getProvisioningCapabilities();Log.e(TAG, "getUnprovisionedMeshNode:capabilities=" + (capabilities == null));if (capabilities != null) {final MeshNetwork network = provisioningViewModel.getNetworkLiveData().getMeshNetwork();if (network != null) {try {final int elementCount = capabilities.getNumberOfElements();final Provisioner provisioner = network.getSelectedProvisioner();final int unicast = network.nextAvailableUnicastAddress(elementCount, provisioner);network.assignUnicastAddress(unicast);} catch (IllegalArgumentException ex) {ToastUtil.showToast(mContext, ex.getMessage());}}}}});
}

2.3 选择模型和节点

//选择节点
public ProvisionedMeshNode setSelectNode(String controlAddress) {MeshNetwork network = Consts.sharedViewModel.getNetworkLiveData().getMeshNetwork();ProvisionedMeshNode node = network.getNode(Integer.parseInt(controlAddress));if (node != null) {Consts.sharedViewModel.setSelectedMeshNode(node);mElements.clear();mElements.addAll(node.getElements().values());tag2:for (int i = 0; i < mElements.size(); i++) {List<MeshModel> models = new ArrayList<>(mElements.get(i).getMeshModels().values());tag1:for (int j = 0; j < models.size(); j++) {if (models.get(j) instanceof VendorModel) {Consts.modelConfigurationViewModel.setSelectedElement(mElements.get(i));Consts.modelConfigurationViewModel.setSelectedModel(models.get(j));break tag2;}}}}return node;
}

2.4 配置入网

//入网
@SuppressLint("RestrictedApi")
public void provisionClick() {final UnprovisionedMeshNode node = provisioningViewModel.getUnprovisionedMeshNode().getValue();Log.e(TAG, "isConnected: ((((((((((((( " + (node == null));if (node == null) {Log.e(TAG, "isConnected: " + provisioningViewModel.getNetworkLiveData().getNodeName());provisioningViewModel.getNrfMeshRepository().identifyNode(selectedBluetoothDevice);return;}//配置入网if (node.getProvisioningCapabilities() != null) {Log.e(TAG, "onCreate: " + (node.getProvisioningCapabilities().getAvailableOOBTypes().size() == 1 &&node.getProvisioningCapabilities().getAvailableOOBTypes().get(0) == AuthenticationOOBMethods.NO_OOB_AUTHENTICATION));if (node.getProvisioningCapabilities().getAvailableOOBTypes().size() == 1 &&node.getProvisioningCapabilities().getAvailableOOBTypes().get(0) == AuthenticationOOBMethods.NO_OOB_AUTHENTICATION) {onNoOOBSelected();} else {
//               final DialogFragmentSelectOOBType fragmentSelectOOBType = DialogFragmentSelectOOBType.newInstance(meshNode.getProvisioningCapabilities());
//               fragmentSelectOOBType.show(getSupportFragmentManager(), null);}}
}@SuppressLint("RestrictedApi")
public void setupProvisionerStateObservers() {provisioningViewModel.getProvisioningStatus().observe(this, provisioningStateLiveData -> {if (provisioningStateLiveData != null) {final ProvisionerProgress provisionerProgress = provisioningStateLiveData.getProvisionerProgress();provisioningStateLiveData.getStateList();if (provisionerProgress != null) {final ProvisionerStates state = provisionerProgress.getState();Log.e(TAG, "setupProvisionerStateObservers: state:" + state);switch (state) {case PROVISIONING_CAPABILITIES:Log.e("TAG", "PROVISIONING_CAPABILITIES: " + provisioningViewModel.getNetworkLiveData().getMeshNetwork().getUnicastAddress());String address = String.format(Locale.US, "%04X", provisioningViewModel.getNetworkLiveData().getMeshNetwork().getUnicastAddress());addressMap.put(selectedBluetoothDevice.getAddress(), address);break;case PROVISIONING_FAILED://失败
//                        if (getSupportFragmentManager().findFragmentByTag(DIALOG_FRAGMENT_PROVISIONING_FAILED) == null) {
//                            final String statusMessage = ProvisioningFailedState.parseProvisioningFailure(getApplicationContext(), provisionerProgress.getStatusReceived());
//                            DialogFragmentProvisioningFailedError message = DialogFragmentProvisioningFailedError.newInstance(getString(R.string.ble_title_error_provisioning_failed), statusMessage);
//                            message.show(getSupportFragmentManager(), DIALOG_FRAGMENT_PROVISIONING_FAILED);
//                        }break;case PROVISIONING_AUTHENTICATION_STATIC_OOB_WAITING:case PROVISIONING_AUTHENTICATION_OUTPUT_OOB_WAITING:case PROVISIONING_AUTHENTICATION_INPUT_OOB_WAITING:
//                        if (getSupportFragmentManager().findFragmentByTag(DIALOG_FRAGMENT_AUTH_INPUT_TAG) == null) {
//                            DialogFragmentAuthenticationInput dialogFragmentAuthenticationInput = DialogFragmentAuthenticationInput.
//                                    newInstance(mViewModel.getUnprovisionedMeshNode().getValue());
//                            dialogFragmentAuthenticationInput.show(getSupportFragmentManager(), DIALOG_FRAGMENT_AUTH_INPUT_TAG);
//                        }break;case PROVISIONING_AUTHENTICATION_INPUT_ENTERED:
//                        final DialogFragmentAuthenticationInput fragment = (DialogFragmentAuthenticationInput) getSupportFragmentManager().
//                                findFragmentByTag(DIALOG_FRAGMENT_AUTH_INPUT_TAG);
//                        if (fragment != null) {
//                            fragment.dismiss();
//                        }break;case PROVISIONING_COMPLETE:case NETWORK_TRANSMIT_STATUS_RECEIVED:
//                        if (getSupportFragmentManager().findFragmentByTag(DIALOG_FRAGMENT_CONFIGURATION_STATUS) == null) {
//                            DialogFragmentConfigurationComplete fragmentConfigComplete = DialogFragmentConfigurationComplete.
//                                    newInstance(getString(R.string.title_configuration_compete), getString(R.string.configuration_complete_summary));
//                            fragmentConfigComplete.show(getSupportFragmentManager(), DIALOG_FRAGMENT_CONFIGURATION_STATUS);
//                        }Log.e(TAG, "setupProvisionerStateObservers: " + "PROVISIONING_COMPLETE");handlerProvisioning.sendEmptyMessageDelayed(3, 3000);break;case PROVISIONER_UNASSIGNED:setResultIntent();break;default:break;}}}});}public void onNoOOBSelected() {final UnprovisionedMeshNode node = provisioningViewModel.getUnprovisionedMeshNode().getValue();if (node != null) {try {node.setNodeName(provisioningViewModel.getNetworkLiveData().getNodeName());setupProvisionerStateObservers();provisioningViewModel.getMeshManagerApi().startProvisioning(node);} catch (IllegalArgumentException ex) {ToastUtil.showToast(mContext, ex.getMessage());}}}

2.5 发送消息

/*** Send vendor model acknowledged message** @param opcode     opcode of the message* @param parameters parameters of the message*/
public void sendVendorModelMessage(final int opcode, final byte[] parameters, final boolean acknowledged) {final Element element = Consts.modelConfigurationViewModel.getSelectedElement().getValue();if (element != null) {final VendorModel model = (VendorModel) Consts.modelConfigurationViewModel.getSelectedModel().getValue();if (model != null) {final int appKeyIndex = Consts.modelConfigurationViewModel.getMeshManagerApi().getMeshNetwork().getAppKey(0).getKeyIndex();// final int appKeyIndex = model.getBoundAppKeyIndexes().get(0);final ApplicationKey appKey = Consts.modelConfigurationViewModel.getNetworkLiveData().getMeshNetwork().getAppKey(appKeyIndex);final MeshMessage message;if (acknowledged) {message = new VendorModelMessageAcked(appKey, model.getModelId(), model.getCompanyIdentifier(), opcode, parameters);int address = element.getElementAddress();if (lightEquipmentGroup != null && lightEquipmentGroup.getConnectMethod() == 0) {address = Consts.sharedViewModel.getSelectedGroup().getValue().getAddress();}sendMessage(address, message);} else {message = new VendorModelMessageUnacked(appKey, model.getModelId(), model.getCompanyIdentifier(), opcode, parameters);int address = element.getElementAddress();if (lightEquipmentGroup != null && lightEquipmentGroup.getConnectMethod() == 0) {address = Consts.sharedViewModel.getSelectedGroup().getValue().getAddress();}sendMessage(address, message);}}}
}protected void sendMessage(final int address, @NonNull final MeshMessage meshMessage) {try {Log.e(TAG, "sendMessage: " + checkConnectivity());if (!checkConnectivity())return;Consts.modelConfigurationViewModel.getMeshManagerApi().createMeshPdu(address, meshMessage);} catch (IllegalArgumentException ex) {ToastUtil.showToast(mContext, getString(R.string.ble_title_error));}
}

2.6 订阅网络群组

//订阅网络群组public void subscribe() {final ProvisionedMeshNode meshNode = modelConfigurationViewModel.getSelectedMeshNode().getValue();Log.e(TAG, "meshNodeIsnull: " + (meshNode == null));if (meshNode != null) {final Element element = modelConfigurationViewModel.getSelectedElement().getValue();Log.e(TAG, "elementIsnull: " + (element == null));if (element != null) {final int elementAddress = element.getElementAddress();final MeshModel model = modelConfigurationViewModel.getSelectedModel().getValue();Log.e(TAG, "modelIsnull: " + (model == null));if (model != null) {final int modelIdentifier = model.getModelId();final MeshMessage configModelSubscriptionAdd;Log.e(TAG, "group.getAddressLabel(): " + (group.getAddressLabel() == null));if (group.getAddressLabel() == null) {configModelSubscriptionAdd = new ConfigModelSubscriptionAdd(elementAddress, group.getAddress(), modelIdentifier);} else {configModelSubscriptionAdd = new ConfigModelSubscriptionVirtualAddressAdd(elementAddress, group.getAddressLabel(), modelIdentifier);}sendMessage(meshNode.getUnicastAddress(), configModelSubscriptionAdd);handlerCheckIsConnectIndex=addIndex;handlerCheckIsConnect.removeCallbacksAndMessages(0);handlerCheckIsConnect.sendEmptyMessageDelayed(1,3000);}}}}

 2.7 接收消息

public void onMeshMessageReceived(final int src, @NonNull final MeshMessage meshMessage) {final ProvisionedMeshNode node = mMeshNetwork.getNode(src);if (node != null)if (meshMessage instanceof ProxyConfigFilterStatus) {mProvisionedMeshNode = node;setSelectedMeshNode(node);final ProxyConfigFilterStatus status = (ProxyConfigFilterStatus) meshMessage;final int unicastAddress = status.getSrc();Log.v(TAG, "Proxy configuration source: " + MeshAddress.formatAddress(status.getSrc(), false));mConnectedProxyAddress.postValue(unicastAddress);mMeshMessageLiveData.postValue(status);} else if (meshMessage instanceof ConfigCompositionDataStatus) {final ConfigCompositionDataStatus status = (ConfigCompositionDataStatus) meshMessage;if (mSetupProvisionedNode) {mIsCompositionDataReceived = true;mProvisionedMeshNodeLiveData.postValue(node);mConnectedProxyAddress.postValue(node.getUnicastAddress());mProvisioningStateLiveData.onMeshNodeStateUpdated(ProvisionerStates.COMPOSITION_DATA_STATUS_RECEIVED);mHandler.postDelayed(() -> {Log.e(TAG, "onMeshMessageReceived: 500" );final ConfigDefaultTtlGet configDefaultTtlGet = new ConfigDefaultTtlGet();Log.e(TAG, "onMeshMessageReceived: 3" );mMeshManagerApi.createMeshPdu(node.getUnicastAddress(), configDefaultTtlGet);//}, 500);}, 0);} else {updateNode(node);}} else if (meshMessage instanceof ConfigDefaultTtlStatus) {final ConfigDefaultTtlStatus status = (ConfigDefaultTtlStatus) meshMessage;if (mSetupProvisionedNode) {mIsDefaultTtlReceived = true;mProvisionedMeshNodeLiveData.postValue(node);mProvisioningStateLiveData.onMeshNodeStateUpdated(ProvisionerStates.DEFAULT_TTL_STATUS_RECEIVED);mHandler.postDelayed(() -> {Log.e(TAG, "onMeshMessageReceived: 1500" );final ApplicationKey appKey = mMeshNetworkLiveData.getSelectedAppKey();@SuppressLint("RestrictedApi") final int index = node.getAddedNetKeys().get(0).getIndex();final NetworkKey networkKey = mMeshNetwork.getNetKeys().get(index);final ConfigAppKeyAdd configAppKeyAdd = new ConfigAppKeyAdd(networkKey, appKey);Log.e(TAG, "onMeshMessageReceived: 2" );mMeshManagerApi.createMeshPdu(node.getUnicastAddress(), configAppKeyAdd);//}, 1500);}, 0);} else {updateNode(node);mMeshMessageLiveData.postValue(status);}} else if (meshMessage instanceof ConfigAppKeyStatus) {final ConfigAppKeyStatus status = (ConfigAppKeyStatus) meshMessage;if (mSetupProvisionedNode) {if (status.isSuccessful()) {mIsAppKeyAddCompleted = true;mProvisionedMeshNodeLiveData.postValue(node);mProvisioningStateLiveData.onMeshNodeStateUpdated(ProvisionerStates.APP_KEY_STATUS_RECEIVED);mHandler.postDelayed(() -> {final ConfigNetworkTransmitSet networkTransmitSet = new ConfigNetworkTransmitSet(2, 1);Log.e(TAG, "onMeshMessageReceived: 1" );mMeshManagerApi.createMeshPdu(node.getUnicastAddress(), networkTransmitSet);// }, 1500);}, 0);}} else {updateNode(node);mMeshMessageLiveData.postValue(status);}} else if (meshMessage instanceof ConfigNetworkTransmitStatus) {if (mSetupProvisionedNode) {mSetupProvisionedNode = false;mIsNetworkRetransmitSetCompleted = true;mProvisioningStateLiveData.onMeshNodeStateUpdated(ProvisionerStates.NETWORK_TRANSMIT_STATUS_RECEIVED);} else {updateNode(node);final ConfigNetworkTransmitStatus status = (ConfigNetworkTransmitStatus) meshMessage;mMeshMessageLiveData.postValue(status);}} else if (meshMessage instanceof ConfigModelAppStatus) {if (updateNode(node)) {final ConfigModelAppStatus status = (ConfigModelAppStatus) meshMessage;final Element element = node.getElements().get(status.getElementAddress());if (node.getElements().containsKey(status.getElementAddress())) {mSelectedElement.postValue(element);final MeshModel model = element.getMeshModels().get(status.getModelIdentifier());mSelectedModel.postValue(model);}}} else if (meshMessage instanceof ConfigModelPublicationStatus) {if (updateNode(node)) {final ConfigModelPublicationStatus status = (ConfigModelPublicationStatus) meshMessage;if (node.getElements().containsKey(status.getElementAddress())) {final Element element = node.getElements().get(status.getElementAddress());mSelectedElement.postValue(element);final MeshModel model = element.getMeshModels().get(status.getModelIdentifier());Log.e(TAG, "onMeshMessageReceived: ****************************" );mSelectedModel.postValue(model);}}} else if (meshMessage instanceof ConfigModelSubscriptionStatus) {if (updateNode(node)) {final ConfigModelSubscriptionStatus status = (ConfigModelSubscriptionStatus) meshMessage;if (node.getElements().containsKey(status.getElementAddress())) {final Element element = node.getElements().get(status.getElementAddress());mSelectedElement.postValue(element);final MeshModel model = element.getMeshModels().get(status.getModelIdentifier());mSelectedModel.postValue(model);}}} else if (meshMessage instanceof ConfigNodeResetStatus) {mBleMeshManager.setClearCacheRequired();final ConfigNodeResetStatus status = (ConfigNodeResetStatus) meshMessage;mExtendedMeshNode.postValue(null);Log.e(TAG, "onMeshMessageReceived: 2" );loadNodes();mMeshMessageLiveData.postValue(status);} else if (meshMessage instanceof ConfigRelayStatus) {if (updateNode(node)) {final ConfigRelayStatus status = (ConfigRelayStatus) meshMessage;mMeshMessageLiveData.postValue(status);}} else if (meshMessage instanceof ConfigProxyStatus) {if (updateNode(node)) {final ConfigProxyStatus status = (ConfigProxyStatus) meshMessage;mMeshMessageLiveData.postValue(status);}} else if (meshMessage instanceof GenericOnOffStatus) {if (updateNode(node)) {final GenericOnOffStatus status = (GenericOnOffStatus) meshMessage;if (node.getElements().containsKey(status.getSrcAddress())) {final Element element = node.getElements().get(status.getSrcAddress());mSelectedElement.postValue(element);final MeshModel model = element.getMeshModels().get((int) SigModelParser.GENERIC_ON_OFF_SERVER);mSelectedModel.postValue(model);}}} else if (meshMessage instanceof GenericLevelStatus) {if (updateNode(node)) {final GenericLevelStatus status = (GenericLevelStatus) meshMessage;if (node.getElements().containsKey(status.getSrcAddress())) {final Element element = node.getElements().get(status.getSrcAddress());mSelectedElement.postValue(element);final MeshModel model = element.getMeshModels().get((int) SigModelParser.GENERIC_LEVEL_SERVER);mSelectedModel.postValue(model);}}} else if (meshMessage instanceof VendorModelMessageStatus) {if (updateNode(node)) {final VendorModelMessageStatus status = (VendorModelMessageStatus) meshMessage;if (node.getElements().containsKey(status.getSrcAddress())) {final Element element = node.getElements().get(status.getSrcAddress());mSelectedElement.postValue(element);final MeshModel model = element.getMeshModels().get(status.getModelIdentifier());mSelectedModel.postValue(model);}}}if (mMeshMessageLiveData.hasActiveObservers()) {mMeshMessageLiveData.postValue(meshMessage);}//Refresh mesh network live datamMeshNetworkLiveData.refresh(mMeshManagerApi.getMeshNetwork());}

2.9 字节数据的转换,8位二进制一个字节

public static String hexStringFormatNormal1(CmdNormal cmdNormal) {if (cmdNormal == null) {return "";}/*** 功能码8位二进制组成功能byte* Bit[0]  :  0-不需要从机返回信息 /  1-需要从机返回信息* Bit[1]  :  0-发送 /  1-返回* Bit[3]  :  0-快捷指令 /  1-常规指令* Bit[4:3] :  0-蓝牙灯具 /  1-2.4G灯具 /  2-DMX灯具* Bit[6:5] :  未使用,保持0* Bit[7]  :  0-独立一帧 / 1-多帧数据*/StringBuffer stringBufferFunction = new StringBuffer();CmdFunction cmdFunction = cmdNormal.getCmdFunction();stringBufferFunction.append(cmdFunction.getIsMultiFrame());//7位(0-独立一帧 / 1-多帧数据)stringBufferFunction.append("0");//6位保持0stringBufferFunction.append(cmdFunction.getIsSetting());//5 0-查询 / 1-设置//stringBufferFunction.append("0");//3位保持0stringBufferFunction.append(OrderUtils.numToBinary(cmdFunction.getIsDeviceType(),2));//3,4位(0-蓝牙灯具 /  1-2.4G灯具 /  2-DMX灯具)stringBufferFunction.append(cmdFunction.getIsFunctionNormal());//2位 (0-快捷指令 /  1-常规指令)stringBufferFunction.append(cmdFunction.getIsFunctionBack());//1位(0-发送 /  1-返回)stringBufferFunction.append(cmdFunction.getIsMachineBack());//0位(0-不需要从机返回信息 /  1-需要从机返回信息)//功能码二进制转10进制int functionTen = Integer.parseInt(stringBufferFunction.toString(), 2);StringBuffer stringBuffer = new StringBuffer();stringBuffer.append(bytesToHexString(cmdNormal.getRollCode()));//滚码stringBuffer.append(bytesToHexString(functionTen));//功能码//地址码int address=cmdNormal.getAddress();stringBuffer.append(bytesToHexString(address>> 8 & 0xff));stringBuffer.append(bytesToHexString(address& 0xff));//当前帧stringBuffer.append(bytesToHexString(cmdNormal.getCurrentFrame()));//总帧stringBuffer.append(bytesToHexString(cmdNormal.getTotalFrame()));//数据模式stringBuffer.append(bytesToHexString(cmdNormal.getModeType()));CmdNormal.AllDataMode allDataMode=cmdNormal.getAllDataMode();for(CmdCode cmdCode:allDataMode.getCmdCodeList()){if(cmdCode.getLenth()==1){stringBuffer.append(bytesToHexString(cmdCode.getValue()));}else if(cmdCode.getLenth()==2){stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 8 & 0xff));//高8位stringBuffer.append(bytesToHexString(cmdCode.getValue() & 0xff));//低8位}else if(cmdCode.getLenth()==4){stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 24 & 0xff));//高24位stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 16 & 0xff));//高16位stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 8 & 0xff));//高8位stringBuffer.append(bytesToHexString(cmdCode.getValue() & 0xff));//低8位}else if(cmdCode.getLenth()==6){stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 40 & 0xff));//高40位stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 32 & 0xff));//高32位stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 24 & 0xff));//高24位stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 16 & 0xff));//高16位stringBuffer.append(bytesToHexString(cmdCode.getValue()>> 8 & 0xff));//高8位stringBuffer.append(bytesToHexString(cmdCode.getValue() & 0xff));//低8位}}return stringBuffer.toString();}

 

三,总结:

3.1 整个Mesh通信拓扑的实现还是比较复杂的,所以开源的可能不好找,我也是基于收费厂家的一套Mesh方案实现的组网的步骤,有兴趣的可以了解下组网的概念和组网的流程。

3.2 组网步骤总结:

第一步肯定还是扫描设备,毕竟这是蓝牙最基本功能

Mesh节点在网络内发送数据不会像普通BLE广播需要等一个固定的广播间隔,而是延迟一小段随机时间后发送,所以为了数据不丢失,节点会启用100%占空比来扫描广播信道,扫描窗口时间=扫描间隔

第二步检测key连接设备

mesh对传输的数据进行分层次加密,网络层(Network Layer)数据通过网络密钥(Network Key)加密;应用密钥(App Key)用于加密接入层(Access Layer)数据;配置模型(Configuration Model)的数据则采用设备密钥(Device Key)进行加密

 

第三步选择节点

mesh里面还给每个节点有一些额外的四种可选的特性(Features)。分别是中继Relay,代理Proxy,朋友Friend和 低功耗Low Power features。节点可以在某个时间点选择不支持或者支持多个Feature。

中继(Relay)支持中继的节点,可以帮忙转发收到的消息。因为有了Relay,Mesh网络就可以实现多跳(Hops)。

低功耗和朋友(Low Power Nodes and Friend Nodes), 这是搭配来用的。我们先说Low power节点,类似于对功耗有要求的设备,例如温度传感器。这种类型的设备为了节约功耗,很大的时间都是在休眠的。也就是意味着他们收不到网络中发过来的消息。Friend节点能帮LP节点暂存消息。当LP节点需要的时候,可以发消息给Friend节点, 问问有没有“waiting message”。如果有,就会一条条的发给LP节点。简而言之,Friend节点就像是门卫的张大爷,你(Low power node)想起来的时候去门卫拿你要的信就好了。这种方式和zigbee里面的enddevice向父节点拿数据的方式类似

第四步配置入网

所谓配网就是将未配网的设备变为配网的节点,一般需要一个配网器与末配网设备进行配网交互、验证然后通过后将一些密钥交给对方的一个过程。
一般过程有5个阶段:
1. 信标(Beaconing)阶段
2.邀请 (Invitation)阶段
3. 交换公钥 (Exchange Public Keys)阶段
4. 身份认证 CAuthentication)阶段
5. 分发配网数据 (Distribution Of Provisioning Data)阶段

第五步分配地址

单播地址:分配给节点中的元素地址,地址范围0x0001~0x7FFF,
未分配地址:即无效地址,固定为0x0000,地址的初始值,常用于屏蔽一个设备
组播地址:用于表示一个或多个节点的多个元素,地址范围0xC000~0xFFFF,其中包含256个固定组播地址
虚拟地址:用于表示一个或多个节点的多个元素,每一个虚拟地址逻辑上对应一个128-bit的Label UUID,通过对该Label UUID作哈希运算得出虚拟地址的低14位数值,虚拟地址的范围为0x8000~0xBFFF

第六步选择模型

模型(Model)定义了节点基本功能的最小单位模型,包含实现这个功能所必需的状态和操作状态的消息及其他一些行为 

在蓝牙mesh模型里,消息通信基于客户端-服务器的架构,对外提供状态访问接口的叫做服务器(Server),而访问服务器状态的叫做客户端,模型分为三种

服务器模型:服务器模型包含了一个或多个元素上的一种或多种状态,比如灯泡上包含有通用开关服务器模型(Generic OfOff Server)和灯泡亮度服务器模型(Light Lightneww Server)
客户端模型:客户端模型定义了一系列的消息,用于客户端去请求、设置服务端的状态,比如开关中含有通用开关客户端模型(Generic OnOff Client)以及灯亮度客户端模型(Light Lightness Client),客户端模型不含有状态
控制模型:控制模型可以包含一个或多个客户端模型,用来和其他节点的服务端模型通信;也可以包含一个或多个服务端模型,用于响应其他节点客户端模型发来的消息
蓝牙技术联盟定义的模型被称为标准模型(SIG Adopted Model),16bit标识,目前SIG定义好的模型包括Generic、Sensors、Time and Scenes、Lighting;由厂商定义的模型称为厂商模型(Vendor Model),32bit标识。

第七步发布和订阅

在蓝牙mesh里面发消息的动作我们叫做发布(Publish)。光从字面意思理解大家基本上就能看懂了。我想告诉别人什么事情发生或者做什么事情就叫做发布。谁对某些消息感兴趣就可以订阅这些内容。节点发布消息到单播地址,组播地址或者虚拟地址。节点有兴趣接收这些数据的可以订阅这些地址。

第八步发送消息

蓝牙Mesh采用了消息缓存队列和TTL的优化方案来避免消息的无限制转发。

消息缓存 Message cache:设备都会缓存收到消息的关键信息,以确定是否已经转发过此消息,如果是就忽略此消息。Message cache至少需要能缓存两条消息
Time to Live(TTL): 每个消息都会包含一个Time to Live(TTL)的值,来限制中继的次数,最大可以中继126次。消息每转发一次TTL的值就减1,TTL值为1就不再转发

http://www.tj-hxxt.cn/news/29673.html

相关文章:

  • 杭州做网站比较出名的公司郑州发布最新通告
  • app软件开发制作公司有哪些长春网站优化服务
  • 域名被墙检测优化网站性能监测
  • 做的比较好网站有哪些网站seo排名优化工具
  • 长沙创意网站建设大庆建站公司
  • 帮做非法网站中国国家培训网官网查询
  • 工作一般做网站视频的工作叫做什么深圳seo推广
  • 网站怎么做成手机版百度游戏排行榜
  • 网站模版设计如何写好一篇软文
  • 厦门网站建设方案优化淘宝seo搜索引擎原理
  • 做网站交付标准营销助手下载app下载
  • 张家港做淘宝网站如何做运营推广
  • 垃圾站 WordPress举例网络营销的例子
  • asp企业营销型网站建设上海最新事件
  • 广州门户网站百度极速版客服人工在线咨询
  • 网站建设亻金手指下拉广告推广营销网站
  • 做微商好还是开网站好北京网络营销策划公司
  • 做ps网页设计的网站有哪些安卓优化大师旧版
  • 织梦m网站伪静态semester
  • 建网站用什么服务器好广州seo诊断
  • 有没有做数学题挣钱的网站seo优化服务
  • wordpress内容关键字谷歌优化的最佳方案
  • 做羞羞事免费网站百度新闻首页头条
  • 做网站说要自己贴税点是怎么回事呀有免费推广平台
  • 在哪里做网站效果好百度世界500强排名
  • 网站建设的活怎么接百度产品
  • 凡科网的网站建设好用吗公众号运营
  • 深圳住房和建设局网站全景看房免费行情软件网站下载大全
  • 企业网站建设常见问题网销怎么做才能做好
  • 可以做淘宝推广的网站有哪些内容优化设计答案大全