通过套接字发送多个变量？

Question

我最近开始学习使用 java 中的套接字进行网络连接。所以我创建了一个可以在同一台计算机上玩的多人游戏，但我想让它成为网络多人游戏，然后我了解了套接字，现在，我想将游戏中玩家位置的变量发送到服务器然后可以将该玩家放置在另一台机器上运行的另一个游戏实例中的那个位置。问题是，我只是失败了，所有数据都没有被接收或读取。我还希望职位不断发送和接收，这对我来说也是一个问题......

我尝试使用 ObjectOutputStream 和 ObjectInputStream 发送一个带有变量的 int 数组，但也失败了，所以请你告诉我如何做到这一点，因为我不知道，我似乎无法在网上找到答案。

谢谢

Answer 1

作为最简单的解决方案，使用 Object Streams 将您创建的对象发送到您存储这些坐标的位置，但此类必须实现 Serializable 接口。例如二维坐标：

class Coords implements Serializable {
    int x, y;
    public Coords(int x, int y) {
        this.x = x;
        this.y = y;
    }       
}

...

// To write:
// oos = ObjectOutputStream of the socket
Coords tmp = new Coords(x, y);
oos.writeObject(tmp);
oos.flush();

...

//To read:
//ois = ObjectInputStream of the socket
Coords tmp = (Coords)ois.readObject();

http://java.sun.com/developer/technicalArticles/ALT/sockets/ 也可以帮助你。

Answer 2

试试这样的：

import java.io.*;
import java.net.*;
class Server extends Thread {
    Server() throws IOException {
        serverSocket = new ServerSocket(0);
    }
    public void run() {
        while (true) {
            try {
                Socket client = serverSocket.accept();
                Connect c = new Connect(client);
                c.start();
            } catch (Exception e) {}
        }
    }
    final ServerSocket serverSocket;
}
class Data implements Serializable {
    int[] data = { 1, 2, 3 };
}
class Connect extends Thread {
    public Connect(Socket clientSocket) {
        client = clientSocket;
        try {
            ois = new ObjectInputStream(client.getInputStream());
            oos = new ObjectOutputStream(client.getOutputStream());
        } catch (Exception e1) {
            try {
                client.close();
            } catch (Exception e) {
                System.out.println(e.getMessage());
            }
            return;
        }
    }
    public void run() {
        try {
            oos.writeObject(new Data());
            oos.flush();
            ois.close();
            oos.close();
            client.close();
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
        System.out.println("done");
    }
    final Socket client;
    ObjectInputStream ois;
    ObjectOutputStream oos;
}
class Client {
    Client(int port) {
        this.port = port;
    }
    void connectAndRead() {
        ObjectOutputStream oos = null;
        ObjectInputStream ois = null;
        Socket socket = null;
        Data data = null;
        try {
            socket = new Socket("127.0.0.1", port);
            oos = new ObjectOutputStream(socket.getOutputStream());
            ois = new ObjectInputStream(socket.getInputStream());
            data = (Data) ois.readObject();
            oos.close();
            ois.close();
            for (int d : data.data)
                System.out.println(d);
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }
    final int port;
}
public class Main {
    public static void main(String[] arguments) throws IOException, InterruptedException {
        Server server = new Server();
        server.start();
        Client client = new Client(server.serverSocket.getLocalPort());
        client.connectAndRead();
    }
}