Почему эта программа сокетов не передает данные?

Question

Я пишу свой первый проект сокетов, и у меня проблема.Когда клиент отправляет строку на сервер, сервер не может получить это сообщение.

public class ClientActivity {

    public static final String serverIP = "127.0.0.1";
        private Socket clientSocket = null;
        private static BufferedOutputStream out = null;

    public static void main(String[] args) throws IOException {
        ClientActivity me = new ClientActivity();
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        out.write("Some string");
    }

    public ClientActivity() throws UnknownHostException, IOException {
           clientSocket = new Socket(serverIP, serverPort);
           out = new BufferedOutputStream(clientSocket.getOutputStream());
    }
}

Вот код сервера:

public class DataTransferServer {

    private ServerSocket serverSocket;
    private ArrayList<DataReaderThread> workingThreads;
    private Boolean isListening;
    private Thread listener;

    public static void main(String[] args) throws IOException {
        new DataTransferServer(IProtocolConstants.SERVER_PORT).startServer(); // FIXME
    }

    public DataTransferServer (int port) throws IOException {
        System.out.println("Launch");
        serverSocket = new ServerSocket(port);
        workingThreads = new ArrayList<DataReaderThread>();
        isListening = true;
        listener = new ConnectionListener();
    }

    public void startServer() throws IOException {
        listener.start();
    }

    private class ConnectionListener extends Thread {
        @Override
        public void run() {
            DataReaderThread newThread  = null;
            while (isListening) {
                try {
                    newThread = new DataReaderThread(serverSocket.accept(), DataTransferServer.this);
                    newThread.start();
                    workingThreads.add(newThread);
                    System.out.println("! thread started");
                } catch (IOException e) {
                    e.printStackTrace(); // FIXME
                }
            }
            if (newThread != null) {
                newThread.interrupt();
                newThread = null;
            }
        }
    }


}

А вот слушатель:

public class DataReaderThread extends Thread {
    private Socket socket = null;
    private BufferedInputStream in = null;
    private byte[] stuffBytes = null;

    public DataReaderThread(Socket socket) throws IOException {
        super("DataReaderThread");
        this.socket = socket;
        in = new BufferedInputStream(socket.getInputStream());
stuffBytes = new byte[10];
    }

    public void run() {
        try {
            while (in.read(stuffBytes, 0, stuffBytes.length) != -1) {
System.out.println("Received data:" + new String(stuffBytes));
            }
            in.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public Socket getSocket() {
        return socket;
    }

Answer 1

Я полагаю, что BufferedOutputStream out не отправляет пакет TCP, пока буфер не заполнится.

Попробуйте позвонить flush после write, чтобы немедленно отправить данные:

out.write("Some string");
out.flush();

Вы можете также рассмотреть возможность использования класса PrintWriter , который имеет механизм авто-промывки.

Answer 2

-1 Скомпилируйте свой код перед публикацией ...

public class ClientActivity {

    public void write(String data) {
       out.write(data.getBytes())
       out.flush()
    }

    public static final String serverIP = "127.0.0.1";
        private Socket clientSocket = null;
        private BufferedOutputStream out = null;

    public static void main(String[] args) throws IOException {
        ClientActivity me = new ClientActivity();
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        me.write("Some string");
    }

    public ClientActivity() throws UnknownHostException, IOException {
           clientSocket = new Socket(serverIP, serverPort);
           out = new BufferedOutputStream(clientSocket.getOutputStream());
    }
}