Android·蓝牙通信实现

public class MainActivity extends AppCompatActivity implements AdapterView.OnItemClickListener {
@BindView(R.id.button)
Button button;
@BindView(R.id.button_client)
Button buttonClient;
@BindView(R.id.lvDevices)
ListView lvDevices;
@BindView(R.id.ConstraintLayout)
android.support.constraint.ConstraintLayout ConstraintLayout;
@BindView(R.id.et_client)
EditText etClient;

private String Tag = "MainActivity";
private BluetoothAdapter mBluetoothAdapter;
private List<String> bluetoothDevices = new ArrayList<String>();
private ArrayAdapter<String> arrayAdapter;
private final UUID MY_UUID = UUID
.fromString("abcd1234-ab12-ab12-ab12-abcdef123456");//随便定义一个
private BluetoothSocket clientSocket;
private BluetoothDevice device;
private OutputStream os;
private AcceptThread acceptThread;
private final String NAME = "Bluetooth_Socket";
private BluetoothServerSocket serverSocket;
private BluetoothSocket socket;
private InputStream is;//输入流
private Handler handler = new Handler() {
public void handleMessage(Message msg) {
Toast.makeText(getApplicationContext(), String.valueOf(msg.obj));

super.handleMessage(msg);
}
};

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
ButterKnife.bind(this);
mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
if (ContextCompat.checkSelfPermission(this,
Manifest.permission.ACCESS_COARSE_LOCATION) != PackageManager.PERMISSION_GRANTED) {
ActivityCompat.requestPermissions(this,
new String[]{Manifest.permission.ACCESS_COARSE_LOCATION}, 1);
}
mBluetoothAdapter.enable();
acceptThread = new AcceptThread();
acceptThread.start();
// 设置广播信息过滤
button.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
setProgressBarVisibility(true);
setTitle("正在扫描……");
if (mBluetoothAdapter.isDiscovering()) {
mBluetoothAdapter.cancelDiscovery();
setTitle("从新扫描……");
}
mBluetoothAdapter.startDiscovery();
}
});
buttonClient.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
try {
os.write(etClient.getText().toString().trim().getBytes("utf-8"));
etClient.setText("");
} catch (IOException e) {
e.printStackTrace();
}
}
});
Set<BluetoothDevice> pairedDevices = mBluetoothAdapter.getBondedDevices();
if (pairedDevices.size() > 0) {
for (BluetoothDevice device : pairedDevices) {
bluetoothDevices.add(device.getName() + ":" + device.getAddress());
}
}
arrayAdapter = new ArrayAdapter<String>(this,
android.R.layout.simple_list_item_1, android.R.id.text1, bluetoothDevices);
lvDevices.setAdapter(arrayAdapter);
lvDevices.setOnItemClickListener(this);//Activity实现OnItemClickListener接口
//每搜索到一个设备就会发送一个该广播
IntentFilter filter = new IntentFilter(BluetoothDevice.ACTION_FOUND);
this.registerReceiver(receiver, filter);
//当全部搜索完后发送该广播
filter = new IntentFilter(BluetoothAdapter.ACTION_DISCOVERY_FINISHED);
this.registerReceiver(receiver, filter);
}

private final BroadcastReceiver receiver = new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
String action = intent.getAction();
//如果找到这个设备
if (BluetoothDevice.ACTION_FOUND.equals(action)) {
//获得这个设备的信息
BluetoothDevice device = intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE);
//如果没有被配对过，再添加
boolean getname = false;
if (device.getBondState() != BluetoothDevice.BOND_BONDED) {
//查看是否有添加过
for (int i = 0; i < bluetoothDevices.size(); i++) {
if (bluetoothDevices.get(i).equals(device.getName() + ":" + device.getAddress())) {
getname = true;
}
}
if (!getname) {
bluetoothDevices.add(device.getName() + ":" + device.getAddress());
arrayAdapter.notifyDataSetChanged();
}
}
} else if (BluetoothAdapter.ACTION_DISCOVERY_FINISHED.equals(action)) {
setTitle("扫描完成");
}
}
};

@Override
public void onItemClick(AdapterView<?> parent, View view, int position, long id) {
String s = arrayAdapter.getItem(position);
String address = s.substring(s.indexOf(":") + 1).trim();//把地址解析出来
//主动连接蓝牙服务端
try {
//判断当前是否正在搜索
if (mBluetoothAdapter.isDiscovering()) {
mBluetoothAdapter.cancelDiscovery();
}
try {
if (device == null) {
//获得远程设备
device = mBluetoothAdapter.getRemoteDevice(address);
}
if (clientSocket == null) {
Log.e(Tag, "clientSocket is not null");

//创建客户端蓝牙Socket
clientSocket = device.createRfcommSocketToServiceRecord(MY_UUID);
//开始连接蓝牙，如果没有配对则弹出对话框提示我们进行配对
clientSocket.connect();
//获得输出流（客户端指向服务端输出文本）
os = clientSocket.getOutputStream();
}
} catch (Exception e) {
}
if (os != null) {
Log.e(Tag, "os is not null");
//往服务端写信息
os.write("蓝牙信息来了".getBytes("utf-8"));
}
} catch (Exception e) {
}
}

class AcceptThread extends Thread {
public AcceptThread() {
try {
serverSocket = mBluetoothAdapter.listenUsingRfcommWithServiceRecord(NAME, MY_UUID);
} catch (Exception e) {
}
}

public void run() {
try {
socket = serverSocket.accept();
is = socket.getInputStream();
//循环读取数据
while (true) {
Log.e(Tag, "1");
byte[] buffer = new byte[1024];
Log.e(Tag, "2");
//等待获取数据
int count = is.read(buffer);
Log.e(Tag, "3");
Message msg = new Message();
Log.e(Tag, "4");
msg.obj = new String(buffer, 0, count, "utf-8");
Log.e(Tag, "5");
handler.sendMessage(msg);
Log.e(Tag, "6");
}
} catch (Exception e) {
}
}
}
}