java中怎么實(shí)現(xiàn)時(shí)間控制

java中怎么實(shí)現(xiàn)時(shí)間控制，相信很多沒有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問題。

一：時(shí)間控制的幾種方案

1.1: 從線程方面解決

最簡(jiǎn)單粗暴的一種實(shí)現(xiàn)方案：Thread.sleep(800)，但是很快就被小王給pass掉了。為什么呢？雖然這種方式可以，但是存在一個(gè)隱患，如果在多線程環(huán)境下，線程很容易被interrupt,這樣代碼就會(huì)拋出異常，這樣線程就會(huì)掛起，導(dǎo)致整個(gè)線程異常結(jié)束。實(shí)在是不夠優(yōu)雅，違背了我們?cè)O(shè)計(jì)的初衷。

1.2:使用Timer

查閱了jdk，我發(fā)現(xiàn)有個(gè)實(shí)現(xiàn)定時(shí)的類，使用它是可以的，在jdk中提供了定時(shí)器類，這個(gè)類的主要作用就是控制一定的時(shí)間來(lái)簡(jiǎn)單的定時(shí)執(zhí)行某個(gè)任務(wù)。有點(diǎn)簡(jiǎn)單的elasticJob的設(shè)計(jì)味道。接下來(lái)看一下，用timmer如何實(shí)現(xiàn)延時(shí)。。有點(diǎn)驚喜，我們寫一個(gè)最簡(jiǎn)單的例子來(lái)看一下如何實(shí)現(xiàn)定時(shí)任務(wù)：

public class TimmerTest {  /**   * 測(cè)試方法   */  public void test() {    Timer timer = new Timer();    timer.schedule(new MyTask(), 800);  }  public class MyTask extends TimerTask {    /**     * 運(yùn)行方法     */    @Override    public void run() {      System.out.println("輸出");    }  }}

這是一個(gè)很簡(jiǎn)單的定時(shí)器實(shí)現(xiàn)，可以看出它只需要將方法對(duì)應(yīng)的類繼承自MyTask就可以實(shí)現(xiàn)定時(shí)執(zhí)行，這種方法是可以實(shí)現(xiàn)延時(shí)的效果，但是它有一個(gè)致命的缺點(diǎn)：對(duì)代碼的侵入性太大，為了實(shí)現(xiàn)定時(shí)我們不得已將對(duì)應(yīng)的方法封裝成一個(gè)類，然后放在定時(shí)器里執(zhí)行。這樣的、是可以的，但未免也有點(diǎn)太得不償失了。為此我要更改整個(gè)類的結(jié)構(gòu)，對(duì)于修改一個(gè)東西，我們要盡量按照最簡(jiǎn)單的方式最好的效果來(lái)實(shí)現(xiàn)，所以這種方案也應(yīng)該pass掉。

1.3:redis延時(shí)

在redis中存在一個(gè)命令：EXPIRE，這個(gè)命令可以設(shè)置鍵存活的時(shí)間。一旦超過(guò)指定的時(shí)間，redis就會(huì)將鍵對(duì)應(yīng)的值給刪除掉，因此可以利用這一特性，我們來(lái)曲線實(shí)現(xiàn)延時(shí)功能。在redis的實(shí)際命令如下：

通過(guò)EXPIRE命令可以設(shè)置鍵的過(guò)期時(shí)間，一旦超過(guò)預(yù)設(shè)的時(shí)間，值就會(huì)變成（nil）。利用這一點(diǎn),加入一些業(yè)務(wù)參數(shù)，我們就可以有效的實(shí)現(xiàn)延時(shí)的目的。通過(guò)redis的過(guò)期時(shí)間使用redis的好處有以下幾點(diǎn)：

1:對(duì)代碼的侵入性低，不用額外起另外的線程來(lái)執(zhí)行。只需要加入一個(gè)方法就可以對(duì)單流程的時(shí)間控制

2:實(shí)現(xiàn)方便靈活，通過(guò)key設(shè)值可以加入一些唯一性的id來(lái)表示業(yè)務(wù)含義,從而保證業(yè)務(wù)的穩(wěn)健實(shí)現(xiàn)

3:簡(jiǎn)單,真正的代碼實(shí)現(xiàn)起來(lái)只有很少，下面會(huì)給出代碼示范。

二：redis

2.1：maven中引入redis

引入spring-boot-starter-data-redis，這是springboot專門針對(duì)redis出的整合依賴庫(kù)，整合度要比jedis、和redssion都要好，所以推薦這個(gè)依賴庫(kù)：

<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;@Configurationpublic class RedisConfig {  @Autowired  private RedisTemplate redisTemplate;  /**   * redisTemplate實(shí)例化   *   * @return   */  @Bean  public RedisTemplate redisTemplateInit() {    //設(shè)置序列化Key的實(shí)例化對(duì)象    redisTemplate.setKeySerializer(new StringRedisSerializer());    //設(shè)置序列化Value的實(shí)例化對(duì)象    redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());    return redisTemplate;  }}

2.2：redisTemplate模板工具類

@Componentpublic class RedisManager {  private static final Logger LOGGER = LoggerFactory.getLogger(RedisManager.class);  @Autowired  private RedisTemplate redisTemplate;  /**   * 設(shè)置對(duì)象   *   * @param key key   * @param value value值   * @param <T> 返回值泛型   * @return 正確的值：<T> 錯(cuò)誤的值：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;  }  /**   * 設(shè)置對(duì)象及失效時(shí)間 (單位：秒)   *   * @param key key   * @param value value值   * @param <T> 返回值泛型   * @param time 秒值   * @return 正確的值：<T> 錯(cuò)誤的值：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;  }  /**   * 設(shè)置對(duì)象及失效時(shí)間（單位：毫秒）   *   * @param key key   * @param value value值   * @param <T> 返回值泛型   * @param time 秒值   * @return 正確的值：<T> 錯(cuò)誤的值：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;  }  /**   * 獲取對(duì)象   *   * @param key 鍵   * @return 正確的值：Object值對(duì)象<br>   * 錯(cuò)誤的值：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中實(shí)現(xiàn)時(shí)間控制

2.2.1:在流程中停留一段時(shí)間，通過(guò)無(wú)限循環(huán)來(lái)不斷的從redis取數(shù)值，一旦取到的值為null（redis的鍵值為null）就退出，這樣的寫法有點(diǎn)類似于以前CAS的些許味道，通過(guò)無(wú)限循環(huán)比較值。

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("開始控制時(shí)間");    //start    for (; ; ) {      if (Objects.isNull(redisManager.getObject(requestId))) {        break;      }    }    final long endTime = System.currentTimeMillis();    final long useTime = endTime - startTime;    System.out.println("一共耗費(fèi)時(shí)間：" + useTime);  }}

outPut:

開始控制時(shí)間一共耗費(fèi)時(shí)間：10042

2.2.2:禁止提交一個(gè)訂單太過(guò)于頻繁

/**   * 防止提交過(guò)于頻繁   */  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("提交訂單太過(guò)頻繁，請(qǐng)10秒后重試！");    }else {      redisManager.setObject(orderId,value,10);    }    //continue  }

看完上述內(nèi)容，你們掌握java中怎么實(shí)現(xiàn)時(shí)間控制的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！