1

我制作了一个简单的服务器应用程序，用于将图像发送到连接的客户端。我在主线程中有一个循环，它接受传入的连接，并从相应的套接字创建一个 Client 对象。我有一个活跃客户的列表。每次有新图片可用时，我都会遍历客户端，并向他们发送新数据。如果每个人都保持联系，一切都会顺利进行。但是一旦其中一个客户端断开连接，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) {
            }
        }    
    }
}
4

1 回答 1

0

它不会永远阻塞。它最终会抛出一个 IOException: 'connection reset' 。“永远”意味着您陷入僵局。

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

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

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

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

于 2014-01-28T21:32:34.860 回答