DataOutputStream stucks

Question

我已经创建了一个简单的服务器应用程序，用于向连接的客户端发送图像。我在主线程中有一个循环，它接受传入的连接，并从相应的套接字创建一个客户端对象。我有一个活跃客户的列表。每次有新图片可用时，我都会遍历客户端，并将新数据发送给它们。如果每个人都保持联系，一切都会很顺利。但是一旦其中一个客户端断开连接，DataOutputStream的write方法就会永远停滞。我假设它必须抛出一个异常或其他什么，但事实并非如此。我想我错过了一些简单的东西，但我找不到是什么。下面是我的客户机类的代码：

package hu.rothens.webcam;

import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class Client {

    private static int next_id = 0;
    private int id;
    private Socket socket;
    private WebcamServer ws;
    private DataOutputStream dos;

    public Client(Socket socket, WebcamServer ws, int width, int height) throws IOException {
        this.socket = socket;
        this.ws = ws;
        id = next_id++;
        while (!socket.isConnected());
        dos = new DataOutputStream(socket.getOutputStream());
        dos.writeInt(width);
        dos.writeInt(height);
    }

    public synchronized void sendImage(byte[] array) {
        try {
            System.out.println(id);
            //the code will stuck somewhere after this line
            dos.writeByte(0xFF);
            dos.flush();
            dos.writeInt(array.length);
            dos.write(array);
            dos.flush();
        } catch (IOException e) {
            System.out.println(e); //it won't get here
            ws.removeClient(this);
            try {
                socket.close();
            } catch (Exception ex) {
            }
        }    
    }
}

Answer 1

它不会永远阻塞。它最终会抛出一个IOException：'connection reset‘。‘'Forever’意味着你的部分陷入了死锁。

'while (!socket.isConnected());‘循环是完全没有意义的:由于套接字已经被接受，所以套接字是连接的。如果不是，这是无法处理的。

您不应该在编写0xff之后刷新流，但应该在Client的构造函数中刷新它。

如果客户端在自己的线程上运行，我看不出有任何理由在客户端同步，这是应该的。

您应该同时发送到所有客户端，而不是迭代发送，以便所有客户端都能同时获得服务，并且其中一个客户端的错误或速度缓慢不会影响其他客户端。