在使用蓝牙是 BluetoothAdapter 对蓝牙开启,关闭,获取设备列表,发现设备,搜索等核心功能
下面对它进行封装:
package com.xiaoyu.bluetooth;import java.util.ArrayList;import java.util.Iterator;import java.util.List;import java.util.Set;import android.app.Activity;import android.app.AlertDialog;import android.bluetooth.BluetoothAdapter;import android.bluetooth.BluetoothDevice;import android.content.BroadcastReceiver;import android.content.Context;import android.content.DialogInterface;import android.content.Intent;import android.content.IntentFilter;public class BTManage {// private List<BTItem> mListDeviceBT=null; private BluetoothAdapter mBtAdapter =null; private static BTManage mag=null;private BTManage(){// mListDeviceBT=new ArrayList<BTItem>(); mBtAdapter=BluetoothAdapter.getDefaultAdapter(); }public static BTManage getInstance(){ if(null==mag) mag=new BTManage(); return mag; }private StatusBlueTooth blueStatusLis=null; public void setBlueListner(StatusBlueTooth blueLis){ this.blueStatusLis=blueLis; }public BluetoothAdapter getBtAdapter(){ return this.mBtAdapter; }public void openBluetooth(Activity activity){ if(null==mBtAdapter){ ////Device does not support BluetoothAlertDialog.Builder dialog = new AlertDialog.Builder(activity);dialog.setTitle("No bluetooth devices");dialog.setMessage("Your equipment does not support bluetooth, please change device"); dialog.setNegativeButton("cancel", new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { } });dialog.show();return; } // If BT is not on, request that it be enabled. if (!mBtAdapter.isEnabled()) { /*Intent enableIntent = new Intent(BluetoothAdapter.ACTION_REQUEST_ENABLE); activity.startActivityForResult(enableIntent, 3);*/ mBtAdapter.enable(); } }public void closeBluetooth(){ if(mBtAdapter.isEnabled()) mBtAdapter.disable(); }public boolean isDiscovering(){ return mBtAdapter.isDiscovering(); }public void scanDevice(){// mListDeviceBT.clear(); if(!mBtAdapter.isDiscovering()) mBtAdapter.startDiscovery(); }public void cancelScanDevice(){ if(mBtAdapter.isDiscovering()) mBtAdapter.cancelDiscovery(); }public void registerBluetoothReceiver(Context mcontext){ // Register for broadcasts when start bluetooth search IntentFilter startSearchFilter = new IntentFilter(BluetoothAdapter.ACTION_DISCOVERY_STARTED); mcontext.registerReceiver(mBlueToothReceiver, startSearchFilter); // Register for broadcasts when a device is discovered IntentFilter discoveryFilter = new IntentFilter(BluetoothDevice.ACTION_FOUND); mcontext.registerReceiver(mBlueToothReceiver, discoveryFilter); // Register for broadcasts when discovery has finished IntentFilter foundFilter = new IntentFilter(BluetoothAdapter.ACTION_DISCOVERY_FINISHED); mcontext.registerReceiver(mBlueToothReceiver, foundFilter); }public void unregisterBluetooth(Context mcontext){ cancelScanDevice(); mcontext.unregisterReceiver(mBlueToothReceiver); }public List<BTItem> getPairBluetoothItem(){ List<BTItem> mBTitemList=null; // Get a set of currently paired devices Set<BluetoothDevice> pairedDevices = mBtAdapter.getBondedDevices(); Iterator<BluetoothDevice> it=pairedDevices.iterator(); while(it.hasNext()){ if(mBTitemList==null) mBTitemList=new ArrayList<BTItem>();BluetoothDevice device=it.next(); BTItem item=new BTItem(); item.setBuletoothName(device.getName()); item.setBluetoothAddress(device.getAddress()); item.setBluetoothType(BluetoothDevice.BOND_BONDED); mBTitemList.add(item); } return mBTitemList; } private final BroadcastReceiver mBlueToothReceiver = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { String action = intent.getAction(); if(BluetoothAdapter.ACTION_DISCOVERY_STARTED.equals(action)) { if(blueStatusLis!=null) blueStatusLis.BTDeviceSearchStatus(StatusBlueTooth.SEARCH_START); } else if (BluetoothDevice.ACTION_FOUND.equals(action)){ // When discovery finds a device// Get the BluetoothDevice object from the IntentBluetoothDevice device = intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE);// If it"s already paired, skip it, because it"s been listed alreadyif (device.getBondState() != BluetoothDevice.BOND_BONDED) {BTItem item=new BTItem();item.setBuletoothName(device.getName());item.setBluetoothAddress(device.getAddress());item.setBluetoothType(device.getBondState());if(blueStatusLis!=null) blueStatusLis.BTSearchFindItem(item); // mListDeviceBT.add(item);} }else if (BluetoothAdapter.ACTION_DISCOVERY_FINISHED.equals(action)){ // When discovery is finished, change the Activity title if(blueStatusLis!=null) blueStatusLis.BTDeviceSearchStatus(StatusBlueTooth.SEARCH_END); } } }; }蓝牙开发和socket一致,分为server,client
package com.xiaoyu.bluetooth;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.EOFException;import java.io.IOException;import java.util.UUID;import com.xiaoyu.utils.ThreadPool;import android.bluetooth.BluetoothAdapter;import android.bluetooth.BluetoothServerSocket;import android.bluetooth.BluetoothSocket;import android.os.Handler;import android.os.Message;public class BTServer { /* 一些常量,代表服务器的名称 */ public static final String PROTOCOL_SCHEME_L2CAP = "btl2cap"; public static final String PROTOCOL_SCHEME_RFCOMM = "btspp"; public static final String PROTOCOL_SCHEME_BT_OBEX = "btgoep"; public static final String PROTOCOL_SCHEME_TCP_OBEX = "tcpobex";private BluetoothServerSocket btServerSocket = null; private BluetoothSocket btsocket = null; private BluetoothAdapter mBtAdapter =null; private BufferedInputStream bis=null; private BufferedOutputStream bos=null; private Handler detectedHandler=null;public BTServer(BluetoothAdapter mBtAdapter,Handler detectedHandler){ this.mBtAdapter=mBtAdapter; this.detectedHandler=detectedHandler; }public void startBTServer() { ThreadPool.getInstance().excuteTask(new Runnable() { public void run() { try { btServerSocket = mBtAdapter.listenUsingRfcommWithServiceRecord(PROTOCOL_SCHEME_RFCOMM, UUID.fromString("00001101-0000-1000-8000-00805F9B34FB"));Message msg = new Message(); msg.obj = "请稍候,正在等待客户端的连接..."; msg.what = 0; detectedHandler.sendMessage(msg); btsocket=btServerSocket.accept(); Message msg2 = new Message();String info = "客户端已经连接上!可以发送信息。"; msg2.obj = info; msg.what = 0; detectedHandler.sendMessage(msg2);receiverMessageTask(); } catch(EOFException e){ Message msg = new Message(); msg.obj = "client has close!"; msg.what = 1; detectedHandler.sendMessage(msg); }catch (IOException e) { e.printStackTrace(); Message msg = new Message(); msg.obj = "receiver message error! please make client try again connect!"; msg.what = 1; detectedHandler.sendMessage(msg); } } }); }private void receiverMessageTask(){ ThreadPool.getInstance().excuteTask(new Runnable() { public void run() { byte[] buffer = new byte[2048]; int totalRead; /*InputStream input = null; OutputStream output=null;*/ try { bis=new BufferedInputStream(btsocket.getInputStream()); bos=new BufferedOutputStream(btsocket.getOutputStream()); } catch (IOException e) { e.printStackTrace(); }try { // ByteArrayOutputStream arrayOutput=null; while((totalRead = bis.read(buffer)) > 0 ){ // arrayOutput=new ByteArrayOutputStream(); String txt = new String(buffer, 0, totalRead, "UTF-8");Message msg = new Message(); msg.obj = txt; msg.what = 1; detectedHandler.sendMessage(msg);} } catch (IOException e) { e.printStackTrace(); } } }); }public boolean sendmsg(String msg){ boolean result=false; if(null==btsocket||bos==null) return false; try { bos.write(msg.getBytes()); bos.flush(); result=true; } catch (IOException e) { e.printStackTrace(); } return result; }public void closeBTServer(){ try{ if(bis!=null) bis.close(); if(bos!=null) bos.close(); if(btServerSocket!=null) btServerSocket.close(); if(btsocket!=null) btsocket.close(); }catch(IOException e){ e.printStackTrace(); } } }client功能封装:
package com.xiaoyu.bluetooth;import java.io.BufferedInputStream;import java.io.BufferedOutputStream;import java.io.EOFException;import java.io.IOException;import java.util.UUID;import android.bluetooth.BluetoothAdapter;import android.bluetooth.BluetoothDevice;import android.bluetooth.BluetoothSocket;import android.os.Handler;import android.os.Message;import android.util.Log;import com.xiaoyu.utils.ThreadPool;public class BTClient { final String Tag=getClass().getSimpleName(); private BluetoothSocket btsocket = null; private BluetoothDevice btdevice = null; private BufferedInputStream bis=null; private BufferedOutputStream bos=null; private BluetoothAdapter mBtAdapter =null;private Handler detectedHandler=null;public BTClient(BluetoothAdapter mBtAdapter,Handler detectedHandler){ this.mBtAdapter=mBtAdapter; this.detectedHandler=detectedHandler; }public void connectBTServer(String address){ //check address is correct if(BluetoothAdapter.checkBluetoothAddress(address)){ btdevice = mBtAdapter.getRemoteDevice(address);ThreadPool.getInstance().excuteTask(new Runnable() { public void run() { try { btsocket = btdevice.createRfcommSocketToServiceRecord(UUID.fromString("00001101-0000-1000-8000-00805F9B34FB"));Message msg2 = new Message(); msg2.obj = "请稍候,正在连接服务器:"+BluetoothMsg.BlueToothAddress; msg2.what = 0; detectedHandler.sendMessage(msg2); btsocket.connect(); Message msg = new Message(); msg.obj = "已经连接上服务端!可以发送信息。"; msg.what = 0; detectedHandler.sendMessage(msg);receiverMessageTask(); } catch (IOException e) { e.printStackTrace(); Log.e(Tag, e.getMessage());Message msg = new Message(); msg.obj = "连接服务端异常!请检查服务器是否正常,断开连接重新试一试。"; msg.what = 0; detectedHandler.sendMessage(msg); }} }); } }private void receiverMessageTask(){ ThreadPool.getInstance().excuteTask(new Runnable() { public void run() { byte[] buffer = new byte[2048]; int totalRead; /*InputStream input = null; OutputStream output=null;*/ try { bis=new BufferedInputStream(btsocket.getInputStream()); bos=new BufferedOutputStream(btsocket.getOutputStream()); } catch (IOException e) { e.printStackTrace(); }try { // ByteArrayOutputStream arrayOutput=null; while((totalRead = bis.read(buffer)) > 0 ){ // arrayOutput=new ByteArrayOutputStream(); String txt = new String(buffer, 0, totalRead, "UTF-8");Message msg = new Message(); msg.obj = "Receiver: "+txt; msg.what = 1; detectedHandler.sendMessage(msg);} } catch(EOFException e){ Message msg = new Message(); msg.obj = "server has close!"; msg.what = 1; detectedHandler.sendMessage(msg); }catch (IOException e) { e.printStackTrace(); Message msg = new Message(); msg.obj = "receiver message error! make sure server is ok,and try again connect!"; msg.what = 1; detectedHandler.sendMessage(msg); } } }); }public boolean sendmsg(String msg){ boolean result=false; if(null==btsocket||bos==null) return false; try { bos.write(msg.getBytes()); bos.flush(); result=true; } catch (IOException e) { e.printStackTrace(); } return result; }public void closeBTClient(){ try{ if(bis!=null) bis.close(); if(bos!=null) bos.close(); if(btsocket!=null) btsocket.close(); }catch(IOException e){ e.printStackTrace(); } } }聊天界面,使用上面分装好的类,处理信息
package com.xiaoyu.communication;import java.util.ArrayList;import java.util.List;import android.app.Activity;import android.content.Context;import android.content.Intent;import android.os.Bundle;import android.os.Handler;import android.os.Message;import android.text.TextUtils;import android.view.Menu;import android.view.View;import android.view.View.OnClickListener;import android.view.inputmethod.InputMethodManager;import android.widget.ArrayAdapter;import android.widget.Button;import android.widget.EditText;import android.widget.ListView;import android.widget.RadioGroup;import android.widget.RadioGroup.OnCheckedChangeListener;import android.widget.Toast;import com.xiaoyu.bluetooth.BTClient;import com.xiaoyu.bluetooth.BTManage;import com.xiaoyu.bluetooth.BTServer;import com.xiaoyu.bluetooth.BluetoothMsg;public class BTChatActivity extends Activity { private ListView mListView;private Button sendButton;private Button disconnectButton;private EditText editMsgView;private ArrayAdapter<String> mAdapter;private List<String> msgList=new ArrayList<String>();private BTClient client; private BTServer server;@Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.bt_chat); initView();} private Handler detectedHandler = new Handler(){ public void handleMessage(android.os.Message msg) { msgList.add(msg.obj.toString());mAdapter.notifyDataSetChanged();mListView.setSelection(msgList.size() - 1);}; };private void initView() { mAdapter=new ArrayAdapter<String>(this, android.R.layout.simple_list_item_1, msgList);mListView = (ListView) findViewById(R.id.list);mListView.setAdapter(mAdapter);mListView.setFastScrollEnabled(true);editMsgView= (EditText)findViewById(R.id.MessageText);editMsgView.clearFocus(); RadioGroup group = (RadioGroup)this.findViewById(R.id.radioGroup); group.setOnCheckedChangeListener(new OnCheckedChangeListener() {// @Override// public void onCheckedChanged(RadioGroup arg0, int arg1) {//int radioId = arg0.getCheckedRadioButtonId();// // } @Override public void onCheckedChanged(RadioGroup group, int checkedId) { switch(checkedId){ case R.id.radioNone: BluetoothMsg.serviceOrCilent = BluetoothMsg.ServerOrCilent.NONE; if(null!=client){ client.closeBTClient(); client=null; } if(null!=server){ server.closeBTServer(); server=null; } break; case R.id.radioClient: BluetoothMsg.serviceOrCilent = BluetoothMsg.ServerOrCilent.CILENT; Intent it=new Intent(getApplicationContext(),BTDeviceActivity.class); startActivityForResult(it, 100); break; case R.id.radioServer: BluetoothMsg.serviceOrCilent = BluetoothMsg.ServerOrCilent.SERVICE; initConnecter(); break; } } });sendButton= (Button)findViewById(R.id.btn_msg_send);sendButton.setOnClickListener(new OnClickListener() {@Overridepublic void onClick(View arg0) {String msgText =editMsgView.getText().toString(); if (msgText.length()>0) { if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.CILENT){ if(null==client)return;if(client.sendmsg(msgText)){Message msg = new Message(); msg.obj = "send: "+msgText; msg.what = 1; detectedHandler.sendMessage(msg); }else{Message msg = new Message(); msg.obj = "send fail!! "; msg.what = 1; detectedHandler.sendMessage(msg); }} else if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.SERVICE) { if(null==server)return;if(server.sendmsg(msgText)){Message msg = new Message(); msg.obj = "send: "+msgText; msg.what = 1; detectedHandler.sendMessage(msg); }else{Message msg = new Message(); msg.obj = "send fail!! "; msg.what = 1; detectedHandler.sendMessage(msg); }} editMsgView.setText(""); //editMsgView.clearFocus(); ////close InputMethodManager //InputMethodManager imm = (InputMethodManager)getSystemService(Context.INPUT_METHOD_SERVICE); //imm.hideSoftInputFromWindow(editMsgView.getWindowToken(), 0); }else{ Toast.makeText(getApplicationContext(), "发送内容不能为空!", Toast.LENGTH_SHORT).show();} }}); disconnectButton= (Button)findViewById(R.id.btn_disconnect);disconnectButton.setOnClickListener(new OnClickListener() {@Overridepublic void onClick(View arg0) { if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.CILENT){ if(null==client)return;client.closeBTClient();} else if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.SERVICE) { if(null==server)return;server.closeBTServer();} BluetoothMsg.isOpen = false; BluetoothMsg.serviceOrCilent=BluetoothMsg.ServerOrCilent.NONE; Toast.makeText(getApplicationContext(), "已断开连接!", Toast.LENGTH_SHORT).show();}});} @Override protected void onResume() { super.onResume();if (BluetoothMsg.isOpen) { Toast.makeText(getApplicationContext(), "连接已经打开,可以通信。如果要再建立连接,请先断开!", Toast.LENGTH_SHORT).show(); } }@Override protected void onActivityResult(int requestCode, int resultCode, Intent data) { super.onActivityResult(requestCode, resultCode, data); if(requestCode==100){ //从设备列表返回 initConnecter(); } }private void initConnecter(){ if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.CILENT) { String address = BluetoothMsg.BlueToothAddress; if (!TextUtils.isEmpty(address)) { if(null==client) client=new BTClient(BTManage.getInstance().getBtAdapter(), detectedHandler); client.connectBTServer(address); BluetoothMsg.isOpen = true; } else { Toast.makeText(getApplicationContext(), "address is empty please choose server address !", Toast.LENGTH_SHORT).show(); } } else if (BluetoothMsg.serviceOrCilent == BluetoothMsg.ServerOrCilent.SERVICE) { if(null==server) server=new BTServer(BTManage.getInstance().getBtAdapter(), detectedHandler); server.startBTServer(); BluetoothMsg.isOpen = true; } }@Override public boolean onCreateOptionsMenu(Menu menu) { // Inflate the menu; this adds items to the action bar if it is present. getMenuInflater().inflate(R.menu.main, menu); return true; }}client搜索设备列表,连接选择server界面:
package com.xiaoyu.communication;import java.util.ArrayList;import java.util.List;import android.app.Activity;import android.app.AlertDialog;import android.content.DialogInterface;import android.content.Intent;import android.os.Bundle;import android.view.View;import android.widget.AdapterView;import android.widget.AdapterView.OnItemClickListener;import android.widget.ArrayAdapter;import android.widget.Button;import android.widget.ListView;import com.xiaoyu.bluetooth.BTItem;import com.xiaoyu.bluetooth.BTManage;import com.xiaoyu.bluetooth.BluetoothMsg;import com.xiaoyu.bluetooth.StatusBlueTooth;public class BTDeviceActivity extends Activity implements OnItemClickListener ,View.OnClickListener ,StatusBlueTooth{ // private List<BTItem> mListDeviceBT=new ArrayList<BTItem>(); private ListView deviceListview;private Button btserch;private BTDeviceAdapter adapter;private boolean hasregister=false; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.finddevice); setView();BTManage.getInstance().setBlueListner(this); } private void setView(){deviceListview=(ListView)findViewById(R.id.devicelist);deviceListview.setOnItemClickListener(this); adapter=new BTDeviceAdapter(getApplicationContext());deviceListview.setAdapter(adapter);deviceListview.setOnItemClickListener(this);btserch=(Button)findViewById(R.id.start_seach);btserch.setOnClickListener(this);} @Override protected void onStart() { super.onStart(); //注册蓝牙接收广播if(!hasregister){hasregister=true;BTManage.getInstance().registerBluetoothReceiver(getApplicationContext()); }}@Override protected void onResume() { // TODO Auto-generated method stub super.onResume(); } @Override protected void onPause() { // TODO Auto-generated method stub super.onPause(); }@Override protected void onStop() { super.onStop(); if(hasregister){hasregister=false;BTManage.getInstance().unregisterBluetooth(getApplicationContext());}}@Override protected void onDestroy() { super.onDestroy();} @Override public void onItemClick(AdapterView<?> parent, View view, int position, long id) {final BTItem item=(BTItem)adapter.getItem(position); AlertDialog.Builder dialog = new AlertDialog.Builder(this);// 定义一个弹出框对象dialog.setTitle("Confirmed connecting device");dialog.setMessage(item.getBuletoothName());dialog.setPositiveButton("connect",new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { // btserch.setText("repeat search");BTManage.getInstance().cancelScanDevice();BluetoothMsg.BlueToothAddress=item.getBluetoothAddress(); if(BluetoothMsg.lastblueToothAddress!=BluetoothMsg.BlueToothAddress){ BluetoothMsg.lastblueToothAddress=BluetoothMsg.BlueToothAddress; } setResult(100);finish();}});dialog.setNegativeButton("cancel",new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { BluetoothMsg.BlueToothAddress = null; }});dialog.show();} @Override public void onClick(View v) { BTManage.getInstance().openBluetooth(this);if(BTManage.getInstance().isDiscovering()){BTManage.getInstance().cancelScanDevice();btserch.setText("start search");}else{BTManage.getInstance().scanDevice();btserch.setText("stop search");}} @Override public void BTDeviceSearchStatus(int resultCode) { switch(resultCode){ case StatusBlueTooth.SEARCH_START: adapter.clearData(); adapter.addDataModel(BTManage.getInstance().getPairBluetoothItem()); break; case StatusBlueTooth.SEARCH_END: break; } } @Override public void BTSearchFindItem(BTItem item) { adapter.addDataModel(item); } @Override public void BTConnectStatus(int result) {}}搜索列表adapter:
package com.xiaoyu.communication;import java.util.ArrayList;import java.util.List;import android.content.Context;import android.view.LayoutInflater;import android.view.View;import android.view.ViewGroup;import android.widget.BaseAdapter;import android.widget.TextView;import com.xiaoyu.bluetooth.BTItem;public class BTDeviceAdapter extends BaseAdapter{private List<BTItem> mListItem=new ArrayList<BTItem>();; private Context mcontext=null; private LayoutInflater mInflater=null;public BTDeviceAdapter(Context context){ this.mcontext=context; // this.mListItem=mListItem; this.mInflater=(LayoutInflater)context.getSystemService(Context.LAYOUT_INFLATER_SERVICE);}void clearData(){ mListItem.clear(); }void addDataModel(List<BTItem> itemList){ if(itemList==null || itemList.size()==0) return; mListItem.addAll(itemList); notifyDataSetChanged(); } void addDataModel(BTItem item){ mListItem.add(item); notifyDataSetChanged(); }@Override public int getCount() {return mListItem.size(); } @Override public Object getItem(int position) {return mListItem.get(position); } @Override public long getItemId(int position) {return position; } @Override public View getView(int position, View convertView, ViewGroup parent) { ViewHolder holder=null;if(convertView==null){ holder=new ViewHolder(); convertView = mInflater.inflate(R.layout.device_item_row, null); holder.tv=(TextView)convertView.findViewById(R.id.itemText); convertView.setTag(holder); }else{ holder=(ViewHolder)convertView.getTag(); } holder.tv.setText(mListItem.get(position).getBuletoothName()); return convertView; }class ViewHolder{ TextView tv; }}列表model:
package com.xiaoyu.bluetooth;public class BTItem { private String buletoothName=null; private String bluetoothAddress=null; private int bluetoothType=-1;public String getBuletoothName() { return buletoothName; } public void setBuletoothName(String buletoothName) { this.buletoothName = buletoothName; } public String getBluetoothAddress() { return bluetoothAddress; } public void setBluetoothAddress(String bluetoothAddress) { this.bluetoothAddress = bluetoothAddress; } public int getBluetoothType() { return bluetoothType; } public void setBluetoothType(int bluetoothType) { this.bluetoothType = bluetoothType; }}使用到的辅助类:
package com.xiaoyu.bluetooth;public class BluetoothMsg { public enum ServerOrCilent{NONE,SERVICE,CILENT};//蓝牙连接方式public static ServerOrCilent serviceOrCilent = ServerOrCilent.NONE;//连接蓝牙地址public static String BlueToothAddress = null,lastblueToothAddress=null;//通信线程是否开启public static boolean isOpen = false; } package com.xiaoyu.bluetooth;public interface StatusBlueTooth { final static int SEARCH_START=110; final static int SEARCH_END=112;final static int serverCreateSuccess=211; final static int serverCreateFail=212; final static int clientCreateSuccess=221; final static int clientCreateFail=222; final static int connectLose=231;void BTDeviceSearchStatus(int resultCode); void BTSearchFindItem(BTItem item); void BTConnectStatus(int result); } package com.xiaoyu.utils;import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.ThreadFactory;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;import java.util.concurrent.atomic.AtomicBoolean;import java.util.concurrent.atomic.AtomicInteger;public class ThreadPool { private AtomicBoolean mStopped = new AtomicBoolean(Boolean.FALSE);private ThreadPoolExecutor mQueue;private final int coreSize=2; private final int maxSize=10; private final int timeOut=2; private static ThreadPool pool=null;private ThreadPool() {mQueue = new ThreadPoolExecutor(coreSize, maxSize, timeOut, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), sThreadFactory);// mQueue.allowCoreThreadTimeOut(true);} public static ThreadPool getInstance(){ if(null==pool) pool=new ThreadPool(); return pool; }public void excuteTask(Runnable run) {mQueue.execute(run);} public void closeThreadPool() {if (!mStopped.get()) {mQueue.shutdownNow();mStopped.set(Boolean.TRUE);}} private static final ThreadFactory sThreadFactory = new ThreadFactory() {private final AtomicInteger mCount = new AtomicInteger(1); @Overridepublic Thread newThread(Runnable r) {return new Thread(r, "ThreadPool #" + mCount.getAndIncrement());}};}最后别忘了加入权限
static public boolean createBond(Class btClass, BluetoothDevice btDevice) throws Exception { Method createBondMethod = btClass.getMethod("createBond"); Log.i("life", "createBondMethod = " + createBondMethod.getName()); Boolean returnValue = (Boolean) createBondMethod.invoke(btDevice); return returnValue.booleanValue(); } static public boolean setPin(Class btClass, BluetoothDevice btDevice, String str) throws Exception { Boolean returnValue = null; try { Method removeBondMethod = btClass.getDeclaredMethod("setPin", new Class[] { byte[].class }); returnValue = (Boolean) removeBondMethod.invoke(btDevice, new Object[] { str.getBytes() }); Log.i("life", "returnValue = " + returnValue); } catch (SecurityException e) { // throw new RuntimeException(e.getMessage()); e.printStackTrace(); } catch (IllegalArgumentException e) { // throw new RuntimeException(e.getMessage()); e.printStackTrace(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return returnValue; } // 取消用户输入 static public boolean cancelPairingUserInput(Class btClass, BluetoothDevice device) throws Exception { Method createBondMethod = btClass.getMethod("cancelPairingUserInput"); // cancelBondProcess() Boolean returnValue = (Boolean) createBondMethod.invoke(device); Log.i("life", "cancelPairingUserInputreturnValue = " + returnValue); return returnValue.booleanValue(); }然后监听蓝牙配对的广播 匹配“android.bluetooth.device.action.PAIRING_REQUEST”这个action