当前位置: 首页 > news >正文

境外公司在国内建网站广告公司创意广告语

境外公司在国内建网站,广告公司创意广告语,网页微信版传输文件,wordpress自动部署使用Redis模拟延时队列 实际上通过MQ实现延时队列更加方便,只是在实际业务中种种原因导致最终选择使用redis作为该业务实现的中间件,顺便记录一下。 该业务是用于日程短信提醒,用户添加日程后,就会被放入redis队列中等待被执行发…

使用Redis模拟延时队列

实际上通过MQ实现延时队列更加方便,只是在实际业务中种种原因导致最终选择使用redis作为该业务实现的中间件,顺便记录一下。
该业务是用于日程短信提醒,用户添加日程后,就会被放入redis队列中等待被执行发送短信提醒业务。
本文介绍如何使用Redis来实现一个简单的延时任务队列,通过这个示例,可以帮助你理解如何利用Redis的有序集合特性来管理和执行延时任务。

设计思路

Redis有序集合(Sorted Set)可以很好地用来实现延时队列的功能。通过将任务的执行时间作为分数(score)来存入有序集合中,并定期检查集合中小于等于当前时间的任务来触发执行。

代码实现

JedisCluster连接初始化

首先,我们需要初始化JedisCluster连接来与Redis集群进行交互。

private static final String ZSET_KEY = "sms_delayed_tasks";
private JedisCluster jedisCluster;public void RedisClusterScheduler() {Set<HostAndPort> nodes = new HashSet<>();//从配置文件中读取redis集群配置for (String node : AcpCore.getProp("spring.redis.cluster.nodes").split(",")) {String[] hostPort = node.split(":");nodes.add(new HostAndPort(hostPort[0], Integer.parseInt(hostPort[1])));}GenericObjectPoolConfig<Jedis> poolConfig = new GenericObjectPoolConfig<>();poolConfig.setMaxTotal(128);poolConfig.setMaxIdle(128);poolConfig.setMinIdle(16);jedisCluster = new JedisCluster(nodes, 2000, 2000, 5, AcpCore.getProp("spring.redis.password"), poolConfig);if (!isCalled) {isCalled = true;startTaskChecker();}
}

添加延时任务

我们可以通过指定任务和执行时间来添加延时任务。该方法将执行时间转换为时间戳,并将任务存储在Redis有序集合中。

public void addDelayedTask(String task, String time) {long executeTime = convertToTimestamp(time);if (executeTime > System.currentTimeMillis() / 1000) {jedisCluster.zadd(ZSET_KEY, executeTime, task);log.info("添加任务: " + task + " 执行时间: " + executeTime);} else {log.info("任务时间必须在当前时间之后: " + task);}
}private long convertToTimestamp(String time) {SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");try {return sdf.parse(time).getTime() / 1000;} catch (ParseException e) {e.printStackTrace();return System.currentTimeMillis() / 1000;}
}

检查和执行任务

通过一个定时任务不断检查当前时间之前的任务并执行。

private void startTaskChecker() {executorService.submit(() -> {while (!Thread.currentThread().isInterrupted()) {try {checkAndExecuteTasks();Thread.sleep(1000);} catch (Exception e) {log.info(new Date() + "发生异常但不中断,异常是:" + e);}}});
}private void checkAndExecuteTasks() {long currentTime = System.currentTimeMillis() / 1000;Set<String> tasks = jedisCluster.zrangeByScore(ZSET_KEY, 0, currentTime);for (String task : tasks) {jedisCluster.zrem(ZSET_KEY, task);executeTask(task);}
}

执行任务的逻辑

假设任务内容是一个JSON对象,执行逻辑在这里可以是任何操作,比如调用外部服务、发送消息等。

private void executeTask(String taskJson) {JSONObject task = JSONObject.parseObject(taskJson);// 在此处添加具体的业务逻辑log.info("执行任务: " + task);
}

总结

通过Redis的有序集合和简单的定时器,能够实现一个简洁有效的延时任务队列。
当然,这个示例是一个简化的模型,在生产环境中,你需要考虑任务的幂等性、系统崩溃后的恢复策略、任务的优先级等问题。希望本文能为你提供实现延时队列的思路和参考。

http://www.yayakq.cn/news/461189/

相关文章:

  • 各大网站网址是多少韵达快递小网站怎么做
  • 网站建设与设计ppt不要域名做网站
  • 手机网站框架域名查询中心官网
  • 福田网站-建设深圳信科动画制作专业大学排名
  • 网站开发就业趋势青岛网站策划
  • 网站建设多少钱比较合适免费建商城网站
  • 毕设做网站答辩稿泰州建站价格
  • 网站优化模板海外网络推广招聘
  • 湖南长沙益阳网站建设莆田软件定制开发
  • 接私活做预算的网站wordpress制作企业网站
  • wordpress可以用的邮箱天津网站优化收费
  • 做网站是如果盈利的贵州seo和网络推广
  • 云南网站搭建建设网站开发
  • 受欢迎的丹阳网站建设房产网二手房信息
  • 如何建一个自己网站网站建设网页
  • 一个新手建设网站怎么简单网页版微信登录入口手机
  • 国内个人网站欣赏网站如何快速推广
  • 什么网站做海报河北省建设局材料备案网站
  • 网站做提示框西安+美院+网站建设
  • 做cpa的网站源码一直能打开的网站突然打不开
  • 外贸型网站该如何推广分类网站 制作
  • 做网站源码衡水wap网站建设价格
  • 大连h5建站模板注册公司怎样网上核名
  • 门窗企业网站建设企业服饰网站模板
  • 最简单做网站怎么使用wordpress
  • 加强企业网站建设的通知网页怎么生成长图
  • 哪个全球购网站做的好处seo经验是什么
  • 百度站长之家wordpress管理员密码丢失
  • 哪里做网站一套一百网站建设与维护协议
  • 建网站深圳网站开发一般黄了