java实现时间控制的几种方案

前言:最近小王同学又遇到了一个需求:线上的业务运行了一段时间,后来随着使用人数增多,出现了一个问题是这样的,一个订单会重复创建几次,导致数据库里出现了很多垃圾数据。在测试同学的不断测试下,发现问题出在了前端的一个提交按钮上,有的用户比较“着急”,提交订单时候,一下子快速的点了5、6次(这手速没有几年是练不出来的,咳咳),导致请求一下子都涌进来,后端进行了重复处理。项目经理让小王优化这个点,绝对不能创建多次。还有一个需求是这样的,在与第三方对接过程中,对方提供了token进行时效性验证,过一段时间token就会失效.后台有定时任务在获取,但是偶尔会出现token失效,这是因为在获取的时候,定时任务正在跑,可能正在获取最新的token中,这个时候如何过一段时间(比如800毫秒之后)再请求呢?小王仰望天空45度,思考起来了。。。

一:时间控制的几种方案

1.1: 从线程方面解决

最简单粗暴的一种实现方案:Thread.sleep(800),但是很快就被小王给pass掉了。为什么呢?虽然这种方式可以,但是存在一个隐患,如果在多线程环境下,线程很容易被interrupt,这样代码就会抛出异常,这样线程就会挂起,导致整个线程异常结束。实在是不够优雅,违背了我们设计的初衷。

1.2:使用Timer

查阅了jdk,我发现有个实现定时的类,使用它是可以的,在jdk中提供了定时器类,这个类的主要作用就是控制一定的时间来简单的定时执行某个任务。有点简单的elasticJob的设计味道。接下来看一下,用timmer如何实现延时。。有点惊喜,我们写一个最简单的例子来看一下如何实现定时任务:

public class TimmerTest {
  /**
   * 测试方法
   */
  public void test() {
    Timer timer = new Timer();
    timer.schedule(new MyTask(), 800);
  }
  public class MyTask extends TimerTask {
    /**
     * 运行方法
     */
    @Override
    public void run() {
      System.out.println("输出");
    }
  }
}

这是一个很简单的定时器实现,可以看出它只需要将方法对应的类继承自MyTask就可以实现定时执行,这种方法是可以实现延时的效果,但是它有一个致命的缺点:对代码的侵入性太大,为了实现定时我们不得已将对应的方法封装成一个类,然后放在定时器里执行。这样的、是可以的,但未免也有点太得不偿失了。为此我要更改整个类的结构,对于修改一个东西,我们要尽量按照最简单的方式最好的效果来实现,所以这种方案也应该pass掉。

1.3:redis延时

在redis中存在一个命令:EXPIRE,这个命令可以设置键存活的时间。一旦超过指定的时间,redis就会将键对应的值给删除掉,因此可以利用这一特性,我们来曲线实现延时功能。在redis的实际命令如下:

通过EXPIRE命令可以设置键的过期时间,一旦超过预设的时间,值就会变成(nil)。利用这一点,加入一些业务参数,我们就可以有效的实现延时的目的。通过redis的过期时间使用redis的好处有以下几点:

1:对代码的侵入性低,不用额外起另外的线程来执行。只需要加入一个方法就可以对单流程的时间控制

2:实现方便灵活,通过key设值可以加入一些唯一性的id来表示业务含义,从而保证业务的稳健实现

3:简单,真正的代码实现起来只有很少,下面会给出代码示范。

二:redis

2.1:maven中引入redis

引入spring-boot-starter-data-redis,这是springboot专门针对redis出的整合依赖库,整合度要比jedis、和redssion都要好,所以推荐这个依赖库:

<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-data-redis</artifactId>
     <exclusions>
       <exclusion>
         <groupId>io.lettuce</groupId>
         <artifactId>lettuce-core</artifactId>
       </exclusion>
     </exclusions>
   </dependency>
   <dependency>
     <groupId>redis.clients</groupId>
     <artifactId>jedis</artifactId>
   </dependency>

2.2: 在springboot中配置redis

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class RedisConfig {
  @Autowired
  private RedisTemplate redisTemplate;
  /**
   * redisTemplate实例化
   *
   * @return
   */
  @Bean
  public RedisTemplate redisTemplateInit() {
    //设置序列化Key的实例化对象
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    //设置序列化Value的实例化对象
    redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    return redisTemplate;
  }
}

2.2:redisTemplate模板工具类

