我正在尝试使用从 Socket 检索的 InputStream 创建一个新的 ObjectInputStream。这是我的代码:
这是我的 MessageGetterSender 类的构造函数。程序未到达检查点 4。
public MessageGetterSender(Socket socket) {
System.out.println("MessageGetterSender: Checkpoint 1");
this.socket = socket;
// Get input and output streams
try {
System.out.println("MessageGetterSender: Checkpoint 2");
InputStream is = socket.getInputStream();
System.out.println("MessageGetterSender: Checkpoint 3");
this.in = new ObjectInputStream(is);
System.out.println("MessageGetterSender: Checkpoint 4");
} catch (IOException ioe) {
System.out.println("Could not get ObjectInputStream on socket: " + socket.getLocalPort());
}
try {
this.out = new ObjectOutputStream(socket.getOutputStream());
} catch (IOException ioe) {
System.out.println("Could not get ObjectOutputStream on socket: " + socket.getLocalPort());
}
System.out.println("MessageGetterSender: Checkpoint 5");
}
我正在从一个类实例化一个新的 MessageGetterSender 对象,在该类中我连接到服务器以获取套接字。这是相关代码。它是 InstantMessageClass 的构造函数,该类实例化 MessageGetterSender 对象:
public InstantMessageClient(String username) {
try {
socket = new Socket("localhost", 5555);
} catch (IOException ioe) {
System.out.println("Error: Could not connect to socket on port: " + serverPort);
}
messageGetterSender = new MessageGetterSender(socket);
...
由于代码不会执行到检查点 4,但它确实会执行到检查点 3,因此我非常确定 ObjectInputStream 的实例化是罪魁祸首。但我不明白为什么。有任何想法吗?谢谢您的帮助。
当你构造一个ObjectInputStream
,在构造函数中,该类尝试读取关联的标头ObjectOutputStream
连接的另一端已写入。在读取该标头之前它不会返回。因此,如果您看到构造函数“挂起”,那是因为套接字的另一端尚未使用ObjectOutputStream
,或者尚未刷新数据。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)