利用計時器實現 對象狀態 的 檢測

當對象在創建后，每隔一定的時間需要變化一次狀態，并且該狀態的變化還要通知到用戶，可以利用Java的計時器實現對對象狀態變化的監測。

舉個例子，如種植了一顆植物，植物每隔兩分鐘需要變化一次狀態，讓后根據狀態的不同通知客戶端進行響應的事件處理。

植物生長狀態	生長時間	客戶端的處理
種子	2? 分鐘	顯示植物的幼苗狀態
幼苗	3? 分鐘	顯示植物的成年狀態
成熟	4? 分鐘	顯示植物的成熟狀態
收獲	5 分鐘	提示用戶收獲該作物

該事件處理的流程圖如下：

植物的類圖

articleID?: 植物ID?

roleID: 所屬角色ID?

currentState: 植物的當前狀態?

timer: 生長剩余時間

Java 中計時器的用法:

(1)Timer.schedule(TimerTask?task,Date?time) 安排在制定的時間執行指定的任務。
(2)Timer.schedule(TimerTask?task,Date?firstTime?,long?period) 安排指定的任務在指定的時間開始進行重復的固定延遲執行．
(3)Timer.schedule(TimerTask?task,long?delay) 安排在指定延遲后執行指定的任務．
(4)Timer.schedule(TimerTask?task,long?delay,long?period) 安排指定的任務從指定的延遲后開始進行重復的固定延遲執行．
(5)Timer.scheduleAtFixedRate(TimerTask?task,Date?firstTime,long?period) 安排指定的任務在指定的時間開始進行重復的固定速率執行．
(6)Timer.scheduleAtFixedRate(TimerTask?task,long?delay,long?period) 安排指定的任務在指定的延遲后開始進行重復的固定速率執行．

實現的源碼：

import?java.util.HashMap;

import?java.util.LinkedList;

import?java.util.Timer;

import?java.util.TimerTask;

import?org.apache.mina.common.IoSession;

import?com.toplx.mina.bussiness.handler.utils.ClientInforUtils;

public?class?Sacnning?{

public?static?Boolean?running?=?false;

public?static?void?scanningProduct()?{

Timer?time?=?new?Timer();

long?delay?=?50;

long?period?=?100;

//? 開始執行計劃任務

time.schedule(new?TimerTask()?{

//? 檢測服務器的控制流程

int?k?=?0;

public?void?run()?{

System.out.println(" 開始打印???"?+?k?+?"?次");

k++;

running?=?true;

LinkedList<Product>?list?=?ProductList.productList;

System.out.println("??? 植物生長的鏈表長度為??"?+?list.size());

int?size?=?list.size();

for?(int?i?=?0;?i?<?size;?i++)?{

Product?product?=?list.getFirst();

Integer?tempTime?=?product.getTimer();

System.out.println("???tempTime??"?+?tempTime);

//? 改變作物的時間

if?(tempTime?>?0)?{

tempTime--;

product.setTimer(tempTime);

list.removeFirst();

list.addLast(product);

System.out.println("???? 已經減--");

System.out.println("???? 植物的當前狀態??"+product.getCurrentState());

}?else?{

System.out.println("??? 向客戶端發送植物生長狀態");

Integer?currentState?=?product.getCurrentState();

IoSession?session?=?ClientInforUtils.getSessionByID

.get(product.getRoleID());

System.out.println("--------------------"+product.getRoleID());

System.out.println("--------------------"+session);

switch?(currentState)?{

case?1:

product.setCurrentState(2);

product.setTimer(30);

list.addLast(product);

list.removeFirst();

notifyClient(session,?product.getArticleID(),

product.getCurrentState());

break;

case?2:

product.setCurrentState(3);

product.setTimer(30);

list.addLast(product);

list.removeFirst();

notifyClient(session,?product.getArticleID(),

product.getCurrentState());

break;

case?3:

product.setCurrentState(4);

product.setTimer(30);

list.addLast(product);

list.removeFirst();

notifyClient(session,?product.getArticleID(),

product.getCurrentState());

break;

case?4:

product.setCurrentState(5);

product.setTimer(30);

list.addLast(product);

list.removeFirst();

notifyClient(session,?product.getArticleID(),

product.getCurrentState());

break;

case?5:

product.setCurrentState(6);

product.setTimer(30);

list.addLast(product);

list.removeFirst();

notifyClient(session,?product.getArticleID(),

product.getCurrentState());

break;

case?6:

product.setCurrentState(1);

product.setTimer(30);

list.addLast(product);

list.removeFirst();

notifyClient(session,?product.getArticleID(),

product.getCurrentState());

break;

default:

break;

}

}

}

}

},?delay,?period);

}

public?static?void?notifyClient(IoSession?session,?Integer?articleID,

Integer?state)?{

HashMap<String,?Object>?map;

switch?(state)?{

case?1:

map?=?new?HashMap<String,?Object>();

map.put("Event",?"S_Product_Grow");

map.put("productID",?articleID);

map.put("state",?state);

session.write(map);

break;

case?2:

map?=?new?HashMap<String,?Object>();

map.put("Event",?"S_Product_Grow");

map.put("productID",?articleID);

map.put("state",?state);

System.out.println("??? 客戶端地址??"+session);

session.write(map);

break;

case?3:

map?=?new?HashMap<String,?Object>();

map.put("Event",?"S_Product_Grow");

map.put("productID",?articleID);

map.put("state",?state);

session.write(map);

break;

case?4:

map?=?new?HashMap<String,?Object>();

map.put("Event",?"S_Product_Grow");

map.put("productID",?articleID);

map.put("state",?state);

session.write(map);

break;

case?5:

map?=?new?HashMap<String,?Object>();

map.put("Event",?"S_Product_Grow");

map.put("productID",?articleID);

map.put("state",?state);

session.write(map);

break;

case?6:

map?=?new?HashMap<String,?Object>();

map.put("Event",?"S_Product_Grow");

map.put("productID",?articleID);

map.put("state",?state);

session.write(map);

break;

default:

break;

}

}

}

package?com.toplx.mina.bussiness.handler.allhandlers.product.utils;

public?class?Product?{

private?Integer?articleID;

private?Integer?roleID;

private?Integer?currentState;

private?Integer?timer;

public?Product(Integer?articleID,?Integer?roleID)?{

this.articleID?=?articleID;

<span s