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 Bluetooth 
 AlertDialog.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 Intent
  BluetoothDevice device = intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE);
  // If it's already paired, skip it, because it's been listed already
  if (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);
 }
 }
 }; 
 
 
}

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 {

 /* 一些常量，代表服務(wù)器的名稱 */
 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 = "客戶端已經(jīng)連接上！可以發(fā)送信息。"; 
  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();
 }
 }
 
}

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 = "請稍候，正在連接服務(wù)器:"+BluetoothMsg.BlueToothAddress; 
  msg2.what = 0; 
  detectedHandler.sendMessage(msg2); 
  
  btsocket.connect(); 
  Message msg = new Message(); 
  msg.obj = "已經(jīng)連接上服務(wù)端！可以發(fā)送信息。"; 
  msg.what = 0; 
  detectedHandler.sendMessage(msg); 
 receiverMessageTask();
 } catch (IOException e) {
 e.printStackTrace();
 Log.e(Tag, e.getMessage());
 
 Message msg = new Message(); 
  msg.obj = "連接服務(wù)端異常！請檢查服務(wù)器是否正常，斷開連接重新試一試。"; 
  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() { 
 @Override 
 public 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(), "發(fā)送內(nèi)容不能為空！", Toast.LENGTH_SHORT).show();
  }
 } 
 }); 
 
 disconnectButton= (Button)findViewById(R.id.btn_disconnect); 
 disconnectButton.setOnClickListener(new OnClickListener() { 
 @Override 
 public 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(), "連接已經(jīng)打開，可以通信。如果要再建立連接，請先斷開！",
 Toast.LENGTH_SHORT).show();
 }
 }
 
 @Override
 protected void onActivityResult(int requestCode, int resultCode, Intent data) {
 super.onActivityResult(requestCode, resultCode, data);
 if(requestCode==100){
 //從設(shè)備列表返回
 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;
 }

}

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();
 //注冊藍(lán)牙接收廣播 
 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);// 定義一個彈出框?qū)ο?
 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) {
 
 }

}

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;
 }

}

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 
 }; 
 //藍(lán)牙連接方式 
 public static ServerOrCilent serviceOrCilent = ServerOrCilent.NONE; 
 //連接藍(lán)牙地址 
 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); 
 
 @Override 
 public 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();
 }