只是为了说明我的问题的背景;我正在编写一个客户端服务器应用程序。当客户端最初连接时,服务器访问数据库,并通过在 for 循环中将对象写入对象输出流,将特定表中的所有项目发送到客户端。
问题是,客户端仅读取正在发送的第一个对象。即使我创建一个新对象并将其发送到服务器进行验证,当服务器在插入数据库后将其发回时,客户端也不会拾取它...从代码中提取:
服务器:
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....
最佳答案
您正在客户端读取恰好一个对象。这就是你将得到的全部。
在 Java 中执行基本 IO 时,很少使用available()
,并且通常不会执行您认为它会执行的操作。
从 ObjectInputStream
读取是阻塞的,就像所有其他基本 Java IO 一样。使用 readObject()
您将获得一个对象,或者一个异常 as noted in the javadoc
如果您不知道将接收的对象数量并期望连接保持打开状态,则如何在循环中处理此问题的最简单示例是:
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;
}
}
关于java - readObject 方法仅读取它接收到的第一个对象,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17636850/