沈阳网站建设服务器,外贸软件有用吗,邢台网站制作哪家好,国际网站建设与维护开发背景 为了实现当经纪人A提交分佣后如果三天后其他经纪人没有确认分佣就自动确认分佣#xff0c;如果经纪人A修改分佣后再次提交分佣#xff0c;时间重置为三天
实现方式
第一步#xff1a;引入依赖 dependency groupIdredis.clients/groupId …开发背景 为了实现当经纪人A提交分佣后如果三天后其他经纪人没有确认分佣就自动确认分佣如果经纪人A修改分佣后再次提交分佣时间重置为三天
实现方式
第一步引入依赖 dependency groupIdredis.clients/groupId artifactIdjedis/artifactId version3.6.0/version /dependency 第二步 配置发送过期事件的通知 在redis.config文件中设置 notify-keyspace-events Ex 第二步创建一个jedis工具类
Component
public class JedisUtil {Value(${spring.redis.host})private String host;Value(${spring.redis.port})private Integer port;Value(${spring.redis.password})private String password;private JedisPool jedisPool;PostConstructpublic void init() {JedisPoolConfig poolConfig new JedisPoolConfig();jedisPool new JedisPool(poolConfig, host, port, 2000, password);}public Jedis getJedis() {return jedisPool.getResource();}PreDestroypublic void close() {if (jedisPool ! null) {jedisPool.close();}}
}
第三步发布订阅
本地代码 public static void main(String[] args) {Jedis jedis new Jedis(127.0.0.1, 6379);//有密码就设置jedis.auth(aaaaa);CommissionInfoListener listener new CommissionInfoListener();String expirationSubscription __keyevent0__:expired;new Thread(() - {try {jedis.psubscribe(listener, expirationSubscription);} catch (Exception e) {System.out.println(Subscribing failed. e.getMessage());}}).start();}
springBoot正式项目
Component
Slf4j
public class CommissionInfoLineRunner implements CommandLineRunner {Resourceprivate JedisUtil jedisUtil;Overridepublic void run(String... args) throws Exception {log.info(订阅分佣三天自动确认开始~~~);Jedis jedis jedisUtil.getJedis();CommissionInfoListener listener new CommissionInfoListener();String expirationSubscription __keyevent0__:expired;new Thread(() - {try {jedis.psubscribe(listener, expirationSubscription);} catch (Exception e) {log.info(订阅失败,错误信息{}, e.getMessage());}}).start();}
} 代码解释
1.__keyevent0__:expired含义
键空间通知会发送两种不同类型的事件消息keyspace 和 keyevent keyspace 键空间通知 keyevent 键事件通知 0指的是库名称一般默认为0 2. psubscribe 在使用 Jedis 的 psubscribe 方法时遇到程序卡住不执行的情况是因为 psubscribe 是一个阻塞操作它会持续监听指定模式的消息直到被外部显式地取消订阅。这是 Redis 发布订阅模式的常见行为。它设计为一直运行直到接收到取消订阅的命令。所以在本地运行main方法后要保持运行状态不然订阅不到消息。springboot项目中可以实现CommandLineRunner实现 第四步监听订阅消息
代码
Service
Slf4j
public class CommissionInfoListener extends JedisPubSub {ResourceCommissionInfoService commissionInfoService;Overridepublic void onPMessage(String pattern, String channel, String message) {if (message.contains(aimeng:commissionInfo:confirmation:)) {Long commissionInfoId Long.parseLong(StrUtil.subAfter(message, :, true));log.info(分佣账单三天后自动确认开始分佣id为commissionInfoId);
// commissionInfoService.ok(CollUtil.newArrayList(commissionInfoId));}}}
解释
1.参数message 参数message是当前监听到的key(键) 第五步逻辑代码
jedisUtil.getJedis().setex(COMMISSIONINFO_CONFIRMATION_KEY id, EXPIRETIME, commissionInfo);
