package com.cyy.bluetest; import android.app.Activity; import android.os.Bundle; import android.view.View; import android.view.View.OnClickListener; import android.widget.Button; import android.widget.TextView; import com.cyy.bluetooth.BlueConnetHandler; import com.cyy.bluetooth.BlueDeviceControl; import com.cyy.bluetooth.BlueToothCallBack; public class MainActivity extends Activity implements OnClickListener { private TextView tv; private BlueConnetHandler handler; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); findViewById(R.id.bn).setOnClickListener(this); tv = (Button) findViewById(R.id.tv); } private void blue() { BlueDeviceControl control = new BlueDeviceControl(); control.openBlue();// 打开蓝牙 handler = new BlueConnetHandler(new BlueToothCallBack() { @Override public void getDate(String date) { tv.setText("连接数据: " + date); } @Override public void connect(boolean state) { tv.setText("连接: " + state); } }, "mac地址"); handler.sendEmptyMessage(BlueConnetHandler.CONNECT); } @Override public void onClick(View v) { if (handler.getStateConnect() != 0) { tv.setText("已在连接中....."); } else { tv.setText("连接中....."); blue(); } } }
package com.cyy.bluetooth; import java.util.ArrayList; import java.util.HashMap; import java.util.Map; import java.util.Set; import android.bluetooth.BluetoothAdapter; import android.bluetooth.BluetoothDevice; import android.content.Context; import android.content.SharedPreferences; public class BlueDeviceControl { private BluetoothAdapter adapter; /** 构造方法 */ public BlueDeviceControl() { adapter = BluetoothAdapter.getDefaultAdapter(); } /** 设备是否支持蓝牙 */ public boolean isBlueToothSupported() { return adapter != null; } /** 打开蓝牙 */ public void openBlue() { if (adapter != null && !adapter.isEnabled()) { adapter.enable(); } } /** 关闭蓝牙 */ public void closeBlue() { if (adapter != null && adapter.isEnabled()) { adapter.disable(); } } /** 返回已配对的蓝牙设备 */ public String[] getPartners() { Set<BluetoothDevice> set = adapter.getBondedDevices(); String list[] = new String[set.size()]; int i = 0; for (BluetoothDevice device : set) { list[i] = device.getAddress(); i++; } return list; } /** 返回已配对的蓝牙设备 */ public ArrayList<Map<String, String>> allPartners() { ArrayList<Map<String, String>> list = new ArrayList<Map<String, String>>(); Set<BluetoothDevice> set = adapter.getBondedDevices(); for (BluetoothDevice device : set) { Map<String, String> map = new HashMap<String, String>(); map.put("name", device.getName()); map.put("address", device.getAddress()); list.add(map); } return list; } /** 自动连接上次连接过的蓝牙地址 */ public String getAdress(Context context) { SharedPreferences prference; String BLUE_PREF_NAME = "BLUE_PREF_NAME"; String ADDRESS = "address"; prference = context.getSharedPreferences(BLUE_PREF_NAME, 0); String tmp = prference.getString(ADDRESS, "00:0E:EA:CE:C9:64"); return tmp; } /** 保存蓝牙地址,SharedPreferences保存 */ public void saveAdress(Context context, String mac) { if (context != null) { SharedPreferences prference; String BLUE_PREF_NAME = "BLUE_PREF_NAME"; String ADDRESS = "address"; prference = context.getSharedPreferences(BLUE_PREF_NAME, 0); prference.edit().putString(ADDRESS, mac).commit(); } } }
package com.cyy.bluetooth; import java.io.BufferedInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.UnsupportedEncodingException; import java.util.UUID; import android.bluetooth.BluetoothAdapter; import android.bluetooth.BluetoothDevice; import android.bluetooth.BluetoothSocket; import android.os.Handler; import android.os.Message; public class BlueConnectThread extends Thread { private Handler handler; // 连接非安卓设备固定UUID private final UUID uuid = UUID.fromString("00001101-0000-1000-8000-00805F9B34FB"); private BluetoothDevice device; private BluetoothSocket socket; private OutputStream output; private String mac; public BlueConnectThread(Handler handler) { this.handler = handler; } @Override public void run() { InputStream stream; try { socket.connect(); stream = socket.getInputStream(); output = socket.getOutputStream(); BufferedInputStream input = new BufferedInputStream(stream); Message message = handler.obtainMessage( BlueConnetHandler.CONNECT_SUCCEED, mac); message.sendToTarget(); int length; byte[] bytes = new byte[100]; while ((length = input.read(bytes)) != -1) { byte[] cacheByte = new byte[length]; System.arraycopy(bytes, 0, cacheByte, 0, length); message = handler.obtainMessage(BlueConnetHandler.GET_DATA, cacheByte); message.sendToTarget(); } } catch (IOException e) { Message message = handler.obtainMessage(BlueConnetHandler.CONNECT_FAIL); message.sendToTarget(); System.out.println(e.toString()); } } public boolean sendMsg(String msg) { if (output != null) { try { output.write(msg.getBytes("UTF-8")); return true; } catch (UnsupportedEncodingException e) { System.out.println(e.toString()); } catch (IOException e) { System.out.println(e.toString()); } } return false; } public void setMac(String mac) { this.mac = mac; try { // 判断是不是有效蓝牙地址,如果地址无效IllegalArgumentException异常 device = BluetoothAdapter.getDefaultAdapter().getRemoteDevice(mac); // 更改socket信道 socket = device.createRfcommSocketToServiceRecord(uuid); } catch (IllegalArgumentException e) { System.out.println(e.toString()); } catch (IOException e) { System.out.println(e.toString()); } } }
package com.cyy.bluetooth; import java.nio.ByteBuffer; import android.os.Handler; import android.os.Message; public class BlueConnetHandler extends Handler { private BlueToothCallBack callBack; // 默认,可以自定义测试目标mac地址 private String mac = "00:0E:EA:CE:C9:53"; // 缓冲区1024字节,如果接收的内容多,可以适当增大缓冲区 private ByteBuffer blueData = ByteBuffer.allocate(1024); public static final int CONNECT = 0x111111; public static final int GET_DATA = 0x111111 + 1; public static final int CONNECT_FAIL = 0x111111 + 2; public static final int CONNECT_SUCCEED = 0x111111 + 3; private static final int RESET = 0x111111 + 4; private static final int time = 10 * 1000; private int stateConnect = 0;// 连接状态,默认未开始连接 private BlueConnectThread thread; public BlueConnetHandler(BlueToothCallBack callBack) { this.callBack = callBack; } public BlueConnetHandler(BlueToothCallBack callBack, String mac) { this.callBack = callBack; this.mac = mac; } @Override public void handleMessage(Message msg) { super.handleMessage(msg); switch (msg.what) { case CONNECT: if (thread == null || !thread.isAlive()) { stateConnect = CONNECT; thread = new BlueConnectThread(this); thread.setMac(mac); thread.start(); } break; case CONNECT_FAIL: stateConnect = CONNECT_FAIL; dealACallBack(false); // 设置连接失败后继续重新连接,10秒后重启 this.sendEmptyMessageDelayed(CONNECT, time); break; case CONNECT_SUCCEED: stateConnect = CONNECT_SUCCEED; mac = (String) msg.obj; callBack.connect(true); dealACallBack(true); break; case GET_DATA:// 从蓝牙获取到一些数据,通常一组数据分几次发送过来 byte[] bytes = (byte[]) msg.obj; blueData.put(bytes); this.removeMessages(RESET); this.sendEmptyMessageDelayed(RESET, 100); break; case RESET: // 从蓝牙获取一组数据后发送出去 decodeReSet(); break; default: break; } } private void dealACallBack(boolean isConnect) { if (null != callBack) { callBack.connect(isConnect); } } /** 根据蓝牙协议解析数据。然后重置data */ private void decodeReSet() { blueData.flip(); // String data = bytes2String(blueData.array()); // 简单地处理,具体还要根据协议来解析数据 String data = new String(blueData.array()); if (callBack != null) { callBack.getDate(data); } blueData.clear(); } /** 16进制字节数组转换成十进制字符串 */ private String bytes2String(byte[] bytes) { long sum = 0; for (int i = 0; i < bytes.length; i++) { long cache = bytes[i] & 0xff; for (int j = 0; j < i; j++) { cache = cache << 4 << 4; } sum += cache; } return sum + ""; } public int getStateConnect() { return stateConnect; } public boolean sendMsg(String msg) { if (thread != null) { return thread.sendMsg(msg); } return false; } }
代码开源 SVN:http://code.taobao.org/svn/blueconnect/trunk
原文地址:http://blog.csdn.net/chenlove1/article/details/42738461