Android Bluetooth 通信技术深入--聊天小应用

android 蓝牙 聊天
  1. 1. 效果示意图
  2. 2.开发步骤
  3. 3.具体的实现
    1. 3.1 开启蓝牙
    2. 3.2 搜索蓝牙
    3. 3.3 连接蓝牙设备
    4. 3.4 创建蓝牙socket
    5. 3.5 读取和写入数据
    6. 3.6 关闭连接

目前，市场上的大部分手机都带有蓝牙，尽管使用的不多，但作为开发者，我们还有必要了解其原理。最近的项目需要用到蓝牙技术，于是写了个 蓝牙的聊天小demo。

1. 效果示意图

这里需要两部手机进行测试。其中一部作为蓝牙服务器，另一部作为蓝牙客户端，进行通信。
客户端截图：
client
服务器截图：
server

2.开发步骤

  1. 开启蓝牙；
  2. 搜索蓝牙设备；
  3. 创建蓝牙socket，读取输出流；
  4. 读取和写入数据；
  5. 关闭连接和蓝牙。

3.具体的实现

3.1 开启蓝牙

首先获取蓝牙适配器，若存在蓝牙未开则打开蓝牙，如下代码：

1
2
3
4
5
6
7
8
9
BluetoothAdapter mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
        if (mBluetoothAdapter == null) {
            Toast.makeText(getActivity(), "无蓝牙功能", Toast.LENGTH_SHORT).show();
        } else {
            if (!mBluetoothAdapter.isEnabled()) {
                Intent enableBtIntent = new Intent(BluetoothAdapter.ACTION_REQUEST_ENABLE);
                startActivityForResult(enableBtIntent, REQUEST_ENABLE_BT);
            }
        }

3.2 搜索蓝牙

首先开启蓝牙搜索功能，然后通过注册广播，搜索蓝牙设备，搜索完成后将其加入到蓝牙列表。
搜索蓝牙：

1
2
3
4
5
6
7
8
9
10
11
if (mBluetoothAdapter.isDiscovering()) {
    mBluetoothAdapter.cancelDiscovery();
    mBtnStartSearch.setText("重新搜索");
} else {
    mDatas.clear();
    mAdapter.notifyDataSetChanged();
    //添加设备信息到列表
    init();
}
mBluetoothAdapter.startDiscovery();
mBtnStartSearch.setText("ֹͣ停止搜索");

注册蓝牙广播：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
/**
     * 搜索设备广播
     */
private final BroadcastReceiver mReceiver = new BroadcastReceiver() {
    @Override
    public void onReceive(Context context, Intent intent) {
        String action = intent.getAction();
        if (BluetoothDevice.ACTION_FOUND.equals(action)) {
            // 获得设备信息
            BluetoothDevice device = intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE);
            // 绑定的状态不一样则进行添加
            if (device.getBondState() != BluetoothDevice.BOND_BONDED) {
                mDatas.add(new BtInfo(device.getName(), device.getAddress(), false));
                mAdapter.notifyDataSetChanged();
                mListView.setSelection(mDatas.size() - 1);
            }
            // 搜索完成
        } else if (BluetoothAdapter.ACTION_DISCOVERY_FINISHED.equals(action)) {
            if (mListView.getCount() == 0) {
                Toast.makeText(context, "没有发现设备！", Toast.LENGTH_SHORT).show();
            }
            mBtnStartSearch.setText("重新搜索");
        }
    }
};
 /**
 * 注册广播
 */
private void registerBroadcast() {
    //设备被发现广播
    IntentFilter discoveryFilter = new IntentFilter(BluetoothDevice.ACTION_FOUND);
    getActivity().registerReceiver(mReceiver, discoveryFilter);
    // 设备发现完成
    IntentFilter foundFilter = new IntentFilter(BluetoothAdapter.ACTION_DISCOVERY_FINISHED);
    getActivity().registerReceiver(mReceiver, foundFilter);
}

3.3 连接蓝牙设备

这里，使用listview展示蓝牙列表信息，item 的点击事件即为连接相应的蓝牙设备，点击某一项后跳转到会话页面，并通知他刷新信息，为方便，这里使用了EventBus来订阅事件，避免使用接口，如下listview 的item 的点击事件：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
//列表item设置监听，
mListView.setOnItemClickListener(new AdapterView.OnItemClickListener() {
    @Override
    public void onItemClick(AdapterView<?> adapterView, View view, int i, long l) {
        BtInfo info = mDatas.get(i);
        //好友mac地址
        MainActivity.FRIEND_MAC_ADDRESS = info.getAddress();
        //显示提示对话框
        final AlertDialog.Builder dialog = new AlertDialog.Builder(getActivity());
        dialog.setTitle("连接");
        dialog.setMessage("名称：" + info.getName() + "\n" + "地址：" + info.getAddress());
        dialog.setPositiveButton("连接", new DialogInterface.OnClickListener() {
            @Override
            public void onClick(DialogInterface dialogInterface, int i) {
                mBluetoothAdapter.cancelDiscovery();
                mBtnStartSearch.setText("重新搜索");
                //连接后，跳转到会话页面
                MainActivity.mType = MainActivity.Type.CILENT;
                //viewPager 显示第二页
                MainActivity.mViewPager.setCurrentItem(1);
                //通知 ChatListFragment 刷新信息
                EventBus.getDefault().post(new EventMsg(1));
                dialogInterface.dismiss();
            }
        });
        dialog.setNegativeButton("取消", new DialogInterface.OnClickListener() {
            @Override
            public void onClick(DialogInterface dialogInterface, int i) {
                MainActivity.FRIEND_MAC_ADDRESS = "";
                dialogInterface.dismiss();
            }
        });
        dialog.show();
    }
});

