Android BLE与终端通信（四）——实现服务器与客户端即时通讯功能下载_Word模板_21

is_196623

暂无简介

Android BLE与终端通信（四）——实现服务器与客户端即时通讯功能Android BLE与终端通信（四）——实现服务器与客户端即时通讯功能 Android BLE与终端通信(四)——实现服务器与客户端即时通讯功能在开始之前，别忘了添加权限一.OpenBluetooth Google的API上说的是十分的清楚，我们作为初学者要把他当做说明书一样来看待这样的话，我们就来实现打开蓝牙并且打开可见性，可见性默认是120s，MAX为3600s，这里在强调一遍，打开蓝牙有两种方式，一种是弹框提示，一种是强制打开，这在之前也是提过好多次了的 /** * 打开蓝牙并且搜索...

Android BLE与终端通信（四）——实现服务器与客户端即时通讯功能 Android BLE与终端通信(四)——实现服务器与客户端即时通讯功能在开始之前，别忘了添加权限

一.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.printStackTrwww.shanxiwang.netace(); 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

本文档为【Android BLE与终端通信（四）——实现服务器与客户端即时通讯功能】，请使用软件OFFICE或WPS软件打开。作品中的文字与图均可以修改和编辑，图片更改请在作品中右键图片并更换，文字修改请直接点击文字进行修改，也可以新增和删除文档中的内容。

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

热门搜索

历史搜索