- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我在linux系统上遇到过一个socket通信的问题,通信过程是这样的:client发消息要求server做一个计算任务,任务完成后等待server返回result消息。
但是如果任务耗时较长,比如40分钟左右,客户端就会挂起等待结果消息,即使从服务器端,结果消息已经写入socket响应客户端,但是如果任务花费的时间很短,例如一分钟,它通常可以收到结果消息。此外,此问题仅发生在客户环境中,通信过程在我们的测试环境中表现正常。
我怀疑这个问题的原因是客户环境和测试环境的套接字默认超时值不同,但是在这两个环境中,客户端和服务器的后续值是相同的。
getSoTimeout:0
getReceiveBufferSize:43690
getSendBufferSize:8192
getSoLinger:-1
getTrafficClass:0
getKeepAlive:false
getTcpNoDelay:false
客户端的代码如下:
Message msg = null;
ObjectInputStream in = client.getClient().getInputStream();
//if no message readObject() will hang here
while ( true ) {
try {
Object recObject = in.readObject();
System.out.println("Client received msg.");
msg = (Message)recObject;
return msg;
}catch (Exception e) {
e.printStackTrace();
return null;
}
}
服务器上的代码是这样的,
ObjectOutputStream socketOutStream = getSocketOutputStream();
try {
MessageJobComplete msgJobComplete = new MessageJobComplete(reportFile, outputFile );
socketOutStream.writeObject(msgJobComplete);
}catch(Exception e) {
e.printStackTrace();
}
为了解决这个问题,我添加了flush和reset方法,但是问题依然存在:
ObjectOutputStream socketOutStream = getSocketOutputStream();
try {
MessageJobComplete msgJobComplete = new MessageJobComplete(reportFile, outputFile );
socketOutStream.flush();
logger.debug("AbstractJob#reply to the socket");
socketOutStream.writeObject(msgJobComplete);
socketOutStream.reset();
socketOutStream.flush();
logger.debug("AbstractJob#after Flush Reply");
}catch(Exception e) {
e.printStackTrace();
logger.error("Exception when sending MessageJobComplete."+e.getMessage());
}
所以有谁知道我下一步应该做什么来解决这个问题。我猜是环境设置的原因,但我不知道环境因素会影响套接字通信?
而使用Tcp/Ip协议(protocol)通信的socket,问题是与长时间任务有关,那么tcp取什么值会影响socket通信的超时呢?
经过我对日志的分析,我发现在将消息写入套接字后,没有抛出/捕获异常。但总是在15分钟后,用于接受客户端请求的Server Side的objectInputStream.readObject()代码片段出现异常。但是socket.getSoTimeout的值为0,所以抛出Timed out Exception很奇怪。
{2012-01-09 17:44:13,908} ERROR java.net.SocketException: Connection timed out
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.read(SocketInputStream.java:146)
at sun.security.ssl.InputRecord.readFully(InputRecord.java:312)
at sun.security.ssl.InputRecord.read(InputRecord.java:350)
at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:809)
at sun.security.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:766)
at sun.security.ssl.AppInputStream.read(AppInputStream.java:94)
at sun.security.ssl.AppInputStream.read(AppInputStream.java:69)
at java.io.ObjectInputStream$PeekInputStream.peek(ObjectInputStream.java:2265)
at java.io.ObjectInputStream$BlockDataInputStream.peek(ObjectInputStream.java:2558)
at java.io.ObjectInputStream$BlockDataInputStream.peekByte(ObjectInputStream.java:2568)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1314)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:368)
那么为什么会抛出 Connection Timed out 异常呢?
最佳答案
这个问题解决了。使用 tcpdump
捕获消息流。我发现在应用程序级别,ObjectOutputStream.writeObject()
方法被调用,而在 tcp 级别,多次发现 [TCP ReTransmission]
。
所以,我得出结论,连接可能已经死了,尽管使用 netstat -an
命令 tcp 连接状态仍然是 ESTABLISHED
。
所以我写了一个测试应用程序来定期从服务器发送测试消息作为心跳消息。然后这个问题就消失了。
关于java - ObjectInputStream.readObject()在socket通信过程中永远挂起,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8798985/
当我尝试模拟 ObjectInputStream 对象时,我得到一个 NullPointerException。更准确地说,当调用此行时: when(inputStream.readObject())
这是我的代码: ObjectInputStream ois = null; UserRegistration UR = new UserRegistration(); Scan
所以我试图将一个对象从客户端发送到服务器,然后我用这个对象做一些事情。我验证了发送时对象包含数据。当我在调试器中读取对象时,它的所有属性均为 null。 下面是我发送对象的位置: private cl
我正在使用套接字对java网络进行编程,并使用简单对象在远程程序之间交换数据。 在本例中,我有一个使用以下方法构造的ObjectInputStream: new ObjectInputStream(S
我一直在尝试制作一款两人多米诺骨牌游戏。目前,我希望在玩家 2 的屏幕上模仿玩家 1 的 Action ,仅此而已。如果我启动玩家 1 的屏幕并移动一些多米诺骨牌,则当我启动玩家 2 的屏幕时会出现更
这个问题已经有答案了: Sending the same but modifed object over ObjectOutputStream (2 个回答) 已关闭 4 年前。 我正在尝试通过套接字
我在一个文件中存储了多个对象。这与 ObjectInputStream 有关。如果我有以下代码: FileInputStream fis = new FileInputStream(filename)
这个问题已经有答案了: Java socket/serialization, object won't update (2 个回答) 已关闭 8 年前。 我有多个客户端和一台服务器。服务器在一个线程中
我有一系列通过网络套接字发送的对象。 用于读取数据的代码已经实现并且可以工作,但我的问题是有时套接字超时会中断对象的读取(ObjectInputStream.readObject()),从而损坏流.
当我尝试从服务器发送一个对象时,我的计算机似乎崩溃了,第 27 行尝试接收该对象,我想我得到了一个无效的类型代码:0一次,但通常只是崩溃,所以我必须重新启动 new Thread(
我试图在第24行的客户端中实例化一个ObjectInputStream,但它不会,我可以实例化一个ObjectOutputStream,但不能实例化Input。 private class C
我正在尝试使用以下代码读取我保存的文件: public void saveOnFile() { try { ObjectOutputStream output = ne
我保存了一个ArrayList作为带有 ObjectOutputStream 的对象。现在,我如何在另一个应用程序项目上使用 ObjectInputStream 读取该对象?我尝试了一下,它抛出了 C
我有两个类。在第一个类中,我从List中写入数据,在第二堂课中,我想读取这些数据并将其放入listview中。它正确保存数据,但是当我尝试获取它时,logcat 给出错误: java.lang.Cla
我正在尝试将 ArrayList 发送到 Android 设备上的客户端。服务器说它发送了该对象,但是在 Android 设备上它挂起。我已经阅读过,在创建 ObjectInputStream 时,必
我正在通过 java 套接字将文件从 Google glass 设备读取到 PC。由于 catch 语句抛出 eof 异常,我的其余代码被忽略。我该如何解决这个问题? 代码:接收图像(并将其放入简单的
几天前,我开始编写一个小型多人游戏,其中我使用 ObjectInputStreams 和 ObjectOutputStreams 与服务器交换数据。但由于某种原因,服务器没有收到任何东西。所以我寻求一
我有一个套接字,它每隔几秒通过 ObjectOutputStream 向客户端发送一个对象列表。在服务器端,每次 writeObject(myList) 之后,我执行 flush 然后 reset。使
这个问题已经有答案了: ObjectInput and Output streams are not being accepted by client/server (2 个回答) 已关闭 5 年前。
我在使用二进制文件加载应用程序时遇到问题。我正在尝试从二进制文件中读取数据并将数据注入(inject)到我的应用程序中的一些 HashMaps/ArrayLists 中。 public void lo
我是一名优秀的程序员,十分优秀!