如何解決替換AsyncTask以連接套接字的問題？

我正在嘗試使用這種方法（標記答案）來替換我的代碼，AsyncTask以便在 android 和服務器中的用戶之間建立連接，這就是我所做的：

注意：我沒有使用任何特定的模式，只是試圖在基本結構上實作這個目標。

主要活動 ：

public class MainActivity extends AppCompatActivity {
    private ClientConnection connection;


    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        connection = new ClientConnection(inputServerIp.getText().toString(), inputUserName.getText().toString(), Integer.parseInt(inputPort.getText().toString()));
    }
}

客戶端連接：

public class ClientConnection {
    private Socket serverSocket;
    private ConnectionTask taskRunner;

    public ClientConnection(String ipAddress, String userName, int dstPort) {
        this.ipAddress = ipAddress;
        this.userName = userName;
        this.dstPort = dstPort;
    }

    public void connect() {
        taskRunner.executeAsync(new ConnectionRunningTask(ipAddress, dstPort), (data) -> {
            serverSocket = data;
        });
    }

連接任務：

public class ConnectionTask {

    private final Executor executor = Executors.newSingleThreadExecutor();
    private final Handler handler = new Handler(Looper.getMainLooper());

    public interface Callback<R> {
        void onComplete(R result);
    }

    public void executeAsync(Callable<R> callable, Callback<R> callback) {
        executor.execute(() -> {
            try {
                final R result = callable.call();
                handler.post(() -> {
                    callback.onComplete(result);
                });
            } catch (Exception e) {
                e.printStackTrace();
            }
        });
    }
}

連接運行任務：

public class ConnectionRunningTask implements Callable<Socket> {
    private final String ipAddress;
    private final Integer dstPort;

    public ConnectionRunningTask(String ipAddress, Integer dstPort) {
        this.ipAddress = ipAddress;
        this.dstPort = dstPort;
    }

    @Override
    public Socket call() throws IOException {
        return new Socket(ipAddress, dstPort);
    }
}

因此，基于上面的代碼，我將嘗試解釋我嘗試過的內容以及當前的問題是什么：

問題：基于上面的代碼，我在 connect() 中收到以下錯誤，它告訴我資料是 R 并且您無法將其設定為 serverSocket，并且由于此錯誤我無法構建應用程式。

然后我試圖取代所有R與Socket在ConnectionTask類（R回呼和可贖回），在這種情況下，應用程式能夠建立和運行。

public interface Callback<Socket> {
    void onComplete(Socket result);
}

public void executeAsync(Callable<Socket> callable, Callback<Socket> callback) {
    executor.execute(() -> {
        try {
            final Socket result = callable.call();
            handler.post(() -> {
                callback.onComplete(result);
            });
        } catch (Exception e) {
            e.printStackTrace();
        }
    });
}

但是基于上述方法，當我點擊連接按鈕時，我會收到一個錯誤，這是我得到的：

2021-12-06 04:02:26.942 16417-16417/ir.atlaspio.atlasclientchat E/AndroidRuntime: FATAL EXCEPTION: main
    Process: ir.atlaspio.atlasclientchat, PID: 16417
    java.lang.NullPointerException: Attempt to invoke virtual method 'void ir.atlaspio.atlasclientchat.networking.ConnectionTask.executeAsync(java.util.concurrent.Callable, ir.atlaspio.atlasclientchat.networking.ConnectionTask$Callback)' on a null object reference
        at ir.atlaspio.atlasclientchat.networking.ClientConnection.connect(ClientConnection.java:38)
        at ir.atlaspio.atlasclientchat.MainActivity$1.onClick(MainActivity.java:61)
        at android.view.View.performClick(View.java:4780)
        at com.google.android.material.button.MaterialButton.performClick(MaterialButton.java:1119)
        at android.view.View$PerformClick.run(View.java:19866)
        at android.os.Handler.handleCallback(Handler.java:739)
        at android.os.Handler.dispatchMessage(Handler.java:95)
        at android.os.Looper.loop(Looper.java:135)
        at android.app.ActivityThread.main(ActivityThread.java:5254)
        at java.lang.reflect.Method.invoke(Native Method)
        at java.lang.reflect.Method.invoke(Method.java:372)
        at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:903)
        at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:698)
2021-12-06 04:07:27.221 16417-16417/ir.atlaspio.atlasclientchat I/Process: Sending signal. PID: 16417 SIG: 9

在服務器端，我還檢查了傳入的連接，但那里什么也沒發生……

uj5u.com熱心網友回復：

你不是taskRunner在里面實體化ClientConnection。將此行添加到建構式：

public ClientConnection(String ipAddress, String userName, int dstPort) {
    this.ipAddress = ipAddress;
    this.userName = userName;
    this.dstPort = dstPort;
    this.taskRunner = new ConnectionTask(); // <-- this line here
}

標籤：爪哇 安卓 插座 并发

上一篇：python腳本來計算互聯網上傳和下載和抖動

下一篇：無法使用TCP套接字pyton在服務器上接收多條訊息