![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143253-697a1e153a338.png\")
<\/p>\n\u76ee\u5f55<\/p>\n
1.\u539f\u59cb\u7684\u70b9\u8d5e\u4e1a\u52a1<\/p>\n
1.1\u9875\u9762\u539f\u578b<\/p>\n
1.2\u70b9\u8d5e\u4e1a\u52a1<\/p>\n
1.2.1\u6570\u636e\u5e93\u8868<\/p>\n
1.2.2\u4e1a\u52a1\u6d41\u7a0b<\/p>\n
1.2.3\u4e1a\u52a1\u4ee3\u7801<\/p>\n
1.3 \u539f\u59cb\u65b9\u6848\u7684\u6027\u80fd\u74f6\u9888<\/p>\n
2.\u9ad8\u5e76\u53d1\u4f18\u5316\u601d\u8def：Redis + \u5408\u5e76\u5199\u8bf7\u6c42<\/p>\n
2.1 \u4f18\u5316\u65b9\u5411\u5206\u6790<\/p>\n
2.2\u4fee\u6539\u4e4b\u540e\u7684\u4e1a\u52a1\u5206\u6790<\/p>\n
2.2.1\u6838\u5fc3\u4e1a\u52a1\u6d41\u7a0b<\/p>\n
2.2.2Redis \u6570\u636e\u7ed3\u6784\u9009\u578b<\/p>\n
2.3\u4ee3\u7801\u5b9e\u73b0<\/p>\n
2.3.1\u4ee3\u7801\u5b9e\u73b0\u6d41\u7a0b\u56fe<\/p>\n
2.3.2\u6838\u5fc3\u63a5\u53e3\u6539\u9020（\u70b9\u8d5e \/ \u53d6\u6d88）<\/p>\n
2.3.3Pipeline \u4f18\u5316\u6279\u91cf\u67e5\u8be2\u6027\u80fd<\/p>\n
2.3.4 \u5b9a\u65f6\u4efb\u52a1\u6279\u91cf\u540c\u6b65\u70b9\u8d5e\u6570<\/p>\n
3.\u8fdb\u4e00\u6b65\u4f18\u5316：\u5b9a\u671f\u6301\u4e45\u5316\u5230\u6570\u636e\u5e93，\u91c7\u7528LRU\u79fb\u9664\u6700\u8fd1\u6700\u5c11\u8bbf\u95ee<\/p>\n
3.1\u5b9a\u4e49\u65b0\u7684Redis\u7ed3\u6784\u7528\u4e8e\u5b9e\u73b0LRU\u548c\u6301\u4e45\u5316<\/p>\n
3.1.1LRU \u8bbf\u95ee\u7b56\u7565\u8868<\/p>\n
3.1.2\u4e1a\u52a1\u7c7b\u578b\u6620\u5c04\u8868 (Hash)<\/p>\n
3.2\u4e1a\u52a1\u6d41\u7a0b<\/p>\n
3.2.1\u5b9e\u65f6\u4ea4\u4e92\u6d41\u7a0b<\/p>\n
3.2.2\u5f02\u6b65\u6301\u4e45\u5316\u6d41\u7a0b<\/p>\n
3.3\u4ee3\u7801\u5b9e\u73b0<\/p>\n
\u672c\u6587\u4e3b\u8981\u662f\u6211\u4e2a\u4eba\u5b66\u4e60\u5929\u673a\u5b66\u5802\u8fd9\u4e2a\u9879\u76ee\u81ea\u5df1\u7684\u4e00\u4e9b\u7406\u89e3\u548c\u4f18\u5316\u90e8\u5206，\u4e3b\u8981\u662f\u6458\u51fa\u9879\u76ee\u4e2d\u4e00\u4e9b\u6bd4\u8f83\u901a\u7528\u7684\u90e8\u5206，\u65b9\u4fbf\u5927\u5bb6\u4ee5\u53ca\u81ea\u5df1\u4e4b\u540e\u5982\u679c\u9047\u5230\u4e86\u7c7b\u4f3c\u7684\u4e1a\u52a1\u53ef\u4ee5\u8fdb\u884c\u53c2\u8003\u4f7f\u7528<\/p>\n
\u5f53\u7528\u6237\u70b9\u51fb\u70b9\u8d5e\u6309\u94ae\u7684\u65f6\u5019，\u7b2c\u4e00\u6b21\u70b9\u51fb\u662f\u70b9\u8d5e，\u6309\u94ae\u4f1a\u9ad8\u4eae；\u7b2c\u4e8c\u6b21\u70b9\u51fb\u662f\u53d6\u6d88，\u70b9\u8d5e\u6309\u94ae\u53d8\u7070：<\/p>\n
<\/p>\n
\u8868\u53ea\u6709\u4e00\u5f20，\u5f88\u7b80\u5355，\u5c31\u662f\u8c01\u7ed9\u54ea\u4e2a\u4e1a\u52a1\u70b9\u4e86\u8d5e\u7684\u4e00\u4e2a\u8bb0\u5f55；\u70b9\u8d5e\u6570\u5c31\u662f\u7edf\u8ba1\u8fd9\u6761\u6570\u636e\u6709\u591a\u5c11\u4eba\u70b9\u8d5e\u4e86\u3002liked_record \u7528\u4e8e\u8bb0\u5f55\u70b9\u8d5e\u884c\u4e3a，\u901a\u8fc7 biz_type \u533a\u5206\u4e0d\u540c\u4e1a\u52a1\u3001biz_id \u5173\u8054\u5177\u4f53\u4e1a\u52a1 ID，\u7ed3\u5408\u7528\u6237 ID \u505a\u552f\u4e00\u7d22\u5f15\u9632\u6b62\u91cd\u590d\u70b9\u8d5e：<\/p>\n
CREATE TABLE IF NOT EXISTS `liked_record` (
\n `id` bigint NOT NULL AUTO_INCREMENT COMMENT '\u4e3b\u952eid',
\n `user_id` bigint NOT NULL COMMENT '\u7528\u6237id',
\n `biz_id` bigint NOT NULL COMMENT '\u70b9\u8d5e\u7684\u4e1a\u52a1id',
\n `biz_type` VARCHAR(16) NOT NULL COMMENT '\u70b9\u8d5e\u7684\u4e1a\u52a1\u7c7b\u578b',
\n `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '\u521b\u5efa\u65f6\u95f4',
\n `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '\u66f4\u65b0\u65f6\u95f4',
\n PRIMARY KEY (`id`),
\n UNIQUE KEY `idx_biz_user` (`biz_id`,`user_id`)
\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='\u70b9\u8d5e\u8bb0\u5f55\u8868'; <\/p>\n
\u4e1a\u52a1\u65b9（\u5982\u4e92\u52a8\u95ee\u7b54）\u5219\u5728\u81ea\u8eab\u8868\u4e2d\u7ef4\u62a4 liked_times \u5b57\u6bb5，\u8bb0\u5f55\u70b9\u8d5e\u603b\u6570\u3002<\/p>\n
\u70b9\u8d5e\u5c31\u65b0\u589e\u4e00\u6761\u70b9\u8d5e\u8bb0\u5f55，\u53d6\u6d88\u70b9\u8d5e\u5c31\u5220\u9664\u8bb0\u5f55<\/p>\n<\/li>\n
\u7528\u6237\u4e0d\u80fd\u91cd\u590d\u70b9\u8d5e<\/p>\n<\/li>\n
\u70b9\u8d5e\u6570\u7531\u5177\u4f53\u7684\u4e1a\u52a1\u65b9\u4fdd\u5b58，\u9700\u8981\u901a\u77e5\u4e1a\u52a1\u65b9\u66f4\u65b0\u70b9\u8d5e\u6570<\/p>\n<\/li>\n<\/ul>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143253-697a1e156d713.png\")
<\/p>\n
\u9700\u8981\u6ce8\u610f\u7684\u662f，\u7531\u4e8e\u6bcf\u6b21\u70b9\u8d5e\u7684\u4e1a\u52a1\u7c7b\u578b\u4e0d\u540c，\u6240\u4ee5\u6ca1\u6709\u5fc5\u8981\u901a\u77e5\u5230\u6240\u6709\u4e1a\u52a1\u65b9，\u800c\u662f\u4ec5\u4ec5\u901a\u77e5\u4e0e\u5f53\u524d\u70b9\u8d5e\u4e1a\u52a1\u5173\u8054\u7684\u4e1a\u52a1\u65b9\u5373\u53ef\u3002<\/p>\n
\u5728RabbitMQ\u4e2d，\u5229\u7528TOPIC\u7c7b\u578b\u7684\u4ea4\u6362\u673a，\u7ed3\u5408\u4e0d\u540c\u7684RoutingKey，\u53ef\u4ee5\u5b9e\u73b0\u901a\u77e5\u5bf9\u8c61\u7684\u53d8\u5316\u3002\u6211\u4eec\u9700\u8981\u8ba9\u4e0d\u540c\u7684\u4e1a\u52a1\u65b9\u76d1\u542c\u4e0d\u540c\u7684RoutingKey，\u7136\u540e\u53d1\u9001\u901a\u77e5\u65f6\u6839\u636e\u70b9\u8d5e\u7c7b\u578b\u4e0d\u540c，\u53d1\u9001\u4e0d\u540cRoutingKey：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143253-697a1e15abc7a.png\")
<\/p>\n
\u2460\u70b9\u8d5e\u76f8\u5173\u4ee3\u7801<\/p>\n
MQ\u5e38\u91cf<\/p>\n
package com.tianji.common.constants;<\/p>\n
public interface MqConstants {
\n interface Exchange{
\n \/*\u70b9\u8d5e\u8bb0\u5f55\u6709\u5173\u7684\u4ea4\u6362\u673a*\/
\n String LIKE_RECORD_EXCHANGE = "like.record.topic";
\n }
\n interface Queue {
\n String ERROR_QUEUE_TEMPLATE = "error.{}.queue";
\n }
\n interface Key{
\n \/*\u70b9\u8d5e\u7684RoutingKey*\/
\n String LIKED_TIMES_KEY_TEMPLATE = "{}.times.changed";
\n \/*\u95ee\u7b54*\/
\n String QA_LIKED_TIMES_KEY = "QA.times.changed";
\n \/*\u7b14\u8bb0*\/
\n String NOTE_LIKED_TIMES_KEY = "NOTE.times.changed";<\/p>\n
}
\n}<\/p>\n
DTO<\/p>\n
@Data
\n@NoArgsConstructor
\n@AllArgsConstructor
\npublic class LikedTimesDTO {
\n \/**
\n * \u70b9\u8d5e\u7684\u4e1a\u52a1id
\n *\/
\n private Long bizId;
\n \/**
\n * \u603b\u7684\u70b9\u8d5e\u6b21\u6570
\n *\/
\n private Integer likedTimes;
\n} <\/p>\n
service\u5b8c\u6574\u4e1a\u52a1\u4ee3\u7801<\/p>\n
package com.tianji.remark.service.impl;<\/p>\n
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
\nimport com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
\nimport com.tianji.common.autoconfigure.mq.RabbitMqHelper;
\nimport com.tianji.common.utils.StringUtils;
\nimport com.tianji.common.utils.UserContext;
\nimport com.tianji.remark.domain.dto.LikeRecordFormDTO;
\nimport com.tianji.remark.domain.po.LikedRecord;
\nimport com.tianji.remark.mapper.LikedRecordMapper;
\nimport com.tianji.remark.service.ILikedRecordService;
\nimport lombok.RequiredArgsConstructor;<\/p>\n
import java.util.List;
\nimport java.util.Set;
\nimport java.util.stream.Collectors;<\/p>\n
import static com.tianji.common.constants.MqConstants.Exchange.LIKE_RECORD_EXCHANGE;
\nimport static com.tianji.common.constants.MqConstants.Key.LIKED_TIMES_KEY_TEMPLATE;<\/p>\n
\/**
\n * <p>
\n * \u70b9\u8d5e\u8bb0\u5f55\u8868 \u670d\u52a1\u5b9e\u73b0\u7c7b
\n * <\/p>
\n *\/
\n@Service
\n@RequiredArgsConstructor
\npublic class LikedRecordServiceImpl extends ServiceImpl<LikedRecordMapper, LikedRecord> implements ILikedRecordService {<\/p>\n
private final RabbitMqHelper mqHelper;<\/p>\n
@Override
\n public void addLikeRecord(LikeRecordFormDTO recordDTO) {
\n \/\/ 1.\u57fa\u4e8e\u524d\u7aef\u7684\u53c2\u6570，\u5224\u65ad\u662f\u6267\u884c\u70b9\u8d5e\u8fd8\u662f\u53d6\u6d88\u70b9\u8d5e
\n boolean success = recordDTO.getLiked() ? like(recordDTO) : unlike(recordDTO);
\n \/\/ 2.\u5224\u65ad\u662f\u5426\u6267\u884c\u6210\u529f，\u5982\u679c\u5931\u8d25，\u5219\u76f4\u63a5\u7ed3\u675f
\n if (!success) {
\n return;
\n }
\n \/\/ 3.\u5982\u679c\u6267\u884c\u6210\u529f，\u7edf\u8ba1\u70b9\u8d5e\u603b\u6570
\n Integer likedTimes = lambdaQuery()
\n .eq(LikedRecord::getBizId, recordDTO.getBizId())
\n .count();
\n \/\/ 4.\u53d1\u9001MQ\u901a\u77e5
\n mqHelper.send(
\n LIKE_RECORD_EXCHANGE,
\n StringUtils.format(LIKED_TIMES_KEY_TEMPLATE, recordDTO.getBizType()),
\n LikedTimesDTO.of(recordDTO.getBizId(), likedTimes));
\n }<\/p>\n
private boolean unlike(LikeRecordFormDTO recordDTO) {
\n return remove(new QueryWrapper<LikedRecord>().lambda()
\n .eq(LikedRecord::getUserId, UserContext.getUser())
\n .eq(LikedRecord::getBizId, recordDTO.getBizId()));
\n }<\/p>\n
private boolean like(LikeRecordFormDTO recordDTO) {
\n Long userId = UserContext.getUser();
\n \/\/ 1.\u67e5\u8be2\u70b9\u8d5e\u8bb0\u5f55
\n Integer count = lambdaQuery()
\n .eq(LikedRecord::getUserId, userId)
\n .eq(LikedRecord::getBizId, recordDTO.getBizId())
\n .count();
\n \/\/ 2.\u5224\u65ad\u662f\u5426\u5b58\u5728，\u5982\u679c\u5df2\u7ecf\u5b58\u5728，\u76f4\u63a5\u7ed3\u675f
\n if (count > 0) {
\n return false;
\n }
\n \/\/ 3.\u5982\u679c\u4e0d\u5b58\u5728，\u76f4\u63a5\u65b0\u589e
\n LikedRecord r = new LikedRecord();
\n r.setUserId(userId);
\n r.setBizId(recordDTO.getBizId());
\n r.setBizType(recordDTO.getBizType());
\n save(r);
\n return true;
\n }
\n} <\/p>\n
\u2461\u6279\u91cf\u67e5\u8be2\u70b9\u8d5e\u72b6\u6001（\u5176\u5b9e\u5c31\u76f8\u5f53\u4e8e\u67e5\u8be2\u7528\u6237\u4e3a\u54ea\u4e9b\u6d88\u606f\u8fdb\u884c\u4e86\u70b9\u8d5e），\u4f9b\u4e1a\u52a1\u65b9\u67e5\u8be2\u5f53\u524d\u7528\u6237\u5bf9\u6307\u5b9a\u4e1a\u52a1\u7684\u70b9\u8d5e\u72b6\u6001，\u8fd4\u56de\u70b9\u8d5e\u8fc7\u7684\u4e1a\u52a1 ID \u96c6\u5408\u3002<\/p>\n
\u4e1a\u52a1\u4ee3\u7801：<\/p>\n
\/**
\n * \u5224\u65ad\u4e1a\u52a1\u662f\u5426\u88ab\u8be5\u7528\u6237\u70b9\u8d5e
\n *
\n * @param bizIds \u4e1a\u52a1id\u5217\u8868
\n * @return \u4e1a\u52a1\u662f\u5426\u88ab\u70b9\u8d5e
\n *\/
\n @Override
\n public Set<Long> isBizLiked(List<Long> bizIds) {
\n \/\/ 1.\u83b7\u53d6\u767b\u5f55\u7528\u6237id
\n Long userId = UserContext.getUser();
\n \/\/ 2.\u67e5\u8be2\u70b9\u8d5e\u72b6\u6001
\n List<LikedRecord> list = lambdaQuery()
\n .in(LikedRecord::getBizId, bizIds)
\n .eq(LikedRecord::getUserId, userId)
\n .list();
\n \/\/ 3.\u8fd4\u56de\u7ed3\u679c
\n return list.stream().map(LikedRecord::getBizId).collect(Collectors.toSet());
\n } <\/p>\n
\u539f\u59cb\u65b9\u6848\u80fd\u6ee1\u8db3\u529f\u80fd\u9700\u6c42，\u4f46\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\u66b4\u9732\u51fa\u81f4\u547d\u95ee\u9898：<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143253-697a1e15cca62.png\")
<\/p>\n<\/p>\n
\u9488\u5bf9\u9ad8\u5e76\u53d1\u5199\u573a\u666f，\u5e38\u89c1\u4f18\u5316\u624b\u6bb5\u6709\u4e09\u79cd：<\/p>\n
\u70b9\u8d5e\u4e1a\u52a1\u7684\u6838\u5fc3\u7279\u6027\u662f\u300c\u6700\u7ec8\u7ed3\u679c\u6709\u6548，\u4e2d\u95f4\u8fc7\u7a0b\u53ef\u5ffd\u7565\u300d<\/span>\u2014\u2014 \u7528\u6237\u53cd\u590d\u70b9\u8d5e \/ \u53d6\u6d88，\u6700\u7ec8\u53ea\u9700\u8981\u4fdd\u7559\u300c\u662f\u5426\u70b9\u8d5e\u300d\u548c\u300c\u6700\u7ec8\u70b9\u8d5e\u6570\u300d，\u5b8c\u5168\u9002\u914d\u300c\u5408\u5e76\u5199\u8bf7\u6c42\u300d\u65b9\u6848\u3002\u56e0\u6b64\u6211\u4eec\u9009\u62e9\u300cRedis \u7f13\u5b58 + \u5b9a\u65f6\u6279\u91cf\u540c\u6b65\u300d<\/span>\u7684\u4f18\u5316\u8def\u5f84，\u517c\u987e\u9ad8\u6027\u80fd\u4e0e\u6570\u636e\u4e00\u81f4\u6027\u3002<\/p>\n<\/p>\n \u4f18\u5316\u540e\u7684\u70b9\u8d5e\u6d41\u7a0b\u6838\u5fc3\u662f\u300c\u5148\u5199\u7f13\u5b58，\u540e\u6279\u91cf\u540c\u6b65\u300d：<\/p>\n \u8fd9\u91cc\u7ed9\u4e24\u5e45\u56fe，\u4e00\u4efd\u9ed1\u9a6c\u7684，\u4e00\u4efd\u6309\u6211\u81ea\u5df1\u7684\u7406\u89e3\u753b（\u5176\u5b9e\u611f\u89c9\u9ed1\u9a6c\u7684\u6709\u70b9\u62bd\u8c61）<\/p>\n \u57fa\u4e8e\u70b9\u8d5e\u4e1a\u52a1\u7684\u4e24\u4e2a\u6838\u5fc3\u6570\u636e（\u7528\u6237\u70b9\u8d5e\u8bb0\u5f55\u3001\u4e1a\u52a1\u70b9\u8d5e\u6570），\u6211\u4eec\u9009\u62e9\u4e24\u79cd Redis \u6570\u636e\u7ed3\u6784：<\/p>\n \u9009\u578b\u6df1\u5c42\u601d\u8003：<\/p>\n \u4e24\u79cdRedis\u7ed3\u6784\u793a\u4f8b\u5982\u4e0b：<\/p>\n \u70b9\u8d5e\u8bb0\u5f55（\u5224\u65ad\u7528\u6237\u662f\u5426\u70b9\u8d5e）<\/p>\n KEY（bizId）<\/p>\n VALUE(userId)<\/p>\n<\/tr>\n bizId:1<\/p>\n<\/td>\n userId:1<\/p>\n<\/td>\n<\/tr>\n userId:2<\/p>\n<\/td>\n<\/tr>\n userId:3<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u70b9\u8d5e\u6570\u91cf<\/p>\n KEY（bizType）<\/p>\n Member(bizId)<\/p>\n Score(likedTimes)<\/p>\n<\/tr>\n likes:qa<\/p>\n<\/td>\n bizId:1001<\/p>\n<\/td>\n 10<\/p>\n<\/td>\n<\/tr>\n bizId:1002<\/p>\n<\/td>\n 5<\/p>\n<\/td>\n<\/tr>\n likes:note<\/p>\n<\/td>\n bizId:2001<\/p>\n<\/td>\n 9<\/p>\n<\/td>\n<\/tr>\n bizId:2002<\/p>\n<\/td>\n 21<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \u66ff\u6362\u539f\u6709\u7684\u6570\u636e\u5e93\u64cd\u4f5c，\u6539\u4e3a Redis \u64cd\u4f5c，\u6838\u5fc3\u4ee3\u7801\u5982\u4e0b：<\/p>\n @Service @Override \/\/ \u70b9\u8d5e：SADD\u8fd4\u56de1\u5219\u6210\u529f（\u672a\u70b9\u8d5e\u8fc7），0\u5219\u5931\u8d25（\u91cd\u590d\u70b9\u8d5e） \/\/ \u53d6\u6d88\u70b9\u8d5e：SREM\u8fd4\u56de1\u5219\u6210\u529f（\u5df2\u70b9\u8d5e），0\u5219\u5931\u8d25 \u6279\u91cf\u67e5\u8be2\u70b9\u8d5e\u72b6\u6001\u65f6，\u82e5\u9010\u4e2a\u8c03\u7528 SISMEMBER，\u4f1a\u4ea7\u751f\u591a\u6b21 Redis \u7f51\u7edc\u4ea4\u4e92\u3002\u6211\u4eec\u4f7f\u7528 Redis Pipeline \u5c06\u591a\u4e2a\u547d\u4ee4\u6253\u5305\u53d1\u9001，\u4e00\u6b21\u7f51\u7edc\u5f80\u8fd4\u5b8c\u6210\u6240\u6709\u67e5\u8be2：<\/p>\n @Override \u4f7f\u7528 SpringTask \u5b9e\u73b0\u5b9a\u65f6\u4efb\u52a1，\u6bcf\u9694 20 \u79d2\u4ece ZSet \u4e2d\u53d6\u51fa\u5f85\u540c\u6b65\u6570\u636e，\u6279\u91cf\u53d1\u9001 MQ：<\/p>\n @Component @Scheduled(fixedDelay = 20000) \/\/ 20\u79d2\u6267\u884c\u4e00\u6b21 \/\/ \u6838\u5fc3\u540c\u6b65\u903b\u8f91 \u7528\u4e8e\u5b58\u50a8 \u6bcf\u4e2a\u4e1a\u52a1\u6700\u540e\u4e00\u6b21\u88ab\u8bbf\u95ee（\u70b9\u8d5e\/\u67e5\u8be2）\u7684\u65f6\u95f4\u6233 \u3002Score \u8d8a\u5c0f\u4ee3\u8868\u8d8a\u4e45\u6ca1\u8bbf\u95ee（\u51b7\u6570\u636e）\u3002<\/p>\n \u7528\u4e8e\u5b58\u50a8 \u4e1a\u52a1ID\u5bf9\u5e94\u7684\u4e1a\u52a1\u7c7b\u578b ，\u786e\u4fdd\u6301\u4e45\u5316\u65f6\u80fd\u77e5\u9053\u6bcf\u4e2a ID \u662f\u4ec0\u4e48\u7c7b\u578b\u7684\u4e1a\u52a1\u3002<\/p>\n \u2460 \u70b9\u8d5e \/ \u53d6\u6d88\u70b9\u8d5e<\/p>\n \u2461\u67e5\u8be2\u70b9\u8d5e\u72b6\u6001<\/p>\n \u5b9a\u65f6\u4efb\u52a1 (\u6bcf 3\u5206\u949f\u6267\u884c\u4e00\u6b21，\u8fd9\u91cc\u6839\u636e\u5b9e\u9645\u60c5\u51b5\u8fdb\u884c\u8c03\u6574)<\/p>\n 1. \u5bb9\u91cf\u68c0\u67e5 : \u68c0\u67e5 LRU ZSet \u8bb0\u5f55\u7684\u6570\u91cf\u662f\u5426\u8d85\u8fc7\u6700\u5927\u9608\u503c (\u5982 10000)\u3002 2. \u7b5b\u9009\u51b7\u6570\u636e : \u5982\u679c\u8d85\u9650，\u6309\u5206\u6570\u4ece\u5c0f\u5230\u5927 (\u65f6\u95f4\u4ece\u65e7\u5230\u65b0) \u6293\u53d6\u6700\u4e45\u672a\u8bbf\u95ee\u7684\u4e00\u6279\u4e1a\u52a1ID\u3002 3. \u6570\u636e\u540c\u6b65 (Diff & Sync) : \u00a0 \u00a0– \u5bf9\u4e8e\u6bcf\u4e2a\u51b7\u4e1a\u52a1ID，\u53d6\u51fa Redis \u4e2d\u7684\u7528\u6237\u5217\u8868\u4e0e DB \u4e2d\u7684\u7528\u6237\u5217\u8868\u3002 \u00a0 \u00a0– \u8ba1\u7b97\u5dee\u5f02 : \u627e\u51fa Redis \u4e2d\u65b0\u589e\u7684\u7528\u6237 (\u9700\u63d2\u5165 DB) \u548c Redis \u4e2d\u5df2\u79fb\u9664\u7684\u7528\u6237 (\u9700\u4ece DB \u5220\u9664)\u3002 \u00a0 \u00a0– \u6279\u91cf\u843d\u5e93 : \u6267\u884c\u6570\u636e\u5e93\u7684\u63d2\u5165\u548c\u5220\u9664\u64cd\u4f5c，\u786e\u4fdd\u6570\u636e\u4e00\u81f4\u3002 4. \u5185\u5b58\u91ca\u653e : \u540c\u6b65\u6210\u529f\u540e，\u5f7b\u5e95\u5220\u9664 Redis \u4e2d\u7684\u76f8\u5173 Key (Set, Hash, ZSet)，\u91ca\u653e\u5185\u5b58\u7a7a\u95f4\u3002<\/p>\n package com.tianji.remark.service.impl;<\/p>\n import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import java.util.*; import static com.tianji.common.constants.MqConstants.Exchange.LIKE_RECORD_EXCHANGE; \/** private final RabbitMqHelper mqHelper; @Override \/\/ \u66f4\u65b0\u8bbf\u95ee\u65f6\u95f4(LRU) \u548c \u4e1a\u52a1\u7c7b\u578b\u6620\u5c04 \/\/ 3.\u5982\u679c\u6267\u884c\u6210\u529f，\u7edf\u8ba1\u70b9\u8d5e\u603b\u6570 @Override \/\/ 2.\u68c0\u67e5Redis\u4e2d\u662f\u5426\u5b58\u5728 key，\u4e0d\u5b58\u5728\u5219\u5c1d\u8bd5\u4ece\u6570\u636e\u5e93\u52a0\u8f7d for (int i = 0; i < bizIds.size(); i++) { if (!missingBizIds.isEmpty()) { \/\/ 3.\u66f4\u65b0LRU\u8bbf\u95ee\u65f6\u95f4 \/\/ 4.\u67e5\u8be2\u70b9\u8d5e\u72b6\u6001 private void loadBizLikesFromDb(List<Long> bizIds) { \/\/ \u5206\u7ec4 \/\/ \u5199\u5165Redis String key = RedisConstants.LIKE_BIZ_KEY_PREFIX + bizId; \/\/ \u7f13\u5b58\u4e1a\u52a1\u7c7b\u578b @Override \/\/ 2.\u83b7\u53d6\u6700\u65e7\u7684\u8bb0\u5f55 if (CollUtils.isEmpty(tuples)) { for (ZSetOperations.TypedTuple<String> tuple : tuples) { \/\/ 3.\u83b7\u53d6Redis\u4e2d\u7684\u6570\u636e \/\/ 4.\u83b7\u53d6DB\u4e2d\u7684\u6570\u636e \/\/ 5.\u8ba1\u7b97\u5dee\u5f02 Set<String> toDelete = new HashSet<>(userIdsInDb); \/\/ 6.\u540c\u6b65\u5230DB List<LikedRecord> newRecords = toAdd.stream().map(uid -> { if (!toDelete.isEmpty()) { \/\/ 7.\u6e05\u7406Redis @Override private boolean unlike(LikeRecordFormDTO recordDTO) { private boolean like(LikeRecordFormDTO recordDTO) { public interface RedisConstants { import com.tianji.remark.service.ILikedRecordService; import java.util.List;<\/p>\n @Slf4j @Value("${tj.remark.task.biz-types:QA,NOTE}") @Value("${tj.remark.task.max-biz-size:30}") private final ILikedRecordService recordService;<\/p>\n @Scheduled(fixedDelay = 2000) @Scheduled(fixedDelay = 10000) \u611f\u5174\u8da3\u7684\u5b9d\u5b50\u53ef\u4ee5\u5173\u6ce8\u4e00\u6ce2，\u540e\u7eed\u4f1a\u66f4\u65b0\u66f4\u591a\u6709\u7528\u7684\u77e5\u8bc6！！！<\/span><\/p>\n \u76ee\u5f552.2\u4fee\u6539\u4e4b\u540e\u7684\u4e1a\u52a1\u5206\u6790<\/h3>\n
2.2.1\u6838\u5fc3\u4e1a\u52a1\u6d41\u7a0b<\/h4>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143254-697a1e160c20b.png\")
<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143254-697a1e16473f5.png\")
<\/p>\n2.2.2Redis \u6570\u636e\u7ed3\u6784\u9009\u578b<\/h4>\n
\n
\u6570\u636e\u7c7b\u578b\u6570\u636e\u7ed3\u6784Key \u8bbe\u8ba1\u6838\u5fc3\u4f5c\u7528<\/tr>\n \n\n \u7528\u6237\u70b9\u8d5e\u8bb0\u5f55<\/td>\n Set<\/td>\n likes:set:biz:{bizId}<\/td>\n \u5b58\u50a8\u7ed9\u67d0\u4e1a\u52a1\u70b9\u8d5e\u7684\u6240\u6709\u7528\u6237 ID，\u5229\u7528 Set \u7684\u552f\u4e00\u6027\u9632\u91cd\u590d\u70b9\u8d5e，SCARD \u5feb\u901f\u7edf\u8ba1\u603b\u6570<\/td>\n<\/tr>\n \n \u5f85\u540c\u6b65\u70b9\u8d5e\u6570<\/td>\n ZSet<\/td>\n likes:times:type:{bizType}<\/td>\n \u5b58\u50a8\u4e1a\u52a1 ID \u4e0e\u6700\u65b0\u70b9\u8d5e\u6570，\u5229\u7528 ZSet \u7684 member \u552f\u4e00\u6027\u907f\u514d\u91cd\u590d\u540c\u6b65<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n \n
\n
\n \n\n \n \n \n \n \n \n \n
\n \n\n \n \n \n \n \n \n \n \n \n \n \n \n \n 2.3\u4ee3\u7801\u5b9e\u73b0<\/h3>\n
2.3.1\u4ee3\u7801\u5b9e\u73b0\u6d41\u7a0b\u56fe<\/h4>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143254-697a1e168b565.png\")
<\/p>\n2.3.2\u6838\u5fc3\u63a5\u53e3\u6539\u9020（\u70b9\u8d5e \/ \u53d6\u6d88）<\/h4>\n
\npublic class LikedRecordServiceRedisImpl implements ILikedRecordService {
\n private final StringRedisTemplate redisTemplate;<\/p>\n
\n public void addLikeRecord(LikeRecordFormDTO recordDTO) {
\n \/\/ 1. \u70b9\u8d5e\/\u53d6\u6d88\u70b9\u8d5e（\u64cd\u4f5cRedis Set）
\n boolean success = recordDTO.getLiked() ? like(recordDTO) : unlike(recordDTO);
\n if (!success) return;
\n \/\/ 2. \u7edf\u8ba1Redis\u4e2d\u70b9\u8d5e\u603b\u6570
\n Long likedTimes = redisTemplate.opsForSet()
\n .size(RedisConstants.LIKE_BIZ_KEY_PREFIX + recordDTO.getBizId());
\n if (likedTimes == null) return;
\n \/\/ 3. \u66f4\u65b0ZSet\u5f85\u540c\u6b65\u6570\u636e
\n redisTemplate.opsForZSet().add(
\n RedisConstants.LIKES_TIMES_KEY_PREFIX + recordDTO.getBizType(),
\n recordDTO.getBizId().toString(),
\n likedTimes
\n );
\n }<\/p>\n
\n private boolean like(LikeRecordFormDTO recordDTO) {
\n String key = RedisConstants.LIKE_BIZ_KEY_PREFIX + recordDTO.getBizId();
\n Long result = redisTemplate.opsForSet().add(key, UserContext.getUser().toString());
\n return result != null && result > 0;
\n }<\/p>\n
\n private boolean unlike(LikeRecordFormDTO recordDTO) {
\n String key = RedisConstants.LIKE_BIZ_KEY_PREFIX + recordDTO.getBizId();
\n Long result = redisTemplate.opsForSet().remove(key, UserContext.getUser().toString());
\n return result != null && result > 0;
\n }
\n} <\/p>\n2.3.3Pipeline \u4f18\u5316\u6279\u91cf\u67e5\u8be2\u6027\u80fd<\/h4>\n
\npublic Set<Long> isBizLiked(List<Long> bizIds) {
\n Long userId = UserContext.getUser();
\n \/\/ Pipeline\u6279\u91cf\u6267\u884cSISMEMBER
\n List<Object> results = redisTemplate.executePipelined((RedisCallback<Object>) connection -> {
\n StringRedisConnection src = (StringRedisConnection) connection;
\n for (Long bizId : bizIds) {
\n String key = RedisConstants.LIKE_BIZ_KEY_PREFIX + bizId;
\n src.sIsMember(key, userId.toString());
\n }
\n return null;
\n });
\n \/\/ \u8fc7\u6ee4\u51fa\u70b9\u8d5e\u8fc7\u7684\u4e1a\u52a1ID
\n return IntStream.range(0, results.size())
\n .filter(i -> (boolean) results.get(i))
\n .mapToObj(bizIds::get)
\n .collect(Collectors.toSet());
\n} <\/p>\n2.3.4 \u5b9a\u65f6\u4efb\u52a1\u6279\u91cf\u540c\u6b65\u70b9\u8d5e\u6570<\/h4>\n
\npublic class LikedTimesCheckTask {
\n \/\/ \u652f\u6301\u7684\u4e1a\u52a1\u7c7b\u578b（\u53ef\u914d\u7f6e\u5316）
\n private static final List<String> BIZ_TYPES = List.of("QA", "NOTE");
\n private static final int MAX_BIZ_SIZE = 30; \/\/ \u5355\u6b21\u6700\u5927\u540c\u6b65\u6570\u91cf<\/p>\n
\n public void checkLikedTimes(){
\n for (String bizType : BIZ_TYPES) {
\n recordService.readLikedTimesAndSendMessage(bizType, MAX_BIZ_SIZE);
\n }
\n }
\n}<\/p>\n
\n@Override
\npublic void readLikedTimesAndSendMessage(String bizType, int maxBizSize) {
\n String key = RedisConstants.LIKES_TIMES_KEY_PREFIX + bizType;
\n \/\/ \u4eceZSet\u4e2d\u53d6\u51fa\u5e76\u5220\u9664\u524dN\u6761\u6570\u636e（\u539f\u5b50\u64cd\u4f5c）
\n Set<ZSetOperations.TypedTuple<String>> tuples = redisTemplate.opsForZSet().popMin(key, maxBizSize);
\n if (CollUtils.isEmpty(tuples)) return;
\n \/\/ \u8f6c\u6362\u4e3aMQ\u6d88\u606f\u4f53
\n List<LikedTimesDTO> list = tuples.stream()
\n .filter(t -> t.getValue() != null && t.getScore() != null)
\n .map(t -> LikedTimesDTO.of(Long.valueOf(t.getValue()), t.getScore().intValue()))
\n .collect(Collectors.toList());
\n \/\/ \u6279\u91cf\u53d1\u9001MQ
\n mqHelper.send(LIKE_RECORD_EXCHANGE,
\n StringUtils.format(LIKED_TIMES_KEY_TEMPLATE, bizType), list);
\n} <\/p>\n3.\u8fdb\u4e00\u6b65\u4f18\u5316：\u5b9a\u671f\u6301\u4e45\u5316\u5230\u6570\u636e\u5e93，\u91c7\u7528LRU\u79fb\u9664\u6700\u8fd1\u6700\u5c11\u8bbf\u95ee<\/h2>\n
3.1\u5b9a\u4e49\u65b0\u7684Redis\u7ed3\u6784\u7528\u4e8e\u5b9e\u73b0LRU\u548c\u6301\u4e45\u5316<\/h3>\n
3.1.1LRU \u8bbf\u95ee\u7b56\u7565\u8868<\/span><\/h4>\n
\n
KEY（likes:access:strategy）MEMBER（bizId）SCORE（timestamp）\u8bf4\u660e<\/tr>\n \n\n likes:access:strategy<\/td>\n 102<\/td>\n 1735689600000<\/td>\n \u4e1a\u52a1 102 \u6700\u540e\u8bbf\u95ee\u4e8e 08:00（\u6700\u51b7）<\/td>\n<\/tr>\n \n 101<\/td>\n 1735691400000<\/td>\n \u4e1a\u52a1 101 \u6700\u540e\u8bbf\u95ee\u4e8e 08:30<\/td>\n<\/tr>\n \n 103<\/td>\n 1735693200000<\/td>\n \u4e1a\u52a1 103 \u6700\u540e\u8bbf\u95ee\u4e8e 09:00（\u6700\u70ed）<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n 3.1.2\u4e1a\u52a1\u7c7b\u578b\u6620\u5c04\u8868 (Hash)<\/h4>\n
\n
KEY（likes:biz:type）FIELD（bizId）VALUE（bizType）\u8bf4\u660e<\/tr>\n \n\n likes:biz:type<\/td>\n 101<\/td>\n "QA"<\/td>\n \u4e1a\u52a1 101 \u662f\u95ee\u7b54\u7c7b\u578b<\/td>\n<\/tr>\n \n <\/td>\n 102<\/td>\n "NOTE"<\/td>\n \u4e1a\u52a1 102 \u662f\u7b14\u8bb0\u7c7b\u578b<\/td>\n<\/tr>\n \n <\/td>\n 103<\/td>\n "QA"<\/td>\n \u4e1a\u52a1 103 \u662f\u95ee\u7b54\u7c7b\u578b<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n 3.2\u4e1a\u52a1\u6d41\u7a0b<\/h3>\n
3.2.1\u5b9e\u65f6\u4ea4\u4e92\u6d41\u7a0b<\/h4>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143254-697a1e16cefbd.png\")
<\/p>\n\n
\n
\n
3.2.2\u5f02\u6b65\u6301\u4e45\u5316\u6d41\u7a0b<\/h4>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143254-697a1e16ec1de.png\")
<\/p>\n3.3\u4ee3\u7801\u5b9e\u73b0<\/h3>\n
\nimport com.tianji.api.dto.remark.LikedTimesDTO;
\nimport com.tianji.common.autoconfigure.mq.RabbitMqHelper;
\nimport com.tianji.common.utils.CollUtils;
\nimport com.tianji.common.utils.StringUtils;
\nimport com.tianji.common.utils.UserContext;
\nimport com.tianji.remark.constants.RedisConstants;
\nimport com.tianji.remark.domain.dto.LikeRecordFormDTO;
\nimport com.tianji.remark.domain.po.LikedRecord;
\nimport com.tianji.remark.mapper.LikedRecordMapper;
\nimport com.tianji.remark.service.ILikedRecordService;
\nimport lombok.RequiredArgsConstructor;
\nimport org.springframework.data.redis.connection.StringRedisConnection;
\nimport org.springframework.data.redis.core.RedisCallback;
\nimport org.springframework.data.redis.core.StringRedisTemplate;
\nimport org.springframework.data.redis.core.ZSetOperations;
\nimport org.springframework.stereotype.Service;
\nimport org.springframework.transaction.annotation.Transactional;<\/p>\n
\nimport java.util.stream.Collectors;
\nimport java.util.stream.IntStream;<\/p>\n
\nimport static com.tianji.common.constants.MqConstants.Key.LIKED_TIMES_KEY_TEMPLATE;<\/p>\n
\n * <p>
\n * \u70b9\u8d5e\u8bb0\u5f55\u8868 \u670d\u52a1\u5b9e\u73b0\u7c7b
\n * <\/p>
\n *\/
\n@Service
\n@RequiredArgsConstructor
\npublic class LikedRecordServiceRedisImpl extends ServiceImpl<LikedRecordMapper, LikedRecord> implements ILikedRecordService {<\/p>\n
\n private final StringRedisTemplate redisTemplate;<\/p>\n
\n public void addLikeRecord(LikeRecordFormDTO recordDTO) {
\n \/\/ 1.\u57fa\u4e8e\u524d\u7aef\u7684\u53c2\u6570，\u5224\u65ad\u662f\u6267\u884c\u70b9\u8d5e\u8fd8\u662f\u53d6\u6d88\u70b9\u8d5e
\n boolean success = recordDTO.getLiked() ? like(recordDTO) : unlike(recordDTO);
\n \/\/ 2.\u5224\u65ad\u662f\u5426\u6267\u884c\u6210\u529f，\u5982\u679c\u5931\u8d25，\u5219\u76f4\u63a5\u7ed3\u675f
\n if (!success) {
\n return;
\n }<\/p>\n
\n String bizIdStr = recordDTO.getBizId().toString();
\n redisTemplate.opsForZSet().add(RedisConstants.LIKES_ACCESS_STRATEGY_KEY, bizIdStr, System.currentTimeMillis());
\n redisTemplate.opsForHash().put(RedisConstants.LIKES_BIZ_TYPE_MAP_KEY, bizIdStr, recordDTO.getBizType());<\/p>\n
\n Long likedTimes = redisTemplate.opsForSet()
\n .size(RedisConstants.LIKE_BIZ_KEY_PREFIX + recordDTO.getBizId());
\n if (likedTimes == null) {
\n return;
\n }
\n \/\/ 4.\u7f13\u5b58\u70b9\u603b\u6570\u5230Redis
\n redisTemplate.opsForZSet().add(
\n RedisConstants.LIKES_TIMES_KEY_PREFIX + recordDTO.getBizType(),
\n recordDTO.getBizId().toString(),
\n likedTimes
\n );
\n }<\/p>\n
\n public Set<Long> isBizLiked(List<Long> bizIds) {
\n \/\/ 1.\u83b7\u53d6\u767b\u5f55\u7528\u6237id
\n Long userId = UserContext.getUser();<\/p>\n
\n List<Long> missingBizIds = new ArrayList<>();
\n \/\/ \u4f7f\u7528pipeline\u6279\u91cf\u5224\u65adkey\u662f\u5426\u5b58\u5728
\n List<Object> existsResults = redisTemplate.executePipelined((RedisCallback<Object>) connection -> {
\n StringRedisConnection src = (StringRedisConnection) connection;
\n for (Long bizId : bizIds) {
\n src.exists(RedisConstants.LIKE_BIZ_KEY_PREFIX + bizId);
\n }
\n return null;
\n });<\/p>\n
\n Boolean exists = (Boolean) existsResults.get(i);
\n if (exists == null || !exists) {
\n missingBizIds.add(bizIds.get(i));
\n }
\n }<\/p>\n
\n loadBizLikesFromDb(missingBizIds);
\n }<\/p>\n
\n long now = System.currentTimeMillis();
\n redisTemplate.executePipelined((RedisCallback<Object>) connection -> {
\n StringRedisConnection src = (StringRedisConnection) connection;
\n for (Long bizId : bizIds) {
\n src.zAdd(RedisConstants.LIKES_ACCESS_STRATEGY_KEY, now, bizId.toString());
\n }
\n return null;
\n });<\/p>\n
\n List<Object> objects = redisTemplate.executePipelined((RedisCallback<Object>) connection -> {
\n StringRedisConnection src = (StringRedisConnection) connection;
\n for (Long bizId : bizIds) {
\n String key = RedisConstants.LIKE_BIZ_KEY_PREFIX + bizId;
\n src.sIsMember(key, userId.toString());
\n }
\n return null;
\n });
\n \/\/ 5.\u8fd4\u56de\u7ed3\u679c
\n return IntStream.range(0, objects.size()) \/\/ \u521b\u5efa\u4ece0\u5230\u96c6\u5408size\u7684\u6d41
\n .filter(i -> (boolean) objects.get(i)) \/\/ \u904d\u5386\u6bcf\u4e2a\u5143\u7d20，\u4fdd\u7559\u7ed3\u679c\u4e3atrue\u7684\u89d2\u6807i
\n .mapToObj(bizIds::get)\/\/ \u7528\u89d2\u6807i\u53d6bizIds\u4e2d\u7684\u5bf9\u5e94\u6570\u636e，\u5c31\u662f\u70b9\u8d5e\u8fc7\u7684id
\n .collect(Collectors.toSet());\/\/ \u6536\u96c6
\n }<\/p>\n
\n \/\/ \u67e5\u8be2DB
\n List<LikedRecord> list = lambdaQuery().in(LikedRecord::getBizId, bizIds).list();
\n if (CollUtils.isEmpty(list)) {
\n return;
\n }<\/p>\n
\n Map<Long, List<LikedRecord>> map = list.stream().collect(Collectors.groupingBy(LikedRecord::getBizId));<\/p>\n
\n redisTemplate.executePipelined((RedisCallback<Object>) connection -> {
\n StringRedisConnection src = (StringRedisConnection) connection;
\n for (Map.Entry<Long, List<LikedRecord>> entry : map.entrySet()) {
\n Long bizId = entry.getKey();
\n List<LikedRecord> records = entry.getValue();
\n if (CollUtils.isEmpty(records)) continue;<\/p>\n
\n String[] userIds = records.stream().map(r -> r.getUserId().toString()).toArray(String[]::new);
\n src.sAdd(key, userIds);<\/p>\n
\n String bizType = records.get(0).getBizType();
\n src.hSet(RedisConstants.LIKES_BIZ_TYPE_MAP_KEY, bizId.toString(), bizType);
\n }
\n return null;
\n });
\n }<\/p>\n
\n @Transactional(rollbackFor = Exception.class)
\n public void persistOldRecords(int maxCapacity) {
\n \/\/ 1.\u68c0\u67e5\u5bb9\u91cf\u662f\u5426\u8d85\u6807
\n Long size = redisTemplate.opsForZSet().zCard(RedisConstants.LIKES_ACCESS_STRATEGY_KEY);
\n if (size == null || size <= maxCapacity) {
\n return;
\n }
\n long removeCount = size – maxCapacity;<\/p>\n
\n Set<ZSetOperations.TypedTuple<String>> tuples = redisTemplate.opsForZSet()
\n .rangeWithScores(RedisConstants.LIKES_ACCESS_STRATEGY_KEY, 0, removeCount – 1);<\/p>\n
\n return;
\n }<\/p>\n
\n String bizIdStr = tuple.getValue();
\n Long bizId = Long.valueOf(bizIdStr);<\/p>\n
\n Set<String> userIdsInRedis = redisTemplate.opsForSet().members(RedisConstants.LIKE_BIZ_KEY_PREFIX + bizIdStr);
\n if (userIdsInRedis == null) {
\n userIdsInRedis = new HashSet<>();
\n }<\/p>\n
\n List<LikedRecord> dbRecords = lambdaQuery().eq(LikedRecord::getBizId, bizId).list();
\n Set<String> userIdsInDb = dbRecords.stream().map(r -> r.getUserId().toString()).collect(Collectors.toSet());<\/p>\n
\n Set<String> toAdd = new HashSet<>(userIdsInRedis);
\n toAdd.removeAll(userIdsInDb);<\/p>\n
\n toDelete.removeAll(userIdsInRedis);<\/p>\n
\n if (!toAdd.isEmpty()) {
\n \/\/ \u83b7\u53d6bizType
\n Object bizTypeObj = redisTemplate.opsForHash().get(RedisConstants.LIKES_BIZ_TYPE_MAP_KEY, bizIdStr);
\n String bizType = (bizTypeObj != null) ? bizTypeObj.toString() :
\n (!dbRecords.isEmpty() ? dbRecords.get(0).getBizType() : "UNKNOWN");<\/p>\n
\n LikedRecord r = new LikedRecord();
\n r.setBizId(bizId);
\n r.setUserId(Long.valueOf(uid));
\n r.setBizType(bizType);
\n return r;
\n }).collect(Collectors.toList());
\n saveBatch(newRecords);
\n }<\/p>\n
\n List<Long> userIdsToDelete = toDelete.stream().map(Long::valueOf).collect(Collectors.toList());
\n lambdaUpdate().eq(LikedRecord::getBizId, bizId).in(LikedRecord::getUserId, userIdsToDelete).remove();
\n }<\/p>\n
\n redisTemplate.delete(RedisConstants.LIKE_BIZ_KEY_PREFIX + bizIdStr);
\n redisTemplate.opsForHash().delete(RedisConstants.LIKES_BIZ_TYPE_MAP_KEY, bizIdStr);
\n redisTemplate.opsForZSet().remove(RedisConstants.LIKES_ACCESS_STRATEGY_KEY, bizIdStr);
\n }
\n }<\/p>\n
\n public void readLikedTimesAndSendMessage(String bizType, int maxBizSize) {
\n \/\/ 1.\u8bfb\u53d6\u5e76\u79fb\u9664Redis\u4e2d\u7f13\u5b58\u7684\u70b9\u8d5e\u603b\u6570
\n String key = RedisConstants.LIKES_TIMES_KEY_PREFIX + bizType;
\n Set<ZSetOperations.TypedTuple<String>> tuples = redisTemplate.opsForZSet().popMin(key, maxBizSize);
\n if (CollUtils.isEmpty(tuples)) {
\n return;
\n }
\n \/\/ 2.\u6570\u636e\u8f6c\u6362
\n List<LikedTimesDTO> list = new ArrayList<>(tuples.size());
\n for (ZSetOperations.TypedTuple<String> tuple : tuples) {
\n String bizId = tuple.getValue();
\n Double likedTimes = tuple.getScore();
\n if (bizId == null || likedTimes == null) {
\n continue;
\n }
\n list.add(new LikedTimesDTO(Long.valueOf(bizId), likedTimes.intValue()));
\n }
\n \/\/ 3.\u53d1\u9001MQ\u6d88\u606f
\n mqHelper.send(
\n LIKE_RECORD_EXCHANGE,
\n StringUtils.format(LIKED_TIMES_KEY_TEMPLATE, bizType),
\n list);
\n }<\/p>\n
\n \/\/ 1.\u83b7\u53d6\u7528\u6237id
\n Long userId = UserContext.getUser();
\n \/\/ 2.\u83b7\u53d6Key
\n String key = RedisConstants.LIKE_BIZ_KEY_PREFIX + recordDTO.getBizId();
\n \/\/ 3.\u6267\u884cSREM\u547d\u4ee4
\n Long result = redisTemplate.opsForSet().remove(key, userId.toString());
\n return result != null && result > 0;
\n }<\/p>\n
\n \/\/ 1.\u83b7\u53d6\u7528\u6237id
\n Long userId = UserContext.getUser();
\n \/\/ 2.\u83b7\u53d6Key
\n String key = RedisConstants.LIKE_BIZ_KEY_PREFIX + recordDTO.getBizId();
\n \/\/ 3.\u6267\u884cSADD\u547d\u4ee4
\n Long result = redisTemplate.opsForSet().add(key, userId.toString());
\n return result != null && result > 0;
\n }
\n}
\npackage com.tianji.remark.constants;<\/p>\n
\n \/*\u7ed9\u4e1a\u52a1\u70b9\u8d5e\u7684\u7528\u6237\u96c6\u5408\u7684KEY\u524d\u7f00，\u540e\u7f00\u662f\u4e1a\u52a1id*\/
\n String LIKE_BIZ_KEY_PREFIX = "likes:set:biz:";
\n \/*\u4e1a\u52a1\u70b9\u8d5e\u6570\u7edf\u8ba1\u7684KEY\u524d\u7f00，\u540e\u7f00\u662f\u4e1a\u52a1\u7c7b\u578b*\/
\n String LIKES_TIMES_KEY_PREFIX = "likes:times:type:";
\n \/*\u4e1a\u52a1\u70b9\u8d5e\u4e1a\u52a1\u7c7b\u578b\u6620\u5c04*\/
\n String LIKES_BIZ_TYPE_MAP_KEY = "likes:biz:type";
\n \/*\u4e1a\u52a1\u70b9\u8d5e\u8bbf\u95ee\u7b56\u7565\u96c6\u5408（\u7528\u4e8eLFU\/LRU）*\/
\n String LIKES_ACCESS_STRATEGY_KEY = "likes:access:strategy";
\n}
\npackage com.tianji.remark.task;<\/p>\n
\nimport lombok.RequiredArgsConstructor;
\nimport lombok.extern.slf4j.Slf4j;
\nimport org.springframework.beans.factory.annotation.Value;
\nimport org.springframework.cloud.context.config.annotation.RefreshScope;
\nimport org.springframework.scheduling.annotation.Scheduled;
\nimport org.springframework.stereotype.Component;<\/p>\n
\n@Component
\n@RequiredArgsConstructor
\n@RefreshScope \/\/ \u652f\u6301Nacos\u52a8\u6001\u5237\u65b0\u914d\u7f6e
\npublic class LikedTimesCheckTask {<\/p>\n
\n private List<String> bizTypes;<\/p>\n
\n private int maxBizSize;<\/p>\n
\n public void checkLikedTimes(){
\n for (String bizType : bizTypes) {
\n recordService.readLikedTimesAndSendMessage(bizType, maxBizSize);
\n }
\n }<\/p>\n
\n public void checkOldRecords(){
\n int maxCapacity = 10000;
\n recordService.persistOldRecords(maxCapacity);
\n }
\n} <\/p>\n<\/p>\n<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/01\/20260128143255-697a1e171475b.png\")
<\/p>\n","protected":false},"excerpt":{"rendered":"
\n1.\u539f\u59cb\u7684\u70b9\u8d5e\u4e1a\u52a1
\n1.1\u9875\u9762\u539f\u578b
\n1.2\u70b9\u8d5e\u4e1a\u52a1
\n1.2.1\u6570\u636e\u5e93\u8868
\n1.2.2\u4e1a\u52a1\u6d41\u7a0b
\n1.2.3\u4e1a\u52a1\u4ee3\u7801
\n1.3 \u539f\u59cb\u65b9\u6848\u7684\u6027\u80fd\u74f6\u9888
\n2.\u9ad8\u5e76\u53d1\u4f18\u5316\u601d\u8def：Redis \u5408\u5e76\u5199\u8bf7\u6c42
\n2.1 \u4f18\u5316\u65b9\u5411\u5206\u6790
\n2.2\u4fee\u6539\u4e4b\u540e\u7684\u4e1a\u52a1\u5206\u6790
\n2.2.1\u6838\u5fc3\u4e1a\u52a1\u6d41\u7a0b
\n2.2.2Redis \u6570\u636e\u7ed3\u6784\u9009\u578b
\n2.3\u4ee3\u7801\u5b9e\u73b0
\n2.3.1\u4ee3\u7801\u5b9e\u73b0\u6d41\u7a0b\u56fe
\n2.3.2\u6838\u5fc3\u63a5\u53e3\u6539\u9020（\u70b9\u8d5e \/ \u53d6\u6d88）
\n2.3.3Pipeli<\/p>\n","protected":false},"author":2,"featured_media":67542,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[98,963,100],"topic":[],"class_list":["post-67552","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-spring-boot","tag-spring-cloud","tag-100"],"yoast_head":"\n