PlayerFinder: Force cached all offline players when its amount > 2k

Author: sandtechnology

src/main/java/org/maxgamer/quickshop/QuickShop.java

@@ -1144,6 +1144,11 @@ public void run() {
         if (getConfig().getBoolean("purge.at-server-startup")) {
             shopPurger.purge();
         }
+        //Detect and do offline player name to uuid caching
+        OfflinePlayer[] offlinePlayers = getServer().getOfflinePlayers();
+        if (offlinePlayers.length > 2000) {
+            getServer().getScheduler().runTaskAsynchronously(this, () -> PlayerFinder.doLargeOfflineCachingWork(this, offlinePlayers));
+        }
         Util.debugLog("Now using display-type: " + AbstractDisplayItem.getNowUsing().name());
         getLogger().info("QuickShop Loaded! " + enableTimer.stopAndGetTimePassed() + " ms.");
     }

src/main/java/org/maxgamer/quickshop/listener/PlayerListener.java

@@ -55,6 +55,7 @@
 import org.maxgamer.quickshop.util.InteractUtil;
 import org.maxgamer.quickshop.util.MsgUtil;
 import org.maxgamer.quickshop.util.PermissionChecker;
+import org.maxgamer.quickshop.util.PlayerFinder;
 import org.maxgamer.quickshop.util.Util;
 import org.maxgamer.quickshop.util.reload.ReloadResult;
 import org.maxgamer.quickshop.util.reload.ReloadStatus;
@@ -389,6 +390,7 @@ public void onInventoryClose(InventoryCloseEvent e) {
     @EventHandler(ignoreCancelled = true, priority = EventPriority.MONITOR)
     public void onJoin(PlayerJoinEvent e) {
         Util.debugLog("Player " + e.getPlayer().getName() + " using locale " + e.getPlayer().getLocale() + ": " + plugin.text().of(e.getPlayer(), "file-test").forLocale());
+        PlayerFinder.updateStashIfNeeded(e.getPlayer());
         // Notify the player any messages they were sent
         if (plugin.getConfig().getBoolean("shop.auto-fetch-shop-messages")) {
             //Run Task later to make sure locale is correct

src/main/java/org/maxgamer/quickshop/util/PlayerFinder.java

@@ -24,12 +24,17 @@
 import org.bukkit.Bukkit;
 import org.bukkit.OfflinePlayer;
 import org.bukkit.Server;
+import org.bukkit.entity.Player;
 import org.jetbrains.annotations.Nullable;
+import org.maxgamer.quickshop.QuickShop;
 
 import java.util.Arrays;
 import java.util.Locale;
+import java.util.Map;
+import java.util.Set;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
 
 /**
  * A player finder for finding player by name
@@ -39,8 +44,12 @@
  */
 public final class PlayerFinder {
 
+    //Hold store for large server
+    private static final Map<String, UUID> string2UUIDStash = new java.util.concurrent.ConcurrentHashMap<>();
     private static final Cache<String, UUID> string2UUIDCache = CacheBuilder.newBuilder().expireAfterAccess(60, TimeUnit.MINUTES).build();
 
+    private static volatile boolean isStashNeeded;
+
     private PlayerFinder() {
     }
 
@@ -49,37 +58,54 @@ public static UUID findUUIDByName(String name) {
     }
 
     @Nullable
-    private static OfflinePlayer findPlayerByName(String name, java.util.Collection<? extends org.bukkit.OfflinePlayer> players) {
-        //Cache all players when offline player is too many
-        boolean cacheAllPlayers = players.size() > 5000;
-        OfflinePlayer result = null;
+    private static OfflinePlayer findPlayerByName(String name, java.util.Collection<? extends org.bukkit.OfflinePlayer> players, boolean isOfflinePlayer) {
         for (OfflinePlayer player : players) {
             String playerName = player.getName();
             if (playerName != null) {
                 if (playerName.equalsIgnoreCase(name)) {
-                    result = player;
-                    if (!cacheAllPlayers) {
-                        return result;
-                    }
-                }
-                if (cacheAllPlayers) {
-                    string2UUIDCache.put(playerName.toLowerCase(Locale.ROOT), player.getUniqueId());
+                    return player;
                 }
             }
         }
-        return result;
+        return null;
+    }
+
+    public static Set<String> getCachedOfflinePlayerNames() {
+        return string2UUIDStash.keySet();
+    }
+
+    public static void updateStashIfNeeded(Player player) {
+        if (isStashNeeded) {
+            string2UUIDStash.put(player.getName().toLowerCase(Locale.ROOT), player.getUniqueId());
+        }
+    }
+
+    public static void doLargeOfflineCachingWork(QuickShop quickShop, OfflinePlayer[] offlinePlayers) {
+        quickShop.getLogger().log(Level.INFO, "Large server detected (offline player > 2000), start offline player caching...");
+        isStashNeeded = true;
+        for (OfflinePlayer offlinePlayer : quickShop.getServer().getOfflinePlayers()) {
+            string2UUIDStash.put(offlinePlayer.getName(), offlinePlayer.getUniqueId());
+        }
+        quickShop.getLogger().log(Level.INFO, "Done! cached " + offlinePlayers.length + " players.");
     }
 
     public static OfflinePlayer findOfflinePlayerByName(String name) {
         OfflinePlayer result;
-        UUID uuid = string2UUIDCache.getIfPresent(name.toLowerCase(Locale.ROOT));
+        UUID uuid;
+
+        uuid = string2UUIDCache.getIfPresent(name.toLowerCase(Locale.ROOT));
+
+        if (uuid == null && !string2UUIDStash.isEmpty()) {
+            uuid = string2UUIDStash.get(name.toLowerCase(Locale.ROOT));
+        }
+
         if (uuid != null) {
             return Bukkit.getOfflinePlayer(uuid);
         } else {
             Server server = Bukkit.getServer();
-            result = findPlayerByName(name, server.getOnlinePlayers());
+            result = findPlayerByName(name, server.getOnlinePlayers(), false);
             if (result == null) {
-                result = findPlayerByName(name, Arrays.asList(server.getOfflinePlayers()));
+                result = findPlayerByName(name, Arrays.asList(server.getOfflinePlayers()), true);
             }
             if (result == null) {
                 result = Bukkit.getServer().getOfflinePlayer(name);

src/main/java/org/maxgamer/quickshop/util/Util.java

@@ -1429,7 +1429,12 @@ public static File getCacheFolder() {
     public static List<String> getPlayerList() {
         List<String> tabList = plugin.getServer().getOnlinePlayers().stream().map(Player::getName).collect(Collectors.toList());
         if (plugin.getConfig().getBoolean("include-offlineplayer-list")) {
-            tabList.addAll(Arrays.stream(plugin.getServer().getOfflinePlayers()).map(OfflinePlayer::getName).filter(Objects::nonNull).collect(Collectors.toList()));
+            Set<String> names = PlayerFinder.getCachedOfflinePlayerNames();
+            if (!names.isEmpty()) {
+                tabList.addAll(names);
+            } else {
+                tabList.addAll(Arrays.stream(plugin.getServer().getOfflinePlayers()).map(OfflinePlayer::getName).filter(Objects::nonNull).collect(Collectors.toList()));
+            }
         }
         return tabList;
     }