Мне нужно, чтобы мое приложение для Android подключалось к нескольким устройствам и обменивалось с ними информацией.
Для этого я пытаюсь создать поток, который получает подключение от устройства, сохранить его MAC-номер, отключить иоткройте соединение для получения нового диспозитива, но во всех моих попытках я не могу восстановить соединение, генерирующее Failed, потому что управление линией выдает ошибку.
Кроме того, когда Bluetooth генерирует ошибку, я не могуЧтобы создать метод для восстановления соединения или для запуска нового, я должен перезагрузить Bluetooth вручную, чтобы восстановить соединение.А для моего приложения для Android использование ручного способа подключения не годится.
Может ли кто-нибудь помочь мне показать способ управления потоками, чтобы я мог подключаться и отключаться от нескольких устройств?
Нижеследует коду потоков
private class ServeClass extends Thread {
private BluetoothServerSocket serverSocket;
public ServeClass() {
try {
//Servidor que recebe um Socket
Log.e("BluetoothServerSocket","ServerSocket conectado");
} catch (Exception e) {
e.printStackTrace();
}
}
public void run() {
while (socket == null) {
try {
Message message = Message.obtain();
message.what = STATE_CONNECTING;
// recebe um BluetoothSocket para gerenciar a mensagem
socket = serverSocket.accept();
handler.sendMessage(message);
} catch (IOException e) {
e.printStackTrace();
Message message = Message.obtain();
message.what = STATE_CONNECTION_FAILED;
handler.sendMessage(message);
}
if (socket != null) {
Message message = Message.obtain();
message.what = STATE_CONNECTED;
handler.sendMessage(message);
sendRecive=new SendRecive(socket);
sendRecive.start();
break;
}
}
}
}
Обработчик
Handler handler = new Handler(new Handler.Callback() {
@Override
public boolean handleMessage(Message msg) {
switch (msg.what) {
case STATE_LISTENING:
content.setText("Escutando");
break;
case STATE_CONNECTING:
content.setText("Conectando");
break;
case STATE_CONNECTED:
content.setText("Conectado");
//botao.setVisibility(View.VISIBLE);
break;
case STATE_CONNECTION_FAILED:
content.setText("Conexão Falha");
break;
case STATE_MESSAGE_RECEIVED:
byte[] readBuffer= (byte[]) msg.obj;
String tempMsg= new String(readBuffer,0,msg.arg1);
botao.setText(tempMsg);
break;
}
return true;
}
});
Тема Отправить / Получить
private class SendRecive extends Thread {
private final BluetoothSocket bluetoothSocket;
private final InputStream inputStream;
private final OutputStream outputStream;
public SendRecive(BluetoothSocket socket) {
bluetoothSocket = socket;
InputStream tempIn = null;
OutputStream tempOut = null;
try {
tempIn = bluetoothSocket.getInputStream();
tempOut = bluetoothSocket.getOutputStream();
Log.e("TESTE_CONTRUTOR", "TESTE_CONTRUTOR");
} catch (IOException e) {
e.printStackTrace();
}
inputStream = tempIn;
outputStream = tempOut;
}
@Override
public void run() {
byte[] buffer = new byte[1024];
int bytes;
while (true) {
try {
bytes = inputStream.read(buffer);
handler.obtainMessage(STATE_MESSAGE_RECEIVED, bytes, -1, buffer).sendToTarget();
socket = null;
} catch (IOException e) {
e.printStackTrace();
}
}
}
public void write(byte[] bytes) {
try {
outputStream.write(bytes);
} catch (IOException e) {
e.printStackTrace();
}
}
}
Клиент темы
private class ClientClass extends Thread {
private BluetoothSocket socket;
private BluetoothDevice device;
public ClientClass(BluetoothDevice device) {
this.device = device;
try {
socket = this.device.createRfcommSocketToServiceRecord(MYUUID);
} catch (Exception e) {
Log.e("Erro", String.valueOf(e));
e.printStackTrace();
}
}
@Override
public void run() {
try {
socket.connect();
Message message = Message.obtain();
message.what = STATE_CONNECTED;
handler.sendMessage(message);
sendRecive = new SendRecive(socket);
sendRecive.start();
} catch (IOException e) {
e.printStackTrace();
Message message = Message.obtain();
message.what = STATE_CONNECTION_FAILED;
handler.sendMessage(message);
}
}
public void cancel() {
try {
socket.close();
Message message = Message.obtain();
message.what = STATE_LISTENING;
handler.sendMessage(message);
} catch (IOException e) {
e.printStackTrace();
}
}