0

シンプルなピアツーピアゲームを作成しています。現在、サーバー/クライアント (ノード) 側で作業しています。奇妙な問題が発生しました。ObjectOutputStreamソケットから作成できますが、プログラムはの作成で停止ObjectInputStreamします。ソケットを保存してストリームを作成するには、独自のクラスを使用しています (以下のコード)。私が間違っていることは何ですか？

public void run() {
    try {
        while (this.listen) {

            temp = serverSocket.accept();
            sockList.addSocket(temp);
            sockList.addObjOutStrm(temp);
            sockList.addObjInStrm(temp); // <------------------------ program stops


            setChanged();
            notifyObservers(temp);

            System.out.println("SERVER: Dodalem uzytkownika, oto pelna lista:\n\n"
                            + sockList + "\n");

            synchronized (sockList) {
                for (ObjectOutputStream oos : sockList.getOOSList()) {
                    oos.writeObject(sockList.extractToString());
                }
            }
        }
    } catch (IOException e) {
        System.err.println("SERVER: Błąd I/O serwera podczas nasluchu");
        //e.printStackTrace();
    }
}

ソケットとストリームを格納する独自のクラス:

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

public class SocketList {
    private List<ObjectOutputStream> obOutStrList;
    private List<ObjectInputStream> obInStrList;
    private List<Socket> sockList;

    private int maxUsers;
    private int currentUsers;

    public SocketList() {
        obOutStrList = Collections
                .synchronizedList(new ArrayList<ObjectOutputStream>());
        obInStrList = Collections
                .synchronizedList(new ArrayList<ObjectInputStream>());
        sockList = Collections.synchronizedList(new ArrayList<Socket>());

        maxUsers = 4;
        currentUsers = 0;
    }

    synchronized public void addSocket(Socket sock) {
        if (sockList.size() < 4) {
            sockList.add(sock);
            currentUsers++;
        } else {
            System.out.println("sockList: Blad max uzytkownikow");
        }
    }

    synchronized public void addObjOutStrm(Socket sock) {
        try {
            obOutStrList.add(new ObjectOutputStream(sock.getOutputStream()));
        } catch (IOException e) {
            System.out.println("Problem z uzyskaniem strumienia wyjsciowego dla " + sock.getInetAddress().getHostAddress().toString());
            e.printStackTrace();
        }
    }

    synchronized public void addObjInStrm(Socket sock) {
        try {
            obInStrList.add(new ObjectInputStream(sock.getInputStream()));
        } catch (IOException e) {
            System.out.println("Problem z uzyskaniem strumienia wejsciowego dla " + sock.getInetAddress().getHostAddress().toString());
            e.printStackTrace();
        }
    }

    synchronized public void removeSock(Socket s) {
        if (sockList.contains(s)) {
            System.out.println("SOCKETLIST: Usuwam " + s.toString());
            sockList.remove((Socket) s);
        }
    }

    synchronized public List<Socket> getSockList() {
        return sockList;
    }

    synchronized public List<ObjectOutputStream> getOOSList() {
        return obOutStrList;
    }

    synchronized public List<ObjectInputStream> getOISList() {
        return obInStrList;
    }

    public String toString() {
        return sockList.toString();
    }

    public String[] extractToString() {
        String[] retArr = new String[currentUsers];

        for (int i = 0; i < sockList.size(); i++)
            retArr[i] = sockList.get(i).getInetAddress().getHostAddress()
                    .toString();

        return retArr;
    }

}
4

1 に答える 1

1

これを実行しますか? オブジェクトの読み取りと書き込みはあまり移植性がありません。通信には XML や JSON などのデータ構造を持つある種のプロトコルを使用してください。これははるかにポータブルです。
あなたの問題に：

new ObjectInputStream(sock.getInputStream())

JavaDoc に記載されているように、ヘッダーがストリームに書き込まれるまでブロックして待機します。

このコンストラクターは、対応する ObjectOutputStream がヘッダーを書き込んでフラッシュするまでブロックします。

全体として、別のアーキテクチャを強くお勧めします。マルチスレッドを使用してサーバー上のクライアント接続を処理し、場合によってはスレッド プールやメッセージ キューを使用することもできます。java.util.concurrentこれに必要なものはすべてパッケージを参照 してください。

まず、こちらをご覧ください: http://tutorials.jenkov.com/java-multithreaded-servers/multithreaded-server.html

于 2012-11-09T14:35:24.703 に答える