这几天最大的事可能就是美国总统的上任，双十一，还有乐视股价了，乍一看，好像和我们没什么关系，其实肯定是有的了，要不然他也成不了新闻啊，有一点我们得改变，就是我们必须要希望我们自己国家的企业能过强大，我们必须支持他们，哪怕他做的不够好，这个问题其实就像一个国家一样，我们都知道许多政策是不合理的，或者说有很多制度是坑人的，但是我们不能因为这些而不爱我们的国家，那么企业也是一样，就拿乐视来说，股价跌了，公司遇到资金问题了，你看看这些媒体都在报道什么，全是负面消息，马上倒闭了，或者说是撑不住了，没有一家媒体是支持乐视，都是在等着看笑话，恨不得把人家祖宗十八代都挖出来，凉一凉，这些都让我看到这些新闻都不想在点进去，还有就是锤子，你看看国外的品牌对国人的腐蚀度，国内的品牌居然远不及他，人家一个做手机的，好歹也是国产品牌，我们不想着让他走出国门，而是想着看他的笑话，媒体恨不得他明天早上就能倒闭，这倒还是一个头条新闻，其实，要是企业都走出去了，国家也就变得强大了，这个时候，你到别的国家旅游的时候人家就不会另眼相看了，人家在嘲笑你的时候，你是不是还挺高兴的，我们不能这么恬不知耻，我们要支持我们国家的每一个企业，即使他做的不好，我们也不能嘲笑每一个企业，因为他有可能就是你以后出去引以为豪的企业，是你自己国家的。
这是最终效果，也是通过蓝牙进行数据传输，实时传输，可见蓝牙传输数据之强大
首先要说的就是我的处理方式，我是把service和activity之间的通讯当成两个应用来处理的，为什么要这样做呢？其实是为了有些时候我们会把蓝牙在后台的service设置成了一个单独的进程，设置成单独的进程的好处也是有的，可以单独的运作，系统会单独的给他开辟一块内存出来保证他的运行，因为这个时候service已经相当于一个单独的应用了，所以说，这个时候我们要想和service通信，那就是跨进程了，而不是线程了，这个时候大家都会想到aidl，他是专门来处理进程之间的通讯问题的，别逗了，好么，谁他么傻，就一个服务，我还得去写一个aidl，要是这样的话，我也就不会写这篇文章了，列位，看大招！
它引用了一个Handler对象，以便others能够向它发送消息。该类允许跨进程间基于Message的通信(即两个进程间可以通过Message进行通信)，在服务端使用Handler创建一个 Messenger，客户端持有这个Messenger就可以与服务端通信了
和直接使用AIDL不同的是Messenger利用了Handler处理通信，所以它是线程安全的（不支持并发处理）；而我们平时用的AIDL是非线程安全的（支持并发处理）。所以大多数时候我们应用中是不需要处理夸进程并发处理通信的，而且最重要的是蓝牙喜欢并发的发送数据，而且还要很有顺序，所以这时选择Messenger会比AIDL更加容易操作。其实Messenger最终还是aidl的实现方式，是不是屌爆了。
① service 内部需要有一个 Handler 的实现，它被用来处理从每一个 client(activity) 发送过的来请求
② 通过这个 Handler ，来生成一个 Messenger
③ 在 service 的onBind() 方法中，需要向 client(activity) 返回由该 Messenger 生成的一个 IBinder 实例
④ client 使用从 service 返回的 IBinder 实例来初始化一个 Messenger， 然后使用该 Messenger 与 service 进行通信
⑤ service 通过它自身内部的 Handler 实现(Handler的handleMessage() 方法中)来处理从 client 发送过来的请求
1、创建activity中的Messenger
//创建activity中的Messenger mMessenger = new Messenger(new IncomingHandler(this)); 12 122、实现client(activity)端的handler
// client(activity端) 端 Handler 的实现 private class IncomingHandler extends Handler { private final WeakReference<BaseActivity> mActivity; public IncomingHandler(BaseActivity activity) { mActivity = new WeakReference<>(activity); } /* * 处理从Service发送至该Activity的消息 */ @Override public void handleMessage(Message msg) { BaseActivity activity = mActivity.get(); if (activity != null) { switch (msg.what) { case BleService.MSG_BLUETOOTH_ON://检测到蓝牙已开启 ToastUtil.showToast("检测到蓝牙已打开"); break; default: super.handleMessage(msg); } } } } 1234567891011121314151617181920212223242526272829 12345678910111213141516171819202122232425262728293、client 端 ServiceConnection 的实现 服务和activity绑定，必须实现ServiceConnection
//与服务的连接回调 private ServiceConnection serviceConnection = new ServiceConnection() { // 当与service的连接建立后被调用 @Override public void onServiceConnected(ComponentName name, IBinder service) { // 客户端(activity) 与 服务 不在同一个进程中的话，是不可以进行显示强制类型转换的 // 使用从Service返回的IBinder来生成一个Messenger mService = new Messenger(service); // 生成一个Message Message msg = Message.obtain(); if (msg != null) { msg.what = MSG_BIND_SUCCESS; msg.replyTo = mMessenger; // 向Service 发送Message sendMessage(msg); } else { mService = null; } //activity与service绑定成功 } // 当与service的连接意外断开时被调用 @Override public void onServiceDisconnected(ComponentName name) { mService = null; } }; 123456789101112131415161718192021222324252627282930 1234567891011121314151617181920212223242526272829304、client 端 向service发送消息
protected synchronized void sendMessage(Message msg) { if (msg != null && mService != null) { try { mService.send(msg); } catch (RemoteException e) { unbindService(serviceConnection); } } } 123456789 1234567895、service端创建Messenger和handler
① 创建Messenger
//创建service中的Messenger 用来和activity通信 mHandler = new IncomingHandler(this); mMessenger = new Messenger(mHandler); 123 123② 创建handler
// service 端 Handler 的实现 private static class IncomingHandler extends Handler { private final WeakReference<BleService> mService; //使用弱引用进行优化 public IncomingHandler(BleService service) { mService = new WeakReference<>(service); } //用来处理activity发来的消息 @Override public synchronized void handleMessage(Message msg) { //拿到service对象 BleService service = mService.get(); if (service != null) { switch (msg.what) {//根据发送过来消息的种类来处理消息 case MSG_REGISTER: service.mClients.add(msg.replyTo);//添加订阅者 LogUtil.fussenLog().d("1008611" + "======注册service====="); break; case MSG_UNREGISTER: service.mClients.remove(msg.replyTo);//移除此消息 LogUtil.fussenLog().d("1008611" + "======注销service====="); break; default: super.handleMessage(msg); } } } } 123456789101112131415161718192021222324252627282930313233 123456789101112131415161718192021222324252627282930313233③ 拿到IBinder对象
@Nullable @Override public IBinder onBind(Intent intent) { return mMessenger.getBinder(); } 12345 12345做到这，activity与service的通信框架就基本搭建完成了，这个时候不管service是一个单独的进程还是服务，那么都可以和activity就行无缝的通信了，记住不是并发而是有序的
在 Android蓝牙4.0之玩爆智能穿戴、家具(一) 一文中，我们已经讲述过了一遍蓝牙基本的开发流程，下面我们就来说下具体的流程和方法，还有处理方式，列位，不管你是高手还是未来的高手，请听一听我的方法，我们都需要共同进步，这篇文章要是说的有理，或者说对你有很大的启发，那就赶紧关注我的微信公共号，要不然这篇文章的价值体现何在？好吧，可以开始了
1、开启蓝牙，就不说了，现在说扫描蓝牙，首先是activity向service发送一个消息，告知service，让service在后台处理，扫描成功，向activity发送消息，将扫描到的数据一并带过去，扫描失败，告知activity自行处理，不管怎样给出一个扫描时间，不能一直扫描，我的处理方式，就是5秒后关闭扫描，这时候也有各个手机的兼容问题，所以时间不能太长，浪费资源(耗电)，并且会有不能预测的问题出现① activity向service发消息，扫描蓝牙
/** * 向服务发送消息，开始扫描蓝牙 */ private void startScan() { if (!BleUtils.isOpenBle(this)) { ToastUtil.showToast("蓝牙未开启，请先开启蓝牙"); return; } progressDialog.setMessage("搜索中..."); progressDialog.show(); Message msg = Message.obtain(null, BleService.MSG_START_SCAN); sendMessage(msg); } 1234567891011121314 1234567891011121314② service收到消息，开始扫描工作
/** * 服务开始扫描所有蓝牙设备 */ private void startScanBleDevice() { mHandler.postDelayed(new Runnable() { @Override public void run() { mBlueToothAdapter.stopLeScan(mLeScanCallback); // 5秒后结束扫描 // 通知界面扫描结束 并传递数据 if (mLeDevices != null && mLeDevices.size() > 0) { Message msg = Message.obtain(null, SCAN_BLE_DEVICE_RESULT); msg.arg1 = MSG_SCAN_SUCCESS; msg.obj = mLeDevices;//将扫描到的蓝牙设备集合传递到activity去 sendMessage(msg); } else { // 通知没有扫描到 Message msg = Message.obtain(null, SCAN_BLE_DEVICE_RESULT); msg.arg1 = MSG_SCAN_FAIL; sendMessage(msg); } } }, 5 * 1000); if (mLeDevices != null && mLeDevices.size() > 0) { mLeDevices.clear(); // 清空当前的数据。 } if (mDeviceAddress != null && mDeviceAddress.size() > 0) { mDeviceAddress.clear(); } mBlueToothAdapter.startLeScan(mLeScanCallback); } 1234567891011121314151617181920212223242526272829303132 12345678910111213141516171819202122232425262728293031322、实现BluetoothAdapter.LeScanCallback，在上文中我们在这个回调里拿到了附近所有的设备信息，但是在实战中，我们谁都不会去这么做，其实呢，我们在扫描的阶段就应该过滤出自己的设备，不将其他设备展示出来，这样才是我们真正的需求呀，如何过滤呢，Demo源码中已经有很好的方案了，可下载源码查看，这里就不讲了，有可能，每个设备的过滤方法都不一样，但是一般情况下都是通过UUID来过滤的，我们采取的是使用UUID和广播双层过滤
3、如果说没有问题的话，你的设备应该已经显示在你的手机上了，下一步就是连接了，然后又和上面一样activity发送连接消息向service，然后service收到消息进行处理，代码不再贴出，现在就是service处理消息的问题了，那么service收到消息该怎么处理才好呢，此时应该开启异步连接任务，让他去连接，最好这样做，要不然很有可能会出现问题，目前各个手机蓝牙都已经很少了，偶尔会冒出个毛病来，但是不影响大局
/** * 连接设备 * * @param device */ private void connectDevice(BluetoothDevice device) { if (device == null) { return; } mBluetoothDevice = device; //开启异步连接任务 new ConnectDeviceTask().execute(); } //异步去连接设备 private class ConnectDeviceTask extends AsyncTask<String, Integer, String> { @Override protected void onPreExecute() { } @Override protected String doInBackground(String... params) { try { if (mBluetoothDevice != null) { mBluetoothGatt = mBluetoothDevice.connectGatt(BleService.this, false, mBluetoothCallback); } return ""; } catch (Exception e) { e.printStackTrace(); } return null; } @Override protected void onPostExecute(String result) { } } 123456789101112131415161718192021222324252627282930313233343536373839 1234567891011121314151617181920212223242526272829303132333435363738394、实现BluetoothGattCallback，这个回调是最主要的啦，刚才是连接，那么我们暂时只关心BluetoothGattCallback回调中的onConnectionStateChange，那么在这里我们究竟要做些什么呢？其实这个方法执行了也就意味着蓝牙设备和手机连接已经成功了，我们应该先通知activity蓝牙设备连接成功，可是并不是这样的，一般情况下，我们暂时是不通知的，其实通知也是可以的，这不是说了么，为了安全么，所以处理的方式是一旦连接失败，立即通知，那么成功呢，别急，我们是和硬件打交道的，我们肯定会和硬件约定一个彼此认识的唯一标示吧，你不能说你拿着你的手机什么设备都连呀，那恐怕不行吧，这里我只是抛砖引玉，具体怎么做，还得看你们怎么约定的，Demo中是直接通知页面了
//连接状态回调方法 @Override public void onConnectionStateChange(BluetoothGatt gatt, int status, int newState) { if (newState == BluetoothProfile.STATE_CONNECTED) {//连接成功 LogUtil.fussenLog().d("1008611" + "=======设备连接连接成功======"); //去发现该设备服务 mBluetoothGatt.discoverServices(); isDeviceConnection = true; } else {//连接失败 LogUtil.fussenLog().d("1008611" + "=======设备连接连接失败======"); mBluetoothGatt.close(); mBluetoothGatt = null; if (isDeviceConnection) { isDeviceConnection = false; } } sendDeviceConnectionState();//通知页面 } 123456789101112131415161718192021 1234567891011121314151617181920215、这个时候，我们要做的就是等这个方法返回成功之后，调用蓝牙发现服务的方法，先让他去寻找这个设备的服务，这个时候让我们把目光都投向BluetoothGattCallback回调中的onServicesDiscovered方法中来，能不能发现设备中的service的结果都会在这里出现，在这里我们要做的事情就是拿到自己设备中的服务，还有像有的数据是要进行订阅的，在这里就得订阅了，这个时候我们就得和设备进行通信了，比如下发配置值，获取设备电量什么的，都在这里执行
@Override public void onServicesDiscovered(BluetoothGatt gatt, int status) { if (status == BluetoothGatt.GATT_SUCCESS) {//已发现该设备的服务 //寻找服务之后，我们就可以和设备进行通信，比如下发配置值，获取设备电量什么的 LogUtil.fussenLog().d("1008611" + "=======onServicesDiscovered======"); //通过UUID拿到设备里的服务service mDeviceService = mBluetoothGatt.getService(UUIDUtils.CMD_SERVICE); //通过UUID拿到设备里的Characteristic cmdRespondCharacter = mDeviceService.getCharacteristic(UUIDUtils.CMD_READ_CHARACTERISTIC); cmdWriteCharacter = mDeviceService.getCharacteristic(UUIDUtils.CMD_WRITE_CHARACTERISTIC); btWriteCharacter = mDeviceService.getCharacteristic(UUIDUtils.CMD_BT_WRITE_CHARACTERISTIC); btRespondCharacter = mDeviceService.getCharacteristic(UUIDUtils.CMD_BT_READ_CHARACTERISTIC); //开启订阅事件后 设备可以主动的发送数据给你 //通知后相应的Characteristic数据会在 onCharacteristicChanged()方法中返回 //这里我订阅了cmdRespondCharacter，btRespondCharacter enableNotification(true, mBluetoothGatt, cmdRespondCharacter); enableNotification(true, mBluetoothGatt, btRespondCharacter); //写入数据 nextWrite(); } else {//未发现该设备的服务 //这里我暂时没有做处理 } } 12345678910111213141516171819202122232425262728 123456789101112131415161718192021222324252627286、订阅事件：就是当设备需要主动的向你发送数据时，这时候，你应该先订阅，否则onCharacteristicChanged方法是不会执行的
private void enableNotification(boolean enable, BluetoothGatt gatt, BluetoothGattCharacteristic characteristic) { if (gatt == null || characteristic == null) return; //这一步必须要有 否则收不到通知 gatt.setCharacteristicNotification(characteristic, enable); BluetoothGattDescriptor clientConfig = characteristic.getDescriptor(UUIDUtils.CCC); if (enable) { clientConfig.setValue(BluetoothGattDescriptor.ENABLE_NOTIFICATION_VALUE); } else { clientConfig.setValue(BluetoothGattDescriptor.DISABLE_NOTIFICATION_VALUE); } //准备数据 BleWriteData bData = new BleWriteData(); bData.write_type = BleWriteData.DESCRIP_WRITE;//数据种类 bData.object = clientConfig; //将数据加入队列 mWriteQueue.add(bData); } 12345678910111213141516171819 123456789101112131415161718197、写入数据：这个时候我们写的数据就是为了能获得设备的信息，或者发送一些指令，那要怎么写呢？这里就得注意了
① 写数据的时候必须是有序的，不能并发，这个时候我们就得用到队列了，一定不能乱，首先创建一个数据的队列，并且必须是先进先出
Queue mWriteQueue = new ConcurrentLinkedQueue();//数据队列
ConcurrentLinkedQueue介绍：
ConcurrentLinkedQueue是一个基于链接节点的无界线程安全队列，它采用先进先出的规则对节点进行排序，当我们添加一个元素的时候，它会添加到队列的尾部，当我们获取一个元素时，它会返回队列头部的元素。
② 在第6步的时候我们已经准备过数据了，这个时候就开始准备发送数据了，现在给出发送数据的代码
/** * 写入数据，方法是同步的 */ private synchronized void nextWrite() { if (!mWriteQueue.isEmpty() && !isWriting) { doWrite(mWriteQueue.poll());//从数据队列里取出数据 } } 12345678 12345678③ 正式写入数据：这个时候要注意的就是为了保证在数据很多的情况下都能够发送成功，必须要有一个超时的判定，一旦超时，要么重新发送，要么直接丢掉数据，继续发送，具体情况得和硬件沟通，发送完之后，就得到onCharacteristicWrite方法中检查是否写入成功，但是我第一次调用的是mBluetoothGatt.writeDescriptor(),所以我要在onDescriptorWrite()方法中检查我发送的数据是否发送完毕
private void doWrite(BleWriteData data) { if (mBluetoothGatt == null) { return; } if (data.write_type == BleWriteData.CMD) { // cmd write if (cmdWriteCharacter != null) { cmdWriteCharacter.setWriteType(BluetoothGattCharacteristic.WRITE_TYPE_NO_RESPONSE);//设置为WRITE_TYPE_NO_RESPONSE，这样速度会快 cmdWriteCharacter.setValue(data.write_data); mBluetoothGatt.writeCharacteristic(cmdWriteCharacter); isWriting = true; latSendData = data; if (timeOutThread == null) { //开启超时判断线程 initTimeOutThread(); } } } else if (data.write_type == BleWriteData.DESCRIP_WRITE) { // BluetoothGattDescriptor isWriting = true; mBluetoothGatt.writeDescriptor((BluetoothGattDescriptor) data.object); } else { nextWrite(); } } 123456789101112131415161718192021222324 123456789101112131415161718192021222324④ 检查数据是否发送完毕，我在这里 检查的是我定义的数据队列一旦数据队列中没有数据，那么我认为数据已经发送完毕，具体还得看硬件有没有其他要求，我是这样做的
/** * 写入完Descriptor之后调用此方法 应在此检查数据是否发送完毕 * @param gatt * @param descriptor * @param status */ @Override public void onDescriptorWrite(BluetoothGatt gatt, BluetoothGattDescriptor descriptor, int status) { if (mWriteQueue.isEmpty()) { isWriting = false; //数据写入完毕 可以在此处通知页面或者做其他工作 } else { //如果队列中还有数据，继续写入 isWriting = false; nextWrite(); } } 1234567891011121314151617181920 1234567891011121314151617181920⑤ 超时判断：在这里采用的是轮询方式，但是逻辑的话各个设备都是不一样的，这里只是简单的说下
/** * 指令超时判断的线程 */ class TimeOutThread extends Thread { @Override public void run() { while (timeOutThread_Start) { if (isWriting) { if (timeOutTime == 6) { // 超时三秒啦 重发 if (timeOutNum == 3) { // 超时3次 放弃当前这条指令 发送下一条 isWriting = false; mWriteQueue.clear(); timeOutNum = 0; timeOutTime = 0; //发送超时信息 sendTimeOutMessage(); nextWrite(); continue; } if (reSendData != null && latSendData != null && reSendData.write_type == latSendData.write_type && Arrays.toString(reSendData.write_data).equals(Arrays.toString(latSendData.write_data))) { timeOutNum++; } else { timeOutNum = 1; } if (latSendData != null) { doWrite(latSendData); reSendData = latSendData; } timeOutTime = 0; } else { int num = 0; while (isWriting) { SystemClock.sleep(10); num++; if (num == 50) { break; } } timeOutTime++; } } else { int num = 0; while (!isWriting) { SystemClock.sleep(10); num++; if (num == 1000) { break; } } } } } } 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354558、onCharacteristicChanged方法 我们的业务最主要的就是设备采取数据，然后发送数据到手机上来，所以，关注的数据一般都是在onCharacteristicChanged方法里，因为我们需要设备主动发送数据过来，然后验证和解析，处理的方式就是对于相对重要的数据要进行CRC8校验，一旦失败，就得通知页面，可能你所关心的和我所关心的不一样，但是道理都是相通的，下面贴出代码
/**被订阅的Characteristic的值要是改变 调用此方法 * 执行此方法的前提就是要被订阅 * @param gatt * @param characteristic */ @Override public void onCharacteristicChanged(BluetoothGatt gatt, BluetoothGattCharacteristic characteristic) { //拿到characteristic的值 byte[] data = characteristic.getValue(); // 通过characteristic.getUUID()来判断是谁发送值给你 来执行相应的操作 if (characteristic.getUuid().equals(UUIDUtils.CMD_BT_READ_CHARACTERISTIC)) { // BT handleBTDataAvailable(data);//拿到数据后解析 并发送给页面 } else { // CMD命令的返回 if (TLUtil.validateCRC8(data)) {//进行CRC8码验证 验证成功后 解析数据 LogUtil.fussenLog().e("1008611" + "========BLE CMD命令的返回========="); handleCharacteristicData(data); } else { //CRC8码验证失败 通知界面 Message msg = Message.obtain(null, MSG_CRC8_ERROR); sendMessage(msg); } } } 2