无法通过蓝牙将Arduino传输的消息接收到android应用中

如何解决无法通过蓝牙将Arduino传输的消息接收到android应用中

我试图通过来回发送简单的字符串，通过我的android应用程序与ESP 32芯片进行通信。我能够成功地将数据发送到ESP32串行监视器，但无法将数据重新接收到我的套接字 InputStream 中。到目前为止，这是我在Arduino中针对ESP32和Android的实现。

Arduino代码

#include "BluetoothSerial.h" //Header File for Serial Bluetooth,will be added default into Arduino
#include <SoftwareSerial.h>  
BluetoothSerial ESP_BT;
int incoming;

void setup() {

ESP_BT.begin("ESP32_IRegained"); //Name of your Bluetooth Signal
Serial.begin(9600); //Start Serial monitor in 9600

//  pinMode (13,OUTPUT);//Specify that LED pin is output
}

void loop() {

if (ESP_BT.available()) //Check if we receive anything from Bluetooth
{
  incoming = ESP_BT.read(); //Read what we recevive 
  Serial.print((char)incoming);
}

if(ESP_BT.available())  // If stuff was typed in the serial monitor
{
   char c = (char) Serial.write();
   // Send any characters the Serial monitor prints to the bluetooth
  Serial.print(c); 
}
 delay(20); 
}

MainActivity.java

public class MessageActivity extends AppCompatActivity {

private static final String TAG = MessageActivity.class.getName();
private EditText etText;
private Button btnSend,btnClear;
private TextView tvSent;
String address = null;
private ProgressDialog progress;
BluetoothAdapter myBluetooth = null;
public BluetoothSocket btSocket = null;
private boolean isBtConnected = false;
//SPP UUID. Look for it
static final UUID myUUID = UUID.fromString("00001101-0000-1000-8000-00805F9B34FB");
String s;
String data;

OutputStream mmOutputStream;
InputStream mmInputStream;
Thread workerThread;
byte[] readBuffer;
int readBufferPosition;
int counter;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);

    address = "24:0A:C4:00:21:06"; //receive the address of the bluetooth device

    //view of the LightControl
    setContentView(R.layout.activity_message);

    //call the widgets
    etText = (EditText) findViewById(R.id.editText);
    btnSend = (Button) findViewById(R.id.buttonSend);
    btnClear = (Button) findViewById(R.id.buttonReceive);
    tvSent = findViewById(R.id.tvMessageSent);
    //Disconnect();
    new MessageActivity.ConnectBT().execute(); //Call the class to connect

    new Thread(new ClientThread()).start();
}

class ClientThread implements Runnable {
    @SuppressWarnings("deprecation")
    @Override
    public void run() {
        try {
            receiveData();
        } catch (UnknownHostException e1) {
            e1.printStackTrace();
        } catch (IOException e1) {
            e1.printStackTrace();
        }
    }
}

@SuppressLint("SetTextI18n")
public void onSend(View view) {
    if (TextUtils.isEmpty(etText.getText().toString())) {
        Toast.makeText(MessageActivity.this,"Enter text",Toast.LENGTH_SHORT).show();
        etText.requestFocus();
    } else {
        s = etText.getText().toString();
        s.concat("\n");
        try {
            btSocket.getOutputStream().write(etText.getText().toString().getBytes());
            etText.setText("");
        } catch (IOException e) {
            msg("Error");
        }
        tvSent.append("\nSent Data: " + s + "\n");
    }
}

public void onReceive(View v) {
    try {
        data = String.valueOf(btSocket.getInputStream().read());
        Log.d(TAG,"Message Received: " + data);
    } catch (IOException e) {
        msg("Error" + e.getMessage());
    }
}

@Override
protected void onDestroy() {
    Disconnect();
    super.onDestroy();
}

private void Disconnect() {
    if (btSocket != null) //If the btSocket is busy
    {
        try {
            btSocket.close(); //close connection
        } catch (IOException e) {
            msg("Error");
        }
    }
    finish(); //return to the first layout

}

public void receiveData() throws IOException {

}

// fast way to call Toast
private void msg(String s) {
    Toast.makeText(getApplicationContext(),s,Toast.LENGTH_LONG).show();
}

@SuppressLint("StaticFieldLeak")
private class ConnectBT extends AsyncTask<Void,Void,Void>  // UI thread
{
    private boolean ConnectSuccess = true; //if it's here,it's almost connected

    @Override
    protected void onPreExecute() {
        progress = ProgressDialog.show(MessageActivity.this,"Connecting...","Please wait!!!");  //show a progress dialog
    }

    @Override
    protected Void doInBackground(Void... devices) //while the progress dialog is shown,the connection is done in background
    {
        try {
            if (btSocket == null || !isBtConnected) {
                myBluetooth = BluetoothAdapter.getDefaultAdapter();//get the mobile bluetooth device
                BluetoothDevice dispositivo = myBluetooth.getRemoteDevice(address);//connects to the device's address and checks if it's available
                btSocket = dispositivo.createInsecureRfcommSocketToServiceRecord(myUUID);//create a RFCOMM (SPP) connection
                BluetoothAdapter.getDefaultAdapter().cancelDiscovery();
                mmOutputStream = btSocket.getOutputStream();
                mmInputStream = btSocket.getInputStream();
                btSocket.connect();//start connection
            }

        } catch (IOException e) {
            ConnectSuccess = false;//if the try failed,you can check the exception here
        }
        return null;
    }

    @Override
    protected void onPostExecute(Void result) //after the doInBackground,it checks if everything went fine
    {
        super.onPostExecute(result);

        if (!ConnectSuccess) {
            msg("Connection Failed. Is it a SPP Bluetooth? Try again.");
            finish();
        } else {
            msg("Connected.");
            isBtConnected = true;
        }
        progress.dismiss();
    }
}

void beginListenForData() {
    final Handler handler = new Handler(this.getMainLooper());
    final byte delimiter = 10; // This is the ASCII code for a newline
    // character
    readBufferPosition = 0;
    readBuffer = new byte[1024];
    workerThread = new Thread(new Runnable() {
        public void run() {
            Looper.prepare();
            while (!Thread.currentThread().isInterrupted()) {
                try {
                    int bytesAvailable = mmInputStream.available();
                    if (bytesAvailable > 0) {
                        byte[] packetBytes = new byte[bytesAvailable];
                        mmInputStream.read(packetBytes);
                        for (int i = 0; i < bytesAvailable; i++) {
                            byte b = packetBytes[i];
                            if (b == delimiter) {
                                byte[] encodedBytes = new byte[readBufferPosition];
                                System.arraycopy(readBuffer,encodedBytes,encodedBytes.length);
                                final String data = new String(
                                        encodedBytes,"US-ASCII");
                                readBufferPosition = 0;

                                handler.post(new Runnable() {
                                    public void run() {
                                        tvSent.setText("\nReceived Data: " + data);
                                    }
                                });
                            } else {
                                readBuffer[readBufferPosition++] = b;
                            }
                        }
                    }
                } catch (IOException ex) {
                    Log.d(TAG,"run: " + ex.getMessage());
                }
            }
            Looper.loop();
        }
    });
    workerThread.start();
}

@Override
protected void onPause() {
    progress.dismiss();
    super.onPause();
}

@Override
protected void onStop() {
    progress.dismiss();
    super.onStop();
 }
}