<dependencies>  
    <dependency>  
        <groupId>redis.clients</groupId>  
        <artifactId>jedis</artifactId>  
        <version>3.7.0</version> <!-- 使用你需要的版本 -->  
    </dependency>  
</dependencies>

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Tuple;
import java.util.Set;
import java.util.HashSet;
import java.util.List;
import java.util.ArrayList;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
public class HotSearch {
    private static final String REDIS_HOST = "localhost";
    private static final int REDIS_PORT = 6379;
    private static final String HISTORY_SET = "history";
    private static final String ZSET_PREFIX = "zset:";
    private static final int TOP_TEN = 10;
    private static final String BAD_WORDS = "bad"; // 替換為需要過濾的關(guān)鍵詞  
    private static final String FILTERED_WORD = "***"; // 替換為過濾后的關(guān)鍵詞  
    private static final int BAD_WORD_THRESHOLD = 100; // 替換為過濾的閾值，超過則認為是不雅文字  
    private static final List<String> BAD_WORD_LIST = IntStream.range(0, BAD_WORDS.length()).mapToObj(i -> BAD_WORDS.substring(i, i + 1)).collect(Collectors.toList()); // 將BAD_WORDS轉(zhuǎn)為List，方便后續(xù)操作  
    public static void main(String[] args) {
        Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT);
        String userId = "user1"; // 當(dāng)前登陸的個人用戶ID，需要根據(jù)實際情況獲取  
        String searchWord = "test"; // 需要搜索的字符  
        hotSearch(jedis, userId, searchWord);
    }
    public static void hotSearch(Jedis jedis, String userId, String searchWord) {
        // 獲取當(dāng)前用戶的搜索歷史記錄  
        Set<String> history = jedis.smembers(HISTORY_SET + ":" + userId);
        if (history == null) history = new HashSet<>();
        history.add(searchWord); // 將新搜索詞加入歷史記錄  
        jedis.sadd(HISTORY_SET + ":" + userId, history); // 將歷史記錄存入redis中  
        history.remove(searchWord); // 去掉新搜索詞，只保留舊的歷史記錄  
        // 將搜索詞加入zset中，記錄該字符被搜索的個數(shù)以及當(dāng)前的時間戳   
        jedis.zadd(ZSET_PREFIX + userId, getScore(searchWord), searchWord);
        System.out.println("Added " + searchWord + " to hot search with score " + getScore(searchWord));
        // 過濾不雅文字，如果是不雅文字則替換為***，并累加不雅文字的搜索次數(shù)  
        if (BAD_WORD_LIST.contains(searchWord)) {
            if (jedis.zscore(ZSET_PREFIX + userId, FILTERED_WORD) == null) { // 如果該詞在zset中不存在，則加入并設(shè)置得分  
                jedis.zadd(ZSET_PREFIX + userId, BAD_WORD_THRESHOLD, FILTERED_WORD); // 設(shè)置得分為BAD_WORD_THRESHOLD，表示這是一個不雅文字  
                jedis.incrBy(HISTORY_SET + ":bad", 1); // 累加不雅文字的搜索次數(shù)，存儲在bad歷史的集合中，方便后續(xù)統(tǒng)計和過濾處理  
            } else { // 如果該詞在zset中已存在，則只累加搜索次數(shù)，并更新得分（得分+1）  
                jedis.zincrby(ZSET_PREFIX + userId, 1, FILTERED_WORD); // 得分為當(dāng)前得分+1，表示這是一個不雅文字的再次搜索  
                jedis.incrBy(HISTORY_SET + ":bad", 1); // 累加不雅文字的搜索次數(shù)，存儲在bad歷史的集合中，方便后續(xù)統(tǒng)計和過濾處理  
            }
            System.out.println("The word " + searchWord + " is filtered and replaced with " + FILTERED_WORD); // 輸出過濾后的結(jié)果  
        } else { // 如果不是不雅文字，則正常加入熱搜列表并設(shè)置得分  
            jedis.zadd(ZSET_PREFIX + userId, getScore(searchWord), searchWord); // 正常加入熱搜列表并設(shè)置得分  
            System.out.println("Added normal word " + searchWord + " to hot search with score " + getScore(searchWord)); // 輸出正常加入熱搜列表的結(jié)果
        }
        // 獲取平臺上最熱搜索的十條數(shù)據(jù)  
        Set<Tuple> hotData = jedis.zrevrangeWithScores(ZSET_PREFIX + userId, 0, TOP_TEN - 1);
        List<String> hotWords = hotData.stream().map(Tuple::getElement).collect(Collectors.toList());
        List<Integer> hotScores = hotData.stream().map(Tuple::getScore).collect(Collectors.toList());
        System.out.println("Top " + TOP_TEN + " hot searches are: " + hotWords + " with scores: " + hotScores);
    }
    // 用于計算得分的方法，這里采用了最簡單的得分方式，只考慮了搜索頻率和時間戳，實際情況可能需要更復(fù)雜的算法 
    private static int getScore(String word) {
        return 1;
    }
}