0

对于我正在学习的 Java 类,我需要使用套接字在客户端和服务器之间来回传递数据。虽然我可以获得传递字符串数据的示例,但我需要能够来回传递自定义类对象(即产品)和这些对象的列表。我无法让服务器成功读取输入。我尝试创建一个简单的代码示例,看看是否有人可以查明问题所在。我确实知道我没有完整的代码,但我什至无法让服务器读取该类正在写入流的对象(在这种情况下,我正在编写一个字符串只是为了尝试让它工作,但需要读/写对象)。这是我的代码。我花了好几个小时尝试这个并研究其他人的问题和答案,但仍然无法让它发挥作用。

这里是示例代码:

简单的服务器:

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class simpleServer {

    public static final int PORT_NO = 8888;
    static ObjectInputStream serverReader = null;


    public static void main(String[] args) throws IOException, InterruptedException {

        ServerSocket serverSocket = new ServerSocket(PORT_NO);
        System.out.println("... server is accepting request");
        Object myObject = null;
        while (true) {
            Socket socket = serverSocket.accept();
            System.out.println("creating reader");
            ObjectOutputStream objOut = new ObjectOutputStream(socket.getOutputStream());
            serverReader = new ObjectInputStream(socket.getInputStream());
            System.out.println("created reader");
            try {
                System.out.println("try to read");
                myObject = serverReader.readObject();
                System.out.println("read it");
                System.out.println(myObject);
                if (myObject != null) objOut.writeUTF("Got something");
                else objOut.writeUTF("got nothing");
                if ("quit".equals(myObject.toString())) serverSocket.close(); 
            } catch (ClassNotFoundException e1) {
                // TODO Auto-generated catch block
                System.out.println("cath for readobject");
            }
            catch (Exception e) {

                System.out.println("other error");
                System.out.println(e.getMessage());
            }
        }

    }
}

简单的客户端:

public static void main(String[] args) {
    Socket socket;
    try {
        socket = new Socket("localhost", ProductDBServer.PORT_NO);
        ObjectOutputStream objOut = new ObjectOutputStream(socket.getOutputStream()); 
        ObjectInputStream  objIn  = new ObjectInputStream(socket.getInputStream()); 

        objOut.writeUTF("loadProductsFromDisk");
        objOut.flush();
        String myString = objIn.toString();
        //System.out.println(myString);
        if (!"quit".equals(objIn.toString().trim())) {
            //System.out.println("reading line 1");
            String line;
            try {
                line = (String)objIn.readObject();
                //System.out.println("line is " + line);
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            objIn.close();
            //System.out.println("result: " + line);
        }

        System.out.println("closing socket");
        socket.close();

    } catch (UnknownHostException e) {
        // TODO Auto-generated catch block
        System.out.println("Unknownhostexception");
        e.printStackTrace();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        System.out.println("ioexception");
        e.printStackTrace();
    } 


}

代码似乎运行到服务器端尝试读取我发送的对象的位置,然后死掉。有人可以看到我做错了什么吗?这似乎是一件很简单的事情,但我似乎无法让它发挥作用。谢谢你的帮助!

4

2 回答 2

0

要将对象写入 ObjectOutputStream,您需要调用 writeObject()。

不写UTF()。

要从 ObjectInputStream 中读取对象,您需要调用 readObject()。

不是 toString()。

于 2013-06-30T00:46:23.760 回答
0

在您的代码中查看:

// Simple Client 
objOut.writeUTF("loadProductsFromDisk");           // Line 8

您正在向"loadProductsFromDisk"服务器端发送 UTF-8 格式的字符串。所以为了在服务器端接收和读取它,你需要这样的东西:

String clientReq = serverReader.readUTF();  

serverReader你的ObjectInputStream对象在哪里。

否则,如果您希望发送和接收对象,则必须分别使用 writeObject()&readObject()方法。

于 2021-04-07T06:04:16.347 回答