java之 Timer 類的簡單使用案例

          (如果您看到本文章務必看結尾！)

第一次用Timer類，記錄一下個人理解。

場景：做蘋果內容結果驗證時，根據蘋果支付憑證去蘋果官方服務器驗證是否支付成功。但因為蘋果服務器比較慢，第一次驗證的結果也許不是實時結果，需要多次驗證。

所以就使用到了Timer類，定時限制次數去驗證支付結果。

我設計的是每秒驗證一次，共驗證十次。

 

其實就Timer來講就是一個調度器,而TimerTask呢只是一個實現了run方法的一個類,而具體的TimerTask需要由你自己來實現,例如這樣:

Timer timer = new Timer();
timer.schedule(new TimerTask() {
        public void run() {
            System.out.println("每秒執行一次");
        }
}, 500 , 1000);

 

方法摘要：

void cancel()    終止此計時器，丟棄所有當前已安排的任務。

int purge()     從此計時器的任務隊列中移除所有已取消的任務。

void schedule(TimerTask task, Date time)     安排在指定的時間執行指定的任務。

void schedule(TimerTask task, Date firstTime, long period)     安排指定的任務在指定的時間開始進行重復的固定延遲執行。

void schedule(TimerTask task, long delay)     安排在指定延遲后執行指定的任務。

void schedule(TimerTask task, long delay, long period)     安排指定的任務從指定的延遲后開始進行重復的固定延遲執行。

void scheduleAtFixedRate(TimerTask task, Date firstTime, long period)     安排指定的任務在指定的時間開始進行重復的固定速率執行。

void scheduleAtFixedRate(TimerTask task, long delay, long period)     安排指定的任務在指定的延遲后開始進行重復的固定速率執行。

 

知識點：線程中的變量參數用專門的變量類，如： ConcurrentMap<String, Integer> map  

Test類：

package com.xxxx.controller;

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.URL;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

import com.alibaba.fastjson.JSONObject;
import com.wfcm.utils.R;

public class Test {

    private static ConcurrentMap<String, Integer> map = new ConcurrentHashMap<>();
    
    private static final String certificateUrlTest = "https://sandbox.itunes.apple.com/verifyReceipt"; 
    
    public static void main(String[] args) {
         
         System.out.println(tim().toString());
         
    }
    
    private static R tim () {
        final Timer timer = new Timer(); 
        final String certificateCode1 = "234234234234";
         timer.schedule(new TimerTask() {
             
             @Override  
             public void run() {
                 if (map.get(certificateCode1) != null) {
                 map.put(certificateCode1, map.get(certificateCode1) + 1);
                 } else {
                     map.put(certificateCode1, 1);
                 }
                 if (map.get(certificateCode1) >= 20) {
                     map.remove(certificateCode1);
                     timer.cancel();
                 }
                 String r1 = sendHttpsCoon(certificateUrlTest, certificateCode1);
                 if (JSONObject.parseObject(r1).getString("status").equals("0")) {
                     map.remove(certificateCode1);
                     timer.cancel();
                 }
                 System.out.println("設定指定任務task在指定延遲delay后執行");  
             }  
        },500 , 1000); 
        System.out.println("******************方法結束");
        return R.error("68"); 
    }
    
    private static String sendHttpsCoon(String url, String code){  
        if(url.isEmpty()){  
            return null;  
        }  
        try {  
            //設置SSLContext  
            SSLContext ssl = SSLContext.getInstance("SSL");  
            ssl.init(null, new TrustManager[]{myX509TrustManager}, null);  
              
            //打開連接  
            HttpsURLConnection conn = (HttpsURLConnection) new URL(url).openConnection();  
            //設置套接工廠  
            conn.setSSLSocketFactory(ssl.getSocketFactory());  
            //加入數據  
            conn.setRequestMethod("POST");  
            conn.setDoOutput(true);  
            conn.setRequestProperty("Content-type","application/json");  
              
            JSONObject obj = new JSONObject();  
            obj.put("receipt-data", code);  
              
            BufferedOutputStream buffOutStr = new BufferedOutputStream(conn.getOutputStream());  
            buffOutStr.write(obj.toString().getBytes());  
            buffOutStr.flush();  
            buffOutStr.close();  
              
            //獲取輸入流  
            BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));  
              
            String line = null;  
            StringBuffer sb = new StringBuffer();  
            while((line = reader.readLine())!= null){  
                sb.append(line);  
            }  
            return sb.toString();  
          
        } catch (Exception e) {  
            return null;  
        }  
    }  
    
    private static TrustManager myX509TrustManager = new X509TrustManager() {  
        
        @Override  
        public X509Certificate[] getAcceptedIssuers() {  
            return null;  
        }  
          
        @Override  
        public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {  
              
        }  
          
        @Override  
        public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {  
              
        }  
    };  
}
        

 

---

 

第二次修訂：

在后續的學習中發現了一個更好的方法，同時也發現了Timer的不足之處。更多請看下面文章，寫的很好：

Timer的缺陷分析

.綜上所述，推薦使用ScheduleExecutorService ，在以后的開發中盡可能使用ScheduledExecutorService（JDK1.5以后）替代Timer。

或者使用Quartz，據說它也改善了這兩大缺陷