Сокеты Android Java задерживают отправку данных

У меня была эта проблема для случая, когда я хотел передать некоторые данные на точку доступа Esp8266-01. Я думаю, что эта задержка произошла из-за того, что if (client. available()) внутри while (client.connected())loop ожидает получения данных, пока клиент не будет доступен. следовательно, делает задержку (у меня было ровно 5 секунд). чтобы избежать этого неприятного поведения, я добавил возврат каретки '\r' в команду записи AsyncTask в файле Android MainActivity.java, а затем изменил эскиз Arduino, чтобы дождаться, пока сервер не получит возврат каретки, я имею в виду такой код, как этот String request = client.readStringUntil('\r'); наконец, две кнопки как известные как btn1 и btn2 в приложении для Android, отправляют две строки /led/on и /led/off соответственно. к настоящему времени ESP8266 получает возврат каретки и немедленно очищает клиент, после чего нет задержки для выполнения другого раздела программы. Следующая программа включает или выключает один светодиод (контакт 0 GPIO ESP8266-01) в зависимости от нажатой кнопки в приложении Android. но не забудьте установить заземление GPIO 0 ESP8266-01 только во время его программирования и не забудьте сначала подключить мобильный Wi-Fi к сети Wi-Fi ESP, но вы также можете использовать конфигурацию Wi-Fi для автоматического подключения к Wi-Fi ESP (см. это ссылка).

Код Ардуино:

#include<ESP8266WiFi.h>
// WiFi Definitions
const char* ssid = "Esp8266TestNet";
const char* password = "Esp8266Test"; // has to be longer than 7 chars
const char* value = "";

int ledPin = 0; // GPIO 0
WiFiServer server(80);

void setup() {

   Serial.begin(115200);
   delay(10);
   pinMode(ledPin, OUTPUT);
   digitalWrite(ledPin, HIGH); // turn on

   WiFi.mode(WIFI_AP);
   WiFi.softAP(ssid, password, 1, false);
  
   server.begin();
}

void loop() {
  // Check of client has connected
  WiFiClient client = server.available();
  if(!client) {
    return;
  }

  // Read the request line
  String request = client.readStringUntil('\r');
  Serial.println(request);
  client.flush();
  
  // Match request
  if(request.indexOf("/led/on") != -1) {
     digitalWrite(ledPin, HIGH);
     value = "on";
  } else if (request.indexOf("/led/off") != -1) {
     digitalWrite(ledPin, LOW);
      value = "off";
  }
  else {
    Serial.println("not validate");
    }
  
  client.flush();
   
  // JSON response
  String s = "HTTP/1.1 200 OK\r\n";
  s += "Content-Type: application/json\r\n\r\n";
  s += "{\"data\":{\"message\":\"success\",\"value\":\"";
  s += value;
  s += "\"}}\r\n";
  s += "\n";

  // Send the response to the client
  client.print(s);
  delay(1);
  Serial.println("Client disconnected");

  // The client will actually be disconnected when the function returns and the client object is destroyed
}

XML-файл манифеста:

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.example.myhgrtest">
    <uses-permission android:name="android.permission.INTERNET"/>

    <application
        android:allowBackup="true"
        android:icon="@mipmap/ic_launcher"
        android:label="@string/app_name"
        android:roundIcon="@mipmap/ic_launcher_round"
        android:supportsRtl="true"
        android:theme="@style/AppTheme">
        <activity android:name=".MainActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>

</manifest>

Activity_main.xml:

<?xml version="1.0" encoding="utf-8"?>
<androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context=".MainActivity">
    <Button
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:id="@+id/btn1"
        android:text="btn1"
        app:layout_constraintLeft_toLeftOf="parent"
        app:layout_constraintRight_toRightOf="parent"
        app:layout_constraintTop_toTopOf="parent"
        ></Button>
    <Button
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:id="@+id/btn2"
        android:text="btn2"
        app:layout_constraintBottom_toBottomOf="parent"
        app:layout_constraintLeft_toLeftOf="parent"
        app:layout_constraintRight_toRightOf="parent"
        app:layout_constraintTop_toTopOf="parent"
        ></Button>
