While-Schleife im Java-Thread wird nicht ausgeführt

Question

Ich mache einen Minecraft-Mod, in dem ein Socket-Server im Hintergrund laufen soll, der auf eine Nachricht vom Python-Client wartet.

Der Server läuft in einem Thread.

Hier ist der Code, in dem ich den Thread starte:

Thread t = new Thread(new Runnable() {

            @Override
            public void run() {
                try {
                    InterPythonJavaCommunicatorServer.begin(socket, sockIn, sockOut);
                }catch (IOException e){
                    System.out.println("Woah! Somethings gone wrong! ringing a alarm now!");
                }
            }
        });
        t.start();
        t.join();

Und die gesamte Serverklasse

package com.satyamedh.minecraft_ai_helper.communicator;

import com.satyamedh.minecraft_ai_helper.Movement;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.net.Socket;

public class InterPythonJavaCommunicatorServer{

    public static void begin(Socket socket, BufferedReader sockIn, BufferedWriter sockOut) throws IOException {
        boolean done = false;
        while (true) {
            System.out.println("Test!");
            boolean ready = sockIn.ready();
            if(!ready) {
                return;
            }
            try {
                String response = sockIn.readLine(); // Stops Here!
                System.out.println(response);
                //if (response == null) {
                    //System.out.println("Remote process closed the connection.");
                    //done=true;
                //}
            if (response.equals("forward\n")){
                    boolean o = Movement.forward(1);
                    if (o){
                        sockOut.write("done");
                        sockOut.flush();
                    }
                }
            } catch (IOException e) {
                System.out.println("Welp! ALARM BOI!");
            }
        }
    }

}

Ich habe den gesamten Code unterbrochen und es scheint anzuhalten String response = sockIn.readLine();. Und die Test!Nachricht wird nur einmal ausgeführt.

Ps: Ich habe stundenlang gegoogelt und gesucht warum! kann nicht scheinen, etwas verwandtes zu finden!

Ich weiß, es könnte sehr dumm und leicht erwischt sein :)

Bearbeiten: Wie @DevParzival sagte, habe ich versucht, zu verwenden, t.join();aber es macht immer noch das gleiche! Ich habe den obigen Code so bearbeitet, dass er meinem aktuellen Code entspricht.

Edit2: Hier ist der Client-Code (Python)

import socket

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(("", 1243))
server_socket.listen(5)

print(
    "TCPServer Waiting for client on port 1243")

while 1:
    client_socket, address = server_socket.accept()
    print(
        "I got a connection from ", address)
    while 1:
        data = input("SEND( TYPE q or Q to Quit):")
        if data == 'Q' or data == 'q':
            client_socket.send(bytes(data, encoding='utf8'))
            client_socket.close()
            break
        else:
            client_socket.send(bytes(data, encoding='utf8'))

        data = client_socket.recv(512)
        if data == 'q' or data == 'Q':
            client_socket.close()
            break
        else:
            print("RECEIVED:", data)

Danke im Voraus

Answer 1

Versuchen Sie, NewLine | CHR(10) | \nZeichen am Ende der Nutzlast des Python-Pakets zu senden. Wenn Sie sie socketIn.readLine()auf einer empfangenden Seite verwenden, wartet sie vor der Rückgabe auf einen Zeilenbegrenzer.

Wenn Sie den Java NonBlocking NIO-Socket studieren möchten, können Sie hier mein Beispielprogramm studieren. Bitte beachten Sie, dass der NIO-Socket einen ganz anderen Ansatz benötigt https://stackoverflow.com/a/26312841/185565