3.4 创建蓝牙socket

由于socketd的操作会阻塞线程，这里在子线程中进行创建。
BluetoothSocket 客户端线程：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
// 客户端线程
private class ClientThread extends Thread {
    public void run() {
        try {
            mSocket = mDevice.createRfcommSocketToServiceRecord(UUID.fromString("00001101-0000-1000-8000-00805F9B34FB"));
            Message msg = new Message();
            msg.obj = "请稍候，正在连接服务器:" + MainActivity.FRIEND_MAC_ADDRESS;
            msg.what = STATUS_CONNECT;
            mHandler.sendMessage(msg);
            mSocket.connect();
            msg = new Message();
            msg.obj = "已经连接上服务端！可以发送信息。";
            msg.what = STATUS_CONNECT_SUCCESS;
            mHandler.sendMessage(msg);
            // 启动接受数据
            mReadThread = new ReadThread();
            mReadThread.start();
        } catch (IOException e) {
            Message msg = new Message();
            msg.obj = "连接服务端异常！断开连接重新试一试。";
            msg.what = STATUS_CONNECT_SUCCESS;
            mHandler.sendMessage(msg);
        }
    }
}

创建蓝牙连接时需要用到UUID,如需查看更多UUID，请点击这里。
BluetoothServerSocket蓝牙服务端socket线程：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 // 服务器端线程
private class ServerThread extends Thread {
    public void run() {
        try {
            // 创建一个蓝牙服务器 参数分别：服务器名称、UUID
            mServerSocket = mBluetoothAdapter.listenUsingRfcommWithServiceRecord("btserver",
                    UUID.fromString("00001101-0000-1000-8000-00805F9B34FB"));
            Message msg = new Message();
            msg.obj = "请稍候，正在等待客户端的连接...";
            msg.what = STATUS_CONNECT;
            mHandler.sendMessage(msg);
			/* 接受客户端的连接请求 */
            mSocket = mServerSocket.accept();
            msg = new Message();
            msg.obj = "客户端已经连接上！可以发送信息。";
            msg.what = STATUS_CONNECT;
            mHandler.sendMessage(msg);
            // 启动接受数据
            mReadThread = new ReadThread();
            mReadThread.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

启动蓝牙客户端和服务端线程方法如下(详情参见类的onEventMainThread方法)：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
if (MainActivity.mType == MainActivity.Type.CILENT) {
    String address = MainActivity.FRIEND_MAC_ADDRESS;//蓝牙地址
    if (!TextUtils.isEmpty(address)) {
        mDevice = mBluetoothAdapter.getRemoteDevice(address);
        mClientThread = new ClientThread();
        mClientThread.start();
        MainActivity.isOpen = true;
    } else {
        Toast.makeText(getActivity(), "address is null !", Toast.LENGTH_SHORT).show();
    }
} else if (MainActivity.mType == MainActivity.Type.SERVER) {
    mServerThread = new ServerThread();
    mServerThread.start();
    MainActivity.isOpen = true;
}

3.5 读取和写入数据

这里主要是通过获取输入输出流来读取和发送数据，以读取数据为例，如下现读取数据线程代码：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
// 读取数据
private class ReadThread extends Thread {
    public void run() {
        byte[] buffer = new byte[1024];
        int bytes;
        InputStream is = null;
        try {
            is = mSocket.getInputStream();
            while (true) {
                if ((bytes = is.read(buffer)) > 0) {
                    byte[] buf_data = new byte[bytes];
                    for (int i = 0; i < bytes; i++) {
                        buf_data[i] = buffer[i];
                    }
                    String s = new String(buf_data);
                    Message msg = new Message();
                    msg.obj = s;
                    msg.what = 1;
                    mHandler.sendMessage(msg);
                }
            }
        } catch (IOException e1) {
            e1.printStackTrace();
        } finally {
            try {
                is.close();
            } catch (IOException e1) {
                e1.printStackTrace();
            }
        }
    }
}

发送消息与此类似，具体请参见 会话类 。

3.6 关闭连接

主要是关闭各个线程和关闭socket。

至此，整个蓝牙同信已经完成，测试时需要两个手机，一个座位服务器，一个作为客户端，实现他们间的通信。

示例demo下载

当前网速较慢或者你使用的浏览器不支持博客特定功能，请尝试刷新或换用Chrome、Firefox等现代浏览器