6

私は現在、ここにあるReliableUDPプロトコルのJava実装を使用しています。プロジェクトにはチュートリアルがまったくないので、問題を特定するのは非常に難しいことがわかりました。

クライアントとサーバーをセットアップしました。サーバーはlocalhost：1234で実行され、クライアントはlocalhost：1235で実行されます。サーバーが最初に確立され、接続をリッスンしてループします-

try {
            ReliableSocket clientSocket = server.socket.accept();
            InetSocketAddress clientAddress = (InetSocketAddress) clientSocket.getRemoteSocketAddress();

            Logger.getLogger("ServerConnectionListener").info("New Connection from "+
                    clientAddress.getHostName()+":"+clientAddress.getPort()+" Processing...");
            LessurConnectedClient client = new LessurConnectedClient(clientSocket);
            ClientCommunicationSocketListener listener = new ClientCommunicationSocketListener(this, client);
            clientSocket.addListener(listener);
        } catch (Exception e) {
            e.printStackTrace();
        }

接続が確立されると、そのソケットでイベントのリスナーが作成されます-

class ClientCommunicationSocketListener implements ReliableSocketListener {
    ServerConnectionListener connectionListener;
    LessurConnectedClient client;

    public ClientCommunicationSocketListener(ServerConnectionListener connectionListener, LessurConnectedClient client){
        this.connectionListener = connectionListener;
        this.client = client;
    }

    @Override
    public void packetReceivedInOrder() {
        connectionListener.server.handlePacket(client);
    }

    @Override
    public void packetReceivedOutOfOrder() {
        connectionListener.server.handlePacket(client);
    }
}

パケットが受信されると、server.handlePacketに渡されます。server.handlePacketは、「PacketReceived！」を出力するデバッグルーチンを実行します。

私のクライアントはそのようにサーバーに接続します-

LessurClient client = new LessurClient();
        InetSocketAddress a = (InetSocketAddress) server.getSocket().getLocalSocketAddress();
        Logger.getLogger("client-connector").info("Trying to connect to server "+
                a.getAddress().toString()+":"+
                a.getPort());
        client.connect(a.getAddress(), a.getPort());
// LessurClient.connect
    public void connect(InetAddress address, int port){
            try {
                socket = new ReliableSocket(address, port, InetAddress.getLocalHost(), 1235);
                isConnected = true;
                Logger.getLogger("LessurClient").info("Connected to server "+address.getHostAddress()+":"+port);
            } catch (IOException e) {
                e.printStackTrace();
            }

        }

コードをリンクしたので、キー「Z」を押すと、サーバーにパケットが送信されます-

public void sendPacket(GamePacket packet){
        if(!isConnected){
            Logger.getLogger("LessurClient").severe("Can't send packet. Client is not connected to any server.");
            return;
        }
        try {
            OutputStream o = socket.getOutputStream();
            o.write(packet.getData());
            o.flush();
            Logger.getLogger("LessurClient").info("Sending Packet with data \""+packet.getData()+"\" to server "+socket.getInetAddress().toString()+":"+socket.getPort());
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

私の問題は、32パケットを送信した後、サーバーがパケットを受信しなくなり、64パケットを送信した後、サーバーがクラッシュすることです。コードを調べたところ、ReliableSocket.java：1815の_recvQueueSize変数を32から40に変更したときに、何もせずに40パケットを送信できるようになったため、受信キューからパケットが削除されていないことに関連しているようです。うまくいかない。

誰かが私がこの問題を特定するのを手伝ってもらえますか？私は一日中コードを見てきました。

4

1 に答える 1

4

私はなんとか問題を解決することができました。

ご覧のとおり、これはRUDPの実装であるため、ほとんどのSocketクラスを拡張します。具体的には、ReliableSocket.getInputStream（）は、マネージド入力ストリームにカスタムコーディングされました。私の問題は、パケットを受信して​​いましたが、バッファから読み取っていなかったことです。

バッファから読み取ることになっているパケットを受信すると、それ以外の場合、パケットはキューからドロップされません。

ですから、私がしなければならなかったのは、パケットを受信するたびに、パケットのサイズを読み取って続行することだけでした。

于 2011-12-07T07:59:05.840 に答える