В настоящее время я использую Java-реализацию протокола Reliable UDP, найденную здесь. Проект не имеет абсолютно никаких руководств, поэтому мне было очень трудно выявить проблемы.
Я установил клиента и сервер. Сервер работает на 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, который выполняет отладочную процедуру печати "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 пакетов без того, чтобы что-то пошло не так.
Может ли кто-нибудь помочь мне определить эту проблему? Я весь день смотрю на код.