Android BLE与终端通信（四）——实现服务器与客户端即时通讯功能

前面几篇一直在讲一些基础，其实说实话，蓝牙主要为多的还是一些概念性的东西，当你把概念都熟悉了之后，你会很简单的就可以实现一些逻辑，主要是Socket和I/O流的操作，今天就来一起做一个聊天的小程序，我们都知道，我们实现蓝牙连接，蓝牙是有主从关系的，所以有客户端和服务端之分，我们新建一个工程——BLE_QQ(hh,毕竟是即时通讯嘛，和QQ挨个边)

参考Google的API：http://developer.android.com/guide/topics/connectivity/bluetooth.html

这里写图片描述

在开始之前，别忘了添加权限

<uses-permission android:name="android.permission.BLUETOOTH" />
<uses-permission android:name="android.permission.BLUETOOTH_ADMIN" />

一.OpenBluetooth

Google的API上说的是十分的清楚，我们作为初学者要把他当做说明书一样来看待

这里写图片描述

这样的话，我们就来实现打开蓝牙并且打开可见性，可见性默认是120s，MAX为3600s，这里在强调一遍，打开蓝牙有两种方式，一种是弹框提示，一种是强制打开，这在之前也是提过好多次了的

/**
     * 打开蓝牙并且搜索
     */
    public void openBluetooth(View v) {
        // 开启搜索
        Intent discoverableIntent = new Intent(
                BluetoothAdapter.ACTION_REQUEST_DISCOVERABLE);
        // 设置可见性300s
        discoverableIntent.putExtra(
                BluetoothAdapter.EXTRA_DISCOVERABLE_DURATION, 300);
        startActivity(discoverableIntent);

        // 强制打开
        // mBluetoothAdapter.enable();
    }

CloseBluetooth

关闭蓝牙也就直接调用BluetoothAdapter的disable()方法;

    /**
     * 关闭蓝牙
     */
    public void closeBluetooth(View v) {
        mBluetoothAdapter.disable();
    }

客户端

我们在MainActivity中写一个button直接跳转到ClientActivity中去

    /**
     * 打开客户端
     */
    public void Client(View v) {
        startActivity(new Intent(this, ClientActivity.class));
    }

ClientActivity

package com.example.ble_qq;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.SocketOptions;
import java.util.UUID;

import com.example.ble_qq.ServiceActivity.ReceiverInfoThread;

import android.app.Activity;
import android.bluetooth.BluetoothAdapter;
import android.bluetooth.BluetoothDevice;
import android.bluetooth.BluetoothServerSocket;
import android.bluetooth.BluetoothSocket;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.text.TextUtils;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;

/**
 * 客户端
 * 
 * @author LGL
 *
 */
public class ClientActivity extends Activity {

    // 连接成功
    private static final int CONN_SUCCESS = 0x1;
    // 连接失败
    private static final int CONN_FAIL = 0x2;
    private static final int RECEIVER_INFO = 0x3;
    // 设置文本框为空
    private static final int SET_EDITTEXT_NULL = 0x4;
    // 接收到的消息
    private TextView tv_content;
    // 输入框
    private EditText et_info;

    // 发送按钮
    private Button btn_send;

    // 本地蓝牙适配器
    private BluetoothAdapter mBluetoothAdapter = null;

    // 远程设备
    private BluetoothDevice device = null;

    // 蓝牙设备Socket客户端
    private BluetoothSocket socket = null;

    private boolean isReceiver = true;

    // 设备名称
    private static final String NAME = "LGL";

    // 输入输出流
    private PrintStream out;
    private BufferedReader in;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        // TODO Auto-generated method stub
        super.onCreate(savedInstanceState);
        setTitle("客户端");
        setContentView(R.layout.activity_client);

