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

創(chuàng)新互聯(lián)建站是一家專注于成都網(wǎng)站設計、成都網(wǎng)站制作與策劃設計,濠江網(wǎng)站建設哪家好?創(chuàng)新互聯(lián)建站做網(wǎng)站,專注于網(wǎng)站建設10年,網(wǎng)設計領域的專業(yè)建站公司;建站業(yè)務涵蓋:濠江等地區(qū)。濠江做網(wǎng)站價格咨詢:13518219792

一：時間控制的幾種方案

1.1: 從線程方面解決

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

1.2:使用Timer

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

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("輸出");    }  }}

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

1.3:redis延時

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

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

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

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

3:簡單,真正的代碼實現(xiàn)起來只有很少，下面會給出代碼示范。

二：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;@Configurationpublic 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模板工具類

@Componentpublic 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中實現(xiàn)時間控制

2.2.1:在流程中停留一段時間，通過無限循環(huán)來不斷的從redis取數(shù)值，一旦取到的值為null（redis的鍵值為null）就退出，這樣的寫法有點類似于以前CAS的些許味道，通過無限循環(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("開始控制時間");    //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  }

看完上述內(nèi)容，你們掌握java中怎么實現(xiàn)時間控制的方法了嗎？如果還想學到更多技能或想了解更多相關內(nèi)容，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！

新聞名稱：java中怎么實現(xiàn)時間控制
網(wǎng)頁URL：http://www.rwnh.cn/article16/gopcgg.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供營銷型網(wǎng)站建設、網(wǎng)站維護、全網(wǎng)營銷推廣、域名注冊、網(wǎng)站排名、軟件開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)