AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

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

2016-01-27 2617
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： <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开发
物联网
API
数据格式
XML
小程序
关键词：
Android功能
云服务器 ECS通信
Android终端
云服务器 ECS功能
Android客户端
刘桂林
目录
相关文章
陈明勇
|
1月前
|
人工智能 搜索推荐 程序员
用 Go 语言轻松构建 MCP 客户端与服务器
本文介绍了如何使用 mcp-go 构建一个完整的 MCP 应用，包括服务端和客户端两部分。 - 服务端支持注册工具（Tool）、资源（Resource）和提示词（Prompt），并可通过 stdio 或 sse 模式对外提供服务； - 客户端通过 stdio 连接服务器，支持初始化、列出服务内容、调用远程工具等操作。
陈明勇
298 3
山东布谷科技_sun
|
1月前
|
NoSQL 应用服务中间件 PHP
布谷一对一直播源码android版环境配置流程及功能明细
部署需基于 CentOS 7.9 系统，硬盘不低于 40G，使用宝塔面板安装环境，包括 PHP 7.3（含 Redis、Fileinfo 扩展）、Nginx、MySQL 5.6、Redis 和最新 Composer。Swoole 扩展需按步骤配置。2021.08.05 后部署需将站点目录设为 public 并用 ThinkPHP 伪静态。开发环境建议 Windows 操作系统与最新 Android Studio，基础配置涉及 APP 名称修改、接口域名更换、包名调整及第三方登录分享（如 QQ、微信）的配置，同时需完成阿里云与腾讯云相关设置。
山东布谷科技_sun
58 5
蓝易云
|
2月前
|
网络协议 开发者 Python
Socket如何实现客户端和服务器间的通信
通过上述示例，展示了如何使用Python的Socket模块实现基本的客户端和服务器间的通信。Socket提供了一种简单且强大的方式来建立和管理网络连接，适用于各种网络编程应用。理解和掌握Socket编程，可以帮助开发者构建高效、稳定的网络应用程序。
蓝易云
110 10
DevKevin
|
4月前
|
存储 开发工具 git
[Git] 深入理解 Git 的客户端与服务器角色
Git 的核心设计理念是分布式，每个仓库既可以是客户端也可以是服务器。通过 GitHub 远程仓库和本地仓库的协作，Git 实现了高效的版本管理和代码协作。GitHub 作为远程裸仓库，存储项目的完整版本历史并支持多客户端协作；本地仓库则通过 `.git` 文件夹独立管理版本历史，可在离线状态下进行提交、回滚等操作，并通过 `git pull` 和 `git push` 与远程仓库同步。这种分布式特性使得 Git 在代码协作中具备强大的灵活性和可靠性。
DevKevin
114 18
[Git] 深入理解 Git 的客户端与服务器角色
蚝油菜花
|
5月前
|
存储 人工智能 自然语言处理
ChatMCP：基于 MCP 协议开发的 AI 聊天客户端，支持多语言和自动化安装 MCP 服务器
ChatMCP 是一款基于模型上下文协议（MCP）的 AI 聊天客户端，支持多语言和自动化安装。它能够与多种大型语言模型（LLM）如 OpenAI、Claude 和 OLLama 等进行交互，具备自动化安装 MCP 服务器、SSE 传输支持、自动选择服务器、聊天记录管理等功能。
蚝油菜花
1813 16
ChatMCP：基于 MCP 协议开发的 AI 聊天客户端，支持多语言和自动化安装 MCP 服务器
jsjsjjs
|
3月前
|
算法 安全 Java
即时通讯安全篇（一）：正确地理解和使用Android端加密算法
本文主要讨论针对Android这样的移动端应用开发时，如何正确的理解目前常用的加密算法，为诸如即时通讯应用的实战开发，如何在合适的场景下选择适合的算法，提供一些参考。
jsjsjjs
99 0
shiningrise
|
6月前
|
开发框架 .NET C#
在 ASP.NET Core 中创建 gRPC 客户端和服务器
本文介绍了如何使用 gRPC 框架搭建一个简单的“Hello World”示例。首先创建了一个名为 GrpcDemo 的解决方案，其中包含一个 gRPC 服务端项目 GrpcServer 和一个客户端项目 GrpcClient。服务端通过定义 `greeter.proto` 文件中的服务和消息类型，实现了一个简单的问候服务 `GreeterService`。客户端则通过 gRPC 客户端库连接到服务端并调用其 `SayHello` 方法，展示了 gRPC 在 C# 中的基本使用方法。
shiningrise
106 5
在 ASP.NET Core 中创建 gRPC 客户端和服务器
jianz123
|
6月前
|
Android开发 数据安全/隐私保护 虚拟化
安卓手机远程连接登录Windows服务器教程
安卓手机远程连接登录Windows服务器教程
jianz123
1087 4
弹性计算小冉
|
27天前
|
存储 缓存 弹性计算
阿里云经济型e实例云服务器评测：企业官网搭建的性价比之选
阿里云服务器经济型e实例可以用来搭建企业网站吗？云服务器作为搭建企业官网的基础设施，其性能、稳定性、成本等因素直接影响着官网的运营效果。阿里云经济型e实例云服务器作为一款性价比较高的产品，备受用户关注。许多企业在选择云服务器搭建官网时，都会将其纳入考虑范围。本文将详细探讨阿里云经济型e实例云服务器的特点、性能表现、稳定性与可靠性，以及成本考量，最终解答是否适合用它来搭建企业官网。
弹性计算小冉
81 6
弹性计算小冉
|
2月前
|
存储 缓存 网络协议
阿里云特惠云服务器99元与199元配置与性能和适用场景解析：高性价比之选
2025年，阿里云长效特惠活动继续推出两款极具吸引力的特惠云服务器套餐：99元1年的经济型e实例2核2G云服务器和199元1年的通用算力型u1实例2核4G云服务器。这两款云服务器不仅价格亲民，而且性能稳定可靠，为入门级用户和普通企业级用户提供了理想的选择。本文将对这两款云服务器进行深度剖析，包括配置介绍、实例规格、使用场景、性能表现以及购买策略等方面，帮助用户更好地了解这两款云服务器，以供参考和选择。
弹性计算小冉
389 7