@Component
public class RedisManager {
  private static final Logger LOGGER = LoggerFactory.getLogger(RedisManager.class);
  @Autowired
  private RedisTemplate redisTemplate;
  /**
   * 设置对象
   *
   * @param key key
   * @param value value值
   * @param <T> 返回值泛型
   * @return 正确的值:<T> 错误的值:null
   */
  @SuppressWarnings("unchecked")
  public <T> ValueOperations<String, T> setObject(final String key, final T value) {
    final ValueOperations<String, T> operation = redisTemplate.opsForValue();
    operation.set(key, value);
    return operation;
  }
  /**
   * 设置对象及失效时间 (单位:秒)
   *
   * @param key key
   * @param value value值
   * @param <T> 返回值泛型
   * @param time 秒值
   * @return 正确的值:<T> 错误的值:null
   */
  @SuppressWarnings("unchecked")
  public <T> ValueOperations<String, T> setObject(final String key, final T value, final long time) {
    final ValueOperations<String, T> operation = redisTemplate.opsForValue();
    operation.set(key, value, time, TimeUnit.SECONDS);
    return operation;
  }
  /**
   * 设置对象及失效时间(单位:毫秒)
   *
   * @param key key
   * @param value value值
   * @param <T> 返回值泛型
   * @param time 秒值
   * @return 正确的值:<T> 错误的值:null
   */
  @SuppressWarnings("unchecked")
  public <T> ValueOperations<String, T> setObjectForMillSeconds(final String key, final T value, final long time) {
    final ValueOperations<String, T> operation = redisTemplate.opsForValue();
    operation.set(key, value, time, TimeUnit.MILLISECONDS);
    return operation;
  }
  /**
   * 获取对象
   *
   * @param key 键
   * @return 正确的值:Object值对象<br>
   * 错误的值:null
   */
  @SuppressWarnings("unchecked")
  public Object getObject(final String key) {
    final ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();
    if (valueOperations == null || !redisTemplate.hasKey(key)) {
      return null;
    }
    final Object object = valueOperations.get(key);
    return object;
  }
  /**
   * 从缓存中获取string值
   *
   * @param key
   * @return*/
  @SuppressWarnings("unchecked")
  public String getString(final String key) {
    String value = "";
    final ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();
    if (valueOperations != null && redisTemplate.hasKey(key)) {
      final Object object = valueOperations.get(key);
      if (null != object) {
        LOGGER.info("--getString--object not empty");
        value = object.toString();
      } else {
        LOGGER.info("--getString--object empty");
      }
    }
    return value;
  }

2.2:在redis中实现时间控制

2.2.1:在流程中停留一段时间,通过无限循环来不断的从redis取数值,一旦取到的值为null(redis的键值为null)就退出,这样的写法有点类似于以前CAS的些许味道,通过无限循环比较值。

import com.youjia.orders.redis.RedisManager;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Objects;
/**
 * @Auther: Yrion
 * @Date: 2019-01-11 23:36
 */
public class RedisTest extends OrderProviderApplicationTests {
  @Autowired
  private RedisManager redisManager;
  @Test
  public void test() {
    controlTime("10000001", 10L);
  }
  public void controlTime(String requestId, Long timeOut) {
    if (Objects.isNull(requestId) || Objects.isNull(timeOut)) {
      return;
    }
    //something code
    final String value = "value";
    redisManager.setObject(requestId, value, timeOut);
    final long startTime = System.currentTimeMillis();
    System.out.println("开始控制时间");
    //start
    for (; ; ) {
      if (Objects.isNull(redisManager.getObject(requestId))) {
        break;
      }
    }
    final long endTime = System.currentTimeMillis();
    final long useTime = endTime - startTime;
    System.out.println("一共耗费时间:" + useTime);
  }
}

outPut:

开始控制时间
一共耗费时间:10042

2.2.2:禁止提交一个订单太过于频繁

 /**
   * 防止提交过于频繁
   */
  public void preventFrequentSubmit(Long orderId) throws Exception{
    //some code
    final String key = String.valueOf(orderId);
    final String value = "orderValue";
    if (redisManager.getObject(String.valueOf(orderId))!=null){
      throw new Exception("提交订单太过频繁,请10秒后重试!");
    }else {
      redisManager.setObject(orderId,value,10);
    }
    //continue
  }

三:总结

本篇博文讲述了在平时工作中,我们可能会遇到的一些关于时间控制的问题,在这个问题上我又进行了进一步的探讨,如何实现优雅的解决问题?我们解决问题不仅仅是要把这个问题解决了,而是要考虑如何更好更秒的解决,这就要善于利用一些中间件或者工具类提供的功能特性,善于发现、及时变通,把这种特性利用到我们的代码中,会对我们的开发起到推波助澜、如虎添翼的作用!

以上所述是小编给大家介绍的java实现时间控制的几种方案,希望对大家有所帮助,如果大家有任何疑问欢迎给我留言,小编会及时回复大家的!

(0)

相关推荐

