0

只是为了说明我的问题的背景；我正在编写一个客户端服务器应用程序。当客户端最初连接时，服务器访问数据库并通过在 for 循环中将对象写入 objectoutputstream 将特定表中的所有项目发送到客户端。

问题是，客户端只读取正在发送的第一个对象。即使我创建了一个新对象并将其发送到服务器进行验证，当服务器在插入数据库后将其发回时，客户端也不会接收它...从代码中提取：

服务器：

public void loadClients()
{

    ArrayList <Client> list = dBCon.loadClients();
    try
    {
        for (int i =0; i<list.size();i++)
        {
            sendtoClient(list.get(i));
        }
    }
    catch (IOException e)
    {
        e.printStackTrace();
    }

}

public void sendtoClient(Object obj) throws IOException
{
    _out.writeObject(obj);
    _out.flush();
    _out.reset();

}

客户：

socket = new Socket("localhost", 4447);
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());
Object objIn = ois.readObject();
Client client = (Client)objIn;
switch(client.actionType)
{
    case ("ADD"):
    {
        if(clientFrame.tbDeals!=null)
        {
            clientFrame.tbDeals.addClient(client);
            break;
        }
        else
        {
            clientList.add(client);
            System.out.println(client.clientName);
            break;

        }
    }

}

编辑：我也尝试过在客户端使用 while 循环。然后 ois.available() 返回 0....

4

1 回答 1

3

您正在客户端读取一个对象。这就是你将要得到的一切。

available()在 Java 中进行基本 IO 时很少使用，而且通常不会像您认为的那样做。

从 a 读取ObjectInputStream是阻塞的，就像所有其他基本 Java IO 一样。使用您将获得一个对象，或者javadoc 中指出readObject()的异常

如果您不知道您将接收的对象数量并期望连接保持打开状态，您将如何在循环中处理此问题的最简单示例是：

while (true) {

    try {
        Object o = ois.readObject();
        /// do something with the object you just read
    } catch ( EOFException e) {
        System.out.println("remote connection closed!");
        e.printStackTrace();
        break;
    }
}
于 2013-07-14T06:30:20.717 回答