        initView();
        // 初始化Socket客户端连接
        init();

    }

    private void initView() {
        // 初始化
        tv_content = (TextView) findViewById(R.id.tv_content);
        et_info = (EditText) findViewById(R.id.et_info);
        btn_send = (Button) findViewById(R.id.btn_send);
    }

    private void init() {
        tv_content.setText("客户端已经启动，正在与服务端连接...\n");
        // 开始连接
        new Thread(new Runnable() {

            @Override
            public void run() {

                try {
                    // 得到本地蓝牙适配器
                    mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
                    // 通过本地适配器得到地址,这个地址可以公共扫描来获取，就是getAddress()返回的地址
                    device = mBluetoothAdapter
                            .getRemoteDevice("98:6C:F5:CE:0E:81");
                    // 根据UUID返回一个socket,要与服务器的UUID一致
                    socket = device.createRfcommSocketToServiceRecord(UUID
                            .fromString("00000000-2527-eef3-ffff-ffffe3160865"));
                    if (socket != null) {
                        // 连接
                        socket.connect();
                        // 处理流
                        out = new PrintStream(socket.getOutputStream());

                        in = new BufferedReader(new InputStreamReader(socket
                                .getInputStream()));
                    }
                    // 连接成功发送handler
                    handler.sendEmptyMessage(CONN_SUCCESS);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                    Message mes = handler.obtainMessage(CONN_FAIL,
                            e.getLocalizedMessage());
                    handler.sendMessage(mes);
                }

            }
        }).start();
    }

    /**
     * Handler接收消息
     * 
     */
    private Handler handler = new Handler() {
        public void handleMessage(Message msg) {
            switch (msg.what) {
            case CONN_SUCCESS:
                setInfo("连接成功! \n");
                btn_send.setEnabled(true);
                Log.i("设备的名称", device.getName());
                Log.i("设备的UUID", device.getUuids() + "");
                Log.i("设备的地址", device.getAddress());
                // 开始接收信息
                new Thread(new ReceiverInfoThread()).start();
                break;
            case CONN_FAIL:
                setInfo("连接失败! \n");
                setInfo(msg.obj.toString() + "\n");
                break;
            case RECEIVER_INFO:
                setInfo(msg.obj.toString() + "\n");
                break;
            case SET_EDITTEXT_NULL:
                et_info.setText("");
                break;

            }
        }
    };

    /**
     * 接收消息的线程
     */
    class ReceiverInfoThread implements Runnable {

        @Override
        public void run() {
            String info = null;
            while (isReceiver) {
                try {
                    info = in.readLine();
                    Message msg = handler.obtainMessage(RECEIVER_INFO);
                    handler.sendMessage(msg);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 发送消息
     */
    public void SendText(View v) {
        final String text = et_info.getText().toString();
        // 不能为空
        if (!TextUtils.isEmpty(text)) {
            Toast.makeText(this, "不能为空", Toast.LENGTH_SHORT).show();
        }
        new Thread(new Runnable() {

            @Override
            public void run() {
                // 输出
                out.println(text);
                out.flush();
                // 把文本框设置为空
                handler.sendEmptyMessage(SET_EDITTEXT_NULL);
            }
        }).start();
    }

    /**
     * 拼接文本信息
     */
    private void setInfo(String info) {
        StringBuffer sb = new StringBuffer();
        sb.append(tv_content.getText());
        sb.append(info);
        tv_content.setText(sb);
    }
}

服务端

我们在MainActivity中写一个button直接跳转到ServiceActivity中去

    /**
     * 打开服务端
     */
    public void Service(View v) {
        startActivity(new Intent(this, ServiceActivity.class));
    }

ServiceActivity

package com.example.ble_qq;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.util.UUID;

import android.app.Activity;
import android.bluetooth.BluetoothAdapter;
import android.bluetooth.BluetoothServerSocket;
import android.bluetooth.BluetoothSocket;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.text.TextUtils;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;

/**
 * 服务端
 * 
 * @author LGL
 *
 */
public class ServiceActivity extends Activity {

    // 连接成功
    private static final int CONN_SUCCESS = 0x1;
    // 连接失败
    private static final int CONN_FAIL = 0x2;
    private static final int RECEIVER_INFO = 0x3;
    // 设置文本框为空
    private static final int SET_EDITTEXT_NULL = 0x4;
    // 接收到的消息
    private TextView tv_content;
    // 输入框
    private EditText et_info;

    // 发送按钮
    private Button btn_send;

    // 本地蓝牙适配器
    private BluetoothAdapter mBluetoothAdapter = null;

    // 蓝牙设备Socket服务端
    private BluetoothServerSocket serviceSocket = null;

    // 蓝牙设备Socket客户端
    private BluetoothSocket socket = null;

    // 设备名称‘
    private static final String NAME = "LGL";

    private boolean isReceiver = true;

    // 输入输出流
    private PrintStream out;
    private BufferedReader in;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        // TODO Auto-generated method stub
        super.onCreate(savedInstanceState);
        setTitle("服务端");
        setContentView(R.layout.activity_service);

        initView();
        // 创建蓝牙服务端的Socket
        initService();
    }

    private void initView() {
        // 初始化
        tv_content = (TextView) findViewById(R.id.tv_content);
        et_info = (EditText) findViewById(R.id.et_info);
        btn_send = (Button) findViewById(R.id.btn_send);

    }

    private void initService() {
        tv_content.setText("服务器已经启动，正在等待设备连接...\n");
        // 开启线程操作
        new Thread(new Runnable() {

            @Override
            public void run() {
                // 得到本地适配器
                mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
                // 创建蓝牙Socket服务端
                try {
                    // 服务端地址
                    serviceSocket = mBluetoothAdapter
                            .listenUsingInsecureRfcommWithServiceRecord(
                                    NAME,
                                    UUID.fromString("00000000-2527-eef3-ffff-ffffe3160865"));
                    // 阻塞线程等待连接
                    socket = serviceSocket.accept();
                    if (socket != null) {
                        // I/O流
                        out = new PrintStream(socket.getOutputStream());

                        in = new BufferedReader(new InputStreamReader(socket
                                .getInputStream()));
                    }
                    // 连接成功发送handler
                    handler.sendEmptyMessage(CONN_SUCCESS);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                    Message mes = handler.obtainMessage(CONN_FAIL,
                            e.getLocalizedMessage());
                    handler.sendMessage(mes);
                }

            }
        }).start();
    }

    /**
     * Handler接收消息
     * 
     */
    private Handler handler = new Handler() {
        public void handleMessage(Message msg) {
            switch (msg.what) {
            case CONN_SUCCESS:
                setInfo("连接成功! \n");
                btn_send.setEnabled(true);
                new Thread(new ReceiverInfoThread()).start();
                break;
            case CONN_FAIL:
                setInfo("连接失败! \n");
                setInfo(msg.obj.toString() + "\n");
                break;
            case RECEIVER_INFO:
                setInfo(msg.obj.toString() + "\n");
                break;
            case SET_EDITTEXT_NULL:
                et_info.setText("");
                break;

            }
        }
    };

    /**
     * 接收消息的线程
     */
    class ReceiverInfoThread implements Runnable {

        @Override
        public void run() {
            String info = null;
            while (isReceiver) {
                try {
                    info = in.readLine();
                    Message msg = handler.obtainMessage(RECEIVER_INFO);
                    handler.sendMessage(msg);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 发送消息
     */
    public void SendText(View v) {
        final String text = et_info.getText().toString();
        // 不能为空
        if (!TextUtils.isEmpty(text)) {
            Toast.makeText(this, "不能为空", Toast.LENGTH_SHORT).show();
        }
        new Thread(new Runnable() {

            @Override
            public void run() {
                // 输出
                out.println(text);
                out.flush();
                // 把文本框设置为空
                handler.sendEmptyMessage(SET_EDITTEXT_NULL);
            }
        }).start();
    }

    /**
     * 拼接文本信息
     */
    private void setInfo(String info) {
        StringBuffer sb = new StringBuffer();
        sb.append(tv_content.getText());
        sb.append(info);
        tv_content.setText(sb);
    }
}

XML

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical" >

    <TextView
        android:id="@+id/tv_content"
        android:layout_width="match_parent"
        android:layout_height="0dp"
        android:layout_weight="1" />

    <EditText
        android:id="@+id/et_info"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" />

    <Button
        android:id="@+id/btn_send"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:onClick="SendText"
        android:text="发送" />

</LinearLayout>