使用Bloom Filter高效管理遊戲活動推送

import redis.clients.jedis.*;
import redis.clients.jedis.UnifiedJedis;


public class TairBloomFilterDemo {
    static HostAndPort hostAndPort = new HostAndPort("r-bp1y****svonly41srpd.redis.rds.aliyuncs.com", 6379);  // 您可以在控制台擷取執行個體串連地址與連接埠號碼。
    static JedisClientConfig config = DefaultJedisClientConfig.builder().password("tw:Da***3").build(); // 執行個體帳號密碼。
    static UnifiedJedis unifiedJedis = new UnifiedJedis(hostAndPort, config);
    private static final String BLOOM_KEY = "activity_popup";

    /**
    * 建立一個Bloom Filter Key。
    */
    public static void createBloom() {
        try {
            unifiedJedis.bfReserve(BLOOM_KEY, 0.01, 50000);
        } catch (Exception e) {
            e.printStackTrace(); // 逾時等異常情況
        }
    }

    /**
    * 查詢Bloom Filter中是否已經存在指定的玩家ID。
    */
    public static boolean shouldShowPopup(String playerId) {
        try {
            return !unifiedJedis.bfExists(BLOOM_KEY, playerId);
        } catch (Exception e) {
            e.printStackTrace(); // 逾時等異常情況
            return true;
        }
    }

    /**
    * 將玩家ID添加到Bloom Filter Key中。
    */
    public static void updatePopupState(String playerId) {
        try {
            unifiedJedis.bfAdd(BLOOM_KEY, playerId);
        } catch (Exception e) {
            e.printStackTrace(); // 逾時等異常情況。
        }
    }

    /**
    * 向指定玩家ID進行推送。
    */
    public static void handlePopup(String playerId) {
        if (shouldShowPopup(playerId)) {
            // 進行推送。
            System.out.println("推送給玩家: " + playerId);
            // 更新推送狀態。
            updatePopupState(playerId);
        } else {
            System.out.println("玩家 " + playerId + " 已推送過");
        }
    }

    public static void main(String[] args) {
        createBloom();
        // 假設玩家ID為player123。
        String playerId = "player123";

        // 第一次調用時，應該推送。
        handlePopup(playerId);

        // 第二次調用時，不應該再推送。
        handlePopup(playerId);
    }
}

推送給玩家: player123
玩家 player123 已推送過