</androidx.constraintlayout.widget.ConstraintLayout>

Основная активность.java:

package com.example.myhgrtest;

import androidx.appcompat.app.AppCompatActivity;

import android.os.AsyncTask;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.Toast;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.HttpURLConnection;
import java.net.Socket;
import java.net.URL;

public class MainActivity extends AppCompatActivity {
    Button btn1,btn2;
    TcpClient mTcpClient;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        btn1=findViewById(R.id.btn1);
        btn2=findViewById(R.id.btn2);
        btn1.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {

                send_request1();
            }
        });
        btn2.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                send_request2();
            }
        });
    }
    public class ConnectTask extends AsyncTask<String, String, TcpClient> {

        @Override
        protected TcpClient doInBackground(String... message) {

            //we create a TCPClient object
            mTcpClient = new TcpClient(new TcpClient.OnMessageReceived() {
                @Override
                //here the messageReceived method is implemented
                public void messageReceived(String message) {
                    //this method calls the onProgressUpdate
                    publishProgress(message);
                }
            });
            mTcpClient.run();

            return null;
        }

        @Override
        protected void onProgressUpdate(String... values) {
            super.onProgressUpdate(values);
            //response received from server
            Log.d("test", "response " + values[0]);
            //process server response here....

        }
    }
    public void send_request1() {
        send_request1 sr = new send_request1();
        sr.execute();
    }
    public void send_request2() {
        send_request2 sr = new send_request2();
        sr.execute();
    }
    class send_request1 extends AsyncTask<Void, Void, String> {

        @Override
        protected String doInBackground(Void... voids) {
            try {             /*note : ip address must be in Quotation mark*/
                /*note : port doesn't need to be inside the Quotation mark*/
                Socket s = new Socket(/*ip address :*/"192.168.4.1",/*port :*/ 80);
                PrintWriter printWriter = new PrintWriter(s.getOutputStream());
                printWriter.write("/led/on"+"\r");
                printWriter.flush();
                printWriter.close();
                s.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            return null;
        }

        @Override
        public void onPostExecute(final String Data) {
            /*Data is what you receive from your server*/
            Log.e("my_Data","Data is : " + Data);
        }
    }
    class send_request2 extends AsyncTask<Void, Void, String> {

        @Override
        protected String doInBackground(Void... voids) {
            try {
                /*note : ip address must be in Quotation mark*/
                /*note : port doesn't need to be inside the Quotation mark*/
                Socket s = new Socket(/*ip address :*/"192.168.4.1",/*port :*/ 80);
                PrintWriter printWriter = new PrintWriter(s.getOutputStream());
                printWriter.write("/led/off"+"\r");
                printWriter.flush();
                printWriter.close();
                s.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            return null;
        }

        @Override
        public void onPostExecute(final String Data) {
            /*Data is what you receive from your server*/
            Log.e("my_Data","Data is : " + Data);
            //Toast.makeText(MainActivity.this, Data, Toast.LENGTH_SHORT).show();
        }
    }

}

Я не думаю, что кто-то может сказать наверняка, в чем проблема. Чтобы вы (и другие) не гонялись за призраками, вы действительно хотите разделить свою проблему:

• Убедитесь, что ваш 'doInBackground' не задерживается, например. войдя в систему ведения журнала Android, консоль, отладчик или выполнив что-то простое в пользовательском интерфейсе.
• Убедитесь, что отправка на стороне Android не задерживается, написав крошечный слушатель, например. Java и запустить его на своем ПК.
• Убедитесь, что прослушивание не задерживается, создав крошечный отправитель на Java и запустив его на своем ПК.

Таким образом, разделите свою проблему, пока не найдете основную причину :)