GeyserMC-Mirror/Geyser
1
0
Fork 0
mirror of https://github.com/GeyserMC/Geyser.git synced 2025-12-21 07:49:32 +00:00
Code Issues Releases Activity

Introduce limit for the maximum number of connected clients per address

Browse Source
This commit is contained in:
onebeastchris
2025-07-30 01:32:29 +02:00
parent 4746651aea
commit b3424a13a4
2 changed files with 30 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
core/src/main/java/org/geysermc/geyser/network/UpstreamPacketHandler.java
View File

@@ -89,6 +89,7 @@ import java.util.concurrent.TimeUnit;
public class UpstreamPacketHandler extends LoggingPacketHandler {
private boolean networkSettingsRequested = false;
private boolean receivedLoginPacket = false;
private final Deque<String> packsToSend = new ArrayDeque<>();
private final CompressionStrategy compressionStrategy;
@@ -188,11 +189,23 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
return PacketSignal.HANDLED;
}
if (receivedLoginPacket) {
GeyserImpl.getInstance().getLogger().warning("Received duplicate login packet from " + session.name());
session.disconnect("Received duplicate login packet!");
return PacketSignal.HANDLED;
}
receivedLoginPacket = true;
if (!networkSettingsRequested) {
session.disconnect(GeyserLocale.getLocaleStringLog("geyser.network.outdated.client", GameProtocol.getAllSupportedBedrockVersions()));
return PacketSignal.HANDLED;
}
if (!geyser.getSessionManager().addPendingSession(session)) {
session.disconnect("Too many connections are originating from this location!");
return PacketSignal.HANDLED;
}
// Set the block translation based off of version
session.setBlockMappings(BlockRegistries.BLOCKS.forVersion(loginPacket.getProtocolVersion()));
session.setItemMappings(Registries.ITEMS.forVersion(loginPacket.getProtocolVersion()));
@@ -204,6 +217,11 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
return PacketSignal.HANDLED;
}
if (GeyserImpl.getInstance().connectionByXuid(session.xuid()) != null) {
session.disconnect(GeyserLocale.getLocaleStringLog("geyser.auth.already_loggedin", session.name()));
return PacketSignal.HANDLED;
}
// Fire SessionInitializeEvent here as we now know the client data
geyser.eventBus().fire(new SessionInitializeEvent(session));
@@ -211,8 +229,6 @@ public class UpstreamPacketHandler extends LoggingPacketHandler {
playStatus.setStatus(PlayStatusPacket.Status.LOGIN_SUCCESS);
session.sendUpstreamPacket(playStatus);
geyser.getSessionManager().addPendingSession(session);
this.resourcePackLoadEvent = new SessionLoadResourcePacksEventImpl(session);
this.geyser.eventBus().fire(this.resourcePackLoadEvent);

13
core/src/main/java/org/geysermc/geyser/session/SessionManager.java
View File

@@ -61,10 +61,19 @@ public final class SessionManager {
@Getter(AccessLevel.PACKAGE)
private final Map<InetAddress, AtomicInteger> connectedClients = new ConcurrentHashMap<>();
/**
* Specifies the maximum amount of connections per address
*/
private final static int MAX_CONNECTIONS_PER_ADDRESS = Integer.getInteger("Geyser.MaxConnectionsPerAddress", 10);
/**
* Called once the player has successfully authenticated to the Geyser server.
*/
public void addPendingSession(GeyserSession session) {
public boolean addPendingSession(GeyserSession session) {
if (getAddressMultiplier(session.getSocketAddress().getAddress()) > MAX_CONNECTIONS_PER_ADDRESS) {
return false;
}
pendingSessions.add(session);
connectedClients.compute(session.getSocketAddress().getAddress(), (key, count) -> {
if (count == null) {
@@ -74,6 +83,8 @@ public final class SessionManager {
count.incrementAndGet();
return count;
});
return true;
}
/**