热门文章

最新文章

  • 1
    FastAPI开发者福音！FastAPI-MCP：将FastAPI秒变MCP服务器的开源神器，无需配置自动转换！
  • 2
    阿里云服务器安装宝塔面板、安装网站（新手图文教程）
  • 3
    阿里云轻量应用服务器38元与云服务器99元和199元区别及选择参考
  • 4
    阿里云X86/ARM/GPU/裸金属/超算等五大服务器架构技术特点、场景适配与选型策略
  • 5
    阿里云服务器实例规格怎么选？经济型、通用算力型、计算型、通用型、内存型场景化选购指南
  • 6
    阿里云GPU服务器gn6v、gn7i、gn6i性能特点、区别及选择参考
  • 7
    DHCP服务器配置
  • 8
    阿里云服务器4核16G配置整理：ECS实例规格、CPU型号及适用场景说明
  • 9
    阿里云服务器四种购买方式解析：自定义、快速、活动、云市场镜像选购流程参考
  • 10
    阿里云服务器经济型e与通用算力型u1各自性能、适用场景解析与使用常见问题参考
  • 1
    Android cmdline-tools版本与最小JDK的关系
    52
  • 2
    如何查看Flutter应用在Android设备上已被撤销的权限？
    136
  • 3
    如何在Android设备上撤销Flutter应用程序的所有权限？
    132
  • 4
    在Android设备上运行Flutter应用程序时，如果遇到设备未授权的问题该如何解决？
    150
  • 5
    Flutter环境配置完成后，如何在Android设备上运行Flutter应用程序？
    222
  • 6
    如何在Android Studio中配置Flutter环境？
    279
  • 7
    移动端数据抓取：Android App的TLS流量解密方案
    83
  • 8
    Android系统SELinux安全机制详解
    93
  • 9
    布谷一对一直播源码android版环境配置流程及功能明细
    58
  • 10
    Android网络请求演变：从Retrofit到Flow的转变过程。
    96

    • 相关课程

    更多
  • ECS上云入门三部曲
  • 服务器硬件基础
  • Linux Web服务器Nginx搭建与配置
  • 7天玩转云服务器
  • 云服务器选型、迁云最佳实践
  • 云服务器ECS基本操作

    • 相关电子书

    更多
  • 如何运维千台以上游戏云服务器
  • 网站/服务器取证 实践与挑战
  • ECS快储存加密技术

    • 相关实验场景

    更多
  • 使用阿里云ECS搭建一套网页IDE
  • 幻兽帕鲁联机服务快速部署【有ECS用户】
  • 幻兽帕鲁联机服务快速部署【无ECS用户】
  • 云原生场景自动化响应ECS系统事件
  • ECS实例选型最佳实践
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月