Redis实现未读消息计数的示例代码

// 添加未读数（默认新增1条待审核提醒）
appletredisutil.addunreadcount(citypartner.getid());

import jakarta.annotation.resource;
import org.springblade.business.constant.rediskeyconstant;
import org.springblade.business.pojo.entity.productapplyrecord;
import org.springblade.business.service.productapplyrecordservice;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.stereotype.component;
import java.util.objects;
 
@component // 注入spring容器，全局可用
public class appletredisutil {
 
    @resource
    private redistemplate<string, long> redistemplate; // 操作redis的核心组件
 
    // 1. 重载方法：默认给城市合伙人新增1条未读消息
    public void addunreadcount(long miniuserid) {
        addunreadcount(miniuserid, 1l);
    }
 
    // 2. 核心方法：支持自定义新增未读条数，含数据准确性校验
    public void addunreadcount(long miniuserid, long value) {
        // 2.1 工具类无法直接注入service，通过spring上下文获取
        productapplyrecordservice productapplyrecordservice = springcontextutil.getbean(productapplyrecordservice.class);
        
        // 2.2 查该城市合伙人的总申请数（未读上限，避免未读数超过实际总数）
        long totalcount = productapplyrecordservice.lambdaquery()
            .eq(productapplyrecord::getcitypartnerid, miniuserid)
            .count();
        
        // 2.3 查当前redis中的未读数量（空值兜底返回0，避免空指针）
        long currentunread = getunreadcount(miniuserid);
        
        // 2.4 修正未读数量：若累加后超总申请数，取总申请数（防止数据异常）
        value = (currentunread + value) > totalcount ? totalcount : (currentunread + value);
        
        // 2.5 更新redis：用“常量前缀+用户id”作为key，原子自增未读数量
        redistemplate.opsforvalue().increment(rediskeyconstant.product_apply_unread_num + miniuserid, value);
    }
 
    // 3. 查询未读数量：空值兜底，确保返回非null
    public long getunreadcount(long miniuserid) {
        string key = rediskeyconstant.product_apply_unread_num + miniuserid;
        long unread = redistemplate.opsforvalue().get(key);
        return objects.isnull(unread) ? 0l : unread;
    }
 
    // 4. 重置未读数量：先置0再删key，确保状态彻底清空
    public void resetunreadcount(long miniuserid) {
        string key = rediskeyconstant.product_apply_unread_num + miniuserid;
        redistemplate.opsforvalue().set(key, 0l);
        redistemplate.delete(key);
    }
}