Tair (Redis® OSS-Compatible):Uso de filtros Bloom para gestionar notificaciones push de eventos de juego

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

public class TairBloomFilterDemo {
    // Replace with your instance endpoint, port number, and password.
    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";

    /**
     * Creates the Bloom filter with a 1% false positive rate and capacity for 50,000 player IDs.
     */
    public static void createBloom() {
        try {
            unifiedJedis.bfReserve(BLOOM_KEY, 0.01, 50000);
        } catch (Exception e) {
            e.printStackTrace(); // Handle connection timeouts and other errors.
        }
    }

    /**
     * Returns true if the player has not yet received the notification.
     */
    public static boolean shouldShowPopup(String playerId) {
        try {
            return !unifiedJedis.bfExists(BLOOM_KEY, playerId);
        } catch (Exception e) {
            e.printStackTrace(); // Handle connection timeouts and other errors.
            return true;
        }
    }

    /**
     * Records that the player has received the notification.
     */
    public static void updatePopupState(String playerId) {
        try {
            unifiedJedis.bfAdd(BLOOM_KEY, playerId);
        } catch (Exception e) {
            e.printStackTrace(); // Handle connection timeouts and other errors.
        }
    }

    /**
     * Sends a notification to the player if they haven't received one yet.
     */
    public static void handlePopup(String playerId) {
        if (shouldShowPopup(playerId)) {
            System.out.println("Push a notification to the player: " + playerId);
            updatePopupState(playerId);
        } else {
            System.out.println("Player " + playerId + " has already been notified.");
        }
    }

    public static void main(String[] args) {
        createBloom();
        String playerId = "player123";

        handlePopup(playerId); // Sends the notification on first login.
        handlePopup(playerId); // Skips the notification on subsequent logins.
    }
}

Push a notification to the player: player123
Player player123 has already been notified.