{"id":4242,"date":"2023-07-14T14:05:09","date_gmt":"2023-07-14T06:05:09","guid":{"rendered":"https:\/\/www.zeroheart.xyz\/wordpress\/?p=4242"},"modified":"2023-07-14T14:05:09","modified_gmt":"2023-07-14T06:05:09","slug":"redis%e5%8f%af%e4%bb%a5%e5%ae%9e%e7%8e%b0%e5%8a%9f%e8%83%bd%e6%80%bb%e7%bb%93","status":"publish","type":"post","link":"https:\/\/www.zeroheart.xyz\/wordpress\/?p=4242","title":{"rendered":"redis\u53ef\u4ee5\u5b9e\u73b0\u529f\u80fd\u603b\u7ed3"},"content":{"rendered":"\n

\u539f\u6587\uff1aRedis \u53ea\u4f1a\u7528\u7f13\u5b58\uff1f20\u79cd\u5999\u7528\u8ba9\u540c\u4e8b\u76f4\u547c\u725bX (qq.com)<\/a> \uff0c\u539f\u6587\u6392\u7248\u5f88\u597d\uff0c\u63a8\u8350\u770b\u539f\u6587<\/p>\n\n\n\n

\u4e0b\u9762\u6574\u7406\u4e8620\u79cd Redis \u7684\u5999\u7528\u573a\u666f\uff0c\u6bcf\u4e2a\u65b9\u6848\u90fd\u7528\u4e00\u4e2a\u5b9e\u9645\u7684\u4e1a\u52a1\u9700\u6c42\u5e76\u7ed3\u5408\u6570\u636e\u7ed3\u6784\u7684API\u6765\u8bb2\u89e3\uff0c\u5e0c\u671b\u5927\u5bb6\u80fd\u591f\u7406\u89e3\u5176\u5e95\u5c42\u7684\u5b9e\u73b0\u65b9\u5f0f\uff0c\u5b66\u4f1a\u4e3e\u4e00\u53cd\u4e09\uff0c\u5e76\u8fd0\u7528\u5230\u9879\u76ee\u7684\u65b9\u65b9\u9762\u9762\uff1a<\/p>\n\n\n\n

\n

\u672c\u6587\u7a0d\u5fae\u6709\u70b9\u70b9\u957f\uff0c\u5982\u679c\u65f6\u95f4\u4e0d\u591f\uff0c\u5efa\u8bae\u770b\u4e00\u4e0b\u76ee\u5f55\uff0c\u6536\u85cf\u8d77\u6765\uff0c\u7528\u7684\u65f6\u5019\u518d\u7ffb\u51fa\u6765\u770b\u770b\u3002<\/p>\n<\/blockquote>\n\n\n\n

\u6d4b\u8bd5\u6e90\u7801\uff1ahttps:\/\/github.com\/vehang\/ehang-spring-boot\/tree\/main\/spring-boot-011-redis<\/p>\n\n\n\n

1\u7f13\u5b58<\/h2>\n\n\n\n

\u672c\u6587\u5047\u5b9a\u4f60\u5df2\u7ecf\u4e86\u89e3\u8fc7Redis\uff0c\u5e76\u77e5\u6653Redis\u6700\u57fa\u7840\u7684\u4e00\u4e9b\u4f7f\u7528\uff0c\u5982\u679c\u4f60\u5bf9Redis\u7684\u57fa\u7840API\u8fd8\u4e0d\u4e86\u89e3\uff0c\u53ef\u4ee5\u5148\u770b\u4e00\u4e0b\u83dc\u9e1f\u6559\u7a0b\uff1ahttps:\/\/www.runoob.com\/redis\uff0c\u90a3\u4e48\u7f13\u5b58\u90e8\u5206\u53ca\u57fa\u7840API\u7684\u6f14\u793a\uff0c\u5c31\u4e0d\u8fc7\u591a\u6765\u8bb2\u89e3\u4e86\uff1b<\/p>\n\n\n\n

\u4f46\u662f\uff0c\u57fa\u672c\u7684\u6570\u636e\u7ed3\u6784\uff0c\u5728\u8fd9\u91cc\u518d\u5217\u4e3e\u4e00\u4e0b\uff0c\u65b9\u4fbf\u540e\u7eed\u65b9\u6848\u7684\u7406\u89e3\uff1a<\/p>\n\n\n\n

\u7ed3\u6784\u7c7b\u578b<\/th>\u7ed3\u6784\u5b58\u50a8\u7684\u503c<\/th>\u7ed3\u6784\u7684\u8bfb\u5199\u80fd\u529b<\/th><\/tr><\/thead>
String\u5b57\u7b26\u4e32<\/strong><\/td>\u53ef\u4ee5\u662f\u5b57\u7b26\u4e32\u3001\u6574\u6570\u6216\u6d6e\u70b9\u6570<\/td>\u5bf9\u6574\u4e2a\u5b57\u7b26\u4e32\u6216\u5b57\u7b26\u4e32\u7684\u4e00\u90e8\u5206\u8fdb\u884c\u64cd\u4f5c\uff1b\u5bf9\u6574\u6570\u6216\u6d6e\u70b9\u6570\u8fdb\u884c\u81ea\u589e\u6216\u81ea\u51cf\u64cd\u4f5c\uff1b<\/td><\/tr>
List\u5217\u8868<\/strong><\/td>\u4e00\u4e2a\u94fe\u8868\uff0c\u94fe\u8868\u4e0a\u7684\u6bcf\u4e2a\u8282\u70b9\u90fd\u5305\u542b\u4e00\u4e2a\u5b57\u7b26\u4e32<\/td>\u5bf9\u94fe\u8868\u7684\u4e24\u7aef\u8fdb\u884cpush\u548cpop\u64cd\u4f5c\uff0c\u8bfb\u53d6\u5355\u4e2a\u6216\u591a\u4e2a\u5143\u7d20\uff1b\u6839\u636e\u503c\u67e5\u627e\u6216\u5220\u9664\u5143\u7d20\uff1b<\/td><\/tr>
Set\u96c6\u5408<\/strong><\/td>\u5305\u542b\u5b57\u7b26\u4e32\u7684\u65e0\u5e8f\u96c6\u5408<\/td>\u5b57\u7b26\u4e32\u7684\u96c6\u5408\uff0c\u5305\u542b\u57fa\u7840\u7684\u65b9\u6cd5\u6709\uff1a\u770b\u662f\u5426\u5b58\u5728\u3001\u6dfb\u52a0\u3001\u83b7\u53d6\u3001\u5220\u9664\uff1b\u8fd8\u5305\u542b\u8ba1\u7b97\u4ea4\u96c6\u3001\u5e76\u96c6\u3001\u5dee\u96c6\u7b49<\/td><\/tr>
Hash\u6563\u5217<\/strong><\/td>\u5305\u542b\u952e\u503c\u5bf9\u7684\u65e0\u5e8f\u6563\u5217\u8868<\/td>\u5305\u542b\u65b9\u6cd5\u6709\uff1a\u6dfb\u52a0\u3001\u83b7\u53d6\u3001\u5220\u9664\u5355\u4e2a\u5143\u7d20<\/td><\/tr>
Zset\u6709\u5e8f\u96c6\u5408<\/strong><\/td>\u548c\u6563\u5217\u4e00\u6837\uff0c\u7528\u4e8e\u5b58\u50a8\u952e\u503c\u5bf9<\/td>\u5b57\u7b26\u4e32\u6210\u5458\u4e0e\u6d6e\u70b9\u6570\u5206\u6570\u4e4b\u95f4\u7684\u6709\u5e8f\u6620\u5c04\uff1b\u5143\u7d20\u7684\u6392\u5217\u987a\u5e8f\u7531\u5206\u6570\u7684\u5927\u5c0f\u51b3\u5b9a\uff1b\u5305\u542b\u65b9\u6cd5\u6709\uff1a\u6dfb\u52a0\u3001\u83b7\u53d6\u3001\u5220\u9664\u5355\u4e2a\u5143\u7d20\u4ee5\u53ca\u6839\u636e\u5206\u503c\u8303\u56f4\u6216\u6210\u5458\u6765\u83b7\u53d6\u5143\u7d20<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n
    \n
  • \u4f9d\u8d56\u4ee5\u4e0b\u6240\u6709\u901a\u8fc7SpringBoot\u6d4b\u8bd5\u7684\u7528\u4f8b\uff0c\u90fd\u9700\u8981\u5f15\u5165 Redis \u7684\u4f9d\u8d56<dependency>
        <groupId>org.springframework.boot<\/groupId>
        <artifactId>spring-boot-starter-data-redis<\/artifactId>
    <\/dependency><\/code><\/li>\n<\/ul>\n\n\n\n

    2\u62bd\u5956<\/h2>\n\n\n\n

    \u66fe\u51e0\u4f55\u65f6\uff0c\u62bd\u5956\u662f\u4e92\u8054\u7f51APP\u70ed\u8877\u7684\u4e00\u79cd\u63a8\u5e7f\u3001\u62c9\u65b0\u7684\u65b9\u5f0f\uff0c\u8282\u5047\u65e5\u6ca1\u6709\u597d\u7684\u7b56\u5212\uff0c\u90a3\u5c31\u62bd\u4e2a\u5956\u5427\uff01\u4e00\u5806\u7528\u6237\u53c2\u4e0e\u8fdb\u6765\uff0c\u7136\u540e\u968f\u673a\u62bd\u53d6\u51e0\u4e2a\u5e78\u8fd0\u7528\u6237\u7ed9\u4e88\u5b9e\u7269\/\u865a\u62df\u7684\u5956\u54c1\uff1b\u6b64\u65f6\uff0c\u5f00\u53d1\u4eba\u5458\u5c31\u9700\u8981\u5199\u4e0a\u4e00\u4e2a\u62bd\u5956\u7684\u7b97\u6cd5\uff0c\u6765\u5b9e\u73b0\u5e78\u8fd0\u7528\u6237\u7684\u62bd\u53d6\uff1b\u5176\u5b9e\u6211\u4eec\u5b8c\u5168\u53ef\u4ee5\u5229\u7528Redis\u7684\u96c6\u5408\uff08Set\uff09\uff0c\u5c31\u80fd\u8f7b\u677e\u5b9e\u73b0\u62bd\u5956\u7684\u529f\u80fd\uff1b<\/p>\n\n\n\n

    \u529f\u80fd\u5b9e\u73b0\u9700\u8981\u7684API<\/p>\n\n\n\n

      \n
    • SADD<\/strong> key member1 [member2]\uff1a\u6dfb\u52a0\u4e00\u4e2a\u6216\u8005\u591a\u4e2a\u53c2\u4e0e\u7528\u6237\uff1b<\/li>\n\n\n\n
    • SRANDMEMBER<\/strong> KEY [count]\uff1a\u968f\u673a\u8fd4\u56de\u4e00\u4e2a\u6216\u8005\u591a\u4e2a\u7528\u6237\uff1b<\/li>\n\n\n\n
    • SPOP<\/strong> key\uff1a\u968f\u673a\u8fd4\u56de\u4e00\u4e2a\u6216\u8005\u591a\u4e2a\u7528\u6237\uff0c\u5e76\u5220\u9664\u8fd4\u56de\u7684\u7528\u6237\uff1b<\/li>\n<\/ul>\n\n\n\n

      SRANDMEMBER \u548c SPOP  \u4e3b\u8981\u7528\u4e8e\u4e24\u79cd\u4e0d\u540c\u7684\u62bd\u5956\u6a21\u5f0f\uff0cSRANDMEMBER \u9002\u7528\u4e8e\u4e00\u4e2a\u7528\u6237\u53ef\u4e2d\u5956\u591a\u6b21\u7684\u573a\u666f\uff08\u5c31\u662f\u4e2d\u5956\u4e4b\u540e\uff0c\u4e0d\u4ece\u7528\u6237\u6c60\u4e2d\u79fb\u9664\uff0c\u7ee7\u7eed\u53c2\u4e0e\u5176\u4ed6\u5956\u9879\u7684\u62bd\u53d6\uff09\uff1b\u800c SPOP \u5c31\u9002\u7528\u4e8e\u4ec5\u80fd\u4e2d\u4e00\u6b21\u7684\u573a\u666f\uff08\u4e00\u65e6\u4e2d\u5956\uff0c\u5c31\u5c06\u7528\u6237\u4ece\u7528\u6237\u6c60\u4e2d\u79fb\u9664\uff0c\u540e\u7eed\u7684\u62bd\u5956\uff0c\u5c31\u4e0d\u53ef\u80fd\u518d\u62bd\u5230\u8be5\u7528\u6237\uff09\uff1b \u901a\u5e38 SPOP \u4f1a\u7528\u7684\u4f1a\u6bd4\u8f83\u591a\u3002<\/p>\n\n\n\n

      Redis-cli \u64cd\u4f5c<\/h3>\n\n\n\n
      127.0.0.1:6379> SADD raffle user1
      (integer) 1
      127.0.0.1:6379> SADD raffle user2 user3 user4 user5 user6 user7 user8 user9 user10
      (integer) 9
      127.0.0.1:6379> SRANDMEMBER raffle 2
      1) \"user5\"
      2) \"user2\"
      127.0.0.1:6379> SPOP raffle 2
      1) \"user3\"
      2) \"user4\"
      127.0.0.1:6379> SPOP raffle 2
      1) \"user10\"
      2) \"user9\"<\/code><\/pre>\n\n\n\n
      SpringBoot \u5b9e\u73b0<\/h3>\n\n\n\n
      import lombok.extern.slf4j.Slf4j;
      import org.junit.jupiter.api.Test;
      import org.springframework.beans.factory.annotation.Autowired;
      import org.springframework.boot.test.context.SpringBootTest;
      import org.springframework.data.redis.core.RedisTemplate;

      import java.util.List;

      \/**
       * @author<\/strong> \u4e00\u884cJava
       * @title<\/strong>: RaffleMain
       * @projectName<\/strong> ehang-spring-boot
       * @description<\/strong>: TODO
       * @date<\/strong> 2022\/7\/18 15:17
       *\/
      @Slf4j
      @SpringBootTest
      public class RaffleMain {
          private final String KEY_RAFFLE_PROFIX = \"raffle:\";
          @Autowired
          RedisTemplate redisTemplate;

          @Test
          void test() {
              Integer raffleId = 1;
              join(raffleId, 1000, 1001, 2233, 7890, 44556, 74512);
              List lucky = lucky(raffleId, 2);
              log.info(\"\u6d3b\u52a8\uff1a{} \u7684\u5e78\u8fd0\u4e2d\u5956\u7528\u6237\u662f\uff1a{}\", raffleId, lucky);
          }

          public void join(Integer raffleId, Integer... userIds) {
              String key = KEY_RAFFLE_PROFIX + raffleId;
              redisTemplate.opsForSet().add(key, userIds);
          }

          public List lucky(Integer raffleId, long num) {
              String key = KEY_RAFFLE_PROFIX + raffleId;
              \/\/ \u968f\u673a\u62bd\u53d6 \u62bd\u5b8c\u4e4b\u540e\u5c06\u7528\u6237\u79fb\u9664\u5956\u6c60
              List list = redisTemplate.opsForSet().pop(key, num);
              \/\/ \u968f\u673a\u62bd\u53d6 \u62bd\u5b8c\u4e4b\u540e\u7528\u6237\u4fdd\u7559\u5728\u6c60\u5b50\u91cc
              \/\/List list = redisTemplate.opsForSet().randomMembers(key, num);
              return list;
          }

      }<\/code><\/pre>\n\n\n\n
      3Set\u5b9e\u73b0\u70b9\u8d5e\/\u6536\u85cf\u529f\u80fd<\/h2>\n\n\n\n
      \u6709\u4e92\u52a8\u5c5e\u6027APP\u4e00\u822c\u90fd\u4f1a\u6709\u70b9\u8d5e\/\u6536\u85cf\/\u559c\u6b22\u7b49\u529f\u80fd\uff0c\u6765\u63d0\u5347\u7528\u6237\u4e4b\u95f4\u7684\u4e92\u52a8\u3002<\/p>\n\n\n\n
      \u4f20\u7edf\u7684\u5b9e\u73b0<\/strong>\uff1a\u7528\u6237\u70b9\u8d5e\u4e4b\u540e\uff0c\u5728\u6570\u636e\u5e93\u4e2d\u8bb0\u5f55\u4e00\u6761\u6570\u636e\uff0c\u540c\u65f6\u4e00\u822c\u90fd\u4f1a\u5728\u4e3b\u9898\u5e93\u4e2d\u8bb0\u5f55\u4e00\u4e2a\u70b9\u8d5e\/\u6536\u85cf\u6c47\u603b\u6570\uff0c\u6765\u65b9\u4fbf\u663e\u793a\uff1b<\/p>\n\n\n\n
      Redis\u65b9\u6848<\/strong>\uff1a\u57fa\u4e8eRedis\u7684\u96c6\u5408\uff08Set\uff09\uff0c\u8bb0\u5f55\u6bcf\u4e2a\u5e16\u5b50\/\u6587\u7ae0\u5bf9\u5e94\u7684\u6536\u85cf\u3001\u70b9\u8d5e\u7684\u7528\u6237\u6570\u636e\uff0c\u540c\u65f6set\u8fd8\u63d0\u4f9b\u4e86\u68c0\u67e5\u96c6\u5408\u4e2d\u662f\u5426\u5b58\u5728\u6307\u5b9a\u7528\u6237\uff0c\u7528\u6237\u5feb\u901f\u5224\u65ad\u7528\u6237\u662f\u5426\u5df2\u7ecf\u70b9\u8d5e\u8fc7<\/p>\n\n\n\n
      \u529f\u80fd\u5b9e\u73b0\u9700\u8981\u7684API<\/p>\n\n\n\n
        \n
      • SADD<\/strong> key member1 [member2]\uff1a\u6dfb\u52a0\u4e00\u4e2a\u6216\u8005\u591a\u4e2a\u6210\u5458\uff08\u70b9\u8d5e\uff09<\/li>\n\n\n\n
      • SCARD<\/strong> key\uff1a\u83b7\u53d6\u6240\u6709\u6210\u5458\u7684\u6570\u91cf\uff08\u70b9\u8d5e\u6570\u91cf\uff09<\/li>\n\n\n\n
      • SISMEMBER<\/strong> key member\uff1a\u5224\u65ad\u6210\u5458\u662f\u5426\u5b58\u5728\uff08\u662f\u5426\u70b9\u8d5e\uff09<\/li>\n\n\n\n
      • SREM<\/strong> key member1 [member2] \uff1a\u79fb\u9664\u4e00\u4e2a\u6216\u8005\u591a\u4e2a\u6210\u5458\uff08\u70b9\u8d5e\u6570\u91cf\uff09<\/li>\n<\/ul>\n\n\n\n
        Redis-cli API\u64cd\u4f5c<\/h3>\n\n\n\n
        127.0.0.1:6379> sadd like:article:1 user1
        (integer) 1
        127.0.0.1:6379> sadd like:article:1 user2
        (integer) 1
        # \u83b7\u53d6\u6210\u5458\u6570\u91cf\uff08\u70b9\u8d5e\u6570\u91cf\uff09
        127.0.0.1:6379> SCARD like:article:1
        (integer) 2
        # \u5224\u65ad\u6210\u5458\u662f\u5426\u5b58\u5728\uff08\u662f\u5426\u70b9\u5728\uff09
        127.0.0.1:6379> SISMEMBER like:article:1 user1
        (integer) 1
        127.0.0.1:6379> SISMEMBER like:article:1 user3
        (integer) 0
        # \u79fb\u9664\u4e00\u4e2a\u6216\u8005\u591a\u4e2a\u6210\u5458\uff08\u53d6\u6d88\u70b9\u8d5e\uff09
        127.0.0.1:6379> SREM like:article:1 user1
        (integer) 1
        127.0.0.1:6379> SCARD like:article:1
        (integer) 1<\/code><\/pre>\n\n\n\n
        SpringBoot \u64cd\u4f5c<\/h3>\n\n\n\n
        import lombok.extern.slf4j.Slf4j;
        import org.junit.jupiter.api.Test;
        import org.springframework.beans.factory.annotation.Autowired;
        import org.springframework.boot.test.context.SpringBootTest;
        import org.springframework.data.redis.core.RedisTemplate;

        \/**
         * @author<\/strong> \u4e00\u884cJava
         * @title<\/strong>: LikeMain
         * @projectName<\/strong> ehang-spring-boot
         * @description<\/strong>: TODO
         * @date<\/strong> 2022\/7\/18 15:38
         *\/
        @Slf4j
        @SpringBootTest
        public class LikeMain {
            private final String KEY_LIKE_ARTICLE_PROFIX = \"like:article:\";

            @Autowired
            RedisTemplate redisTemplate;

            @Test
            void test() {
                long articleId = 100;
                Long likeNum = like(articleId, 1001, 1002, 2001, 3005, 4003);
                unLike(articleId, 2001);
                likeNum = likeNum(articleId);
                boolean b2001 = isLike(articleId, 2001);
                boolean b3005 = isLike(articleId, 3005);
                log.info(\"\u6587\u7ae0\uff1a{} \u70b9\u8d5e\u6570\u91cf\uff1a{} \u7528\u62372001\u7684\u70b9\u8d5e\u72b6\u6001\uff1a{} \u7528\u62373005\u7684\u70b9\u8d5e\u72b6\u6001\uff1a{}\", articleId, likeNum, b2001, b3005);
            }

            \/**
             * \u70b9\u8d5e
             *
             * @param<\/strong> articleId \u6587\u7ae0ID
             * @return<\/strong> \u70b9\u8d5e\u6570\u91cf
             *\/
            public Long like(Long articleId, Integer... userIds) {
                String key = KEY_LIKE_ARTICLE_PROFIX + articleId;
                Long add = redisTemplate.opsForSet().add(key, userIds);
                return add;
            }

            public Long unLike(Long articleId, Integer... userIds) {
                String key = KEY_LIKE_ARTICLE_PROFIX + articleId;
                Long remove = redisTemplate.opsForSet().remove(key, userIds);
                return remove;
            }

            public Long likeNum(Long articleId) {
                String key = KEY_LIKE_ARTICLE_PROFIX + articleId;
                Long size = redisTemplate.opsForSet().size(key);
                return size;
            }

            public Boolean isLike(Long articleId, Integer userId) {
                String key = KEY_LIKE_ARTICLE_PROFIX + articleId;
                return redisTemplate.opsForSet().isMember(key, userId);
            }

        }<\/code><\/pre>\n\n\n\n
        4\u6392\u884c\u699c<\/h2>\n\n\n\n
        \u6392\u540d\u3001\u6392\u884c\u699c\u3001\u70ed\u641c\u699c\u662f\u5f88\u591aAPP\u3001\u6e38\u620f\u90fd\u6709\u7684\u529f\u80fd\uff0c\u5e38\u7528\u4e8e\u7528\u6237\u6d3b\u52a8\u63a8\u5e7f\u3001\u7ade\u6280\u6392\u540d\u3001\u70ed\u95e8\u4fe1\u606f\u5c55\u793a\u7b49\u529f\u80fd\uff1b<\/p>\n\n\n\n
        \"\u56fe\u7247\"\/<\/figure>\n\n\n\n
        \u6bd4\u5982\u4e0a\u9762\u7684\u70ed\u641c\u699c\uff0c\u70ed\u5ea6\u6570\u636e\u6765\u6e90\u4e8e\u5168\u7f51\u7528\u6237\u7684\u8d21\u732e\uff0c\u4f46\u7528\u6237\u53ea\u5173\u5fc3\u70ed\u5ea6\u6700\u9ad8\u7684\u524d50\u6761\u3002<\/p>\n\n\n\n
        \u5e38\u89c4\u7684\u505a\u6cd5<\/strong>\uff1a\u5c31\u662f\u5c06\u7528\u6237\u7684\u540d\u6b21\u3001\u5206\u6570\u7b49\u7528\u4e8e\u6392\u540d\u7684\u6570\u636e\u66f4\u65b0\u5230\u6570\u636e\u5e93\uff0c\u7136\u540e\u67e5\u8be2\u7684\u65f6\u5019\u901a\u8fc7Order by + limit \u53d6\u51fa\u524d50\u540d\u663e\u793a\uff0c\u5982\u679c\u662f\u53c2\u4e0e\u7528\u6237\u4e0d\u591a\uff0c\u66f4\u65b0\u4e0d\u9891\u7e41\u7684\u6570\u636e\uff0c\u91c7\u7528\u6570\u636e\u5e93\u7684\u65b9\u5f0f\u4e5f\u6ca1\u6709\u5565\u95ee\u9898\uff0c\u4f46\u662f\u4e00\u65e6\u51fa\u73b0\u7206\u70b8\u6027\u70ed\u70b9\u8d44\u8baf\uff08\u6bd4\u5982\uff1a\u5927\u9646\u6536\u590d\u6e7e\u6e7e\uff0cxxx\u67d0\u4e9b\u7eff\u4e86\u7b49\u7b49\uff09\uff0c\u77ed\u65f6\u95f4\u4f1a\u51fa\u73b0\u7206\u70b8\u5f0f\u7684\u6d41\u91cf\uff0c\u77ac\u95f4\u7684\u538b\u529b\u53ef\u80fd\u8ba9\u6570\u636e\u5e93\u625b\u4e0d\u4f4f\uff1b<\/p>\n\n\n\n
        Redis\u65b9\u6848<\/strong>\uff1a\u5c06\u70ed\u70b9\u8d44\u8baf\u5168\u9875\u7f13\u5b58\uff0c\u91c7\u7528Redis\u7684\u6709\u5e8f\u961f\u5217<\/strong>\uff08Sorted Set\uff09\u6765\u7f13\u5b58\u70ed\u5ea6\uff08SCORES\uff09\uff0c\u5373\u53ef\u77ac\u95f4\u7f13\u89e3\u6570\u636e\u5e93\u7684\u538b\u529b\uff0c\u540c\u65f6\u8f7b\u677e\u7b5b\u9009\u51fa\u70ed\u5ea6\u6700\u9ad8\u768450\u6761\uff1b<\/p>\n\n\n\n
        \u529f\u80fd\u5b9e\u73b0\u9700\u8981\u7684\u547d\u4ee4<\/p>\n\n\n\n
          \n
        • ZADD<\/strong> key score1 member1 [score2 member2]\uff1a\u6dfb\u52a0\u5e76\u8bbe\u7f6eSCORES\uff0c\u652f\u6301\u4e00\u6b21\u6027\u6dfb\u52a0\u591a\u4e2a\uff1b<\/li>\n\n\n\n
        • ZREVRANGE<\/strong> key start stop [WITHSCORES] \uff1a\u6839\u636eSCORES\u964d\u5e8f\u6392\u5217\uff1b<\/li>\n\n\n\n
        • ZRANGE<\/strong> key start stop [WITHSCORES] \uff1a\u6839\u636eSCORES\u964d\u5e8f\u6392\u5217\uff1b<\/li>\n<\/ul>\n\n\n\n
          Redis-cli\u64cd\u4f5c<\/h3>\n\n\n\n
          # \u5355\u4e2a\u63d2\u5165
          127.0.0.1:6379> ZADD ranking 1 user1  
          (integer) 1
          # \u6279\u91cf\u63d2\u5165
          127.0.0.1:6379> ZADD ranking 10 user2 50 user3 3 user4 25 user5
          (integer) 4
          # \u964d\u5e8f\u6392\u5217 \u4e0d\u5e26SCORES
          127.0.0.1:6379> ZREVRANGE ranking 0 -1 
          1) \"user3\"
          2) \"user5\"
          3) \"user2\"
          4) \"user4\"
          5) \"user1\"
          # \u964d\u5e8f\u6392\u5217 \u5e26SCORES
          127.0.0.1:6379> ZREVRANGE ranking 0 -1 WITHSCORES
           1) \"user3\"
           2) \"50\"
           3) \"user5\"
           4) \"25\"
           5) \"user2\"
           6) \"10\"
           7) \"user4\"
           8) \"3\"
           9) \"user1\"
          10) \"1\"
          # \u5347\u5e8f
          127.0.0.1:6379> ZRANGE ranking 0 -1 WITHSCORES
           1) \"user1\"
           2) \"1\"
           3) \"user4\"
           4) \"3\"
           5) \"user2\"
           6) \"10\"
           7) \"user5\"
           8) \"25\"
           9) \"user3\"
          10) \"50\"<\/code><\/pre>\n\n\n\n
          SpringBoot\u64cd\u4f5c<\/h3>\n\n\n\n
          import lombok.extern.slf4j.Slf4j;
          import org.junit.jupiter.api.Test;
          import org.springframework.beans.factory.annotation.Autowired;
          import org.springframework.boot.test.context.SpringBootTest;
          import org.springframework.data.redis.core.DefaultTypedTuple;
          import org.springframework.data.redis.core.RedisTemplate;

          import java.util.Set;

          \/**
           * @author<\/strong> \u4e00\u884cJava
           * @title<\/strong>: RankingTest
           * @projectName<\/strong> ehang-spring-boot
           * @description<\/strong>: TODO
           * @date<\/strong> 2022\/7\/18 15:54
           *\/
          @SpringBootTest
          @Slf4j
          public class RankingTest {
              private final String KEY_RANKING = \"ranking\";
              @Autowired
              RedisTemplate redisTemplate;

              @Test
              void test() {
                  add(1001, (double) 60);
                  add(1002, (double) 80);
                  add(1003, (double) 100);
                  add(1004, (double) 90);
                  add(1005, (double) 70);

                  \/\/ \u53d6\u6240\u6709
                  Set<DefaultTypedTuple> range = range(0, -1);
                  log.info(\"\u6240\u6709\u7528\u6237\u6392\u5e8f\uff1a{}\", range);

                  \/\/ \u524d\u4e09\u540d
                  range = range(0, 2);
                  log.info(\"\u524d\u4e09\u540d\u6392\u5e8f\uff1a{}\", range);
              }

              public Boolean add(Integer userId, Double score) {
                  Boolean add = redisTemplate.opsForZSet().add(KEY_RANKING, userId, score);
                  return add;
              }

              public Set<DefaultTypedTuple> range(long min, long max) {
                  \/\/ \u964d\u5e8f
                  Set<DefaultTypedTuple> set = redisTemplate.opsForZSet().reverseRangeWithScores(KEY_RANKING, min, max);
                  \/\/ \u5347\u5e8f
                  \/\/Set<DefaultTypedTuple> set = redisTemplate.opsForZSet().rangeWithScores(KEY_RANKING, min, max);
                  return set;
              }
          }<\/code><\/pre>\n\n\n\n
          \u8f93\u51fa<\/p>\n\n\n\n
          \u6240\u6709\u7528\u6237\u6392\u5e8f\uff1a[DefaultTypedTuple [score=100.0, value=1003], DefaultTypedTuple [score=90.0, value=1004], DefaultTypedTuple [score=80.0, value=1002], DefaultTypedTuple [score=70.0, value=1005], DefaultTypedTuple [score=60.0, value=1001]]
          \u524d\u4e09\u540d\u6392\u5e8f\uff1a[DefaultTypedTuple [score=100.0, value=1003], DefaultTypedTuple [score=90.0, value=1004], DefaultTypedTuple [score=80.0, value=1002]]<\/code><\/pre>\n\n\n\n
          5PV\u7edf\u8ba1\uff08incr\u81ea\u589e\u8ba1\u6570\uff09<\/h2>\n\n\n\n
          Page View\uff08PV\uff09\u6307\u7684\u662f\u9875\u9762\u6d4f\u89c8\u91cf\uff0c\u662f\u7528\u6765\u8861\u91cf\u6d41\u91cf\u7684\u4e00\u4e2a\u91cd\u8981\u6807\u51c6\uff0c\u4e5f\u662f\u6570\u636e\u5206\u6790\u5f88\u91cd\u8981\u7684\u4e00\u4e2a\u4f9d\u636e\uff1b\u901a\u5e38\u7edf\u8ba1\u89c4\u5219\u662f\u9875\u9762\u88ab\u5c55\u793a\u4e00\u6b21\uff0c\u5c31\u52a0\u4e00<\/p>\n\n\n\n
          \u529f\u80fd\u6240\u9700\u547d\u4ee4<\/p>\n\n\n\n
            \n
          • INCR<\/strong>\uff1a\u5c06 key \u4e2d\u50a8\u5b58\u7684\u6570\u5b57\u503c\u589e\u4e00<\/li>\n<\/ul>\n\n\n\n
            Redis-cli \u64cd\u4f5c<\/h3>\n\n\n\n
            127.0.0.1:6379> INCR pv:article:1
            (integer) 1
            127.0.0.1:6379> INCR pv:article:1
            (integer) 2<\/code><\/pre>\n\n\n\n
            6UV\u7edf\u8ba1\uff08HeyperLogLog\uff09<\/h2>\n\n\n\n
            \u524d\u9762\uff0c\u4ecb\u7ecd\u4e86\u901a\u8fc7\uff08INCR\uff09\u65b9\u5f0f\u6765\u5b9e\u73b0\u9875\u9762\u7684PV\uff1b\u9664\u4e86PV\u4e4b\u5916\uff0cUV\uff08\u72ec\u7acb\u8bbf\u5ba2\uff09\u4e5f\u662f\u4e00\u4e2a\u5f88\u91cd\u8981\u7684\u7edf\u8ba1\u6570\u636e\uff1b<\/p>\n\n\n\n
            \u4f46\u662f\u5982\u679c\u8981\u60f3\u901a\u8fc7\u8ba1\u6570\uff08INCR\uff09\u7684\u65b9\u5f0f\u6765\u5b9e\u73b0UV\u8ba1\u6570\uff0c\u5c31\u975e\u5e38\u7684\u9ebb\u70e6\uff0c\u589e\u52a0\u4e4b\u524d\uff0c\u9700\u8981\u5224\u65ad\u8fd9\u4e2a\u7528\u6237\u662f\u5426\u8bbf\u95ee\u8fc7\uff1b\u90a3\u5224\u65ad\u4f9d\u636e\u5c31\u9700\u8981\u989d\u5916\u7684\u65b9\u5f0f\u518d\u8fdb\u884c\u8bb0\u5f55\u3002<\/p>\n\n\n\n
            \u4f60\u53ef\u80fd\u4f1a\u8bf4\uff0c\u4e0d\u662f\u8fd8\u6709Set\u561b\uff01\u4e00\u4e2a\u9875\u9762\u5f04\u4e2a\u96c6\u5408\uff0c\u6765\u4e00\u4e2a\u7528\u6237\u585e\uff08SADD\uff09\u4e00\u4e2a\u7528\u6237\u8fdb\u53bb\uff0c\u8981\u7edf\u8ba1UV\u7684\u65f6\u5019\uff0c\u518d\u901a\u8fc7SCARD\u6c47\u603b\u4e00\u4e0b\u6570\u91cf\uff0c\u5c31\u80fd\u8f7b\u677e\u641e\u5b9a\u4e86\uff1b\u6b64\u65b9\u6848\u786e\u5b9e\u80fd\u5b9e\u73b0UV\u7684\u7edf\u8ba1\u6548\u679c\uff0c\u4f46\u662f\u5ffd\u7565\u4e86\u6210\u672c\uff1b\u5982\u679c\u662f\u666e\u901a\u9875\u9762\uff0c\u51e0\u767e\u3001\u51e0\u5343\u7684\u8bbf\u95ee\uff0c\u53ef\u80fd\u9020\u6210\u7684\u5f71\u54cd\u5fae\u4e4e\u5176\u5fae\uff0c\u5982\u679c\u4e00\u65e6\u9047\u5230\u7206\u6b3e\u9875\u9762\uff0c\u52a8\u8f84\u4e0a\u5343\u4e07\u3001\u4e0a\u4ebf\u7528\u6237\u8bbf\u95ee\u65f6\uff0c\u5c31\u4e00\u4e2a\u9875\u9762UV\u5c06\u4f1a\u5e26\u6765\u975e\u5e38\u5927\u7684\u5185\u5b58\u5f00\u9500\uff0c\u5bf9\u4e8e\u5982\u6b64\u73cd\u8d35\u7684\u5185\u5b58\u6765\u8bf4\uff0c\u8fd9\u663e\u7136\u662f\u4e0d\u5212\u7b97\u7684\u3002<\/p>\n\n\n\n
            \u6b64\u65f6\uff0cHeyperLogLog\u6570\u636e\u7ed3\u6784\uff0c\u5c31\u80fd\u5b8c\u7f8e\u7684\u89e3\u51b3\u8fd9\u4e00\u95ee\u9898\uff0c\u5b83\u63d0\u4f9b\u4e86\u4e00\u79cd\u4e0d\u7cbe\u51c6\u7684\u53bb\u91cd\u8ba1\u6570<\/strong>\u65b9\u6848\uff0c\u6ce8\u610f\uff01\u8fd9\u91cc\u5f3a\u8c03\u4e00\u4e0b\uff0c\u662f\u4e0d\u7cbe\u51c6\u7684\uff0c\u4f1a\u5b58\u5728\u8bef\u5dee\uff0c\u4e0d\u8fc7\u8bef\u5dee\u4e5f\u4e0d\u4f1a\u5f88\u5927\uff0c**\u6807\u51c6\u7684\u8bef\u5dee\u7387\u662f0.81%**\uff0c\u8fd9\u4e2a\u8bef\u5dee\u7387\u5bf9\u4e8e\u7edf\u8ba1UV\u8ba1\u6570\uff0c\u662f\u80fd\u591f\u5bb9\u5fcd\u7684\uff1b\u6240\u4ee5\uff0c\u4e0d\u8981\u5c06\u8fd9\u4e2a\u6570\u636e\u7ed3\u6784\u62ff\u53bb\u505a\u7cbe\u51c6\u7684\u53bb\u91cd\u8ba1\u6570\u3002<\/p>\n\n\n\n
            \u53e6\u5916\uff0cHeyperLogLog \u662f\u4f1a\u5360\u752812KB\u7684\u5b58\u50a8\u7a7a\u95f4<\/strong>\uff0c\u867d\u7136\u8bf4\uff0cRedis \u5bf9 HeyperLogLog \u8fdb\u884c\u4e86\u4f18\u5316\uff0c\u5728\u5b58\u50a8\u6570\u636e\u6bd4\u8f83\u5c11\u7684\u65f6\u5019\uff0c\u91c7\u7528\u4e86\u7a00\u758f\u77e9\u9635\u5b58\u50a8\uff0c\u53ea\u6709\u5728\u6570\u636e\u91cf\u53d8\u5927\uff0c\u7a00\u758f\u77e9\u9635\u7a7a\u95f4\u5360\u7528\u8d85\u8fc7\u9608\u503c\u65f6\uff0c\u624d\u4f1a\u8f6c\u4e3a\u7a7a\u95f4\u4e3a12KB\u7684\u7a20\u5bc6\u77e9\u9635\uff1b\u76f8\u6bd4\u4e8e\u6210\u5343\u3001\u4e0a\u4ebf\u7684\u6570\u636e\u91cf\uff0c\u8fd9\u5c0f\u5c0f\u768412KB\uff0c\u7b80\u76f4\u662f\u592a\u5212\u7b97\u4e86\uff1b\u4f46\u662f\u8fd8\u662f\u5efa\u8bae\uff0c\u4e0d\u8981\u5c06\u5176\u7528\u4e8e\u6570\u636e\u91cf\u5c11\uff0c\u4e14\u9891\u7e41\u521b\u5efa HeyperLogLog \u7684\u573a\u666f\uff0c\u907f\u514d\u4f7f\u7528\u4e0d\u5f53\uff0c\u9020\u6210\u8d44\u6e90\u6d88\u8017\u6ca1\u51cf\u53cd\u589e\u7684\u4e0d\u826f\u6548\u679c\u3002<\/p>\n\n\n\n
            \u529f\u80fd\u6240\u9700\u547d\u4ee4\uff1a<\/p>\n\n\n\n
              \n
            • PFADD<\/strong> key element [element …]\uff1a\u589e\u52a0\u8ba1\u6570\uff08\u7edf\u8ba1UV\uff09<\/li>\n\n\n\n
            • PFCOUNT<\/strong> key [key …]\uff1a\u83b7\u53d6\u8ba1\u6570\uff08\u8d27\u7269UV\uff09<\/li>\n\n\n\n
            • PFMERGE<\/strong> destkey sourcekey [sourcekey …]\uff1a\u5c06\u591a\u4e2a HyperLogLog \u5408\u5e76\u4e3a\u4e00\u4e2a HyperLogLog\uff08\u591a\u4e2a\u5408\u8d77\u6765\u7edf\u8ba1\uff09<\/li>\n<\/ul>\n\n\n\n
              Redis-cli \u64cd\u4f5c<\/h3>\n\n\n\n
              # \u6dfb\u52a0\u4e09\u4e2a\u7528\u6237\u7684\u8bbf\u95ee
              127.0.0.1:6379> PFADD uv:page:1 user1 user2 user3
              (integer) 1
              # \u83b7\u53d6UV\u6570\u91cf
              127.0.0.1:6379> PFCOUNT uv:page:1
              (integer) 3
              # \u518d\u6dfb\u52a0\u4e09\u4e2a\u7528\u6237\u7684\u8bbf\u95ee  user3\u662f\u91cd\u590d\u7528\u6237
              127.0.0.1:6379> PFADD uv:page:1 user3 user4 user5
              (integer) 1
              # \u83b7\u53d6UV\u6570\u91cf user3\u662f\u91cd\u590d\u7528\u6237 \u6240\u4ee5\u8fd9\u91cc\u8fd4\u56de\u7684\u662f5
              127.0.0.1:6379> PFCOUNT uv:page:1
              (integer) 5<\/code><\/pre>\n\n\n\n
              SpringBoot\u64cd\u4f5cHeyperLogLog<\/h3>\n\n\n\n
              \u6a21\u62df\u6d4b\u8bd510000\u4e2a\u7528\u6237\u8bbf\u95eeid\u4e3a2\u7684\u9875\u9762<\/p>\n\n\n\n
              import lombok.extern.slf4j.Slf4j;
              import org.junit.jupiter.api.Test;
              import org.springframework.beans.factory.annotation.Autowired;
              import org.springframework.boot.test.context.SpringBootTest;
              import org.springframework.data.redis.core.RedisTemplate;

              \/**
               * @author<\/strong> \u4e00\u884cJava
               * @title<\/strong>: HeyperLogLog \u7edf\u8ba1UV
               * @projectName<\/strong> ehang-spring-boot
               * @description<\/strong>: TODO
               * @date<\/strong> 2022\/7\/19 16:13
               *\/
              @SpringBootTest
              @Slf4j
              public class UVTest {
                  private final String KEY_UV_PAGE_PROFIX = \"uv:page:\";

                  @Autowired
                  RedisTemplate redisTemplate;

                  @Test
                  public void uvTest() {
                      Integer pageId = 2;
                      for (int i = 0; i < 10000; i++) {
                          uv(pageId, i);
                      }
                      for (int i = 0; i < 10000; i++) {
                          uv(pageId, i);
                      }

                      Long uv = getUv(pageId);
                      log.info(\"pageId:{} uv:{}\", pageId, uv);
                  }

                  \/**
                   * \u7528\u6237\u8bbf\u95ee\u9875\u9762
                   * @param<\/strong> pageId
                   * @param<\/strong> userId
                   * @return<\/strong>
                   *\/
                  private Long uv(Integer pageId, Integer userId) {
                      String key = KEY_UV_PAGE_PROFIX + pageId;
                      return redisTemplate.opsForHyperLogLog().add(key, userId);
                  }

                  \/**
                   * \u7edf\u8ba1\u9875\u9762\u7684UV
                   * @param<\/strong> pageId
                   * @return<\/strong>
                   *\/
                  private Long getUv(Integer pageId) {
                      String key = KEY_UV_PAGE_PROFIX + pageId;
                      return redisTemplate.opsForHyperLogLog().size(key);
                  }
              }<\/code><\/pre>\n\n\n\n
              \u65e5\u5fd7\u8f93\u51fa<\/p>\n\n\n\n
              pageId:2 uv:10023<\/code><\/pre>\n\n\n\n
              \u7531\u4e8e\u5b58\u5728\u8bef\u5dee\uff0c\u8fd9\u91cc\u8bbf\u95ee\u7684\u5b9e\u9645\u8bbf\u95ee\u7684\u6570\u91cf\u662f1\u4e07\uff0c\u7edf\u8ba1\u51fa\u6765\u7684\u591a\u4e8623\u4e2a\uff0c\u5728\u6807\u51c6\u7684\u8bef\u5dee\uff080.81%\uff09\u8303\u56f4\u5185\uff0c\u52a0\u4e0aUV\u6570\u636e\u4e0d\u662f\u5fc5\u987b\u8981\u6c42\u51c6\u786e\uff0c\u56e0\u6b64\u8fd9\u4e2a\u8bef\u5dee\u662f\u53ef\u4ee5\u63a5\u53d7\u7684\u3002<\/p>\n\n\n\n
              7\u53bb\u91cd\uff08BloomFiler\uff09<\/h2>\n\n\n\n
              \u901a\u8fc7\u4e0a\u9762HeyperLogLog\u7684\u5b66\u4e60\uff0c\u6211\u4eec\u638c\u63e1\u4e86\u4e00\u79cd\u4e0d\u7cbe\u51c6\u7684\u53bb\u91cd\u8ba1\u6570<\/strong>\u65b9\u6848\uff0c\u4f46\u662f\u6709\u6ca1\u6709\u53d1\u73b0\uff0c\u4ed6\u6ca1\u529e\u6cd5\u83b7\u53d6\u67d0\u4e2a\u7528\u6237\u662f\u5426\u8bbf\u95ee\u8fc7\uff1b\u7406\u60f3\u4e2d\uff0c\u6211\u4eec\u662f\u5e0c\u671b\u6709\u4e00\u4e2aPFEXISTS<\/code>\u7684\u547d\u4ee4\uff0c\u6765\u5224\u65ad\u67d0\u4e2akey\u662f\u5426\u5b58\u5728\uff0c\u7136\u800cHeyperLogLog\u5e76\u6ca1\u6709\uff1b\u8981\u60f3\u5b9e\u73b0\u8fd9\u4e00\u9700\u6c42\uff0c\u5c31\u5f97 BloomFiler \u4e0a\u573a\u4e86\u3002<\/p>\n\n\n\n
                \n
              • \u4ec0\u4e48\u662fBloom Filter\uff1fBloom Filter\u662f\u7531Bloom\u57281970\u5e74\u63d0\u51fa\u7684\u4e00\u79cd\u591a\u54c8\u5e0c\u51fd\u6570\u6620\u5c04\u7684\u5feb\u901f\u67e5\u627e\u7b97\u6cd5\u3002 \u901a\u5e38\u5e94\u7528\u5728\u4e00\u4e9b\u9700\u8981\u5feb\u901f\u5224\u65ad\u67d0\u4e2a\u5143\u7d20\u662f\u5426\u5c5e\u4e8e\u96c6\u5408\uff0c\u4f46\u662f\u5e76\u4e0d\u4e25\u683c\u8981\u6c42100%\u6b63\u786e\u7684\u573a\u5408<\/strong>\u3002 \u57fa\u4e8e\u4e00\u79cd\u6982\u7387\u6570\u636e\u7ed3\u6784\u6765\u5b9e\u73b0\uff0c\u662f\u4e00\u4e2a\u6709\u8da3\u4e14\u5f3a\u5927\u7684\u7b97\u6cd5\u3002<\/li>\n<\/ul>\n\n\n\n
                \u4e3e\u4e2a\u4f8b\u5b50<\/strong>\uff1a\u5047\u5982\u4f60\u5199\u4e86\u4e00\u4e2a\u722c\u866b\uff0c\u7528\u4e8e\u722c\u53d6\u7f51\u7edc\u4e2d\u7684\u6240\u6709\u9875\u9762\uff0c\u5f53\u4f60\u62ff\u5230\u4e00\u4e2a\u65b0\u7684\u9875\u9762\u65f6\uff0c\u5982\u4f55\u5224\u65ad\u8fd9\u4e2a\u9875\u9762\u662f\u5426\u722c\u53d6\u8fc7\uff1f<\/p>\n\n\n\n
                \u666e\u901a\u505a\u6cd5<\/strong>\uff1a\u6bcf\u722c\u53d6\u4e00\u4e2a\u9875\u9762\uff0c\u5f80\u6570\u636e\u5e93\u63d2\u5165\u4e00\u884c\u6570\u636e\uff0c\u8bb0\u5f55\u4e00\u4e0bURL\uff0c\u6bcf\u6b21\u62ff\u5230\u4e00\u4e2a\u65b0\u7684\u9875\u9762\uff0c\u5c31\u53bb\u6570\u636e\u5e93\u91cc\u9762\u67e5\u8be2\u4e00\u4e0b\uff0c\u5b58\u5728\u5c31\u8bf4\u660e\u722c\u53d6\u8fc7\uff1b<\/p>\n\n\n\n
                \u666e\u901a\u505a\u6cd5\u7684\u7f3a\u70b9<\/strong>\uff1a\u5c11\u91cf\u6570\u636e\uff0c\u7528\u4f20\u7edf\u65b9\u6848\u6ca1\u5565\u95ee\u9898\uff0c\u5982\u679c\u662f\u6d77\u91cf\u6570\u636e\uff0c\u6bcf\u6b21\u722c\u53d6\u524d\u7684\u68c0\u7d22\uff0c\u5c06\u4f1a\u8d8a\u6765\u8d8a\u6162\uff1b\u5982\u679c\u4f60\u7684\u722c\u866b\u53ea\u5173\u5fc3\u5185\u5bb9\uff0c\u5bf9\u6765\u6e90\u6570\u636e\u4e0d\u592a\u5173\u5fc3\u7684\u8bdd\uff0c\u8fd9\u90e8\u5206\u6570\u636e\u7684\u5b58\u50a8\uff0c\u4e5f\u5c06\u6d88\u8017\u4f60\u5f88\u5927\u7684\u7269\u7406\u8d44\u6e90\uff1b<\/p>\n\n\n\n
                \u6b64\u65f6\u901a\u8fc7 BloomFiler \u5c31\u80fd\u4ee5\u5f88\u5c0f\u7684\u5185\u5b58\u7a7a\u95f4\u4f5c\u4e3a\u4ee3\u4ef7\uff0c\u5373\u53ef\u8f7b\u677e\u5224\u65ad\u67d0\u4e2a\u503c\u662f\u5426\u5b58\u5728\u3002<\/p>\n\n\n\n
                \u540c\u6837\uff0cBloomFiler \u4e5f\u4e0d\u90a3\u4e48\u7cbe\u51c6\uff0c\u5728\u9ed8\u8ba4\u53c2\u6570\u60c5\u51b5\u4e0b\uff0c\u662f\u5b58\u57281%\u5de6\u53f3\u7684\u8bef\u5dee\uff1b\u4f46\u662f BloomFiler \u662f\u5141\u8bb8\u901a\u8fc7error_rate\uff08\u8bef\u5dee\u7387\uff09\u4ee5\u53cainitial_size\uff08\u9884\u8ba1\u5927\u5c0f\uff09\u6765\u8bbe\u7f6e\u4ed6\u7684\u8bef\u5dee\u6bd4\u4f8b<\/p>\n\n\n\n
                  \n
                • error_rate<\/strong>\uff1a\u8bef\u5dee\u7387\uff0c\u8d8a\u4f4e\uff0c\u9700\u8981\u7684\u7a7a\u95f4\u5c31\u8d8a\u5927\uff1b<\/li>\n\n\n\n
                • initial_size<\/strong>\uff1a\u9884\u8ba1\u653e\u5165\u503c\u7684\u6570\u91cf\uff0c\u5f53\u5b9e\u9645\u653e\u5165\u7684\u6570\u91cf\u5927\u4e8e\u8bbe\u7f6e\u7684\u503c\u65f6\uff0c\u8bef\u5dee\u7387\u5c31\u4f1a\u9010\u6e10\u5347\u9ad8\uff1b\u6240\u4ee5\u4e3a\u4e86\u907f\u514d\u8bef\u5dee\u7387\uff0c\u53ef\u4ee5\u63d0\u524d\u505a\u597d\u4f30\u503c\uff0c\u907f\u514d\u518d\u6b21\u5927\u7684\u8bef\u5dee\uff1b<\/li>\n<\/ul>\n\n\n\n
                  BloomFiler \u5b89\u88c5<\/h3>\n\n\n\n
                  \u4e3a\u4e86\u65b9\u4fbf\u6d4b\u8bd5\uff0c\u8fd9\u91cc\u4f7f\u7528 Docker \u5feb\u901f\u5b89\u88c5<\/p>\n\n\n\n
                  docker run -d -p 6379:6379 redislabs\/rebloom<\/code><\/pre>\n\n\n\n
                  \u529f\u80fd\u6240\u9700\u7684\u547d\u4ee4<\/p>\n\n\n\n
                    \n
                  • bf.add<\/strong> \u6dfb\u52a0\u5355\u4e2a\u5143\u7d20<\/li>\n\n\n\n
                  • bf.madd<\/strong> \u6279\u91cf\u7530\u95f4<\/li>\n\n\n\n
                  • bf.exists<\/strong> \u68c0\u6d4b\u5143\u7d20\u662f\u5426\u5b58\u5728<\/li>\n\n\n\n
                  • bf.mexists<\/strong> \u6279\u91cf\u68c0\u6d4b<\/li>\n<\/ul>\n\n\n\n
                    Redis-cli\u64cd\u4f5c<\/h3>\n\n\n\n
                    127.0.0.1:6379> bf.add web:crawler baidu
                    (integer) 1
                    127.0.0.1:6379> bf.madd web:crawler tencent bing
                    1) (integer) 1
                    2) (integer) 1
                    127.0.0.1:6379> bf.exists web:crawler baidu
                    (integer) 1
                    127.0.0.1:6379> bf.mexists web:crawler baidu 163
                    1) (integer) 1
                    2) (integer) 0<\/code><\/pre>\n\n\n\n
                    SpringBoot\u6574\u5408<\/h3>\n\n\n\n
                      \n
                    • \u5de5\u5177\u7c7b RedisBloomimport org.springframework.beans.factory.annotation.Autowired;
                      import org.springframework.data.redis.core.StringRedisTemplate;
                      import org.springframework.data.redis.core.script.DefaultRedisScript;
                      import org.springframework.data.redis.core.script.RedisScript;
                      import org.springframework.stereotype.Component;

                      import java.util.Arrays;
                      import java.util.List;

                      \/**
                       * redis\u5e03\u9686\u8fc7\u6ee4\u5668
                       *
                       * @author<\/strong> \u4e00\u884cJava
                       * @title<\/strong>: RedisBloom
                       * @projectName<\/strong> ehang-spring-boot
                       * @description<\/strong>: TODO
                       * @date<\/strong> 2022\/7\/19 17:03
                       *\/
                      @Component
                      public class RedisBloom {

                          private static RedisScript<Boolean> bfreserveScript = new DefaultRedisScript<>(\"return redis.call('bf.reserve', KEYS[1], ARGV[1], ARGV[2])\", Boolean.class);
                          private static RedisScript<Boolean> bfaddScript = new DefaultRedisScript<>(\"return redis.call('bf.add', KEYS[1], ARGV[1])\", Boolean.class);
                          private static RedisScript<Boolean> bfexistsScript = new DefaultRedisScript<>(\"return redis.call('bf.exists', KEYS[1], ARGV[1])\", Boolean.class);
                          private static String bfmaddScript = \"return redis.call('bf.madd', KEYS[1], %s)\";
                          private static String bfmexistsScript = \"return redis.call('bf.mexists', KEYS[1], %s)\";
                          @Autowired
                          private StringRedisTemplate redisTemplate;

                          \/**
                           * \u8bbe\u7f6e\u9519\u8bef\u7387\u548c\u5927\u5c0f\uff08\u9700\u8981\u5728\u6dfb\u52a0\u5143\u7d20\u524d\u8c03\u7528\uff0c\u82e5\u5df2\u5b58\u5728\u5143\u7d20\uff0c\u5219\u4f1a\u62a5\u9519\uff09
                           * \u9519\u8bef\u7387\u8d8a\u4f4e\uff0c\u9700\u8981\u7684\u7a7a\u95f4\u8d8a\u5927
                           *
                           * @param<\/strong> key
                           * @param<\/strong> errorRate   \u9519\u8bef\u7387\uff0c\u9ed8\u8ba40.01
                           * @param<\/strong> initialSize \u9ed8\u8ba4100\uff0c\u9884\u8ba1\u653e\u5165\u7684\u5143\u7d20\u6570\u91cf\uff0c\u5f53\u5b9e\u9645\u6570\u91cf\u8d85\u51fa\u8fd9\u4e2a\u6570\u503c\u65f6\uff0c\u8bef\u5224\u7387\u4f1a\u4e0a\u5347\uff0c\u5c3d\u91cf\u4f30\u8ba1\u4e00\u4e2a\u51c6\u786e\u6570\u503c\u518d\u52a0\u4e0a\u4e00\u5b9a\u7684\u5197\u4f59\u7a7a\u95f4
                           * @return<\/strong>
                           *\/
                          public Boolean bfreserve(String key, double errorRate, int initialSize) {
                              return redisTemplate.execute(bfreserveScript, Arrays.asList(key), String.valueOf(errorRate), String.valueOf(initialSize));
                          }

                          \/**
                           * \u6dfb\u52a0\u5143\u7d20
                           *
                           * @param<\/strong> key
                           * @param<\/strong> value
                           * @return<\/strong> true\u8868\u793a\u6dfb\u52a0\u6210\u529f\uff0cfalse\u8868\u793a\u6dfb\u52a0\u5931\u8d25\uff08\u5b58\u5728\u65f6\u4f1a\u8fd4\u56defalse\uff09
                           *\/
                          public Boolean bfadd(String key, String value) {
                              return redisTemplate.execute(bfaddScript, Arrays.asList(key), value);
                          }

                          \/**
                           * \u67e5\u770b\u5143\u7d20\u662f\u5426\u5b58\u5728\uff08\u5224\u65ad\u4e3a\u5b58\u5728\u65f6\u6709\u53ef\u80fd\u662f\u8bef\u5224\uff0c\u4e0d\u5b58\u5728\u662f\u4e00\u5b9a\u4e0d\u5b58\u5728\uff09
                           *
                           * @param<\/strong> key
                           * @param<\/strong> value
                           * @return<\/strong> true\u8868\u793a\u5b58\u5728\uff0cfalse\u8868\u793a\u4e0d\u5b58\u5728
                           *\/
                          public Boolean bfexists(String key, String value) {
                              return redisTemplate.execute(bfexistsScript, Arrays.asList(key), value);
                          }

                          \/**
                           * \u6279\u91cf\u6dfb\u52a0\u5143\u7d20
                           *
                           * @param<\/strong> key
                           * @param<\/strong> values
                           * @return<\/strong> \u6309\u5e8f 1\u8868\u793a\u6dfb\u52a0\u6210\u529f\uff0c0\u8868\u793a\u6dfb\u52a0\u5931\u8d25
                           *\/
                          public List<Integer> bfmadd(String key, String... values) {
                              return (List<Integer>) redisTemplate.execute(this.generateScript(bfmaddScript, values), Arrays.asList(key), values);
                          }

                          \/**
                           * \u6279\u91cf\u68c0\u67e5\u5143\u7d20\u662f\u5426\u5b58\u5728\uff08\u5224\u65ad\u4e3a\u5b58\u5728\u65f6\u6709\u53ef\u80fd\u662f\u8bef\u5224\uff0c\u4e0d\u5b58\u5728\u662f\u4e00\u5b9a\u4e0d\u5b58\u5728\uff09
                           *
                           * @param<\/strong> key
                           * @param<\/strong> values
                           * @return<\/strong> \u6309\u5e8f 1\u8868\u793a\u5b58\u5728\uff0c0\u8868\u793a\u4e0d\u5b58\u5728
                           *\/
                          public List<Integer> bfmexists(String key, String... values) {
                              return (List<Integer>) redisTemplate.execute(this.generateScript(bfmexistsScript, values), Arrays.asList(key), values);
                          }

                          private RedisScript<List> generateScript(String script, String[] values) {
                              StringBuilder sb = new StringBuilder();
                              for (int i = 1; i <= values.length; i++) {
                                  if (i != 1) {
                                      sb.append(\",\");
                                  }
                                  sb.append(\"ARGV[\").append(i).append(\"]\");
                              }
                              return new DefaultRedisScript<>(String.format(script, sb.toString()), List.class);
                          }

                      }<\/code><\/li>\n\n\n\n
                    • \u6d4b\u8bd5import lombok.extern.slf4j.Slf4j;
                      import org.junit.jupiter.api.Test;
                      import org.springframework.beans.factory.annotation.Autowired;
                      import org.springframework.boot.test.context.SpringBootTest;
                      import org.springframework.data.redis.core.RedisTemplate;

                      import java.util.List;

                      \/**
                       * @author<\/strong> \u4e00\u884cJava
                       * @title<\/strong>: BFTest
                       * @projectName<\/strong> ehang-spring-boot
                       * @description<\/strong>: TODO
                       * @date<\/strong> 2022\/7\/19 17:04
                       *\/
                      @SpringBootTest
                      @Slf4j
                      public class BFTest {

                          private final String KEY_WEB_CRAWLER = \"web:crawler1\";

                          @Autowired
                          RedisBloom bloom;

                          @Autowired
                          RedisTemplate redisTemplate;


                          @Test
                          public void test() {
                              Boolean hasKey = redisTemplate.hasKey(KEY_WEB_CRAWLER);
                              log.info(\"bloom hasKey:{}\", hasKey);
                              if (!hasKey) {
                                  \/\/ \u4e0d\u5b58\u5728\u7684\u65f6\u5019  \u518d\u53bb\u521d\u59cb\u5316
                                  Boolean bfreserve = bloom.bfreserve(KEY_WEB_CRAWLER, 0.0001, 10000);
                                  log.info(\"bloom bfreserve:{}\", bfreserve);
                              }
                              List<Integer> madd = bloom.bfmadd(KEY_WEB_CRAWLER, \"baidu\", \"google\");
                              log.info(\"bloom bfmadd:{}\", madd);

                              Boolean baidu = bloom.bfexists(KEY_WEB_CRAWLER, \"baidu\");
                              log.info(\"bloom bfexists baidu:{}\", baidu);

                              Boolean bing = bloom.bfexists(KEY_WEB_CRAWLER, \"bing\");
                              log.info(\"bloom bfexists bing:{}\", bing);
                          }
                      }
                      <\/code>\u65e5\u5fd7\u8f93\u51facom.ehang.redis.bloom_filter.BFTest      : bloom hasKey:false
                      com.ehang.redis.bloom_filter.BFTest      : bloom bfreserve:true
                      com.ehang.redis.bloom_filter.BFTest      : bloom bfmadd:[1, 1]
                      com.ehang.redis.bloom_filter.BFTest      : bloom bfexists baidu:true
                      com.ehang.redis.bloom_filter.BFTest      : bloom bfexists bing:false<\/code><\/li>\n<\/ul>\n\n\n\n
                      8\u7528\u6237\u7b7e\u5230\uff08BitMap\uff09<\/h2>\n\n\n\n
                      \u5f88\u591aAPP\u4e3a\u4e86\u62c9\u52a8\u7528\u6237\u6d3b\u8dc3\u5ea6\uff0c\u5f80\u5f80\u90fd\u4f1a\u505a\u4e00\u4e9b\u6d3b\u52a8\uff0c\u6bd4\u5982\u8fde\u7eed\u7b7e\u5230\u9886\u79ef\u5206\/\u793c\u5305\u7b49\u7b49<\/p>\n\n\n\n
                      \"\u56fe\u7247\"\/<\/figure>\n\n\n\n
                      \u4f20\u7edf\u505a\u6cd5<\/strong>\uff1a\u7528\u6237\u6bcf\u6b21\u7b7e\u5230\u65f6\uff0c\u5f80\u662f\u6570\u636e\u5e93\u63d2\u5165\u4e00\u6761\u7b7e\u5230\u6570\u636e\uff0c\u5c55\u793a\u7684\u65f6\u5019\uff0c\u628a\u672c\u6708\uff08\u6216\u8005\u6307\u5b9a\u5468\u671f\uff09\u7684\u7b7e\u5230\u6570\u636e\u83b7\u53d6\u51fa\u6765\uff0c\u7528\u4e8e\u5224\u65ad\u7528\u6237\u662f\u5426\u7b7e\u5230\u3001\u4ee5\u53ca\u8fde\u7eed\u7b7e\u5230\u60c5\u51b5\uff1b\u6b64\u65b9\u5f0f\uff0c\u7b80\u5355\uff0c\u7406\u89e3\u5bb9\u6613\uff1b<\/p>\n\n\n\n
                      Redis\u505a\u6cd5<\/strong>\uff1a\u7531\u4e8e\u7b7e\u5230\u6570\u636e\u7684\u5173\u6ce8\u70b9\u5c312\u4e2a\uff1a\u662f\u5426\u7b7e\u5230\uff080\/1\uff09\u3001\u8fde\u7eed\u6027\uff0c\u56e0\u6b64\u5c31\u5b8c\u5168\u53ef\u4ee5\u5229\u7528BitMap\uff08\u4f4d\u56fe\uff09\u6765\u5b9e\u73b0\uff1b<\/p>\n\n\n\n
                      \"\u56fe\u7247\"\/
                      \u4e00\u4e2a\u6708\u7684\u7b7e\u5230\u60c5\u51b5\uff0c4\u4e2a\u5b57\u8282\u5c31\u8bb0\u5f55\u4e86\uff08\u56fe\u6e90\uff1a\u7f51\u7edc\uff09<\/figcaption><\/figure>\n\n\n\n
                      \u5982\u4e0a\u56fe\u6240\u793a\uff0c\u5c06\u4e00\u4e2a\u6708\u768431\u5929\uff0c\u752831\u4e2a\u4f4d\uff084\u4e2a\u5b57\u8282\uff09\u6765\u8868\u793a\uff0c\u504f\u79fb\u91cf\uff08offset\uff09\u4ee3\u8868\u5f53\u524d\u662f\u7b2c\u51e0\u5929\uff0c0\/1\u8868\u793a\u5f53\u524d\u662f\u5426\u7b7e\u5230\uff0c\u8fde\u7eed\u7b7e\u5230\u53ea\u9700\u4ece\u53f3\u5f80\u5de6\u6821\u9a8c\u8fde\u7eed\u4e3a1\u7684\u4f4d\u6570\uff1b<\/p>\n\n\n\n
                      \u7531\u4e8eString\u7c7b\u578b\u7684\u6700\u5927\u4e0a\u9650\u662f512M\uff0c\u8f6c\u6362\u4e3abit\u5219\u662f2^32\u4e2abit\u4f4d\u3002<\/p>\n\n\n\n
                      \u6240\u9700\u547d\u4ee4\uff1a<\/p>\n\n\n\n
                        \n
                      • SETBIT<\/strong> key offset value\uff1a\u5411\u6307\u5b9a\u4f4d\u7f6eoffset\u5b58\u5165\u4e00\u4e2a0\u62161<\/li>\n\n\n\n
                      • GETBIT<\/strong> key offset\uff1a\u83b7\u53d6\u6307\u5b9a\u4f4d\u7f6eoffset\u7684bit\u503c<\/li>\n\n\n\n
                      • BITCOUNT<\/strong> key [start] [end]\uff1a\u7edf\u8ba1BitMap\u4e2d\u503c\u4e3a1\u7684bit\u4f4d\u7684\u6570\u91cf<\/li>\n\n\n\n
                      • BITFIELD<\/strong>: \u64cd\u4f5c\uff08\u67e5\u8be2\uff0c\u4fee\u6539\uff0c\u81ea\u589e\uff09BitMap\u4e2dbit \u6570\u7ec4\u4e2d\u7684\u6307\u5b9a\u4f4d\u7f6eoffset\u7684\u503c\u8fd9\u91cc\u6700\u4e0d\u5bb9\u6613\u7406\u89e3\u7684\u5c31\u662f\uff1aBITFIELD\uff0c\u8be6\u60c5\u53ef\u53c2\u8003\uff1ahttps:\/\/deepinout.com\/redis-cmd\/redis-bitmap-cmd\/redis-cmd-bitfield.html  \u800c\u4e14\u8fd9\u90e8\u5206\u8fd8\u5fc5\u987b\u7406\u89e3\u4e86\uff0c\u5426\u5219\uff0c\u8be5\u9700\u6c42\u7684\u6838\u5fc3\u90e8\u5206\u5c31\u6ca1\u529e\u6cd5\u7406\u89e3\u4e86\uff1b<\/li>\n<\/ul>\n\n\n\n
                        \u9700\u6c42\uff1a\u5047\u5982\u5f53\u524d\u4e3a8\u67084\u53f7\uff0c\u68c0\u6d4b\u672c\u6708\u7684\u7b7e\u5230\u60c5\u51b5\uff0c\u7528\u6237\u5206\u522b\u4e8e1\u30013\u30014\u53f7\u7b7e\u5230\u8fc7<\/p>\n\n\n\n
                        Redis-cli \u64cd\u4f5c\uff1a<\/h3>\n\n\n\n
                        # 8\u67081\u53f7\u7684\u7b7e\u5230
                        127.0.0.1:6379> SETBIT RangeId:Sign:1:8899 0 1
                        (integer) 1

                        # 8\u67083\u53f7\u7684\u7b7e\u5230
                        127.0.0.1:6379> SETBIT RangeId:Sign:1:8899 2 1
                        (integer) 1

                        # 8\u67084\u53f7\u7684\u7b7e\u5230
                        127.0.0.1:6379> SETBIT RangeId:Sign:1:8899 3 1
                        (integer) 1

                        # \u67e5\u8be2\u5404\u5929\u7684\u7b7e\u5230\u60c5\u51b5
                        # \u67e5\u8be21\u53f7
                        127.0.0.1:6379> GETBIT RangeId:Sign:1:8899 0
                        (integer) 1
                        # \u67e5\u8be22\u53f7
                        127.0.0.1:6379> GETBIT RangeId:Sign:1:8899 1
                        (integer) 0
                        # \u67e5\u8be23\u53f7
                        127.0.0.1:6379> GETBIT RangeId:Sign:1:8899 2
                        (integer) 1
                        # \u67e5\u8be24\u53f7
                        127.0.0.1:6379> GETBIT RangeId:Sign:1:8899 3
                        (integer) 1

                        # \u67e5\u8be2\u6307\u5b9a\u533a\u95f4\u7684\u7b7e\u5230\u60c5\u51b5
                        127.0.0.1:6379> BITFIELD RangeId:Sign:1:8899 get u4 0
                        1) (integer) 11<\/code><\/pre>\n\n\n\n
                        \n
                        1-4\u53f7\u7684\u7b7e\u5230\u60c5\u51b5\u4e3a\uff1a1011\uff08\u4e8c\u8fdb\u5236\uff09 ==> 11\uff08\u5341\u8fdb\u5236\uff09<\/p>\n<\/blockquote>\n\n\n\n
                        \u662f\u5426\u7b7e\u5230\u3001\u8fde\u7eed\u7b7e\u5230\u5224\u65ad<\/h3>\n\n\n\n
                        \u7b7e\u5230\u529f\u80fd\u4e2d\uff0c\u6700\u4e0d\u597d\u7406\u89e3\u7684\u5c31\u662f\u662f\u5426\u7b7e\u5230\u3001\u8fde\u7eed\u7b7e\u5230\u7684\u5224\u65ad\uff0c\u5728\u4e0b\u9762SpringBoot\u4ee3\u7801\u4e2d\uff0c\u5c31\u662f\u901a\u8fc7\u8fd9\u6837\u7684\uff1asignFlag >> 1 << 1 != signFlag<\/code>\u6765\u5224\u65ad\u7684\uff0c\u7a0d\u5fae\u6709\u4e00\u70b9\u4e0d\u597d\u7406\u89e3\uff0c\u5728\u8fd9\u91cc\u63d0\u524d\u8bb2\u8ff0\u4e00\u4e0b\uff1b<\/p>\n\n\n\n
                        \u4e0a\u9762\u6d4b\u8bd5\u4e861-4\u53f7\u7684\u7b7e\u5230\u60c5\u51b5\uff0c\u901a\u8fc7BITFIELD<\/code>\u83b7\u53d6\u51fa\u6765signFlag = 11\uff08\u5341\u8fdb\u5236\uff09 = 1011\uff08\u4e8c\u8fdb\u5236\uff09\uff1b<\/p>\n\n\n\n
                        \u8fde\u7eed\u7b7e\u5230\u7684\u5224\u65ad\u4f9d\u636e\u5c31\u662f\uff1a\u4ece\u53f3\u5f80\u5de6\u8ba1\u7b97\u8fde\u7eed\u4e3a1\u7684BIT\u4e2a\u6570<\/strong>\uff0c\u4e8c\u8fdb\u5236 1011 \u8868\u793a\u8fde\u7eed\u7b7e\u5230\u7684\u5929\u6570\u5c31\u662f2\u5929\uff0c2\u5929\u7684\u8ba1\u7b97\u8fc7\u7a0b\u5982\u4e0b\uff1a<\/p>\n\n\n\n
                          \n
                        • \u7b2c\u4e00\u6b65\uff0c\u83b7\u53d6signFlag<\/li>\n\n\n\n
                        • \u7b2c\u4e8c\u6b65\uff0c\u5faa\u73af\u5929\u6570\uff0c\u4ee5\u4e0a\u6d4b\u8bd5\u7528\u4f8b\u662f4\u5929\u7684\u7b7e\u5230\u60c5\u51b5\uff0cfor\u5faa\u73af\u4e5f\u5c31\u662f4\u6b21<\/li>\n\n\n\n
                        • \u7b2c\u4e09\u6b65\uff0c\u4ece\u53f3\u5f80\u5de6\u5faa\u73af\u5224\u65ad\u8fde\u7eed\u7b7e\u5230<\/strong>\uff1a\u9047\u5230\u7b2c\u4e00\u4e2afalse\u7684\u65f6\u5019\uff0c\u7ec8\u6b62\u5e76\u5f97\u5230\u8fde\u7eed\u5929\u6570\u7b7e\u5230\u8be6\u60c5<\/strong>\uff1a\u5faa\u73af\u6240\u6709\u5929\u6570\uff0ctrue\u5c31\u8868\u793a\u5f53\u524d\u7b7e\u5230\u4e86\uff0cfalse\u8868\u793a\u5f53\u5929\u672a\u7b7e\u5230\uff1b\u7b2c\u4e00\u6b21\u5faa\u73afsignFlag = 1011
                          signFlag >> 1   \u7ed3\u679c\uff1a 101
                          signFlag << 1   \u7ed3\u679c\uff1a1010
                          1010 != signFlag\uff081011\uff09 \u7ed3\u679c\uff1atrue  \/\/4\u53f7\u5df2\u7b7e\u5230\uff0c\u8bf4\u660e\u8fde\u7eed\u7b7e\u52301\u5929
                          signFlag >>= 1  \u7ed3\u679c\uff1a 101   \/\/ \u6b64\u65f6signFlag = 101
                          <\/code>\u7b2c\u4e8c\u6b21\u5faa\u73afsignFlag = 101  \/\/ \u524d\u4e00\u6b21\u5faa\u73af\u8ba1\u7b97\u7684\u7ed3\u679c
                          signFlag >> 1   \u7ed3\u679c\uff1a 10
                          signFlag << 1   \u7ed3\u679c\uff1a100
                          100 != signFlag\uff08101\uff09 \u7ed3\u679c\uff1atrue  \/\/3\u53f7\u5df2\u7b7e\u5230\uff0c\u8bf4\u660e\u8fde\u7eed\u7b7e\u52302\u5929
                          signFlag >>= 1  \u7ed3\u679c\uff1a 10   \/\/ \u6b64\u65f6signFlag = 10
                          <\/code>\u7b2c\u4e09\u6b21\u5faa\u73afsignFlag = 10  \/\/ \u524d\u4e00\u6b21\u5faa\u73af\u8ba1\u7b97\u7684\u7ed3\u679c
                          signFlag >> 1   \u7ed3\u679c\uff1a 1
                          signFlag << 1   \u7ed3\u679c\uff1a10
                          10 != signFlag\uff0810\uff09 \u7ed3\u679c\uff1afalse  \/\/2\u53f7\u672a\u7b7e\u5230\uff0c\u8bf4\u660e\u8fde\u7eed\u7b7e\u5230\u4ece\u8fd9\u91cc\u5c31\u65ad\u4e86 
                          signFlag >>= 1  \u7ed3\u679c\uff1a 1   \/\/ \u6b64\u65f6signFlag = 1
                          <\/code>\u5230\u8fd9\u4e00\u6b65\uff0c\u9047\u5230\u7b2c\u4e00\u4e2afalse\uff0c\u8bf4\u660e\u8fde\u7eed\u7b7e\u5230\u4e2d\u65ad\uff1b\u7b2c\u56db\u6b21\u5faa\u73af\uff1asignFlag = 1  \/\/ \u524d\u4e00\u6b21\u5faa\u73af\u8ba1\u7b97\u7684\u7ed3\u679c
                          signFlag >> 1   \u7ed3\u679c\uff1a 0
                          signFlag << 1   \u7ed3\u679c\uff1a 0
                          0 != signFlag\uff081\uff09 \u7ed3\u679c\uff1atrue  \/\/1\u53f7\u5df2\u7b7e\u5230
                          <\/code>\u5230\u6b64\uff0c\u6839\u636eBITFIELD<\/code>\u83b7\u53d6\u51fa\u676511\uff08\u5341\u8fdb\u5236\uff09\uff0c\u5c31\u80fd\u5f97\u52301\u30013\u30014\u53f7\u5df2\u7b7e\u5230\uff0c2\u53f7\u672a\u7b7e\u5230\uff1b\u8fde\u7eed\u7b7e\u52302\u5929\uff1b<\/li>\n<\/ul>\n\n\n\n
                          \u7406\u89e3\u4e0a\u9762\u7684\u903b\u8f91\u4e4b\u540e\uff0c\u518d\u6765\u770b\u4e0b\u9762\u7684SpringBoot\u4ee3\u7801\uff0c\u5c31\u4f1a\u5bb9\u6613\u5f88\u591a\u4e86\uff1b<\/p>\n\n\n\n
                          SpringBoot\u5b9e\u73b0\u7b7e\u5230<\/h3>\n\n\n\n
                          \u7b7e\u5230\u7684\u65b9\u5f0f\u4e00\u822c\u5c31\u4e24\u79cd\uff0c\u6309\u6708\uff08\u5468\uff09\/ \u81ea\u5b9a\u4e49\u5468\u671f\uff0c\u4e0b\u9762\u5c06\u4e24\u79cd\u65b9\u5f0f\u7684\u7b7e\u5230\u5168\u90e8\u5217\u4e3e\u51fa\u6765\uff0c\u4ee5\u4f9b\u5927\u5bb6\u53c2\u8003\uff1a<\/p>\n\n\n\n
                          \u6309\u6708\u7b7e\u5230<\/h4>\n\n\n\n
                          \u7b7e\u5230\u5de5\u5177\u7c7b\uff1a<\/p>\n\n\n\n
                          import lombok.extern.slf4j.Slf4j;
                          import org.joda.time.DateTime;
                          import org.joda.time.format.DateTimeFormat;
                          import org.joda.time.format.DateTimeFormatter;
                          import org.springframework.beans.factory.annotation.Autowired;
                          import org.springframework.data.redis.connection.BitFieldSubCommands;
                          import org.springframework.data.redis.core.RedisCallback;
                          import org.springframework.data.redis.core.StringRedisTemplate;
                          import org.springframework.stereotype.Service;
                          import org.springframework.util.CollectionUtils;

                          import java.util.HashMap;
                          import java.util.List;
                          import java.util.Map;

                          \/**
                           * @author<\/strong> \u4e00\u884cJava
                           * @title<\/strong>: \u6309\u6708\u7b7e\u5230
                           * @projectName<\/strong> ehang-spring-boot
                           * @description<\/strong>: TODO
                           * @date<\/strong> 2022\/7\/18 18:28
                           *\/
                          @Slf4j
                          @Service
                          public class SignByMonthServiceImpl {

                              @Autowired
                              StringRedisTemplate stringRedisTemplate;

                              private int dayOfMonth() {
                                  DateTime dateTime = new DateTime();
                                  return dateTime.dayOfMonth().get();
                              }

                              \/**
                               * \u6309\u7167\u6708\u4efd\u548c\u7528\u6237ID\u751f\u6210\u7528\u6237\u7b7e\u5230\u6807\u8bc6 UserId:Sign:560:2021-08
                               *
                               * @param<\/strong> userId \u7528\u6237id
                               * @return<\/strong>
                               *\/
                              private String signKeyWitMouth(String userId) {
                                  DateTime dateTime = new DateTime();
                                  DateTimeFormatter fmt = DateTimeFormat.forPattern(\"yyyy-MM\");

                                  StringBuilder builder = new StringBuilder(\"UserId:Sign:\");
                                  builder.append(userId).append(\":\")
                                          .append(dateTime.toString(fmt));
                                  return builder.toString();
                              }

                              \/**
                               * \u8bbe\u7f6e\u6807\u8bb0\u4f4d
                               * \u6807\u8bb0\u662f\u5426\u7b7e\u5230
                               *
                               * @param<\/strong> key
                               * @param<\/strong> offset
                               * @param<\/strong> tag
                               * @return<\/strong>
                               *\/
                              public Boolean sign(String key, long offset, boolean tag) {
                                  return this.stringRedisTemplate.opsForValue().setBit(key, offset, tag);
                              }


                              \/**
                               * \u7edf\u8ba1\u8ba1\u6570
                               *
                               * @param<\/strong> key \u7528\u6237\u6807\u8bc6
                               * @return<\/strong>
                               *\/
                              public long bitCount(String key) {
                                  return stringRedisTemplate.execute((RedisCallback<Long>) redisConnection -> redisConnection.bitCount(key.getBytes()));
                              }

                              \/**
                               * \u83b7\u53d6\u591a\u5b57\u8282\u4f4d\u57df
                               *\/
                              public List<Long> bitfield(String buildSignKey, int limit, long offset) {
                                  return this.stringRedisTemplate
                                          .opsForValue()
                                          .bitField(buildSignKey, BitFieldSubCommands.create().get(BitFieldSubCommands.BitFieldType.unsigned(limit)).valueAt(offset));
                              }


                              \/**
                               * \u5224\u65ad\u662f\u5426\u88ab\u6807\u8bb0
                               *
                               * @param<\/strong> key
                               * @param<\/strong> offest
                               * @return<\/strong>
                               *\/
                              public Boolean container(String key, long offest) {
                                  return this.stringRedisTemplate.opsForValue().getBit(key, offest);
                              }


                              \/**
                               * \u7528\u6237\u4eca\u5929\u662f\u5426\u7b7e\u5230
                               *
                               * @param<\/strong> userId
                               * @return<\/strong>
                               *\/
                              public int checkSign(String userId) {
                                  DateTime dateTime = new DateTime();

                                  String signKey = this.signKeyWitMouth(userId);
                                  int offset = dateTime.getDayOfMonth() - 1;
                                  int value = this.container(signKey, offset) ? 1 : 0;
                                  return value;
                              }


                              \/**
                               * \u67e5\u8be2\u7528\u6237\u5f53\u6708\u7b7e\u5230\u65e5\u5386
                               *
                               * @param<\/strong> userId
                               * @return<\/strong>
                               *\/
                              public Map<String, Boolean> querySignedInMonth(String userId) {
                                  DateTime dateTime = new DateTime();
                                  int lengthOfMonth = dateTime.dayOfMonth().getMaximumValue();
                                  Map<String, Boolean> signedInMap = new HashMap<>(dateTime.getDayOfMonth());

                                  String signKey = this.signKeyWitMouth(userId);
                                  List<Long> bitfield = this.bitfield(signKey, lengthOfMonth, 0);
                                  if (!CollectionUtils.isEmpty(bitfield)) {
                                      long signFlag = bitfield.get(0) == null ? 0 : bitfield.get(0);

                                      DateTimeFormatter fmt = DateTimeFormat.forPattern(\"yyyy-MM-dd\");
                                      for (int i = lengthOfMonth; i > 0; i--) {

                                          DateTime dateTime1 = dateTime.withDayOfMonth(i);
                                          signedInMap.put(dateTime1.toString(fmt), signFlag >> 1 << 1 != signFlag);
                                          signFlag >>= 1;
                                      }
                                  }
                                  return signedInMap;
                              }


                              \/**
                               * \u7528\u6237\u7b7e\u5230
                               *
                               * @param<\/strong> userId
                               * @return<\/strong>
                               *\/
                              public boolean signWithUserId(String userId) {
                                  int dayOfMonth = this.dayOfMonth();
                                  String signKey = this.signKeyWitMouth(userId);
                                  long offset = (long) dayOfMonth - 1;
                                  boolean re = false;
                                  if (Boolean.TRUE.equals(this.sign(signKey, offset, Boolean.TRUE))) {
                                      re = true;
                                  }

                                  \/\/ \u67e5\u8be2\u7528\u6237\u8fde\u7eed\u7b7e\u5230\u6b21\u6570,\u6700\u5927\u8fde\u7eed\u6b21\u6570\u4e3a7\u5929
                                  long continuousSignCount = this.queryContinuousSignCount(userId, 7);
                                  return re;
                              }

                              \/**
                               * \u7edf\u8ba1\u5f53\u524d\u6708\u4efd\u4e00\u5171\u7b7e\u5230\u5929\u6570
                               *
                               * @param<\/strong> userId
                               *\/
                              public long countSignedInDayOfMonth(String userId) {
                                  String signKey = this.signKeyWitMouth(userId);
                                  return this.bitCount(signKey);
                              }


                              \/**
                               * \u67e5\u8be2\u7528\u6237\u5f53\u6708\u8fde\u7eed\u7b7e\u5230\u6b21\u6570
                               *
                               * @param<\/strong> userId
                               * @return<\/strong>
                               *\/
                              public long queryContinuousSignCountOfMonth(String userId) {
                                  int signCount = 0;
                                  String signKey = this.signKeyWitMouth(userId);
                                  int dayOfMonth = this.dayOfMonth();
                                  List<Long> bitfield = this.bitfield(signKey, dayOfMonth, 0);

                                  if (!CollectionUtils.isEmpty(bitfield)) {
                                      long signFlag = bitfield.get(0) == null ? 0 : bitfield.get(0);
                                      DateTime dateTime = new DateTime();
                                      \/\/ \u8fde\u7eed\u4e0d\u4e3a0\u5373\u4e3a\u8fde\u7eed\u7b7e\u5230\u6b21\u6570\uff0c\u5f53\u5929\u672a\u7b7e\u5230\u60c5\u51b5\u4e0b
                                      for (int i = 0; i < dateTime.getDayOfMonth(); i++) {
                                          if (signFlag >> 1 << 1 == signFlag) {
                                              if (i > 0) break;
                                          } else {
                                              signCount += 1;
                                          }
                                          signFlag >>= 1;
                                      }
                                  }
                                  return signCount;
                              }


                              \/**
                               * \u4ee57\u5929\u4e00\u4e2a\u5468\u671f\u8fde\u7eed\u7b7e\u5230\u6b21\u6570
                               *
                               * @param<\/strong> period \u5468\u671f
                               * @return<\/strong>
                               *\/
                              public long queryContinuousSignCount(String userId, Integer period) {
                                  \/\/\u67e5\u8be2\u76ee\u524d\u8fde\u7eed\u7b7e\u5230\u6b21\u6570
                                  long count = this.queryContinuousSignCountOfMonth(userId);
                                  \/\/\u6309\u6700\u5927\u8fde\u7eed\u7b7e\u5230\u53d6\u4f59
                                  if (period != null && period < count) {
                                      long num = count % period;
                                      if (num == 0) {
                                          count = period;
                                      } else {
                                          count = num;
                                      }
                                  }
                                  return count;
                              }
                          }<\/code><\/pre>\n\n\n\n
                          \u6d4b\u8bd5\u7c7b\uff1a<\/p>\n\n\n\n
                          import lombok.extern.slf4j.Slf4j;
                          import org.junit.jupiter.api.Test;
                          import org.springframework.beans.factory.annotation.Autowired;
                          import org.springframework.boot.test.context.SpringBootTest;
                          import org.springframework.data.redis.core.StringRedisTemplate;

                          import java.util.Map;

                          \/**
                           * @author<\/strong> \u4e00\u884cJava
                           * @title<\/strong>: SignTest2
                           * @projectName<\/strong> ehang-spring-boot
                           * @description<\/strong>: TODO
                           * @date<\/strong> 2022\/7\/19 12:06
                           *\/
                          @SpringBootTest
                          @Slf4j
                          public class SignTest2 {
                              @Autowired
                              private SignByMonthServiceImpl signByMonthService;

                              @Autowired
                              private StringRedisTemplate redisTemplate;

                              \/**
                               * \u6d4b\u8bd5\u7528\u6237\u6309\u6708\u7b7e\u5230
                               *\/
                              @Test
                              public void querySignDay() {
                                  \/\/\u6a21\u62df\u7528\u6237\u7b7e\u5230
                                  \/\/for(int i=5;i<19;i++){
                                  redisTemplate.opsForValue().setBit(\"UserId:Sign:560:2022-08\", 0, true);
                                  \/\/}

                                  System.out.println(\"560\u7528\u6237\u4eca\u65e5\u662f\u5426\u5df2\u7b7e\u5230:\" + this.signByMonthService.checkSign(\"560\"));
                                  Map<String, Boolean> stringBooleanMap = this.signByMonthService.querySignedInMonth(\"560\");
                                  System.out.println(\"\u672c\u6708\u7b7e\u5230\u60c5\u51b5:\");
                                  for (Map.Entry<String, Boolean> entry : stringBooleanMap.entrySet()) {
                                      System.out.println(entry.getKey() + \": \" + (entry.getValue() ? \"\u221a\" : \"-\"));
                                  }
                                  long countSignedInDayOfMonth = this.signByMonthService.countSignedInDayOfMonth(\"560\");
                                  System.out.println(\"\u672c\u6708\u4e00\u5171\u7b7e\u5230:\" + countSignedInDayOfMonth + \"\u5929\");
                                  System.out.println(\"\u76ee\u524d\u8fde\u7eed\u7b7e\u5230:\" + this.signByMonthService.queryContinuousSignCount(\"560\", 7) + \"\u5929\");
                              }
                          }<\/code><\/pre>\n\n\n\n
                          \u6267\u884c\u65e5\u5fd7\uff1a<\/p>\n\n\n\n
                          c.e.r.bitmap_sign_by_month.SignTest2     : 560\u7528\u6237\u4eca\u65e5\u662f\u5426\u5df2\u7b7e\u5230:0
                          c.e.r.bitmap_sign_by_month.SignTest2     : \u672c\u6708\u7b7e\u5230\u60c5\u51b5:
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-12: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-11: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-10: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-31: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-30: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-19: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-18: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-17: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-16: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-15: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-14: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-13: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-23: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-01: \u221a
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-22: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-21: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-20: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-09: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-08: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-29: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-07: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-28: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-06: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-27: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-05: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-26: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-04: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-25: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-03: \u221a
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-24: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : 2022-08-02: -
                          c.e.r.bitmap_sign_by_month.SignTest2     : \u672c\u6708\u4e00\u5171\u7b7e\u5230:2\u5929
                          c.e.r.bitmap_sign_by_month.SignTest2     : \u76ee\u524d\u8fde\u7eed\u7b7e\u5230:1\u5929<\/code><\/pre>\n\n\n\n
                          \u6307\u5b9a\u65f6\u95f4\u7b7e\u5230<\/h4>\n\n\n\n
                          \u7b7e\u5230\u5de5\u5177\u7c7b\uff1a<\/p>\n\n\n\n
                          package com.ehang.redis.bitmap_sign_by_range;

                          import lombok.extern.slf4j.Slf4j;
                          import org.joda.time.DateTime;
                          import org.springframework.beans.factory.annotation.Autowired;
                          import org.springframework.data.redis.connection.BitFieldSubCommands;
                          import org.springframework.data.redis.core.RedisCallback;
                          import org.springframework.data.redis.core.StringRedisTemplate;
                          import org.springframework.stereotype.Service;
                          import org.springframework.util.CollectionUtils;

                          import java.time.LocalDateTime;
                          import java.time.format.DateTimeFormatter;
                          import java.util.HashMap;
                          import java.util.List;
                          import java.util.Map;

                          \/**
                           * @author<\/strong> \u4e00\u884cJava
                           * @title<\/strong>: SignByRangeServiceImpl
                           * @projectName<\/strong> ehang-spring-boot
                           * @description<\/strong>: TODO
                           * @date<\/strong> 2022\/7\/19 12:27
                           *\/
                          @Slf4j
                          @Service
                          public class SignByRangeServiceImpl {

                              @Autowired
                              StringRedisTemplate stringRedisTemplate;

                              \/**
                               * \u6839\u636e\u533a\u95f4\u7684id \u4ee5\u53ca\u7528\u6237id \u62fc\u63a5key
                               *
                               * @param<\/strong> rangeId \u533a\u95f4ID \u4e00\u822c\u662f\u6307\u5b9a\u6d3b\u52a8\u7684ID\u7b49
                               * @param<\/strong> userId  \u7528\u6237\u7684ID
                               * @return<\/strong>
                               *\/
                              private String signKey(Integer rangeId, Integer userId) {
                                  StringBuilder builder = new StringBuilder(\"RangeId:Sign:\");
                                  builder.append(rangeId).append(\":\")
                                          .append(userId);
                                  return builder.toString();
                              }

                              \/**
                               * \u83b7\u53d6\u5f53\u524d\u65f6\u95f4\u4e0e\u8d77\u59cb\u65f6\u95f4\u7684\u95f4\u9694\u5929\u6570
                               *
                               * @param<\/strong> start \u8d77\u59cb\u65f6\u95f4
                               * @return<\/strong>
                               *\/
                              private int intervalTime(LocalDateTime start) {
                                  return (int) (LocalDateTime.now().toLocalDate().toEpochDay() - start.toLocalDate().toEpochDay());
                              }

                              \/**
                               * \u8bbe\u7f6e\u6807\u8bb0\u4f4d
                               * \u6807\u8bb0\u662f\u5426\u7b7e\u5230
                               *
                               * @param<\/strong> key    \u7b7e\u5230\u7684key
                               * @param<\/strong> offset \u504f\u79fb\u91cf \u4e00\u822c\u662f\u6307\u5f53\u524d\u65f6\u95f4\u79bb\u8d77\u59cb\u65f6\u95f4\uff08\u6d3b\u52a8\u5f00\u59cb\uff09\u7684\u5929\u6570
                               * @param<\/strong> tag    \u662f\u5426\u7b7e\u5230  true:\u7b7e\u5230  false:\u672a\u7b7e\u5230
                               * @return<\/strong>
                               *\/
                              private Boolean setBit(String key, long offset, boolean tag) {
                                  return this.stringRedisTemplate.opsForValue().setBit(key, offset, tag);
                              }

                              \/**
                               * \u7edf\u8ba1\u8ba1\u6570
                               *
                               * @param<\/strong> key \u7edf\u8ba1\u7684key
                               * @return<\/strong>
                               *\/
                              private long bitCount(String key) {
                                  return stringRedisTemplate.execute((RedisCallback<Long>) redisConnection -> redisConnection.bitCount(key.getBytes()));
                              }

                              \/**
                               * \u83b7\u53d6\u591a\u5b57\u8282\u4f4d\u57df
                               *
                               * @param<\/strong> key    \u7f13\u5b58\u7684key
                               * @param<\/strong> limit  \u83b7\u53d6\u591a\u5c11
                               * @param<\/strong> offset \u504f\u79fb\u91cf\u662f\u591a\u5c11
                               * @return<\/strong>
                               *\/
                              private List<Long> bitfield(String key, int limit, long offset) {
                                  return this.stringRedisTemplate
                                          .opsForValue()
                                          .bitField(key, BitFieldSubCommands.create().get(BitFieldSubCommands.BitFieldType.unsigned(limit)).valueAt(offset));
                              }

                              \/**
                               * \u5224\u65ad\u662f\u5426\u7b7e\u5230
                               *
                               * @param<\/strong> key    \u7f13\u5b58\u7684key
                               * @param<\/strong> offest \u504f\u79fb\u91cf \u6307\u5f53\u524d\u65f6\u95f4\u8ddd\u79bb\u8d77\u59cb\u65f6\u95f4\u7684\u5929\u6570
                               * @return<\/strong>
                               *\/
                              private Boolean container(String key, long offest) {
                                  return this.stringRedisTemplate.opsForValue().getBit(key, offest);
                              }

                              \/**
                               * \u6839\u636e\u8d77\u59cb\u65f6\u95f4\u8fdb\u884c\u7b7e\u5230
                               *
                               * @param<\/strong> rangeId
                               * @param<\/strong> userId
                               * @param<\/strong> start
                               * @return<\/strong>
                               *\/
                              public Boolean sign(Integer rangeId, Integer userId, LocalDateTime start) {
                                  int offset = intervalTime(start);
                                  String key = signKey(rangeId, userId);
                                  return setBit(key, offset, true);
                              }

                              \/**
                               * \u6839\u636e\u504f\u79fb\u91cf\u7b7e\u5230
                               *
                               * @param<\/strong> rangeId
                               * @param<\/strong> userId
                               * @param<\/strong> offset
                               * @return<\/strong>
                               *\/
                              public Boolean sign(Integer rangeId, Integer userId, long offset) {
                                  String key = signKey(rangeId, userId);
                                  return setBit(key, offset, true);
                              }

                              \/**
                               * \u7528\u6237\u4eca\u5929\u662f\u5426\u7b7e\u5230
                               *
                               * @param<\/strong> userId
                               * @return<\/strong>
                               *\/
                              public Boolean checkSign(Integer rangeId, Integer userId, LocalDateTime start) {
                                  long offset = intervalTime(start);
                                  String key = this.signKey(rangeId, userId);
                                  return this.container(key, offset);
                              }

                              \/**
                               * \u7edf\u8ba1\u5f53\u524d\u6708\u4efd\u4e00\u5171\u7b7e\u5230\u5929\u6570
                               *
                               * @param<\/strong> userId
                               *\/
                              public long countSigned(Integer rangeId, Integer userId) {
                                  String signKey = this.signKey(rangeId, userId);
                                  return this.bitCount(signKey);
                              }

                              public Map<String, Boolean> querySigned(Integer rangeId, Integer userId, LocalDateTime start) {
                                  int days = intervalTime(start);
                                  Map<String, Boolean> signedInMap = new HashMap<>(days);

                                  String signKey = this.signKey(rangeId, userId);
                                  List<Long> bitfield = this.bitfield(signKey, days + 1, 0);
                                  if (!CollectionUtils.isEmpty(bitfield)) {
                                      long signFlag = bitfield.get(0) == null ? 0 : bitfield.get(0);

                                      DateTimeFormatter fmt = DateTimeFormatter.ofPattern(\"yyyy-MM-dd\");
                                      for (int i = days; i >= 0; i--) {
                                          LocalDateTime localDateTime = start.plusDays(i);
                                          signedInMap.put(localDateTime.format(fmt), signFlag >> 1 << 1 != signFlag);
                                          signFlag >>= 1;
                                      }
                                  }
                                  return signedInMap;
                              }

                              \/**
                               * \u67e5\u8be2\u7528\u6237\u5f53\u6708\u8fde\u7eed\u7b7e\u5230\u6b21\u6570
                               *
                               * @param<\/strong> userId
                               * @return<\/strong>
                               *\/
                              public long queryContinuousSignCount(Integer rangeId, Integer userId, LocalDateTime start) {
                                  int signCount = 0;
                                  String signKey = this.signKey(rangeId, userId);
                                  int days = this.intervalTime(start);
                                  List<Long> bitfield = this.bitfield(signKey, days + 1, 0);

                                  if (!CollectionUtils.isEmpty(bitfield)) {
                                      long signFlag = bitfield.get(0) == null ? 0 : bitfield.get(0);
                                      DateTime dateTime = new DateTime();
                                      \/\/ \u8fde\u7eed\u4e0d\u4e3a0\u5373\u4e3a\u8fde\u7eed\u7b7e\u5230\u6b21\u6570\uff0c\u5f53\u5929\u672a\u7b7e\u5230\u60c5\u51b5\u4e0b
                                      for (int i = 0; i < dateTime.getDayOfMonth(); i++) {
                                          if (signFlag >> 1 << 1 == signFlag) {
                                              if (i > 0) break;
                                          } else {
                                              signCount += 1;
                                          }
                                          signFlag >>= 1;
                                      }
                                  }
                                  return signCount;
                              }
                          }<\/code><\/pre>\n\n\n\n
                          \u6d4b\u8bd5\u5de5\u5177\u7c7b\uff1a<\/p>\n\n\n\n
                          package com.ehang.redis.bitmap_sign_by_range;

                          import lombok.extern.slf4j.Slf4j;
                          import org.junit.jupiter.api.Test;
                          import org.springframework.beans.factory.annotation.Autowired;
                          import org.springframework.boot.test.context.SpringBootTest;

                          import java.time.LocalDateTime;
                          import java.time.format.DateTimeFormatter;
                          import java.util.Map;

                          \/**
                           * @author<\/strong> \u4e00\u884cJava
                           * @title<\/strong>: SignTest
                           * @projectName<\/strong> ehang-spring-boot
                           * @description<\/strong>: TODO
                           * @date<\/strong> 2022\/7\/18 16:11
                           *\/
                          @SpringBootTest
                          @Slf4j
                          public class SignTest {
                              @Autowired
                              SignByRangeServiceImpl signByRangeService;


                              @Test
                              void test() {
                                  DateTimeFormatter isoDateTime = DateTimeFormatter.ISO_DATE_TIME;
                                  \/\/ \u6d3b\u52a8\u5f00\u59cb\u65f6\u95f4
                                  LocalDateTime start = LocalDateTime.of(2022, 8, 1, 1, 0, 0);
                                  Integer rangeId = 1;
                                  Integer userId = 8899;
                                  log.info(\"\u7b7e\u5230\u5f00\u59cb\u65f6\u95f4: {}\", start.format(isoDateTime));
                                  log.info(\"\u6d3b\u52a8ID: {} \u7528\u6237ID: {}\", rangeId, userId);

                                  \/\/ \u624b\u52a8\u6307\u5b9a\u504f\u79fb\u91cf\u7b7e\u5230
                                  signByRangeService.sign(rangeId, userId, 0);

                                  \/\/ \u5224\u65ad\u662f\u5426\u7b7e\u5230
                                  Boolean signed = signByRangeService.checkSign(rangeId, userId, start);
                                  log.info(\"\u4eca\u65e5\u662f\u5426\u7b7e\u5230: {}\", signed ? \"\u221a\" : \"-\");

                                  \/\/ \u7b7e\u5230
                                  Boolean sign = signByRangeService.sign(rangeId, userId, start);
                                  log.info(\"\u7b7e\u5230\u64cd\u4f5c\u4e4b\u524d\u7684\u7b7e\u5230\u72b6\u6001\uff1a{} \uff08-\uff1a\u8868\u793a\u4eca\u65e5\u7b2c\u4e00\u6b21\u7b7e\u5230\uff0c\u221a\uff1a\u8868\u793a\u4eca\u5929\u5df2\u7ecf\u7b7e\u5230\u8fc7\u4e86\uff09\", sign ? \"\u221a\" : \"-\");

                                  \/\/ \u7b7e\u5230\u603b\u6570
                                  long countSigned = signByRangeService.countSigned(rangeId, userId);
                                  log.info(\"\u603b\u5171\u7b7e\u5230: {} \u5929\", countSigned);

                                  \/\/ \u8fde\u7eed\u7b7e\u5230\u7684\u6b21\u6570
                                  long continuousSignCount = signByRangeService.queryContinuousSignCount(rangeId, userId, start);
                                  log.info(\"\u8fde\u7eed\u7b7e\u5230: {} \u5929\", continuousSignCount);

                                  \/\/ \u7b7e\u5230\u7684\u8be6\u60c5
                                  Map<String, Boolean> stringBooleanMap = signByRangeService.querySigned(rangeId, userId, start);
                                  for (Map.Entry<String, Boolean> entry : stringBooleanMap.entrySet()) {
                                      log.info(\"\u7b7e\u5230\u8be6\u60c5> {} : {}\", entry.getKey(), (entry.getValue() ? \"\u221a\" : \"-\"));
                                  }
                              }
                          }<\/code><\/pre>\n\n\n\n
                          \u8f93\u51fa\u65e5\u5fd7\uff1a<\/p>\n\n\n\n
                          \u7b7e\u5230\u5f00\u59cb\u65f6\u95f4: 2022-08-01T01:00:00
                          \u6d3b\u52a8ID: 1 \u7528\u6237ID: 8899
                          \u4eca\u65e5\u662f\u5426\u7b7e\u5230: \u221a
                          \u7b7e\u5230\u64cd\u4f5c\u4e4b\u524d\u7684\u7b7e\u5230\u72b6\u6001\uff1a\u221a \uff08-\uff1a\u8868\u793a\u4eca\u65e5\u7b2c\u4e00\u6b21\u7b7e\u5230\uff0c\u221a\uff1a\u8868\u793a\u4eca\u5929\u5df2\u7ecf\u7b7e\u5230\u8fc7\u4e86\uff09
                          \u603b\u5171\u7b7e\u5230: 3 \u5929
                          \u8fde\u7eed\u7b7e\u5230: 2 \u5929
                          \u7b7e\u5230\u8be6\u60c5> 2022-08-01 : \u221a
                          \u7b7e\u5230\u8be6\u60c5> 2022-08-04 : \u221a
                          \u7b7e\u5230\u8be6\u60c5> 2022-08-03 : \u221a
                          \u7b7e\u5230\u8be6\u60c5> 2022-08-02 : -<\/code><\/pre>\n\n\n\n
                          9GEO\u641c\u9644\u8fd1<\/h2>\n\n\n\n
                          \u5f88\u591a\u751f\u6d3b\u7c7b\u7684APP\u90fd\u5177\u5907\u4e00\u4e2a\u641c\u7d22\u9644\u8fd1\u7684\u529f\u80fd\uff0c\u6bd4\u5982\u7f8e\u56e2\u641c\u7d22\u9644\u8fd1\u7684\u5546\u5bb6\uff1b<\/p>\n\n\n\n
                          \"\u56fe\u7247\"\/
                          \u7f51\u56fe<\/figcaption><\/figure>\n\n\n\n
                          \u5982\u679c\u81ea\u5df1\u60f3\u8981\u6839\u636e\u7ecf\u7eac\u5ea6\u6765\u5b9e\u73b0\u4e00\u4e2a\u641c\u7d22\u9644\u8fd1\u7684\u529f\u80fd\uff0c\u662f\u975e\u5e38\u9ebb\u70e6\u7684\uff1b\u4f46\u662fRedis \u57283.2\u7684\u7248\u672c\u65b0\u589e\u4e86Redis GEO\uff0c\u7528\u4e8e\u5b58\u50a8\u5730\u5740\u4f4d\u7f6e\u4fe1\u606f\uff0c\u5e76\u5bf9\u652f\u6301\u8303\u56f4\u641c\u7d22\uff1b\u57fa\u4e8eGEO\u5c31\u80fd\u8f7b\u677e\u4e14\u5feb\u901f\u7684\u5f00\u53d1\u4e00\u4e2a\u641c\u7d22\u9644\u8fd1\u7684\u529f\u80fd\uff1b<\/p>\n\n\n\n
                          GEO API \u53caRedis-cli \u64cd\u4f5c\uff1a<\/h3>\n\n\n\n
                            \n
                          • geoadd<\/strong>\uff1a\u65b0\u589e\u4f4d\u7f6e\u5750\u6807\u3002127.0.0.1:6379> GEOADD drinks 116.62445 39.86206 starbucks 117.3514785 38.7501247 yidiandian 116.538542 39.75412 xicha
                            (integer) 3<\/code><\/li>\n\n\n\n
                          • geopos<\/strong>\uff1a\u83b7\u53d6\u4f4d\u7f6e\u5750\u6807\u3002127.0.0.1:6379> GEOPOS drinks starbucks
                            1) 1) \"116.62445157766342163\"
                               2) \"39.86206038535793539\"
                            127.0.0.1:6379> GEOPOS drinks starbucks yidiandian mxbc
                            1) 1) \"116.62445157766342163\"
                               2) \"39.86206038535793539\"
                            2) 1) \"117.35148042440414429\"
                               2) \"38.75012383773680114\"
                            3) (nil)<\/code><\/li>\n\n\n\n
                          • geodist<\/strong>\uff1a\u8ba1\u7b97\u4e24\u4e2a\u4f4d\u7f6e\u4e4b\u95f4\u7684\u8ddd\u79bb\u3002\u5355\u4f4d\u53c2\u6570\uff1a127.0.0.1:6379> GEODIST drinks starbucks yidiandian
                            \"138602.4133\"
                            127.0.0.1:6379> GEODIST drinks starbucks xicha
                            \"14072.1255\"
                            127.0.0.1:6379> GEODIST drinks starbucks xicha m
                            \"14072.1255\"
                            127.0.0.1:6379> GEODIST drinks starbucks xicha km
                            \"14.0721\"<\/code>\n
                              \n
                            • m \uff1a\u7c73\uff0c\u9ed8\u8ba4\u5355\u4f4d\u3002<\/li>\n\n\n\n
                            • km \uff1a\u5343\u7c73\u3002<\/li>\n\n\n\n
                            • mi \uff1a\u82f1\u91cc\u3002<\/li>\n\n\n\n
                            • ft \uff1a\u82f1\u5c3a\u3002<\/li>\n<\/ul>\n<\/li>\n\n\n\n
                            • georadius<\/strong>\uff1a\u6839\u636e\u7528\u6237\u7ed9\u5b9a\u7684\u7ecf\u7eac\u5ea6\u5750\u6807\u6765\u83b7\u53d6\u6307\u5b9a\u8303\u56f4\u5185\u7684\u5730\u7406\u4f4d\u7f6e\u96c6\u5408\u3002\u53c2\u6570\u8bf4\u660e127.0.0.1:6379> GEORADIUS drinks 116 39 100 km WITHDIST
                              1) 1) \"xicha\"
                                 2) \"95.8085\"
                              127.0.0.1:6379> GEORADIUS drinks 116 39 100 km WITHDIST WITHCOORD
                              1) 1) \"xicha\"
                                 2) \"95.8085\"
                                 3) 1) \"116.53854042291641235\"
                                    2) \"39.75411928478748536\"
                              127.0.0.1:6379> GEORADIUS drinks 116 39 100 km WITHDIST WITHCOORD WITHHASH
                              1) 1) \"xicha\"
                                 2) \"95.8085\"
                                 3) (integer) 4069151800882301
                                 4) 1) \"116.53854042291641235\"
                                    2) \"39.75411928478748536\"

                              127.0.0.1:6379> GEORADIUS drinks 116 39 120 km WITHDIST WITHCOORD  COUNT 1
                              1) 1) \"xicha\"
                                 2) \"95.8085\"
                                 3) 1) \"116.53854042291641235\"
                                    2) \"39.75411928478748536\"

                              127.0.0.1:6379> GEORADIUS drinks 116 39 120 km WITHDIST WITHCOORD  COUNT 1 ASC
                              1) 1) \"xicha\"
                                 2) \"95.8085\"
                                 3) 1) \"116.53854042291641235\"
                                    2) \"39.75411928478748536\"

                              127.0.0.1:6379> GEORADIUS drinks 116 39 120 km WITHDIST WITHCOORD  COUNT 1 DESC
                              1) 1) \"starbucks\"
                                 2) \"109.8703\"
                                 3) 1) \"116.62445157766342163\"
                                    2) \"39.86206038535793539\"<\/code>\n
                                \n
                              • m \uff1a\u7c73\uff0c\u9ed8\u8ba4\u5355\u4f4d\u3002<\/li>\n\n\n\n
                              • km \uff1a\u5343\u7c73\u3002<\/li>\n\n\n\n
                              • mi \uff1a\u82f1\u91cc\u3002<\/li>\n\n\n\n
                              • ft \uff1a\u82f1\u5c3a\u3002<\/li>\n\n\n\n
                              • WITHDIST: \u5728\u8fd4\u56de\u4f4d\u7f6e\u5143\u7d20\u7684\u540c\u65f6\uff0c \u5c06\u4f4d\u7f6e\u5143\u7d20\u4e0e\u4e2d\u5fc3\u4e4b\u95f4\u7684\u8ddd\u79bb\u4e5f\u4e00\u5e76\u8fd4\u56de\u3002<\/li>\n\n\n\n
                              • WITHCOORD: \u5c06\u4f4d\u7f6e\u5143\u7d20\u7684\u7ecf\u5ea6\u548c\u7eac\u5ea6\u4e5f\u4e00\u5e76\u8fd4\u56de\u3002<\/li>\n\n\n\n
                              • WITHHASH: \u4ee5 52 \u4f4d\u6709\u7b26\u53f7\u6574\u6570\u7684\u5f62\u5f0f\uff0c \u8fd4\u56de\u4f4d\u7f6e\u5143\u7d20\u7ecf\u8fc7\u539f\u59cb geohash \u7f16\u7801\u7684\u6709\u5e8f\u96c6\u5408\u5206\u503c\u3002 \u8fd9\u4e2a\u9009\u9879\u4e3b\u8981\u7528\u4e8e\u5e95\u5c42\u5e94\u7528\u6216\u8005\u8c03\u8bd5\uff0c \u5b9e\u9645\u4e2d\u7684\u4f5c\u7528\u5e76\u4e0d\u5927\u3002<\/li>\n\n\n\n
                              • COUNT \u9650\u5b9a\u8fd4\u56de\u7684\u8bb0\u5f55\u6570\u3002<\/li>\n\n\n\n
                              • ASC: \u67e5\u627e\u7ed3\u679c\u6839\u636e\u8ddd\u79bb\u4ece\u8fd1\u5230\u8fdc\u6392\u5e8f\u3002<\/li>\n\n\n\n
                              • DESC: \u67e5\u627e\u7ed3\u679c\u6839\u636e\u4ece\u8fdc\u5230\u8fd1\u6392\u5e8f\u3002<\/li>\n<\/ul>\n<\/li>\n\n\n\n
                              • georadiusbymember<\/strong>\uff1a\u6839\u636e\u50a8\u5b58\u5728\u4f4d\u7f6e\u96c6\u5408\u91cc\u9762\u7684\u67d0\u4e2a\u5730\u70b9\u83b7\u53d6\u6307\u5b9a\u8303\u56f4\u5185\u7684\u5730\u7406\u4f4d\u7f6e\u96c6\u5408\u3002\u529f\u80fd\u548c\u4e0a\u9762\u7684georadius\u7c7b\u4f3c\uff0c\u53ea\u662fgeoradius\u662f\u4ee5\u7ecf\u7eac\u5ea6\u5750\u6807\u4e3a\u4e2d\u5fc3\uff0c\u8fd9\u4e2a\u662f\u4ee5\u67d0\u4e2a\u5730\u70b9\u4e3a\u4e2d\u5fc3\uff1b<\/li>\n\n\n\n
                              • geohash<\/strong>\uff1a\u8fd4\u56de\u4e00\u4e2a\u6216\u591a\u4e2a\u4f4d\u7f6e\u5bf9\u8c61\u7684 geohash \u503c\u3002127.0.0.1:6379> GEOHASH drinks starbucks xicha
                                1) \"wx4fvbem6d0\"
                                2) \"wx4f5vhb8b0\"<\/code><\/li>\n<\/ul>\n\n\n\n
                                SpringBoot \u64cd\u4f5c<\/h3>\n\n\n\n
                                \u901a\u8fc7SpringBoot\u64cd\u4f5cGEO\u7684\u793a\u4f8b\u5982\u4e0b<\/p>\n\n\n\n
                                import lombok.extern.slf4j.Slf4j;
                                import org.junit.jupiter.api.Test;
                                import org.springframework.beans.factory.annotation.Autowired;
                                import org.springframework.boot.test.context.SpringBootTest;
                                import org.springframework.data.geo.*;
                                import org.springframework.data.redis.connection.RedisGeoCommands;
                                import org.springframework.data.redis.core.RedisTemplate;

                                import java.util.List;

                                \/**
                                 * @author<\/strong> \u4e00\u884cJava
                                 * @title<\/strong>: GEOTest
                                 * @projectName<\/strong> ehang-spring-boot
                                 * @description<\/strong>: TODO
                                 * @date<\/strong> 2022\/7\/28 17:29
                                 *\/
                                @SpringBootTest
                                @Slf4j
                                public class GEOTest {
                                    private final String KEY = \"geo:drinks\";

                                    @Autowired
                                    RedisTemplate redisTemplate;

                                    @Test
                                    public void test() {
                                        add(\"starbucks\", new Point(116.62445, 39.86206));
                                        add(\"yidiandian\", new Point(117.3514785, 38.7501247));
                                        add(\"xicha\", new Point(116.538542, 39.75412));

                                        get(\"starbucks\", \"yidiandian\", \"xicha\");

                                        GeoResults nearByXY = getNearByXY(new Point(116, 39), new Distance(120, Metrics.KILOMETERS));
                                        List<GeoResult> content = nearByXY.getContent();
                                        for (GeoResult geoResult : content) {
                                            log.info(\"{}\", geoResult.getContent());
                                        }

                                        GeoResults nearByPlace = getNearByPlace(\"starbucks\", new Distance(120, Metrics.KILOMETERS));
                                        content = nearByPlace.getContent();
                                        for (GeoResult geoResult : content) {
                                            log.info(\"{}\", geoResult.getContent());
                                        }

                                        getGeoHash(\"starbucks\", \"yidiandian\", \"xicha\");

                                        del(\"yidiandian\", \"xicha\");
                                    }

                                    private void add(String name, Point point) {
                                        Long add = redisTemplate.opsForGeo().add(KEY, point, name);
                                        log.info(\"\u6210\u529f\u6dfb\u52a0\u540d\u79f0\uff1a{} \u7684\u5750\u6807\u4fe1\u606f\u4fe1\u606f\uff1a{}\", name, point);
                                    }


                                    private void get(String... names) {
                                        List<Point> position = redisTemplate.opsForGeo().position(KEY, names);
                                        log.info(\"\u83b7\u53d6\u540d\u79f0\u4e3a\uff1a{} \u7684\u5750\u6807\u4fe1\u606f\uff1a{}\", names, position);
                                    }

                                    private void del(String... names) {
                                        Long remove = redisTemplate.opsForGeo().remove(KEY, names);
                                        log.info(\"\u5220\u9664\u540d\u79f0\u4e3a\uff1a{} \u7684\u5750\u6807\u4fe1\u606f\u6570\u91cf\uff1a{}\", names, remove);
                                    }

                                    \/**
                                     * \u6839\u636e\u5750\u6807 \u83b7\u53d6\u6307\u5b9a\u8303\u56f4\u7684\u4f4d\u7f6e
                                     *
                                     * @param<\/strong> point
                                     * @param<\/strong> distance
                                     * @return<\/strong>
                                     *\/
                                    private GeoResults getNearByXY(Point point, Distance distance) {
                                        Circle circle = new Circle(point, distance);
                                        RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.
                                                newGeoRadiusArgs().
                                                includeDistance(). \/\/ \u5305\u542b\u8ddd\u79bb
                                                includeCoordinates(). \/\/ \u5305\u542b\u5750\u6807
                                                sortAscending(). \/\/ \u6392\u5e8f \u8fd8\u53ef\u9009sortDescending()
                                                limit(5); \/\/ \u83b7\u53d6\u524d\u591a\u5c11\u4e2a
                                        GeoResults geoResults = redisTemplate.opsForGeo().radius(KEY, circle, args);
                                        log.info(\"\u6839\u636e\u5750\u6807\u83b7\u53d6\uff1a{} {} \u8303\u56f4\u7684\u6570\u636e\uff1a{}\", point, distance, geoResults);
                                        return geoResults;
                                    }

                                    \/**
                                     * \u6839\u636e\u4e00\u4e2a\u4f4d\u7f6e\uff0c\u83b7\u53d6\u6307\u5b9a\u8303\u56f4\u5185\u7684\u5176\u4ed6\u4f4d\u7f6e
                                     *
                                     * @param<\/strong> name
                                     * @param<\/strong> distance
                                     * @return<\/strong>
                                     *\/
                                    private GeoResults getNearByPlace(String name, Distance distance) {
                                        RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.
                                                newGeoRadiusArgs().
                                                includeDistance(). \/\/ \u5305\u542b\u8ddd\u79bb
                                                includeCoordinates(). \/\/ \u5305\u542b\u5750\u6807
                                                sortAscending(). \/\/ \u6392\u5e8f \u8fd8\u53ef\u9009sortDescending()
                                                limit(5); \/\/ \u83b7\u53d6\u524d\u591a\u5c11\u4e2a
                                        GeoResults geoResults = redisTemplate.opsForGeo()
                                                .radius(KEY, name, distance, args);
                                        log.info(\"\u6839\u636e\u4f4d\u7f6e\uff1a{} \u83b7\u53d6\uff1a {} \u8303\u56f4\u7684\u6570\u636e\uff1a{}\", name, distance, geoResults);
                                        return geoResults;
                                    }

                                    \/**
                                     * \u83b7\u53d6GEO HASH
                                     *
                                     * @param<\/strong> names
                                     * @return<\/strong>
                                     *\/
                                    private List<String> getGeoHash(String... names) {
                                        List<String> hash = redisTemplate.opsForGeo().hash(KEY, names);
                                        log.info(\"names\uff1a{} \u5bf9\u5e94\u7684hash\uff1a{}\", names, hash);
                                        return hash;
                                    }
                                }<\/code><\/pre>\n\n\n\n
                                \u6267\u884c\u65e5\u5fd7\uff1a<\/p>\n\n\n\n
                                \u6210\u529f\u6dfb\u52a0\u540d\u79f0\uff1astarbucks \u7684\u5750\u6807\u4fe1\u606f\u4fe1\u606f\uff1aPoint [x=116.624450, y=39.862060]
                                \u6210\u529f\u6dfb\u52a0\u540d\u79f0\uff1ayidiandian \u7684\u5750\u6807\u4fe1\u606f\u4fe1\u606f\uff1aPoint [x=117.351479, y=38.750125]
                                \u6210\u529f\u6dfb\u52a0\u540d\u79f0\uff1axicha \u7684\u5750\u6807\u4fe1\u606f\u4fe1\u606f\uff1aPoint [x=116.538542, y=39.754120]

                                \u83b7\u53d6\u540d\u79f0\u4e3a\uff1a[starbucks, yidiandian, xicha] \u7684\u5750\u6807\u4fe1\u606f\uff1a[Point [x=116.624452, y=39.862060], Point [x=117.351480, y=38.750124], Point [x=116.538540, y=39.754119]]

                                \u6839\u636e\u5750\u6807\u83b7\u53d6\uff1aPoint [x=116.000000, y=39.000000] 120.0 KILOMETERS \u8303\u56f4\u7684\u6570\u636e\uff1aGeoResults: [averageDistance: 102.8394 KILOMETERS, results: GeoResult [content: RedisGeoCommands.GeoLocation(name=xicha, point=Point [x=116.538540, y=39.754119]), distance: 95.8085 KILOMETERS, ],GeoResult [content: RedisGeoCommands.GeoLocation(name=starbucks, point=Point [x=116.624452, y=39.862060]), distance: 109.8703 KILOMETERS, ]]
                                RedisGeoCommands.GeoLocation(name=xicha, point=Point [x=116.538540, y=39.754119])
                                RedisGeoCommands.GeoLocation(name=starbucks, point=Point [x=116.624452, y=39.862060])

                                \u6839\u636e\u4f4d\u7f6e\uff1astarbucks \u83b7\u53d6\uff1a 120.0 KILOMETERS \u8303\u56f4\u7684\u6570\u636e\uff1aGeoResults: [averageDistance: 7.03605 KILOMETERS, results: GeoResult [content: RedisGeoCommands.GeoLocation(name=starbucks, point=Point [x=116.624452, y=39.862060]), distance: 0.0 KILOMETERS, ],GeoResult [content: RedisGeoCommands.GeoLocation(name=xicha, point=Point [x=116.538540, y=39.754119]), distance: 14.0721 KILOMETERS, ]]
                                RedisGeoCommands.GeoLocation(name=starbucks, point=Point [x=116.624452, y=39.862060])
                                RedisGeoCommands.GeoLocation(name=xicha, point=Point [x=116.538540, y=39.754119])

                                names\uff1a[starbucks, yidiandian, xicha] \u5bf9\u5e94\u7684hash\uff1a[wx4fvbem6d0, wwgkqqhxzd0, wx4f5vhb8b0]

                                \u5220\u9664\u540d\u79f0\u4e3a\uff1a[yidiandian, xicha] \u7684\u5750\u6807\u4fe1\u606f\u6570\u91cf\uff1a2<\/code><\/pre>\n\n\n\n
                                10\u7b80\u5355\u9650\u6d41<\/h2>\n\n\n\n
                                \u4e3a\u4e86\u4fdd\u8bc1\u9879\u76ee\u7684\u5b89\u5168\u7a33\u5b9a\u8fd0\u884c\uff0c\u9632\u6b62\u88ab\u6076\u610f\u7684\u7528\u6237\u6216\u8005\u5f02\u5e38\u7684\u6d41\u91cf\u6253\u57ae\u6574\u4e2a\u7cfb\u7edf\uff0c\u4e00\u822c\u90fd\u4f1a\u52a0\u4e0a\u9650\u6d41\uff0c\u6bd4\u5982\u5e38\u89c1\u7684sential<\/code>\u3001hystrix<\/code>\uff0c\u90fd\u662f\u5b9e\u73b0\u9650\u6d41\u63a7\u5236\uff1b\u5982\u679c\u9879\u76ee\u7528\u5230\u4e86Redis\uff0c\u4e5f\u53ef\u4ee5\u5229\u7528Redis\uff0c\u6765\u5b9e\u73b0\u4e00\u4e2a\u7b80\u5355\u7684\u9650\u6d41\u529f\u80fd\uff1b<\/p>\n\n\n\n
                                \u529f\u80fd\u6240\u9700\u547d\u4ee4<\/p>\n\n\n\n
                                  \n
                                • INCR<\/strong>\uff1a\u5c06 key \u4e2d\u50a8\u5b58\u7684\u6570\u5b57\u503c\u589e\u4e00<\/li>\n\n\n\n
                                • Expire<\/strong>\uff1a\u8bbe\u7f6ekey\u7684\u6709\u6548\u671f<\/li>\n<\/ul>\n\n\n\n
                                  Redis-cli\u64cd\u4f5c<\/h3>\n\n\n\n
                                  127.0.0.1:6379> INCR r:f:user1
                                  (integer) 1
                                  # \u7b2c\u4e00\u6b21 \u8bbe\u7f6e\u4e00\u4e2a\u8fc7\u671f\u65f6\u95f4
                                  127.0.0.1:6379> EXPIRE r:f:user1 5
                                  (integer) 1
                                  127.0.0.1:6379> INCR r:f:user1
                                  (integer) 2
                                  # \u7b49\u5f855s \u518d\u6b21\u589e\u52a0 \u53d1\u73b0\u5df2\u7ecf\u91cd\u7f6e\u4e86
                                  127.0.0.1:6379> INCR r:f:user1
                                  (integer) 1<\/code><\/pre>\n\n\n\n
                                  SpringBoot\u793a\u4f8b\uff1a<\/h3>\n\n\n\n
                                  import lombok.extern.slf4j.Slf4j;
                                  import org.junit.jupiter.api.Test;
                                  import org.springframework.beans.factory.annotation.Autowired;
                                  import org.springframework.boot.test.context.SpringBootTest;
                                  import org.springframework.data.redis.core.RedisTemplate;

                                  import java.util.concurrent.TimeUnit;

                                  \/**
                                   * @author<\/strong> \u4e00\u884cJava
                                   * @title<\/strong>: \u57fa\u4e8eRedis\u7684\u7b80\u5355\u9650\u6d41
                                   * @projectName<\/strong> ehang-spring-boot
                                   * @description<\/strong>: TODO
                                   * @date<\/strong> 2022\/8\/2 9:43
                                   *\/
                                  @SpringBootTest
                                  @Slf4j
                                  public class FreqTest {
                                      \/\/ \u5355\u4f4d\u65f6\u95f4\uff08\u79d2\uff09
                                      private static final Integer TIME = 5;
                                      \/\/ \u5141\u8bb8\u8bbf\u95ee\u4e0a\u9650\u6b21\u6570
                                      private static final Integer MAX = 100;

                                      @Autowired
                                      RedisTemplate redisTemplate;

                                      @Test
                                      public void test() throws Exception {
                                          String userName = \"user1\";

                                          int tag = 1;

                                          boolean frequency = frequency(userName);
                                          log.info(\"\u7b2c{}\u6b21\u662f\u5426\u653e\u884c\uff1a{}\", tag, frequency);
                                          for (int i = 0; i < 100; i++) {
                                              tag += 1;
                                              frequency(userName);
                                          }
                                          frequency = frequency(userName);
                                          log.info(\"\u7b2c{}\u6b21\u662f\u5426\u653e\u884c\uff1a{}\", tag, frequency);

                                          Thread.sleep(5000);
                                          frequency = frequency(userName);
                                          log.info(\"\u6a21\u62df\u7b49\u5f855s\u540e\uff0c\u7b2c{}\u6b21\u662f\u5426\u653e\u884c\uff1a{}\", tag, frequency);
                                      }

                                      \/**
                                       * \u6821\u9a8c\u8bbf\u95ee\u9891\u7387
                                       *
                                       * @param<\/strong> uniqueId \u7528\u4e8e\u9650\u6d41\u7684\u552f\u4e00ID \u53ef\u4ee5\u662f\u7528\u6237ID\u3001\u6216\u8005\u5ba2\u6237\u7aefIP\u7b49
                                       * @return<\/strong> true\uff1a\u653e\u884c  false\uff1a\u62e6\u622a
                                       *\/
                                      private boolean frequency(String uniqueId) {
                                          String key = \"r:q:\" + uniqueId;
                                          Long increment = redisTemplate.opsForValue().increment(key);
                                          if (increment == 1) {
                                              redisTemplate.expire(key, TIME, TimeUnit.SECONDS);
                                          }

                                          if (increment <= MAX) {
                                              return true;
                                          }

                                          return false;
                                      }
                                  }<\/code><\/pre>\n\n\n\n
                                  \u8fd0\u884c\u65e5\u5fd7\uff1a<\/p>\n\n\n\n
                                  user1 \u7b2c1\u6b21\u8bf7\u6c42\u662f\u5426\u653e\u884c\uff1atrue
                                  user1 \u7b2c101\u6b21\u8bf7\u6c42\u662f\u5426\u653e\u884c\uff1afalse
                                  \u6a21\u62df\u7b49\u5f855s\u540e\uff0cuser1 \u7b2c101\u6b21\u8bf7\u6c42\u662f\u5426\u653e\u884c\uff1atrue<\/code><\/pre>\n\n\n\n
                                  11\u5168\u5c40ID<\/h2>\n\n\n\n
                                  \u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\uff0c\u5f88\u591a\u573a\u666f\u4e0b\u9700\u8981\u5168\u5c40\u7684\u552f\u4e00ID\uff0c\u7531\u4e8eRedis\u662f\u72ec\u7acb\u4e8e\u4e1a\u52a1\u670d\u52a1\u7684\u5176\u4ed6\u5e94\u7528\uff0c\u5c31\u53ef\u4ee5\u5229\u7528Incr<\/code>\u7684\u539f\u5b50\u6027\u64cd\u4f5c\u6765\u751f\u6210\u5168\u5c40\u7684\u552f\u4e00\u9012\u589eID<\/p>\n\n\n\n
                                  \u529f\u80fd\u6240\u9700\u547d\u4ee4<\/p>\n\n\n\n
                                    \n
                                  • INCR<\/strong>\uff1a\u5c06 key \u4e2d\u50a8\u5b58\u7684\u6570\u5b57\u503c\u589e\u4e00<\/li>\n<\/ul>\n\n\n\n
                                    Redis-cli \u5ba2\u6237\u7aef\u6d4b\u8bd5<\/h3>\n\n\n\n
                                    127.0.0.1:6379> incr g:uid
                                    (integer) 1
                                    127.0.0.1:6379> incr g:uid
                                    (integer) 2
                                    127.0.0.1:6379> incr g:uid
                                    (integer) 3<\/code><\/pre>\n\n\n\n
                                    12\u7b80\u5355\u5206\u5e03\u5f0f\u9501<\/h2>\n\n\n\n
                                    \u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\uff0c\u5f88\u591a\u64cd\u4f5c\u662f\u9700\u8981\u7528\u5230\u5206\u5e03\u5f0f\u9501\uff0c\u9632\u6b62\u5e76\u53d1\u64cd\u4f5c\u5e26\u6765\u4e00\u4e9b\u95ee\u9898\uff1b\u56e0\u4e3aredis\u662f\u72ec\u7acb\u4e8e\u5206\u5e03\u5f0f\u7cfb\u7edf\u5916\u7684\u5176\u4ed6\u670d\u52a1\uff0c\u56e0\u6b64\u5c31\u53ef\u4ee5\u5229\u7528redis\uff0c\u6765\u5b9e\u73b0\u4e00\u4e2a\u7b80\u5355\u7684\u4e0d\u5b8c\u7f8e<\/strong>\u5206\u5e03\u5f0f\u9501\uff1b<\/p>\n\n\n\n
                                    \u529f\u80fd\u6240\u9700\u547d\u4ee4<\/p>\n\n\n\n
                                      \n
                                    • SETNX<\/strong>\u00a0key\u4e0d\u5b58\u5728\uff0c\u8bbe\u7f6e\uff1bkey\u5b58\u5728\uff0c\u4e0d\u8bbe\u7f6e#\u00a0\u52a0\u9501
                                      127.0.0.1:6379>\u00a0SETNX\u00a0try_lock\u00a01
                                      (integer)\u00a01
                                      #\u00a0\u91ca\u653e\u9501
                                      127.0.0.1:6379>\u00a0del\u00a0try_lock
                                      (integer)\u00a01
                                      <\/code><\/li>\n\n\n\n
                                    • set  key  value [ex seconds] [nx | xx]\u4e0a\u9762\u7684\u65b9\u5f0f\uff0c\u867d\u7136\u80fd\u591f\u52a0\u9501\uff0c\u4f46\u662f\u4e0d\u96be\u53d1\u73b0\uff0c\u5f88\u5bb9\u6613\u51fa\u73b0\u6b7b\u9501\u7684\u60c5\u51b5\uff1b\u6bd4\u5982\uff0ca\u7528\u6237\u5728\u52a0\u9501\u4e4b\u540e\uff0c\u7a81\u7136\u7cfb\u7edf\u6302\u4e86\uff0c\u6b64\u65f6a\u5c31\u6c38\u8fdc\u4e0d\u4f1a\u91ca\u653e\u4ed6\u6301\u6709\u7684\u9501\u4e86\uff0c\u4ece\u800c\u5bfc\u81f4\u6b7b\u9501\uff1b\u4e3a\u6b64\uff0c\u6211\u4eec\u53ef\u4ee5\u5229\u7528redis\u7684\u8fc7\u671f\u65f6\u95f4\u6765\u9632\u6b62\u6b7b\u9501\u95ee\u9898set try_lock 1 ex 5 nx
                                      <\/code>\"\u56fe\u7247\"<\/li>\n<\/ul>\n\n\n\n
                                      \u4e0d\u5b8c\u7f8e\u7684\u9501<\/strong><\/p>\n\n\n\n
                                      \u4e0a\u9762\u7684\u65b9\u6848\uff0c\u867d\u7136\u89e3\u51b3\u4e86\u6b7b\u9501\u7684\u95ee\u9898\uff0c\u4f46\u662f\u53c8\u5e26\u6765\u4e86\u4e00\u4e2a\u65b0\u7684\u95ee\u9898\uff0c\u6267\u884c\u65f6\u95f4\u5982\u679c\u957f\u4e8e\u81ea\u52a8\u91ca\u653e\u7684\u65f6\u95f4\uff08\u6bd4\u5982\u81ea\u52a8\u91ca\u653e\u662f5\u79d2\uff0c\u4f46\u662f\u4e1a\u52a1\u6267\u884c\u8017\u65f6\u4e868\u79d2\uff09\uff0c\u90a3\u4e48\u5728\u7b2c5\u79d2\u7684\u65f6\u5019\uff0c\u9501\u5c31\u81ea\u52a8\u91ca\u653e\u4e86\uff0c\u6b64\u65f6\u5176\u4ed6\u7684\u7ebf\u7a0b\u5c31\u80fd\u6b63\u5e38\u62ff\u5230\u9501\uff0c\u7b80\u5355\u6d41\u7a0b\u5982\u4e0b\uff1a<\/p>\n\n\n\n
                                      \u6b64\u65f6\u76f8\u540c\u989c\u8272\u90e8\u5206\u7684\u65f6\u95f4\u533a\u95f4\u662f\u7531\u591a\u7ebf\u7a0b\u540c\u65f6\u5728\u6267\u884c\u3002\u800c\u4e14\u6b64\u95ee\u9898\u5728\u6b64\u65b9\u6848\u4e0b\u5e76\u6ca1\u6709\u5b8c\u7f8e\u7684\u89e3\u51b3\u65b9\u6848\uff0c\u53ea\u80fd\u505a\u5230\u5c3d\u53ef\u80fd\u7684\u907f\u514d<\/strong>\uff1a<\/p>\n\n\n\n
                                        \n
                                      • \u65b9\u5f0f\u4e00\uff0cvalue\u8bbe\u7f6e\u4e3a\u968f\u673a\u6570\uff08\u5982\uff1a1234\uff09\uff0c\u5728\u7a0b\u5e8f\u91ca\u653e\u9501\u7684\u65f6\u5019\uff0c\u68c0\u6d4b\u4e00\u4e0b\u662f\u4e0d\u662f\u81ea\u5df1\u52a0\u7684\u9501<\/em>\uff1b\u6bd4\u5982\uff0cA\u7ebf\u7a0b\u5728\u7b2c8s\u91ca\u653e\u7684\u9501\u5c31\u662f\u7ebf\u7a0bB\u52a0\u7684\uff0c\u6b64\u65f6\u5728\u91ca\u653e\u7684\u65f6\u5019\uff0c\u5c31\u53ef\u4ee5\u68c0\u9a8c\u4e00\u4e0bvalue\u662f\u4e0d\u662f\u81ea\u5df1\u5f53\u521d\u8bbe\u7f6e\u7684\u503c\uff081234\uff09\uff0c\u662f\u7684\u5c31\u91ca\u653e\uff0c\u4e0d\u662f\u7684\u5c31\u4e0d\u7ba1\u4e86\uff1b<\/li>\n\n\n\n
                                      • \u65b9\u5f0f\u4e8c\uff0c\u53ea\u5728\u65f6\u95f4\u6d88\u8017\u6bd4\u8f83\u5c0f\u7684\u4e1a\u52a1\u4e0a\u9009\u7528\u6b64\u65b9\u6848<\/em>\uff0c\u5c3d\u53ef\u80fd\u7684\u907f\u514d\u6267\u884c\u65f6\u95f4\u8d85\u8fc7\u9501\u7684\u81ea\u52a8\u91ca\u653e\u65f6\u95f4<\/li>\n<\/ul>\n\n\n\n
                                        13\u8ba4\u8bc6\u7684\u4eba\/\u597d\u53cb\u63a8\u8350<\/h2>\n\n\n\n
                                        \u5728\u652f\u4ed8\u5b9d\u3001\u6296\u97f3\u3001QQ\u7b49\u5e94\u7528\u4e2d\uff0c\u90fd\u4f1a\u770b\u5230\u597d\u53cb\u63a8\u8350\uff1b<\/p>\n\n\n\n
                                        \u597d\u53cb\u63a8\u8350\u5f80\u5f80\u90fd\u662f\u57fa\u4e8e\u4f60\u7684\u597d\u53cb\u5173\u7cfb\u7f51\u6765\u63a8\u8350\uff0c\u5c06\u4f60\u53ef\u80fd\u8ba4\u8bc6\u7684\u4eba\u63a8\u8350\u7ed9\u4f60\uff0c\u8ba9\u4f60\u53bb\u6dfb\u52a0\u597d\u53cb\uff0c\u5982\u679c\u968f\u610f\u5728\u7cfb\u7edf\u627e\u4e2a\u4eba\u63a8\u8350\u7ed9\u4f60\uff0c\u90a3\u4f60\u8ba4\u8bc6\u7684\u53ef\u80fd\u6027\u662f\u975e\u5e38\u5c0f\u7684\uff0c\u6b64\u65f6\u5c31\u5931\u53bb\u4e86\u63a8\u8350\u7684\u76ee\u7684\uff1b<\/p>\n\n\n\n
                                        \u6bd4\u5982\uff0cA\u548cB\u662f\u597d\u53cb\uff0cB\u548cC\u662f\u597d\u53cb\uff0c\u6b64\u65f6A\u548cC\u8ba4\u8bc6\u7684\u6982\u7387\u662f\u6bd4\u8f83\u5927\u7684\uff0c\u5c31\u53ef\u4ee5\u5728A\u548cC\u4e4b\u95f4\u7684\u597d\u53cb\u63a8\u8350\uff1b<\/p>\n\n\n\n
                                        \u57fa\u4e8e\u8fd9\u4e2a\u903b\u8f91\uff0c\u5c31\u53ef\u4ee5\u5229\u7528 Redis \u7684 Set \u96c6\u5408\uff0c\u7f13\u5b58\u5404\u4e2a\u7528\u6237\u7684\u597d\u53cb\u5217\u8868\uff0c\u7136\u540e\u4ee5\u5dee\u96c6\u7684\u65b9\u5f0f\uff0c\u6765\u5b9e\u73b0\u597d\u53cb\u63a8\u8350\uff1b<\/p>\n\n\n\n
                                        \u529f\u80fd\u6240\u9700\u7684\u547d\u4ee4<\/p>\n\n\n\n
                                          \n
                                        • SADD<\/strong> key member [member \u2026]\uff1a\u96c6\u5408\u4e2d\u6dfb\u52a0\u5143\u7d20\uff0c\u7f13\u5b58\u597d\u53cb\u5217\u8868<\/li>\n\n\n\n
                                        • SDIFF<\/strong> key [key \u2026]\uff1a\u53d6\u4e24\u4e2a\u96c6\u5408\u95f4\u7684\u5dee\u96c6\uff0c\u627e\u51fa\u53ef\u4ee5\u63a8\u8350\u7684\u7528\u6237<\/li>\n<\/ul>\n\n\n\n
                                          Redis-cli \u5ba2\u6237\u7aef\u6d4b\u8bd5<\/h3>\n\n\n\n
                                          # \u8bb0\u5f55 \u7528\u62371 \u7684\u597d\u53cb\u5217\u8868
                                          127.0.0.1:6379> SADD fl:user1 user2 user3
                                          (integer) 2
                                          # \u8bb0\u5f55 \u7528\u62372 \u7684\u597d\u53cb\u5217\u8868
                                          127.0.0.1:6379> SADD fl:user2 user1 user4
                                          (integer) 2

                                          # \u7528\u62371 \u53ef\u80fd\u8ba4\u8bc6\u7684\u4eba \uff0c\u628a\u81ea\u5df1\uff08user1\uff09\u53bb\u6389\uff0cuser4\u662f\u53ef\u80fd\u8ba4\u8bc6\u7684\u4eba
                                          127.0.0.1:6379> SDIFF fl:user2 fl:user1
                                          1) \"user1\"
                                          2) \"user4\"

                                          # \u7528\u62372 \u53ef\u80fd\u8ba4\u8bc6\u7684\u4eba \uff0c\u628a\u81ea\u5df1\uff08user2\uff09\u53bb\u6389\uff0cuser3\u662f\u53ef\u80fd\u8ba4\u8bc6\u7684\u4eba
                                          127.0.0.1:6379> SDIFF fl:user1 fl:user2
                                          1) \"user3\"
                                          2) \"user2\"<\/code><\/pre>\n\n\n\n
                                          \u4e0d\u8fc7\u8fd9\u53ea\u662f\u63a8\u8350\u673a\u5236\u4e2d\u7684\u4e00\u79cd\u56e0\u7d20\uff0c\u53ef\u4ee5\u501f\u52a9\u5176\u4ed6\u6761\u4ef6\uff0c\u6765\u589e\u5f3a\u63a8\u8350\u7684\u51c6\u786e\u5ea6\uff1b<\/p>\n\n\n\n
                                          14\u53d1\u5e03\/\u8ba2\u9605<\/h2>\n\n\n\n
                                          \u53d1\u5e03\/\u8ba2\u9605\u662f\u6bd4\u8f83\u5e38\u7528\u7684\u4e00\u79cd\u6a21\u5f0f\uff1b\u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\uff0c\u5982\u679c\u9700\u8981\u5b9e\u65f6\u611f\u77e5\u5230\u4e00\u4e9b\u53d8\u5316\uff0c\u6bd4\u5982\uff1a\u67d0\u4e9b\u914d\u7f6e\u53d1\u751f\u53d8\u5316\u9700\u8981\u5b9e\u65f6\u540c\u6b65\uff0c\u5c31\u53ef\u4ee5\u7528\u5230\u53d1\u5e03\uff0c\u8ba2\u9605\u529f\u80fd<\/p>\n\n\n\n
                                          \u5e38\u7528API<\/p>\n\n\n\n
                                            \n
                                          • PUBLISH<\/strong> channel message\uff1a\u5c06\u6d88\u606f\u63a8\u9001\u5230\u6307\u5b9a\u7684\u9891\u9053<\/li>\n\n\n\n
                                          • SUBSCRIBE<\/strong> channel [channel \u2026]\uff1a\u8ba2\u9605\u7ed9\u5b9a\u7684\u4e00\u4e2a\u6216\u591a\u4e2a\u9891\u9053\u7684\u4fe1\u606f<\/li>\n<\/ul>\n\n\n\n
                                            Redis-cli\u64cd\u4f5c<\/h3>\n\n\n\n
                                            \u5982\u4e0a\u56fe\u6240\u793a\uff0c\u5de6\u4fa7\u591a\u4e2a\u5ba2\u6237\u7aef\u8ba2\u9605\u4e86\u9891\u9053\uff0c\u5f53\u53f3\u4fa7\u5ba2\u6237\u7aef\u5f80\u9891\u9053\u53d1\u9001\u6d88\u606f\u7684\u65f6\u5019\uff0c\u5de6\u4fa7\u5ba2\u6237\u7aef\u90fd\u80fd\u6536\u5230\u5bf9\u5e94\u7684\u6d88\u606f\u3002<\/p>\n\n\n\n
                                            15\u6d88\u606f\u961f\u5217<\/h2>\n\n\n\n
                                            \u8bf4\u5230\u6d88\u606f\u961f\u5217\uff0c\u5e38\u7528\u7684\u5c31\u662fKafka\u3001RabbitMQ\u7b49\u7b49\uff0c\u5176\u5b9e Redis \u5229\u7528 List \u4e5f\u80fd\u5b9e\u73b0\u4e00\u4e2a\u6d88\u606f\u961f\u5217\uff1b<\/p>\n\n\n\n
                                            \u529f\u80fd\u6240\u9700\u7684\u6307\u4ee4<\/p>\n\n\n\n
                                              \n
                                            • RPUSH<\/strong> key value1 [value2]\uff1a\u5728\u5217\u8868\u4e2d\u6dfb\u52a0\u4e00\u4e2a\u6216\u591a\u4e2a\u503c\uff1b<\/li>\n\n\n\n
                                            • BLPOP<\/strong> key1 [key2] timeout\uff1a\u79fb\u51fa\u5e76\u83b7\u53d6\u5217\u8868\u7684\u7b2c\u4e00\u4e2a\u5143\u7d20\uff0c \u5982\u679c\u5217\u8868\u6ca1\u6709\u5143\u7d20\u4f1a\u963b\u585e\u5217\u8868\u76f4\u5230\u7b49\u5f85\u8d85\u65f6\u6216\u53d1\u73b0\u53ef\u5f39\u51fa\u5143\u7d20\u4e3a\u6b62\uff1b<\/li>\n\n\n\n
                                            • BRPOP<\/strong> key1 [key2] timeout\uff1a\u79fb\u51fa\u5e76\u83b7\u53d6\u5217\u8868\u7684\u6700\u540e\u4e00\u4e2a\u5143\u7d20\uff0c \u5982\u679c\u5217\u8868\u6ca1\u6709\u5143\u7d20\u4f1a\u963b\u585e\u5217\u8868\u76f4\u5230\u7b49\u5f85\u8d85\u65f6\u6216\u53d1\u73b0\u53ef\u5f39\u51fa\u5143\u7d20\u4e3a\u6b62\u3002<\/li>\n<\/ul>\n\n\n\n
                                              \u4f9d\u8d56\u8c03\u6574\uff1a<\/p>\n\n\n\n
                                              Spring Boot \u4ece 2.0\u7248\u672c\u5f00\u59cb\uff0c\u5c06\u9ed8\u8ba4\u7684Redis\u5ba2\u6237\u7aefJedis\u66ff\u6362\u4e3aLettuce\uff0c\u5728\u6d4b\u8bd5\u8fd9\u5757\u963b\u585e\u7684\u65f6\u5019\uff0c\u4f1a\u51fa\u73b0\u4e00\u4e2a\u8d85\u65f6\u7684\u5f02\u5e38io.lettuce.core.RedisCommandTimeoutException: Command timed out after 1 minute(s)<\/code>\uff1b\u6ca1\u6709\u627e\u5230\u4e00\u4e2a\u597d\u7684\u89e3\u51b3\u65b9\u5f0f\uff0c\u6240\u4ee5\u8fd9\u91cc\u5c06 Lettuce \u6362\u56de\u6210 Jedis \uff0c\u5c31\u6ca1\u6709\u95ee\u9898\u4e86\uff0cpom.xml \u7684\u914d\u7f6e\u5982\u4e0b\uff1a<\/p>\n\n\n\n
                                              <dependency>
                                                  <groupId>org.springframework.boot<\/groupId>
                                                  <artifactId>spring-boot-starter-data-redis<\/artifactId>
                                                  <exclusions>
                                                      <exclusion>
                                                          <groupId>redis.clients<\/groupId>
                                                          <artifactId>jedis<\/artifactId>
                                                      <\/exclusion>
                                                      <exclusion>
                                                          <artifactId>lettuce-core<\/artifactId>
                                                          <groupId>io.lettuce<\/groupId>
                                                      <\/exclusion>
                                                  <\/exclusions>
                                              <\/dependency>
                                              <!-- jedis\u5ba2\u6237\u7aef -->
                                              <dependency>
                                                  <groupId>redis.clients<\/groupId>
                                                  <artifactId>jedis<\/artifactId>
                                              <\/dependency>
                                              <!-- spring2.X\u96c6\u6210redis\u6240\u9700common-pool2\uff0c\u4f7f\u7528jedis\u5fc5\u987b\u4f9d\u8d56\u5b83-->
                                              <dependency>
                                                  <groupId>org.apache.commons<\/groupId>
                                                  <artifactId>commons-pool2<\/artifactId>
                                              <\/dependency><\/code><\/pre>\n\n\n\n
                                              \u6d4b\u8bd5\u4ee3\u7801\uff1a<\/p>\n\n\n\n
                                              import lombok.extern.slf4j.Slf4j;
                                              import org.junit.jupiter.api.Test;
                                              import org.springframework.beans.factory.annotation.Autowired;
                                              import org.springframework.boot.test.context.SpringBootTest;
                                              import org.springframework.data.redis.core.StringRedisTemplate;

                                              import java.util.concurrent.TimeUnit;

                                              \/**
                                               * @author<\/strong> \u4e00\u884cJava
                                               * @title<\/strong>: QueueTest
                                               * @projectName<\/strong> ehang-spring-boot
                                               * @description<\/strong>: TODO
                                               * @date<\/strong> 2022\/8\/5 14:27
                                               *\/
                                              @SpringBootTest
                                              @Slf4j
                                              public class QueueTest {
                                                  private static final String REDIS_LP_QUEUE = \"redis:lp:queue\";
                                                  private static final String REDIS_RP_QUEUE = \"redis:rp:queue\";

                                                  @Autowired
                                                  StringRedisTemplate stringRedisTemplate;

                                                  \/**
                                                   * \u5148\u8fdb\u540e\u51fa\u961f\u5217
                                                   *\/
                                                  @Test
                                                  public void rightMonitor() {
                                                      while (true) {
                                                          Object o = stringRedisTemplate.opsForList().rightPop(REDIS_LP_QUEUE, 0, TimeUnit.SECONDS);
                                                          log.info(\"\u5148\u8fdb\u540e\u51fa\u961f\u5217 \u63a5\u6536\u5230\u6570\u636e\uff1a{}\", o);
                                                      }
                                                  }

                                                  \/**
                                                   * \u5148\u8fdb\u5148\u51fa\u961f\u5217
                                                   *\/
                                                  @Test
                                                  public void leftMonitor() {
                                                      while (true) {
                                                          Object o = stringRedisTemplate.opsForList().leftPop(REDIS_RP_QUEUE, 0, TimeUnit.SECONDS);
                                                          log.info(\"\u5148\u8fdb\u5148\u51fa\u961f\u5217 \u63a5\u6536\u5230\u6570\u636e\uff1a{}\", o);
                                                      }
                                                  }
                                              }<\/code><\/pre>\n\n\n\n
                                                \n
                                              • \u5148\u8fdb\u5148\u51fa\u6d4b\u8bd5\u6548\u679c\"\u56fe\u7247\"<\/li>\n\n\n\n
                                              • \u5148\u8fdb\u540e\u51fa\u6d4b\u8bd5\u6548\u679c<\/li>\n<\/ul>\n\n\n\n
                                                \u4e0d\u8fc7\uff0c\u5bf9\u6d88\u606f\u7684\u53ef\u9760\u6027\u8981\u6c42\u6bd4\u8f83\u9ad8\u7684\u573a\u666f\uff0c\u5efa\u8bae\u8fd8\u662f\u4f7f\u7528\u4e13\u4e1a\u7684\u6d88\u606f\u961f\u5217\u6846\u67b6\uff0c\u5f53\u503c\u88ab\u5f39\u51fa\u4e4b\u540e\uff0cList \u4e2d\u5c31\u5df2\u7ecf\u4e0d\u5b58\u5728\u5bf9\u5e94\u7684\u503c\u4e86\uff0c\u5047\u5982\u6b64\u65f6\u7a0b\u5e8f\u5d29\u6e83\uff0c\u5c31\u4f1a\u51fa\u73b0\u6d88\u606f\u7684\u4e22\u5931\uff0c\u65e0\u6cd5\u4fdd\u8bc1\u53ef\u9760\u6027\uff1b\u867d\u7136\u8bf4\u4e5f\u6709\u7b56\u7565\u80fd\u591f\u4fdd\u8bc1\u6d88\u606f\u7684\u53ef\u9760\u6027\uff0c\u6bd4\u5982\uff0c\u5728\u5f39\u51fa\u7684\u540c\u65f6\uff0c\u5c06\u5176\u4fdd\u5b58\u5230\u53e6\u5916\u4e00\u4e2a\u961f\u5217\uff08BRPOPLPUSH\uff09\uff0c\u6210\u529f\u4e4b\u540e\uff0c\u518d\u4ece\u53e6\u5916\u7684\u961f\u5217\u4e2d\u79fb\u9664\uff0c\u5f53\u6d88\u606f\u5904\u7406\u5931\u8d25\u6216\u8005\u5f02\u5e38\uff0c\u518d\u91cd\u65b0\u8fdb\u5165\u961f\u5217\u6267\u884c\uff0c\u53ea\u662f\u8fd9\u6837\u505a\u5c31\u5f97\u4e0d\u507f\u5931\u4e86\u3002<\/p>\n\n\n\n
                                                16\u6570\u636e\u5171\u4eab\uff08session\u5171\u4eab\uff09<\/h2>\n\n\n\n
                                                \u65e2\u7136Redis\u80fd\u6301\u4e45\u5316\u6570\u636e\uff0c\u5c31\u53ef\u4ee5\u7528\u5b83\u6765\u5b9e\u73b0\u6a21\u5757\u95f4\u7684\u6570\u636e\u5171\u4eab\uff1bSpringBoot Session \u5229\u7528\u7684\u8fd9\u4e2a\u673a\u5236\u6765\u5b9e\u73b0 Session \u5171\u4eab\uff1b<\/p>\n\n\n\n
                                                  \n
                                                • \u4f9d\u8d56<dependency>
                                                      <groupId>org.springframework.session<\/groupId>
                                                      <artifactId>spring-session-data-redis<\/artifactId>
                                                  <\/dependency><\/code><\/li>\n\n\n\n
                                                • \u5f00\u542fsession\u5171\u4eab@Configuration
                                                  @EnableRedisHttpSession
                                                  public class RedisSessionConfig {
                                                  }<\/code><\/li>\n\n\n\n
                                                • \u6d4b\u8bd5\u4ee3\u7801package com.ehang.redis.controller;

                                                  import org.springframework.web.bind.annotation.GetMapping;
                                                  import org.springframework.web.bind.annotation.RequestMapping;
                                                  import org.springframework.web.bind.annotation.RestController;

                                                  import javax.servlet.http.HttpServletRequest;
                                                  import java.util.Enumeration;
                                                  import java.util.HashMap;
                                                  import java.util.Map;

                                                  \/**
                                                   * @author<\/strong> session \u5171\u4eab
                                                   * @title<\/strong>: RedisSessionController
                                                   * @projectName<\/strong> ehang-spring-boot
                                                   * @description<\/strong>: TODO
                                                   * @date<\/strong> 2022\/8\/5 15:58
                                                   *\/
                                                  @RestController
                                                  @RequestMapping(\"session\")
                                                  public class RedisSessionController {

                                                      \/**
                                                       * \u8bbe\u7f6esession\u7684\u503c
                                                       * @param<\/strong> request
                                                       * @return<\/strong>
                                                       *\/
                                                      @GetMapping(\"set\")
                                                      public Map set(HttpServletRequest request) {
                                                          String id = request.getSession().getId();
                                                          Map<String, String> vas = new HashMap<>();

                                                          String key = \"key\";
                                                          String value = \"value\";
                                                          vas.put(\"id\", id);
                                                          vas.put(key, value);
                                                          \/\/ \u81ea\u5b9a\u4e49session\u7684\u503c
                                                          request.getSession().setAttribute(key, value);

                                                          return vas;
                                                      }

                                                      \/**
                                                       * \u83b7\u53d6session\u7684\u503c
                                                       * @param<\/strong> request
                                                       * @return<\/strong>
                                                       *\/
                                                      @GetMapping(\"get\")
                                                      public Map get(HttpServletRequest request) {
                                                          Map<String, Object> vas = new HashMap<>();

                                                          \/\/ \u904d\u5386\u6240\u6709\u7684session\u503c
                                                          Enumeration<String> attributeNames = request.getSession().getAttributeNames();
                                                          while (attributeNames.hasMoreElements()) {
                                                              String k = attributeNames.nextElement();
                                                              Object va = request.getSession().getAttribute(k);
                                                              vas.put(k, va);
                                                          }

                                                          vas.put(\"id\", request.getSession().getId());

                                                          return vas;
                                                      }
                                                  }<\/code><\/li>\n\n\n\n
                                                • \u6d4b\u8bd5\u5f00\u542f\u4e24\u4e2a\u670d\u52a1\uff0c\u5206\u522b\u63a5\u542c8080\u548c8081\uff0c8080\u8c03\u7528\u8d4b\u503c\u63a5\u53e3\uff0c8081\u8c03\u7528\u83b7\u53d6\u63a5\u53e3\uff0c\u5982\u4e0b\u56fe\uff0c\u53ef\u4ee5\u770b\u5230\uff0c\u4e24\u4e2a\u670d\u52a1\u5171\u4eab\u4e86\u4e00\u4efdSession\u6570\u636e\uff1b<\/li>\n\n\n\n
                                                • Redis\u4e2d\u4fdd\u5b58\u7684\u6570\u636e127.0.0.1:6379> keys spring:*
                                                  1) \"spring:session:sessions:expires:6f1d7d53-fe01-4e80-9e6a-5ff54fffa92a\"
                                                  2) \"spring:session:expirations:1659688680000\"
                                                  3) \"spring:session:sessions:6f1d7d53-fe01-4e80-9e6a-5ff54fffa92a\"<\/code><\/li>\n<\/ul>\n\n\n\n
                                                  17\u5546\u54c1\u7b5b\u9009<\/h2>\n\n\n\n
                                                  \u5546\u57ce\u7c7b\u7684\u5e94\u7528\uff0c\u90fd\u4f1a\u6709\u7c7b\u4f3c\u4e8e\u4e0b\u56fe\u7684\u4e00\u4e2a\u5546\u54c1\u7b5b\u9009\u7684\u529f\u80fd\uff0c\u6765\u5e2e\u7528\u6237\u5feb\u901f\u641c\u7d22\u7406\u60f3\u7684\u5546\u54c1\uff1b<\/p>\n\n\n\n
                                                  \u5047\u5982\u73b0\u5728iphone 100 \u3001\u534e\u4e3amate 5000 \u5df2\u53d1\u5e03\uff0c\u5728\u5404\u5927\u5546\u57ce\u4e0a\u7ebf\uff1b\u4e0b\u9762\u5c31\u901a\u8fc7 Redis \u7684 set \u6765\u5b9e\u73b0\u4e0a\u8ff0\u7684\u5546\u54c1\u7b5b\u9009\u529f\u80fd\uff1b<\/p>\n\n\n\n
                                                  \u529f\u80fd\u6240\u9700\u547d\u4ee4<\/p>\n\n\n\n
                                                    \n
                                                  • SADD<\/strong> key member [member \u2026]\uff1a\u6dfb\u52a0\u4e00\u4e2a\u6216\u591a\u4e2a\u5143\u7d20<\/li>\n\n\n\n
                                                  • SINTER<\/strong> key [key \u2026]\uff1a\u8fd4\u56de\u7ed9\u5b9a\u6240\u6709\u96c6\u5408\u7684\u4ea4\u96c6<\/li>\n<\/ul>\n\n\n\n
                                                    Redis-cli \u5ba2\u6237\u7aef\u6d4b\u8bd5<\/h3>\n\n\n\n
                                                    # \u5c06iphone100 \u6dfb\u52a0\u5230\u54c1\u724c\u4e3a\u82f9\u679c\u7684\u96c6\u5408
                                                    127.0.0.1:6379> sadd brand:apple iphone100
                                                    (integer) 1

                                                    # \u5c06meta5000 \u6dfb\u52a0\u5230\u54c1\u724c\u4e3a\u82f9\u679c\u7684\u96c6\u5408
                                                    127.0.0.1:6379> sadd brand:huawei meta5000
                                                    (integer) 1

                                                    # \u5c06 meta5000 iphone100 \u6dfb\u52a0\u5230\u652f\u63015T\u5185\u5b58\u7684\u96c6\u5408
                                                    127.0.0.1:6379> sadd ram:5t iphone100 meta5000
                                                    (integer) 2

                                                    # \u5c06 meta5000 \u6dfb\u52a0\u5230\u652f\u630110T\u5185\u5b58\u7684\u96c6\u5408
                                                    127.0.0.1:6379> sadd ram:10t meta5000
                                                    (integer) 1

                                                    # \u5c06 iphone100 \u6dfb\u52a0\u5230\u64cd\u4f5c\u7cfb\u7edf\u662fiOS\u7684\u96c6\u5408
                                                    127.0.0.1:6379> sadd os:ios iphone100
                                                    (integer) 1

                                                    # \u5c06 meta5000 \u6dfb\u52a0\u5230\u64cd\u4f5c\u7cfb\u7edf\u662fAndroid\u7684\u96c6\u5408
                                                    127.0.0.1:6379> sadd os:android meta5000
                                                    (integer) 1

                                                    # \u5c06 iphone100 meta5000 \u6dfb\u52a0\u5230\u5c4f\u5e55\u4e3a6.0-6.29\u7684\u96c6\u5408\u4e2d
                                                    127.0.0.1:6379> sadd screensize:6.0-6.29 iphone100 meta5000
                                                    (integer) 2

                                                    # \u7b5b\u9009\u5185\u5b585T\u3001\u5c4f\u5e55\u57286.0-6.29\u7684\u673a\u578b
                                                    127.0.0.1:6379> sinter ram:5t screensize:6.0-6.29
                                                    1) \"meta5000\"
                                                    2) \"iphone100\"

                                                    # \u7b5b\u9009\u5185\u5b5810T\u3001\u5c4f\u5e55\u57286.0-6.29\u7684\u673a\u578b
                                                    127.0.0.1:6379> sinter ram:10t screensize:6.0-6.29
                                                    1) \"meta5000\"

                                                    # \u7b5b\u9009\u5185\u5b585T\u3001\u7cfb\u7edf\u4e3aiOS\u7684\u673a\u578b
                                                    127.0.0.1:6379> sinter ram:5t screensize:6.0-6.29 os:ios
                                                    1) \"iphone100\"

                                                    # \u7b5b\u9009\u5185\u5b585T\u3001\u5c4f\u5e55\u57286.0-6.29\u3001\u54c1\u724c\u662f\u534e\u4e3a\u7684\u673a\u578b
                                                    127.0.0.1:6379> sinter ram:5t screensize:6.0-6.29 brand:huawei
                                                    1) \"meta5000\"<\/code><\/pre>\n\n\n\n
                                                    18\u8d2d\u7269\u8f66<\/h2>\n\n\n\n
                                                    \u5546\u54c1\u7f13\u5b58<\/strong><\/p>\n\n\n\n
                                                    \u7535\u5546\u9879\u76ee\u4e2d\uff0c\u5546\u54c1\u6d88\u606f\uff0c\u90fd\u4f1a\u505a\u7f13\u5b58\u5904\u7406\uff0c\u7279\u522b\u662f\u70ed\u95e8\u5546\u54c1\uff0c\u8bbf\u95ee\u7528\u6237\u6bd4\u8f83\u591a\uff0c\u7531\u4e8e\u5546\u54c1\u7684\u7ed3\u679c\u6bd4\u8f83\u590d\u6742\uff0c\u5e97\u94fa\u4fe1\u606f\uff0c\u4ea7\u54c1\u4fe1\u606f\uff0c\u6807\u9898\u3001\u63cf\u8ff0\u3001\u8be6\u60c5\u56fe\uff0c\u5c01\u9762\u56fe\uff1b\u4e3a\u4e86\u65b9\u4fbf\u7ba1\u7406\u548c\u64cd\u4f5c\uff0c\u4e00\u822c\u90fd\u4f1a\u91c7\u7528 Hash \u7684\u65b9\u5f0f\u6765\u5b58\u50a8\uff08key\u4e3a\u5546\u54c1ID\uff0cfield\u7528\u6765\u4fdd\u5b58\u5404\u9879\u53c2\u6570\uff0cvalue\u4fdd\u5b58\u5bf9\u4e8e\u7684\u503c\uff09<\/p>\n\n\n\n
                                                    \u8d2d\u7269\u8f66<\/strong><\/p>\n\n\n\n
                                                    \u5f53\u5546\u54c1\u4fe1\u606f\u505a\u4e86\u7f13\u5b58\uff0c\u8d2d\u7269\u8f66\u9700\u8981\u505a\u7684\uff0c\u5c31\u662f\u901a\u8fc7Hash\u8bb0\u5f55\u5546\u54c1ID\uff0c\u4ee5\u53ca\u9700\u8981\u8d2d\u4e70\u7684\u6570\u91cf\uff08\u5176\u4e2dkey\u4e3a\u7528\u6237\u4fe1\u606f\uff0cfield\u4e3a\u5546\u54c1ID\uff0cvalue\u7528\u6765\u8bb0\u5f55\u8d2d\u4e70\u7684\u6570\u91cf\uff09 \uff1b<\/p>\n\n\n\n
                                                    \u529f\u80fd\u6240\u9700\u547d\u4ee4<\/p>\n\n\n\n
                                                      \n
                                                    • HSET<\/strong> key field value : \u5c06\u54c8\u5e0c\u8868 key \u4e2d\u7684\u5b57\u6bb5 field \u7684\u503c\u8bbe\u4e3a value ;<\/li>\n\n\n\n
                                                    • HMSET<\/strong> key field1 value1 [field2 value2 ] \uff1a\u540c\u65f6\u5c06\u591a\u4e2a field-value (\u57df-\u503c)\u5bf9\u8bbe\u7f6e\u5230\u54c8\u5e0c\u8868 key \u4e2d\u3002<\/li>\n\n\n\n
                                                    • HGET<\/strong> key field\uff1a\u83b7\u53d6\u5b58\u50a8\u5728\u54c8\u5e0c\u8868\u4e2d\u6307\u5b9a\u5b57\u6bb5\u7684\u503c\u3002<\/li>\n\n\n\n
                                                    • HGETALL<\/strong> key \uff1a\u83b7\u53d6\u5728\u54c8\u5e0c\u8868\u4e2d\u6307\u5b9a key \u7684\u6240\u6709\u5b57\u6bb5\u548c\u503c<\/li>\n\n\n\n
                                                    • HINCRBY<\/strong> key field increment \uff1a\u4e3a\u54c8\u5e0c\u8868 key \u4e2d\u7684\u6307\u5b9a\u5b57\u6bb5\u7684\u6574\u6570\u503c\u52a0\u4e0a\u589e\u91cf increment \u3002<\/li>\n\n\n\n
                                                    • HLEN<\/strong> key\uff1a\u83b7\u53d6\u54c8\u5e0c\u8868\u4e2d\u5b57\u6bb5\u7684\u6570\u91cf<\/li>\n<\/ul>\n\n\n\n
                                                      Redis-cli \u5ba2\u6237\u7aef\u6d4b\u8bd5<\/h3>\n\n\n\n
                                                      # \u8d2d\u7269\u8f66\u6dfb\u52a0\u5355\u4e2a\u5546\u54c1
                                                      127.0.0.1:6379> HSET sc:u1 c001 1
                                                      (integer) 1
                                                      # \u8d2d\u7269\u8f66\u6dfb\u52a0\u591a\u4e2a\u5546\u54c1
                                                      127.0.0.1:6379> HMSET sc:u1 c002 1 coo3 2
                                                      OK
                                                      # \u6dfb\u52a0\u5546\u54c1\u8d2d\u4e70\u6570\u91cf
                                                      127.0.0.1:6379> HINCRBY sc:u1 c002 1
                                                      (integer) 2
                                                      # \u51cf\u5c11\u5546\u54c1\u7684\u8d2d\u4e70\u6570\u91cf
                                                      127.0.0.1:6379> HINCRBY sc:u1 c003 -1
                                                      (integer) 1
                                                      # \u83b7\u53d6\u5355\u4e2a\u7684\u8d2d\u4e70\u6570\u91cf
                                                      127.0.0.1:6379> HGET sc:u1 c002
                                                      \"2\"
                                                      # \u83b7\u53d6\u8d2d\u7269\u8f66\u7684\u5546\u54c1\u6570\u91cf
                                                      127.0.0.1:6379> HLEN sc:u1
                                                      (integer) 3
                                                      # \u8d2d\u7269\u8f66\u8be6\u60c5
                                                      127.0.0.1:6379> HGETALL sc:u1
                                                      1) \"c001\"
                                                      2) \"1\"
                                                      3) \"c002\"
                                                      4) \"2\"
                                                      5) \"coo3\"
                                                      6) \"2\"<\/code><\/pre>\n\n\n\n
                                                      19\u5b9a\u65f6\u53d6\u6d88\u8ba2\u5355\uff08key\u8fc7\u671f\u76d1\u542c\uff09<\/h2>\n\n\n\n
                                                      \u7535\u5546\u7c7b\u7684\u4e1a\u52a1\uff0c\u4e00\u822c\u90fd\u4f1a\u6709\u8ba2\u535530\u5206\u949f\u4e0d\u652f\u4ed8\uff0c\u81ea\u52a8\u53d6\u6d88\u7684\u529f\u80fd\uff0c\u6b64\u65f6\u5c31\u9700\u8981\u7528\u5230\u5b9a\u65f6\u4efb\u52a1\u6846\u67b6\uff0cQuartz\u3001xxl-job\u3001elastic-job \u662f\u6bd4\u8f83\u5e38\u7528\u7684 Java \u5b9a\u65f6\u4efb\u52a1\uff1b\u6211\u4eec\u4e5f\u53ef\u4ee5\u901a\u8fc7 Redis \u7684\u5b9a\u65f6\u8fc7\u671f\u3001\u4ee5\u53ca\u8fc7\u671fkey\u7684\u76d1\u542c\uff0c\u6765\u5b9e\u73b0\u8ba2\u5355\u7684\u53d6\u6d88\u529f\u80fd\uff1b<\/p>\n\n\n\n
                                                        \n
                                                      • Redis key \u8fc7\u671f\u63d0\u9192\u914d\u7f6e\u4fee\u6539 redis \u76f8\u5173\u4e8b\u4ef6\u914d\u7f6e\u3002\u627e\u5230 redis \u914d\u7f6e\u6587\u4ef6 redis.conf\uff0c\u67e5\u770b notify-keyspace-events \u914d\u7f6e\u9879\uff0c\u5982\u679c\u6ca1\u6709\uff0c\u6dfb\u52a0 notify-keyspace-events Ex\uff0c\u5982\u679c\u6709\u503c\uff0c\u5219\u8ffd\u52a0 Ex\uff0c\u76f8\u5173\u53c2\u6570\u8bf4\u660e\u5982\u4e0b\uff1a\n
                                                          \n
                                                        • K<\/code>\uff1akeyspace \u4e8b\u4ef6\uff0c\u4e8b\u4ef6\u4ee5 keyspace@ \u4e3a\u524d\u7f00\u8fdb\u884c\u53d1\u5e03<\/li>\n\n\n\n
                                                        • E<\/code>\uff1akeyevent \u4e8b\u4ef6\uff0c\u4e8b\u4ef6\u4ee5 keyevent@ \u4e3a\u524d\u7f00\u8fdb\u884c\u53d1\u5e03<\/li>\n\n\n\n
                                                        • g<\/code>\uff1a\u4e00\u822c\u6027\u7684\uff0c\u975e\u7279\u5b9a\u7c7b\u578b\u7684\u547d\u4ee4\uff0c\u6bd4\u5982del\uff0cexpire\uff0crename\u7b49<\/li>\n\n\n\n
                                                        • $<\/code>\uff1a\u5b57\u7b26\u4e32\u7279\u5b9a\u547d\u4ee4<\/li>\n\n\n\n
                                                        • l<\/code>\uff1a\u5217\u8868\u7279\u5b9a\u547d\u4ee4<\/li>\n\n\n\n
                                                        • s<\/code>\uff1a\u96c6\u5408\u7279\u5b9a\u547d\u4ee4<\/li>\n\n\n\n
                                                        • h<\/code>\uff1a\u54c8\u5e0c\u7279\u5b9a\u547d\u4ee4<\/li>\n\n\n\n
                                                        • z<\/code>\uff1a\u6709\u5e8f\u96c6\u5408\u7279\u5b9a\u547d\u4ee4<\/li>\n\n\n\n
                                                        • x<\/code>\uff1a\u8fc7\u671f\u4e8b\u4ef6\uff0c\u5f53\u67d0\u4e2a\u952e\u8fc7\u671f\u5e76\u5220\u9664\u65f6\u4f1a\u4ea7\u751f\u8be5\u4e8b\u4ef6<\/li>\n\n\n\n
                                                        • e<\/code>\uff1a\u9a71\u9010\u4e8b\u4ef6\uff0c\u5f53\u67d0\u4e2a\u952e\u56e0 maxmemore \u7b56\u7565\u800c\u88ab\u5220\u9664\u65f6\uff0c\u4ea7\u751f\u8be5\u4e8b\u4ef6<\/li>\n\n\n\n
                                                        • A<\/code>\uff1ag$lshzxe\u7684\u522b\u540d\uff0c\u56e0\u6b64\u201dAKE\u201d\u610f\u5473\u7740\u6240\u6709\u4e8b\u4ef6<\/li>\n<\/ul>\n<\/li>\n\n\n\n
                                                        • \u6dfb\u52a0RedisKeyExpirationListener\u7684\u76d1\u542cimport org.springframework.context.annotation.Bean;
                                                          import org.springframework.context.annotation.Configuration;
                                                          import org.springframework.data.redis.connection.RedisConnectionFactory;
                                                          import org.springframework.data.redis.listener.RedisMessageListenerContainer;

                                                          @Configuration
                                                          public class RedisListenerConfig {

                                                              @Bean
                                                              RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {

                                                                  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
                                                                  container.setConnectionFactory(connectionFactory);
                                                                  return container;
                                                              }
                                                          }
                                                          <\/code>KeyExpirationEventMessageListener<\/code> \u63a5\u53e3\u76d1\u542c\u6240\u6709 db \u7684\u8fc7\u671f\u4e8b\u4ef6 keyevent@*:expired\"<\/code>package com.ehang.redis.config;


                                                          import lombok.extern.slf4j.Slf4j;
                                                          import org.springframework.data.redis.connection.Message;
                                                          import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
                                                          import org.springframework.data.redis.listener.RedisMessageListenerContainer;
                                                          import org.springframework.stereotype.Component;

                                                          \/**
                                                           * \u76d1\u542c\u6240\u6709db\u7684\u8fc7\u671f\u4e8b\u4ef6__keyevent@*__:expired\"
                                                           *
                                                           * @author<\/strong> \u4e00\u884cJava
                                                           * @title<\/strong>: RedisKeyExpirationListener
                                                           * @projectName<\/strong> ehang-spring-boot
                                                           * @description<\/strong>: TODO
                                                           * @date<\/strong> 2022\/8\/5 16:36
                                                           *\/
                                                          @Component
                                                          @Slf4j
                                                          public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

                                                              public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
                                                                  super(listenerContainer);
                                                              }

                                                              \/**
                                                               * \u9488\u5bf9 redis \u6570\u636e\u5931\u6548\u4e8b\u4ef6\uff0c\u8fdb\u884c\u6570\u636e\u5904\u7406
                                                               *
                                                               * @param<\/strong> message
                                                               * @param<\/strong> pattern
                                                               *\/
                                                              @Override
                                                              public void onMessage(Message message, byte[] pattern) {

                                                                  \/\/ \u83b7\u53d6\u5230\u5931\u6548\u7684 key\uff0c\u8fdb\u884c\u53d6\u6d88\u8ba2\u5355\u4e1a\u52a1\u5904\u7406
                                                                  \/\/ \u7531\u4e8e\u8fd9\u91cc\u662f\u76d1\u542c\u4e86\u6240\u6709\u7684key\uff0c\u5982\u679c\u53ea\u5904\u7406\u7279\u5b9a\u6570\u636e\u7684\u8bdd\uff0c\u9700\u8981\u505a\u7279\u6b8a\u5904\u7406
                                                                  String expiredKey = message.toString();
                                                                  log.info(\"\u8fc7\u671f\u7684Key\uff1a{}\", expiredKey);
                                                              }
                                                          }<\/code><\/li>\n\n\n\n
                                                        • \u6d4b\u8bd5\u4e3a\u4e86\u5feb\u901f\u9a8c\u8bc1\u6548\u679c\uff0c\u8fd9\u91cc \u5c06\u8fc7\u671f\u65f6\u95f4\u8c03\u6574\u4e3a2\u79d2\uff1b\u6ce8\u610f\uff0c\u7531\u4e8e\u8fc7\u671f\u4e4b\u540e\uff0cRedis\u4e2d\u7684Key\u5df2\u7ecf\u4e0d\u5b58\u5728\u4e86\uff0c\u56e0\u6b64\uff0c\u4e00\u5b9a\u8981\u5c06\u8ba2\u5355\u53f7\u4f5c\u4e3akey<\/strong>\uff0c\u4e0d\u80fd\u4f5c\u4e3a\u503c\u4fdd\u5b58\uff0c\u5426\u5219\u76d1\u542c\u5230\u8fc7\u671fKey\u4e4b\u540e\uff0c\u5c06\u62ff\u4e0d\u5230\u8fc7\u671f\u7684\u8ba2\u5355\u53f7\uff1b<\/li>\n\n\n\n
                                                        • \u4e0d\u63a8\u8350\u4f7f\u7528\u57fa\u4e8e\u8fd9\u4e00\u5957\u673a\u5236\uff0c\u786e\u5b9e\u80fd\u591f\u5b9e\u73b0\u8ba2\u5355\u7684\u8d85\u65f6\u53d6\u6d88\uff0c\u4f46\u662f\u8fd8\u662f\u4e0d\u592a\u5efa\u8bae\u4f7f\u7528\uff0c\u8fd9\u91cc\u4ec5\u4f5c\u4e3a\u4e00\u4e2a\u601d\u8def\uff1b\u539f\u56e0\u4e3b\u8981\u6709\u4ee5\u4e0b\u51e0\u4e2a\uff1a\n
                                                            \n
                                                          1. redis \u7684\u8fc7\u671f\u5220\u9664\u7b56\u7565\u662f\u91c7\u7528\u5b9a\u65f6\u79bb\u7ebf\u626b\u63cf\uff0c\u6216\u8005\u8bbf\u95ee\u65f6\u61d2\u6027\u68c0\u6d4b\u5220\u9664\uff0c\u5e76\u6ca1\u6709\u529e\u6cd5\u4fdd\u8bc1\u65f6\u6548\u6027\uff0c\u6709\u53ef\u80fdkey\u5df2\u7ecf\u5230\u671f\u4e86\uff0c\u4f46Redis\u5e76\u6ca1\u6709\u626b\u63cf\u5230\uff0c\u5bfc\u81f4\u901a\u77e5\u7684\u5ef6\u8fdf\uff1b<\/li>\n\n\n\n
                                                          2. \u6d88\u606f\u53d1\u9001\u5373\u5fd8\uff08fire and forget\uff09\uff0c\u5e76\u4e0d\u4f1a\u4fdd\u8bc1\u6d88\u606f\u7684\u53ef\u8fbe\u6027\uff0c\u5982\u679c\u6b64\u65f6\u670d\u52a1\u4e0d\u5728\u7ebf\u6216\u8005\u5f02\u5e38\uff0c\u901a\u77e5\u5c31\u518d\u4e5f\u6536\u4e0d\u5230\u4e86\uff1b<\/li>\n<\/ol>\n<\/li>\n<\/ul>\n\n\n\n
                                                            20\u7269\u6d41\u4fe1\u606f\uff08\u65f6\u95f4\u7ebf\uff09<\/h2>\n\n\n\n
                                                            \u5bc4\u5feb\u9012\u3001\u7f51\u8d2d\u7684\u65f6\u5019\uff0c\u67e5\u8be2\u7269\u6d41\u4fe1\u606f\uff0c\u90fd\u4f1a\u7ed9\u6211\u4eec\u5c55\u793axxx\u65f6\u5019\uff0c\u5feb\u9012\u5230\u8fbe\u4ec0\u4e48\u5730\u65b9\u4e86\uff0c\u8fd9\u5c31\u662f\u4e00\u4e2a\u5178\u578b\u7684\u65f6\u95f4\u7ebf\u5217\u8868\uff1b<\/p>\n\n\n\n
                                                            \u6570\u636e\u5e93\u7684\u505a\u6cd5\uff0c\u5c31\u662f\u6bcf\u6b21\u53d8\u66f4\u5c31\u63d2\u5165\u4e00\u6761\u5e26\u65f6\u95f4\u7684\u4fe1\u606f\u8bb0\u5f55\uff0c\u7136\u540e\u6839\u636e\u65f6\u95f4\u548cID\uff08ID\u662f\u5fc5\u987b\u7684\uff0c\u5982\u679c\u51fa\u73b0\u4e24\u4e2a\u76f8\u540c\u7684\u65f6\u95f4\uff0c\u5355\u7eaf\u65f6\u95f4\u6392\u5e8f\uff0c\u4f1a\u9020\u6210\u987a\u5e8f\u4e0d\u5bf9\uff09\uff0c\u6765\u6392\u5e8f\u751f\u6210\u65f6\u95f4\u7ebf\uff1b<\/p>\n\n\n\n
                                                            \u6211\u4eec\u4e5f\u53ef\u4ee5\u901a\u8fc7 Redis \u7684 List \u6765\u5b9e\u73b0\u65f6\u95f4\u7ebf\u529f\u80fd\uff0c\u7531\u4e8e List \u91c7\u7528\u7684\u662f\u53cc\u5411\u94fe\u8868\uff0c\u56e0\u6b64\u5347\u5e8f\uff0c\u964d\u5e8f\u7684\u65f6\u95f4\u7ebf\u90fd\u80fd\u6b63\u5e38\u6ee1\u8db3\uff1b<\/p>\n\n\n\n
                                                              \n
                                                            • RPUSH<\/strong> key value1 [value2]\uff1a\u5728\u5217\u8868\u4e2d\u6dfb\u52a0\u4e00\u4e2a\u6216\u591a\u4e2a\u503c\uff0c\uff08\u5347\u5e8f\u65f6\u95f4\u7ebf\uff09<\/li>\n\n\n\n
                                                            • LPUSH<\/strong> key value1 [value2]\uff1a\u5c06\u4e00\u4e2a\u6216\u591a\u4e2a\u503c\u63d2\u5165\u5230\u5217\u8868\u5934\u90e8\uff08\u964d\u5e8f\u65f6\u95f4\u7ebf\uff09<\/li>\n\n\n\n
                                                            • LRANGE<\/strong> key start stop\uff1a\u83b7\u53d6\u5217\u8868\u6307\u5b9a\u8303\u56f4\u5185\u7684\u5143\u7d20<\/li>\n<\/ul>\n\n\n\n
                                                              Redis-cli \u5ba2\u6237\u7aef\u6d4b\u8bd5<\/p>\n\n\n\n
                                                                \n
                                                              • \u5347\u5e8f127.0.0.1:6379> RPUSH time:line:asc 20220805170000
                                                                (integer) 1
                                                                127.0.0.1:6379> RPUSH time:line:asc 20220805170001
                                                                (integer) 2
                                                                127.0.0.1:6379> RPUSH time:line:asc 20220805170002
                                                                (integer) 3
                                                                127.0.0.1:6379> LRANGE time:line:asc 0 -1
                                                                1) \"20220805170000\"
                                                                2) \"20220805170001\"
                                                                3) \"20220805170002\"<\/code><\/li>\n\n\n\n
                                                              • \u964d\u5e8f127.0.0.1:6379> LPUSH time:line:desc 20220805170000
                                                                (integer) 1
                                                                127.0.0.1:6379> LPUSH time:line:desc 20220805170001
                                                                (integer) 2
                                                                127.0.0.1:6379> LPUSH time:line:desc 20220805170002
                                                                (integer) 3
                                                                127.0.0.1:6379> LRANGE time:line:desc 0 -1
                                                                1) \"20220805170002\"
                                                                2) \"20220805170001\"
                                                                3) \"20220805170000\"<\/code><\/li>\n<\/ul>\n\n\n\n
                                                                \u597d\u4e86\uff0c\u5173\u4e8eRedis \u7684\u5999\u7528\uff0c\u5c31\u4ecb\u7ecd\u5230\u8fd9\u91cc\uff1b\u6709\u4e86\u8fd9\u4e9b\u4e2a\u573a\u666f\u7684\u8fd0\u7528\uff0c\u4e0b\u6b21\u518d\u6709\u9762\u8bd5\u5b98\u95ee\u4f60\uff0cRedis\u9664\u4e86\u7f13\u5b58\u8fd8\u505a\u8fc7\u4ec0\u4e48\uff0c\u76f8\u4fe1\u804a\u4e0a\u4e2a1\u628a\u5c0f\u65f6\uff0c\u5e94\u8be5\u4e0d\u6210\u95ee\u9898\u4e86\u3002<\/p>\n\n\n\n
                                                                \n
                                                                \u6d4b\u8bd5\u6e90\u7801\uff1ahttps:\/\/github.com\/vehang\/ehang-spring-boot\/tree\/main\/spring-boot-011-redis<\/p>\n\n\n\n
                                                                \u5927\u90e8\u5206\u7528\u4f8b\u90fd\u5728test\u76ee\u5f55\u4e0b<\/p>\n<\/blockquote>\n","protected":false},"excerpt":{"rendered":"
                                                                \u539f\u6587\uff1aRedis \u53ea\u4f1a\u7528\u7f13\u5b58\uff1f20\u79cd\u5999\u7528\u8ba9\u540c\u4e8b\u76f4\u547c\u725bX (qq.com) \uff0c\u539f\u6587\u6392\u7248\u5f88\u597d\uff0c\u63a8\u8350\u770b\u539f\u6587 \u4e0b\u9762\u6574\u7406 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[119],"tags":[51],"_links":{"self":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/4242"}],"collection":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=4242"}],"version-history":[{"count":4,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/4242\/revisions"}],"predecessor-version":[{"id":4246,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/4242\/revisions\/4246"}],"wp:attachment":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=4242"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=4242"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=4242"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}