1

我有类:客户端、服务器和背景正在使用 Player 类。我真的不明白为什么我的ObjectInputStream/客户端类ObjectOutputStream不能正常工作。

我在做什么坏事?我的错在哪里?

package Shooter2Dv27082013;
public class Player implements Serializable{
....
public int x=10;
public int y=10;
.... }

package Shooter2Dv27082013;
public class Background extends JPanel implements ActionListener, Serializable {
public int countCollisions=0;
private int time = 20;                       // 0.02s
Timer mainTimer = new Timer(time, this);
....
Player p = new Player(); ... }

现在客户端类:

package Shooter2Dv27082013;


import javax.swing.*;
import java.net.*;
import java.io.*;

public class Client {
    public static void main(String[] ar) {
        JFrame frame = new JFrame("D2 Shooter");
        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        frame.setSize(1000, 520);
        Background bg = new Background();
        frame.add(bg);
        frame.setResizable(false);
        frame.setVisible(true);

        int serverPort = 6666; 
        String address = "127.0.0.1"; /

        Player p = new Player();
        try {
            InetAddress ipAddress = InetAddress.getByName(address); 
            System.out.println("Any of you heard of a socket with IP address " + address + " and port " + serverPort + "?");
            Socket socket = new Socket(ipAddress, serverPort); 
            System.out.println("Yes! I just got hold of the program.");

            InputStream sin = socket.getInputStream();
            OutputStream sout = socket.getOutputStream();

            ObjectInputStream ois = new ObjectInputStream(sin);
            ObjectOutputStream oos = new ObjectOutputStream(sout);

            System.out.println("Streams are created. Let's try send these objects");
            System.out.println();


            System.out.println("P.x : "+bg.p.x);
            while (true) {
                oos.writeObject(bg.p);
                oos.flush();
                oos.close();
                System.out.println("Player X: " + bg.p.x + " Player Y: " + bg.p.y);
                p = (Player) ois.readObject();
                ois.close();
                System.out.println("New X: " + p.x + "New Y: "+p.y);
                System.out.println("Looks like the server is pleased with us. Go ahead and enter more lines.");
                System.out.println();
            }

        } catch (Exception x) {
            x.printStackTrace();
        }
    }
}

它不会将 Object 发送到 Server 类,但它也没有说明错误。

服务器类:

package Shooter2Dv27082013;

import java.net.*;
import java.io.*;
public class Server {
    public static void main(String[] ar)    {
        int port = 6666; 
        try {
            ServerSocket ss = new ServerSocket(port); 
            System.out.println("Waiting for a client...");

            Socket socket = ss.accept(); 
            System.out.println("Got a client :) ... Finally, someone saw me through all the cover!");
            System.out.println();

            InputStream sin = socket.getInputStream();
            OutputStream sout = socket.getOutputStream();

            ObjectInputStream ois = new ObjectInputStream(sin);
            ObjectOutputStream oos = new ObjectOutputStream(sout);

            Player p = new Player();

            while(true) {
                p = (Player) ois.readObject();
                System.out.println("The client just sent me this x: "+p.x+" y: "+p.y);
                p.x=555; p.y=600;
                System.out.println("I change it and now I'm sending it back...");
                oos.writeObject(p);
                oos.flush();
                oos.close();
                System.out.println("Waiting for the next line...");
                System.out.println();
            }
        } catch(Exception x) { x.printStackTrace(); }
    }
}
4

3 回答 3

6

您需要在两端都在 ObjectInputStream 之前构造 ObjectOutputStream。目前你有一个僵局。

需要将闭包移到循环之外。

于 2013-08-27T09:42:59.813 回答
2

您正在循环关闭流。关闭后,您不能使用流或任何资源。

于 2013-08-27T09:41:10.607 回答
0

好的,这就是对象流的工作方式以及无处不在的解决方案。

对象流数据之前是一个 4 字节的“神奇”序列 AC ED 00 05。AnObjectInputStream将在构建时而不是在第一次读取之前查看此数据。这是合乎逻辑的:在应用程序中太远之前,要确保它是正确的流。该序列由ObjectOutputStream构造时缓冲,以便在第一次写入时将其推送到流上。这种方法通常会导致缓冲情况或通过管道或套接字传输的复杂性。幸运的是,所有这些问题都有一个简单而有效的解决方案:

施工后立即冲洗ObjectOutputStream

ObjectOutputStream myStream = new ObjectOutputStream ( anotherStream );
myStream.flush();

在您的客户端和服务器应用程序中。

于 2014-05-25T02:21:15.470 回答