  • java计算工作时间除去节假日以及双休日

    本文实例为大家分享了java计算工作时间的具体代码,不包括节假日.双休日,供大家参考,具体内容如下 package common.util; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; impo

  • Java将日期类型Date时间戳转换为MongoDB的时间类型数据

    存了一个时间类型(Date)的数据到mongo数据库中,但是前台显示的是一串数字.继而引发了如下问题: Java里面如何把 时间戳 1477387464495 转换为 2016-10-25 17:24:24 期望格式的日期字符串. 因为业务需要,在model里面有个Date类型的字段,然后需要按这个时间类型排序.但是在后台处理完之后,返回到前台,发现时间变成了13位数字,学名叫时间戳.不是我想要的具体时间,不适合展示啊.具体有如下 mongo数据库中存储时间类型的数据具体如下: 然后debug的

  • Java控制台输入数组并逆序输出的方法实例 原创

    输入一个数组,然后颠倒次序进行输出,这种算法在程序开发中经常用到,下面我们通过一个小实例来看看怎么实现在控制台输入一个数组,并让其逆序输出的. 源码: import java.util.Scanner; public class Test01 { public static void main(String[] args){ System.out.println("请输入五个数"); int[]l=new int [5]; for(int i=0;i<5;i++) l[i]=ne

  • Java计算两个日期时间之间的天数最简方法

    有一种low的方式,就是你把两个时间都换成秒,然后除以一天的秒数,然后向上取整,就是算的天数.但是这么实现太low啦. jdk有高级的API,我们为啥还要自己去实现呢,问题就是我们不知道. 所以,我在这写个笔记,记录下,jdk 1.8 是怎么做的. /** * 计算两个时间点之间的天数 */ private static void getBetweenDay() { LocalDate start = LocalDate.of(2018, 2, 12); LocalDate now = Loca

  • java实现短信验证码5分钟有效时间

    本文实例为大家分享了java实现短信验证码5分钟有效时间,供大家参考,具体内容如下 实现一个发送短信验证码的请求,要求5分钟之内重复请求,返回同一个验证码. 网上可找到几种方案: 如,存储数据库或缓存中.实现起来比较麻烦,舍弃: 另一种方式即本例,使用session存储.其他方式,暂未进一步了解. 实现步骤: (springmvc) 1.controller中,获取session对象,取code,取不到新生成,并存储session中: 2.单手机号发送量,判断并 +1 记入数据库: 3.Time

  • 轻松理解Java面试和开发中的IoC(控制反转)

    IoC的概念介绍 控制反转(IOC)模式(又称DI:Dependency Injection)就是Inversion of Control,控制反转.在Java开发中,IoC意 味着将你设计好的类交给系统去控制,而不是在你的类内部控制.这称为控制反转. 控制反转(Inversion of Control,英文缩写为IoC)是框架的重要特征,做到控制反转需要一个容器来实现,就是我们所说的IoC容器,最常见的IoC容器是Spring. 控制反转从字面意思看来不是很好理解,其实就是将创建管理对象的工作

  • SpringBoot文件上传控制及Java 获取和判断文件头信息

    之前在使用SpringBoot进行文件上传时,遇到了很多问题.于是在翻阅了很多的博文之后,总算将上传功能进行了相应的完善,便在这里记录下来,供自己以后查阅. 首先,是建立一个标准的SpringBoot 的工程,这里使用的IDE是Intellij Idea,为了方便配置,将默认的配置文件替换为了application.yml. 1.在index.html中进行文件上传功能,这里使用的文件上传方式是ajax,当然也可以按照自己的具体要求使用传统的表单文件上传. <!DOCTYPE html> &l

  • java实现时间控制的几种方案

    前言:最近小王同学又遇到了一个需求:线上的业务运行了一段时间,后来随着使用人数增多,出现了一个问题是这样的,一个订单会重复创建几次,导致数据库里出现了很多垃圾数据.在测试同学的不断测试下,发现问题出在了前端的一个提交按钮上,有的用户比较"着急",提交订单时候,一下子快速的点了5.6次(这手速没有几年是练不出来的,咳咳),导致请求一下子都涌进来,后端进行了重复处理.项目经理让小王优化这个点,绝对不能创建多次.还有一个需求是这样的,在与第三方对接过程中,对方提供了token进行时效性验证,

  • 浅谈Java实现分布式事务的三种方案

    一.问题描述 用户支付完成会将支付状态及订单状态保存在订单数据库中,由订单服务去维护订单数据库.由库存服务去维护库存数据库的信息.下图是系统结构图: 如何实现两个分布式服务(订单服务.库存服务)共同完成一件事即订单支付成功自动减库存,这里的关键是如何保证两个分布式服务的事务的一致性. 尝试解决上边的需求,在订单服务中远程调用减库存接口,伪代码如下: 订单支付结果通知方法{ ​ 更新支付表中支付状态为"成功". ​ 远程调用减库存接口减库存. } 上边的逻辑说明: 1.更新支付表状态为本

  • Java彻底消灭if-else的8种方案

    优化方案 1:提前 return,去除不必要的 else 如果 if-else 代码块包含 return 语句,可以考虑通过提前 return,把多余 else 干掉,使代码更加优雅. 优化前: if(condition){ //doSomething }else{ return ; } 优化后: if(!condition){ return ; } //doSomething 优化方案 2:使用条件三目运算符 使用条件三目运算符可以简化某些 if-else,使代码更加简洁,更具有可读性. 优化

  • Java 如何实现时间控制

    目录 一.间控制的几种方案 1.1 从线程方面解决 1.2使用Timer 1.3redis延时 二.redis 2.1maven中引入redis 2.2 在springboot中配置redis 2.3redisTemplate模板工具类 2.4在redis中实现时间控制 2.4.1无限循环比较值 三.总结 前言: 需求是这样的,在与第三方对接过程中,对方提供了token进行时效性验证,过一段时间token就会失效.后台有定时任务在获取,但是偶尔会出现token失效,这是因为在获取的时候,定时任务

  • Java实现监听文件变化的三种方案详解

    目录 背景 方案一:定时任务 + File#lastModified 方案二:WatchService 方案三:Apache Commons-IO 小结 背景 在研究规则引擎时,如果规则以文件的形式存储,那么就需要监听指定的目录或文件来感知规则是否变化,进而进行加载.当然,在其他业务场景下,比如想实现配置文件的动态加载.日志文件的监听.FTP文件变动监听等都会遇到类似的场景. 本文给大家提供三种解决方案,并分析其中的利弊,建议收藏,以备不时之需. 方案一:定时任务 + File#lastModi

  • Java多线程的同步优化的6种方案

    概述 处理器上的寄存器的读写的速度比内存快几个数量级,为了解决这种速度矛盾,在它们之间加入了高速缓存. 加入高速缓存带来了一个新的问题:缓存一致性.如果多个缓存共享同一块主内存区域,那么多个缓存的数据可能会不一致,需要一些协议来解决这个问题. 在Java内存模型中,分为主内存和线程工作内存,线程使用共享数据时,先从主内存中拷贝数据到工作内存,使用完成之后再写入主内存中. 在Java中,有多线程并发时,我们可以使用多线程同步的方式来解决内存一致性的问题.通常我们可以在程序中添加同步锁来保障数据的安

  • 解决Java中SimpleDateFormat线程不安全的五种方案

    目录 1.什么是线程不安全? 线程不安全的代码 2.解决方案 ① 将SimpleDateFormat变为局部变量 ② 使用synchronized加锁 ③ 使用Lock加锁 ④ 使用ThreadLocal ⑤ 使用DateTimeFormatter 3.线程不安全原因分析 4.各方案优缺点总结 1.什么是线程不安全? 线程不安全也叫非线程安全,是指多线程执行中,程序的执行结果和预期的结果不符的情况就叫做线程不安全. 线程不安全的代码 SimpleDateFormat 就是一个典型的线程不安全事例

  • java实现web实时消息推送的七种方案

    目录 引言 什么是消息推送(push) 短轮询 长轮询 iframe流 SSE (我的方式) MQTT Websocket 自定义推送 Github地址 引言 做了一个小破站,现在要实现一个站内信web消息推送的功能,对,就是下图这个小红点,一个很常用的功能. 不过他还没想好用什么方式做,这里我帮他整理了一下几种方案,并简单做了实现. 案例下载 什么是消息推送(push) 推送的场景比较多,比如有人关注我的公众号,这时我就会收到一条推送消息,以此来吸引我点击打开应用. 消息推送(push)通常是

  • Java解决No enclosing instance of type PrintListFromTailToHead is accessible问题的两种方案

    今天在编译Java程序时遇到如下问题: No enclosing instance of type PrintListFromTailToHead is accessible. Must qualify the allocation with an enclosing instance of type PrintListFromTailToHead (e.g. x.new A() where x is an instance of PrintListFromTailToHead). 源代码为:

  • 详解在java中进行日期时间比较的4种方法

    1. Date.compareTo() java.util.Date提供了在Java中比较两个日期的经典方法compareTo(). 如果两个日期相等,则返回值为0. 如果Date在date参数之后,则返回值大于0. 如果Date在date参数之前,则返回值小于0. @Test void testDateCompare() throws ParseException { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");

随机推荐