我的目标是创建一个从 ObjectInputStream 接收 Message 对象的服务器,然后将该 Message 对象回显到 ObjectOutputStream。
在写入消息后,客户端将消息类型对象发送到服务器,然后接收到的消息类型对象(以及来自连接到服务器的其他客户端的消息类型对象)并解码到客户端的 gui。
Message 对象具有字符串和其他字体信息。
我的问题是服务器没有回显消息类型对象。我有一种感觉,我没有正确地投射,但在这一点上,我只是在尝试不同的东西。
这个想法是使服务器对客户端透明 - 这可能吗,即:服务器对 TestObject 类一无所知?有没有解决的办法?
服务器代码:
import java.net.*;
import java.io.*;
public class Server
{
public SimpleServer() throws IOException, ClassNotFoundException
{
ServerSocket ss = new ServerSocket(4000);
Socket s = ss.accept();
ObjectInputStream ois = new ObjectInputStream(s.getInputStream());
ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
// the 'echo' functionality of the server
Object to = null;
try
{
to = ois.readObject();
}
catch (ClassNotFoundException e)
{
System.out.println("broke");
e.printStackTrace();
}
oos.writeObject(to);
oos.flush();
// close the connections
ois.close();
oos.close();
s.close();
ss.close();
}
public static void main(String args[]) throws IOException, ClassNotFoundException {
new SimpleServer();
}
}
客户端代码:
import java.net.*;
import java.io.*;
public class Client
{
public SimpleClient() throws IOException, ClassNotFoundException
{
Socket s = new Socket( "localhost", 4000 );
ObjectOutputStream oos = new ObjectOutputStream(s.getOutputStream());
ObjectInputStream ois = new ObjectInputStream( s.getInputStream());
TestObject to = new TestObject( 1, "object from client" );
// print object contents
System.out.println( to );
oos.writeObject(to);
oos.flush();
Object received = ois.readObject();
// should match original object contents
System.out.println(received);
oos.close();
ois.close();
}
public static void main(String args[]) throws IOException, ClassNotFoundException
{
new SimpleClient();
}
}
class TestObject implements Serializable
{
int value ;
String id;
public TestObject( int v, String s )
{
this.value=v;
this.id=s;
}
@Override
public String toString()
{
return "value=" + value +
", id='" + id;
}
}
感谢您的时间!
编辑:这是创建的输出:
当客户端连接到服务器时,我收到此消息:线程“主”java.lang.ClassNotFoundException 中的异常:TestObject
这是我运行客户端时的客户端输出: value=1, id='object from client Exception in thread "main" java.net.SocketException: Connection reset