Надежная реализация протокола UDP в Java - Почему это происходит? - PullRequest
Новая
       24

Надежная реализация протокола UDP в Java - Почему это происходит?

6 голосов
/ 07 декабря 2011

В настоящее время я использую Java-реализацию протокола Reliable UDP, который можно найти здесь .В проекте нет абсолютно никаких учебных пособий, поэтому мне было очень трудно определить проблемы.

Я настроил клиент и сервер.Сервер работает на локальном хосте: 1234, а клиент - на локальном хосте: 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, который выполняет процедуру отладки печати «Packet Received!».

Мой клиент подключается к серверу следующим образом - 

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 пакетов происходит сбой.Я исследовал код, и оказалось, что это связано с тем, что пакеты не удаляются из очереди приема, как, например, когда я изменил переменную _recvQueueSize в ReliableSocket.java:1815 с 32 на 40, я мог быТеперь отправьте 40 пакетов без ошибок.

Может ли кто-нибудь помочь мне определить эту проблему?Я искал код весь день.

1 Ответ

4 голосов
/ 07 декабря 2011

Мне удалось решить проблему.

Видите ли, поскольку это реализация RUDP, она расширяет большинство классов Socket.В частности, ReliableSocket.getInputStream () был специально закодирован для управляемого потока ввода.Моя проблема была в том, что я получал пакеты, но не читал из буфера.

Когда вы получаете пакет, который вы должны прочитать из буфера, в противном случае пакет не будет удален из очереди.

Так что все, что мне нужно было сделать, это каждый раз, когда я получал пакет, читал размер пакета и продолжал.

...