在 Android 编程中使用套接字和对象 IO 流答案

【问题标题】：Using sockets and Object IO streams in Android programming在 Android 编程中使用套接字和对象 IO 流
【发布时间】：2012-05-14 21:00:29
【问题描述】：

我正在尝试在我一直在编写的游戏中实现多人游戏，并且我已经成功连接（我认为..），但是当我运行它时，客户端抛出了 EOFException , 并且对象（一个 ArrayList）没有被成功接收到。

服务器线程代码：

    class ServerThread implements Runnable
{
    ServerSocket server = null;
    Socket controlSocket = null;
    ObjectOutputStream outStream = null;
    ObjectInputStream inStream = null;
    @Override
    public void run() {
        setupConnection();
        while(true){
            sendObject(out.getStuff());     
        }


    }
    void setupConnection(){
        Log.e("OUTPUTSHOOTER","init-connect");
        try {
            server = new ServerSocket(SERVERPORT);
            Log.e("OUTPUTSHOOTER","server initiated port: "+SERVERPORT);
        controlSocket = server.accept();
        Log.e("OUTPUTSHOOTER","connected");
        inStream =  new ObjectInputStream(controlSocket.getInputStream());
        outStream = new ObjectOutputStream(controlSocket.getOutputStream());
        } catch (StreamCorruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        Log.e("OUTPUTSHOOTER",server+" "+controlSocket+" "+inStream+" "+outStream);
        }

    public Object recieveObject(){
        Object o = null;
        try {
            o = inStream.readObject();
        } catch (OptionalDataException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return o;
    }
    public void sendObject(Object o)
    {
            try {
                outStream.writeObject(o);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

    }
}

然后是客户端的代码：

    class ClientThread implements Runnable
{
    Socket controlSocket = null;
    ObjectOutputStream outStream = null;
    ObjectInputStream inStream = null;
    @Override
    public void run() {
        setupConnection();
        while(true){
            Log.e("OUTPUTSHOOTER","recieving");
            Object in = recieveObject();
            if(in!= null && in instanceof ArrayList)
            {
                Log.e("OUTPUTSHOOTER","loading");
                out.load((ArrayList<UniverseObject>)in);
            }       
        }


    }

    void setupConnection(){
        Log.e("OUTPUTSHOOTER","ip: "+SERVERIP);
        while(controlSocket == null) {
            try {
                controlSocket = new Socket(SERVERIP,SERVERPORT);
                Log.e("OUTPUTSHOOTER","socket connected");
            } catch (IOException e) {
                e.printStackTrace();
            }

        }
        try {
            Log.e("OUTPUTSHOOTER","attempting streams");
            outStream = new ObjectOutputStream(controlSocket.getOutputStream());
            Log.e("OUTPUTSHOOTER","output working");
            inStream =  new ObjectInputStream(controlSocket.getInputStream());
            Log.e("OUTPUTSHOOTER","streams connected");

        } catch (StreamCorruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
    }
    }
    public Object recieveObject(){
        Object o = null;
        try {
            o = inStream.readObject();
        } catch (OptionalDataException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return o;
    }
    public void sendObject(Object o)
    {
            try {
                outStream.writeObject(o);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

    }
}

这是什么意思？也许更重要的是，我该如何解决？提前谢谢..

【问题讨论】：

您是否正在尝试通过网络接口（wi-fi/mobile）发送序列化对象？在 Android 设备之间还是从服务器到 Android 设备？
我正在尝试通过 wifi 在两个 Android 设备之间发送一个 ArrayList。 IP 地址和套接字是正确的，因为连接本身是成功的，而不是数据传输。

标签： java android sockets

【解决方案1】：

我没有看到你关闭你的输出流。

查看这个 SO 主题：Problem serializing and deserializing ArrayList

【讨论】：

没错，但他获得EOFException 的唯一方法是，如果他正在关闭某些东西，无论是流之一还是套接字。

【解决方案2】：

事实证明服务器没有正确启动它的输入和输出流，即使它的套接字是成功的。不知道为什么，但只有当我先从输出流开始，然后是输入（？）时它才有效。还有一些其他非常奇怪的错误，但至少沟通似乎有效.. 在发布到这里之前，我会更多地研究它们。谢谢大家！

【讨论】：