Java 如何實(shí)現(xiàn)時(shí)間控制

更新時(shí)間：2021年10月14日 10:06:55 作者：芋道源碼

這篇文章主要向大家介紹得是Java 如何實(shí)現(xiàn)時(shí)間控制，文章珠岙舉例說明該內(nèi)容，感興趣得小伙伴可以跟小編一起學(xué)習(xí)下面文章內(nèi)容

需求是這樣的，在與第三方對(duì)接過程中，對(duì)方提供了token進(jìn)行時(shí)效性驗(yàn)證，過一段時(shí)間token就會(huì)失效.后臺(tái)有定時(shí)任務(wù)在獲取，但是偶爾會(huì)出現(xiàn)token失效，這是因?yàn)樵讷@取的時(shí)候，定時(shí)任務(wù)正在跑，可能正在獲取最新的token中，這個(gè)時(shí)候如何過一段時(shí)間(比如800毫秒之后)再請(qǐng)求呢？小王仰望天空45度，思考起來(lái)了。。。

一、間控制的幾種方案

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)驚喜，我們來(lái)寫一個(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.3redis延時(shí)

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

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

1:對(duì)代碼的侵入性低，不用額外起另外的線程來(lái)執(zhí)行。只需要加入一個(gè)方法就可以對(duì)單流程的時(shí)間控制
2:實(shí)現(xiàn)方便靈活，通過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.1maven中引入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;

@Configuration
public 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.3redisTemplate模板工具類

@Component
public 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.4在redis中實(shí)現(xiàn)時(shí)間控制

2.4.1無(wú)限循環(huán)比較值

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

三、總結(jié)

本篇博文講述了在平時(shí)工作中，我們可能會(huì)遇到的一些關(guān)于時(shí)間控制的問題，在這個(gè)問題上我又進(jìn)行了進(jìn)一步的探討，如何實(shí)現(xiàn)優(yōu)雅的解決問題？我們解決問題不僅僅是要把這個(gè)問題解決了，而是要考慮如何更好更秒的解決，這就要善于利用一些中間件或者工具類提供的功能特性，善于發(fā)現(xiàn)、及時(shí)變通，把這種特性利用到我們的代碼中，會(huì)對(duì)我們的開發(fā)起到推波助瀾、如虎添翼的作用！

到此這篇關(guān)于Java 如何實(shí)現(xiàn)時(shí)間控制的文章就介紹到這了,更多相關(guān)Java 實(shí)現(xiàn)時(shí)間控制內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: