开发者社区> 刘桂林> 正文

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

简介: <div class="markdown_views"> <h1 id="android-ble与终端通信四实现服务器与客户端即时通讯功能">Android BLE与终端通信(四)——实现服务器与客户端即时通讯功能</h1> <hr> <blockquote> <p>前面几篇一直在讲一些基础,其实说实话,蓝牙主要为多的还是一些概念性的东西,当你把概念都熟悉了之后,你会很简
+关注继续查看

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>

实际上运行结果是这样的,我们必须准备两部手机,然后先用蓝牙配对,在进行连接

这里写图片描述

这里写图片描述

这样我们两个设备就配对成功了

Demo下载地址:http://download.csdn.net/detail/qq_26787115/9420355

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Android与服务器端数据交互(http协议整合struts2+android)
android中有时候我们不需要用到本机的SQLite数据库提供数据,更多的时候是从网络上获取数据,那么Android怎么从服务器端获取数据呢?有很多种,归纳起来有 一:基于Http协议获取数据方法。
698 0
Android 一些常用跳转应用(其实查源码是一样的但留着Copy的时候方便)
显示网页 Java代码 Uri uri = Uri.parse("http://google.com"); Intent it = new Intent(Intent.ACTION_VIEW, uri); startActivity(it); Uri uri = Uri.
619 0
ArcGIS 客户端跨版本连接Oracle 地理数据库时的兼容性说明
很多用户都会有这样的疑问: 1:我是否可以使用ArcGIS Desktop9.3连接ArcSDE10 2:我是否可以使用ArcGIS 10.
1016 0
Android View加载圆形图片且同时绘制圆形图片的外部边缘边线及边框:LayerDrawable实现
 Android View加载圆形图片且同时绘制圆形图片的外部边缘边线及边框:LayerDrawable实现 LayerDrawable实现的结果和附录文章1,2,3中的layer-list一致。
1003 0
《圣殿祭司的ASP.NET4.0专家技术手册》---- 1-13 ClientBuilderManager类别的编译功能
ClientBuildManager类别提供编译ASP.NET应用程序的方法和属性,并提取产生的组件或产生的源代码。通过它可做预编译,而Aspnet_Compiler.exe命令背后正是ClientBuild- Manager类,但差别是ClientBuildManager类可以通过.NET程序来调用。
1407 0
+关注
刘桂林
心有菩提手有刀,欲成舍利却成妖
188
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载