java定時任務可視化

Ⅰ java 定時任務的幾種實現方式

1. JDK 自帶的定時器實現

   // schele(TimerTask task, long delay) 延遲 delay 毫秒 執行
   // schele(TimerTask task, Date time) 特定時間執行
   public static void main(String[] args) {
   for (int i = 0; i < 10; ++i) {
   new Timer("timer - " + i).schele(new TimerTask() {
   @Override
   public void run() {
   println(Thread.currentThread().getName() + " run ");
   }
   }, 1000);
   }
   }
   2. Quartz 定時器實現

   //首先我們需要定義一個任務類，比如為MyJob02 ，
   //該類需要繼承Job類，然後添加execute(JobExecutionContext context)方法，在
   //這個方法中就是我們具體的任務執行的地方。
   //由希望由調度程序執行的組件實現的介面
   public class MyJob02 implements Job {
   @Override
   public void execute(JobExecutionContext context) throws JobExecutionException {
   // TODO Auto-generated method stub
   // 執行響應的任務.
   System.out.println("HelloJob.execute,"+new Date());
   }
   }

   public class QuartzTest5 {
   
   public static void main(String[] args) throws Exception {
   //SchelerFactory 是一個介面，用於Scheler的創建和管理
   SchelerFactory factory = new StdSchelerFactory();
   //從工廠裡面拿到一個scheler實例
   //計劃表(可能翻譯的不太貼切)，現在我們有了要做的內容，
   //與調度程序交互的主要API
   /*
   * Scheler的生命期，從SchelerFactory創建它時開始，
   到Scheler調用shutdown()方法時結束；Scheler被創建後，
   可以增加、刪除和列舉Job和Trigger，以及執行其它與調度相關的操作
   （如暫停Trigger）。但是，Scheler只有在調用start()方法後，
   才會真正地觸發trigger（即執行job）
   */
   Scheler scheler = factory.getScheler();
   //具體任務.
   //用於定義作業的實例
   //JobBuilder - 用於定義/構建JobDetail實例，用於定義作業的實例。
   JobDetail job = JobBuilder.newJob(MyJob.class).withIdentity("job1", "group1").build();
   
   
   //Trigger（即觸發器） - 定義執行給定作業的計劃的組件
   //TriggerBuilder - 用於定義/構建觸發器實例
   CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")
   .withSchele(CronScheleBuilder.cronSchele("0/1 * * * * ?")).build();
   scheler.scheleJob(job, trigger);
   scheler.start();
   
   
   }
   3. Spring boot 任務調度(這個非常容易實現)

   /*
   * 開啟對定時任務的支持
   * 在相應的方法上添加@Scheled聲明需要執行的定時任務。
   */
   @EnableScheling
   //@EnableScheling註解來開啟對計劃任務的支持
   public class Application {
   
   public static void main(String[] args) {
   SpringApplication.run(Application.class, args);
   }
   }

   @Component
   public class ScheledTasks {
   private Logger logger = LoggerFactory.getLogger(ScheledTasks.class);
   private int i=0;
   //0 0 0 2 * ?
   @Scheled(cron="* * * 2 * ?")
   //@Scheled 註解用於標注這個方法是一個定時任務的方法
   public void testFixDelay() {
   logger.info("執行方法"+i++);
   }
   

Ⅱ java的幾種定時任務

java定時任務有三種：

- JDK自帶 ：JDK自帶的Timer以及JDK1.5+ 新增的ScheledExecutorService；

- Quartz ：簡單卻強大的JAVA作業調度框架

- Spring3.0以後自帶的task ：可以將它看成一個輕量級的Quartz，而且使用起來比Quartz簡單許多；

代碼參考：

1. JDK 自帶的定時器實現

   schele(TimerTask task, Date time) 特定時間執行

   
   public static void main(String[] args) {

   
   for (int i = 0; i < 10; ++i) {

   
   new Timer("timer - " + i).schele(new TimerTask() {

   
   @Override
   public void run() {

   
   println(Thread.currentThread().getName() + " run ");

   
   }

   
   }, new Date(System.currentTimeMillis() + 2000));

   
   }
   }

2. Quartz 定時器實現

   2.1 通過maven引入依賴（這里主要介紹2.3.0） 注意：shiro-scheler中依賴的是1.x版本 如果同時使用會沖突

   <!-- https://mvnrepository.com/artifact/org.quartz-scheler/quartz -->

   
   <dependency>

   
   <groupId>org.quartz-scheler</groupId>

   
   <artifactId>quartz</artifactId>

   
   <version>2.3.0</version>

   
   </dependency>

   2.2創建Job類

   public class TestJob implements Job{

   
   @Override
   public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {

   
   println(Thread.currentThread().getName() + " test job begin " + DateUtil.getCurrentTimeStr());

   
   }
   }

   2.3調度任務

   public static void main(String[] args) throws InterruptedException, SchelerException {
   

   
   Scheler scheler = new StdSchelerFactory().getScheler();

   
   // 開始

   
   scheler.start();

   
   // job 唯一標識 test.test-1

   
   JobKey jobKey = new JobKey("test" , "test-1");

   
   JobDetail jobDetail = JobBuilder.newJob(TestJob.class).withIdentity(jobKey).build();

   
   Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("test" , "test")

// 延遲一秒執行

.startAt(new Date(System.currentTimeMillis() + 1000))

// 每隔一秒執行 並一直重復

.withSchele(SimpleScheleBuilder.simpleSchele().withIntervalInSeconds(1).repeatForever())
.build();

scheler.scheleJob(jobDetail , trigger);

Thread.sleep(5000);
// 刪除job

scheler.deleteJob(jobKey);

}

3.Spring 相關的任務調度

3.1 配置文件實現

spring-schele.xml

<task:scheler id="myScheler" pool-size="10" />

<task:scheled-tasks scheler="myScheler">

<task:scheled ref="job" method="test" cron="0 * * * * ?"/>

</task:scheled-tasks>

3.2註解實現

spring-schele.xml

<task:scheler id="myScheler" pool-size="10" />

// 啟用註解

<task:annotation-driven scheler="myScheler"/>

@Component
public class Task{

@Scheled(cron="0/5 * * * * ? ") //每5秒執行一次
public void execute(){

DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

System.out.println(sdf.format(DateTime.now().toDate())+"*********B任務每5秒執行一次進入測試");

}
}

Ⅲ java消息定時推送怎麼實現

定時任務實現的幾種方式：
Timer：這是java自帶的java.util.Timer類，這個類允許你調度一個java.util.TimerTask任務。使用這種方式可以讓程序按照某一個頻度執行，但不能在指定時間運行。一般用的較少。
ScheledExecutorService：也jdk自帶的一個類；
是基於線程池設計的定時任務類,每個調度任務都會分配到線程池中的一個線程去執行,也就是說,任務是並發執行,互不影響。Spring Task：Spring3.0以後自帶的task，可以看成一個輕量級的Quartz，而且使用起來比Quartz簡單許多。
Quartz：這是一個功能比較強大的的調度器，可以讓程序在指定時間執行，也可以按照某一個頻度執行，配置起來稍顯復雜。
消息推送推薦選擇極光推送軟體，JPush 是經過考驗的大規模 App 推送平台，每天推送消息量級為數百億條。 開發者集成 SDK 後，可以通過調用 API 推送消息。同時，JPush 提供可視化的 web 端控制台發送通知，統計分析推送效果。 JPush 全面支持 Android, iOS, Winphone 三大手機平台。

Ⅳ JAVA實現定時任務的幾種方式

Java 基本的定時任務，總結方法有三種：

1 創建一個thread，然後讓它在while循環內里一直運行著，通過容sleep方法來達到定時任務的效果；

2 用Timer和TimerTask與第一種方法相比有如下好處：

• 當啟動和去取消任務時可以控制

• 第一次執行任務時可以指定你想要的delay時間

3 用ScheledExecutorService是從的java.util.concurrent里，做為並發工具類被引進的，這是最理想的定時任務實現方式，相比於上兩個方法，它有以下好處：

• 相比於Timer的單線程，它是通過線程池的方式來執行任務的

• 可以很靈活的去設定第一次執行任務delay時間

• 提供了良好的約定，以便設定執行的時間間隔

Ⅳ java定時任務怎麼實現

/**
* 普通thread
* 這是最常見的，創建一個thread，然後讓它在while循環里一直運行著，
* 通過sleep方法來達到定時任務的效果。這樣可以快速簡單的實現，代碼如下：
* @author GT
*
*/
public class Task1 {
public static void main(String[] args) {
// run in a second
final long timeInterval = 1000;
Runnable runnable = new Runnable() {
public void run() {
while (true) {
// ------- code for task to run
System.out.println("Hello !!");
// ------- ends here
try {
Thread.sleep(timeInterval);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
};
Thread thread = new Thread(runnable);
thread.start();
}
}
[java] view plain
import java.util.Timer;
import java.util.TimerTask;
/**
*
* 於第一種纖核缺方式相比，優勢 1>當毀辯啟動和去取消任務時可以控制 2>第一次執行任務時可以指定你氏碼想要的delay時間
*
* 在實現時，Timer類可以調度任務，TimerTask則是通過在run()方法里實現具體任務。 Timer實例可以調度多任務，它是線程安全的。
* 當Timer的構造器被調用時，它創建了一個線程，這個線程可以用來調度任務。 下面是代碼：
*
* @author GT
*
*/
public class Task2 {
public static void main(String[] args) {
TimerTask task = new TimerTask() {
@Override
public void run() {
// task to run goes here
System.out.println("Hello !!!");
}
};
Timer timer = new Timer();
long delay = 0;
long intevalPeriod = 1 * 1000;
// scheles the task to be run in an interval
timer.scheleAtFixedRate(task, delay, intevalPeriod);
} // end of main
}
[java] view plain
import java.util.concurrent.Executors;
import java.util.concurrent.ScheledExecutorService;
import java.util.concurrent.TimeUnit;
/**
*
*
* ScheledExecutorService是從Java SE5的java.util.concurrent里，做為並發工具類被引進的，這是最理想的定時任務實現方式。
* 相比於上兩個方法，它有以下好處：
* 1>相比於Timer的單線程，它是通過線程池的方式來執行任務的
* 2>可以很靈活的去設定第一次執行任務delay時間
* 3>提供了良好的約定，以便設定執行的時間間隔
*
* 下面是實現代碼，我們通過ScheledExecutorService#scheleAtFixedRate展示這個例子，通過代碼里參數的控制，首次執行加了delay時間。
*
*
* @author GT
*
*/
public class Task3 {
public static void main(String[] args) {
Runnable runnable = new Runnable() {
public void run() {
// task to run goes here
System.out.println("Hello !!");
}
};
ScheledExecutorService service = Executors
.();
// 第二個參數為首次執行的延時時間，第三個參數為定時執行的間隔時間
service.scheleAtFixedRate(runnable, 10, 1, TimeUnit.SECONDS);
}
}

Ⅵ 關於java定時任務

第一種方抄法是寫一個線程,每秒運行一襲次,檢測當前系統時間,如果是0時0分0秒,那麼就把count設為1
第二種方法是用quartz框架,進行調度,調度規則是每天0點整運行一次,運行的內容就是把count設為1

Ⅶ java中怎麼實現定時功能

我們可以使用Timer和TimerTask類在java中實現定時任務，詳細說明如下：

1、基礎知識
java.util.Timer
一種線程設施，用於安排以後在後台線程中執行的任務。可安排任務執行一次，或者定期重復執行。此類是線程安全的：多個線程可以共享單個 Timer 對象而無需進行外部同步。
java.util.TimerTask
由 Timer 安排為一次執行或重復執行的任務。

2、示例代碼
該示例實現這樣一個功能，在系統運行期間，每30分鍾，系統自動檢查連接池中的可用連接數，並輸出到日誌中。
首先創建一個需要定時執行的任務類，這個任務類需要繼承TimerTask，然後重寫run()方法，run()方法體中的代碼就是定時需要執行的操作，在本demo中，就是獲取連接池中當前可用連接數，並輸出到日誌中，具體實現代碼如下：
public class TaskAvailableConnectNumber extends TimerTask {
private Logger log = Logger.getLogger(TaskAvailableConnectNumber.class);
private ConnectionPool pool=ConnectionPool.getInstance();
@Override
publicvoid run() {
log.debug("當前連接池中可用連接數"+pool.getAvailableConnectNumber());
}
}
下面定義一個監聽器，負責在應用伺服器啟動時打開定時器，監聽器需要實現ServletContextListener介面，並重寫其中的contextInitialized()和contextDestroyed()方法，代碼如下：
public class OnLineListener implements ServletContextListener{
private Logger log = Logger.getLogger(OnLineListener.class);
Timer timer = null;
//在應用伺服器啟動時，會執行該方法
publicvoid contextInitialized(ServletContextEvent arg0) {
//創建一個定時器，用於安排需要定時執行的任務。
timer = new Timer();
//為定時器安排需要定時執行的任務，該任務就是前面創建的任務類TaskAvailableConnectNumber，並指定該任務每30分鍾執行一次。
timer.schele(new TaskAvailableConnectNumber(), 0, 30*60*1000);
log.debug("啟動定時器");
}
//應用伺服器關閉時，會執行該方法，完成關閉定時器的操作。
public void contextDestroyed(ServletContextEvent arg0) {
if(timer!=null){
timer.cancel();//關閉定時器
log.debug("-----定時器銷毀--------");
}
}
}
監聽器要想正常運行，需要在web.xml文件中進行配置，配置信息如下：
<!-- 監聽器配置開始 -->
<listener>
<listener-class>
cn.sdfi.listen.OnLineListener
</listener-class>
</listener>
<!-- 監聽器配置結束 -->
以上步驟完成後，一個簡單的定時器就算開發完成了。

Ⅷ JAVA中定時自動完成任務的實現

JAVA中定時自動完成任務的實現要用到JAVA中的定時器TimerTask和監聽器 聽起來貌似有點困難但是實現起來還是比較容易的！紙老虎~~！

下面的列子很詳細 是關於定時向伺服器上傳（也可以是其他的動作這是看需要關於上傳我博客有寫過可以參考）文件的列子簡單的 步就可以實現

首先創建動作bean

package sun time ;

public class UploadFile{

/**

*實現上傳的代碼s省略 可以看下我下面的 篇日誌

__haiming/blog/static/ / 使用 *** arupload 實現上傳下載[有例子]

__haiming/blog/static/ / 使用Struts 多文件上傳

*/

public void upload()

{

System out println( 系統自動的上傳文件了 );

}

}

創建定時器MyTaker並完成相應的功能

package sun time ;

import java util Calendar;

import java util TimerTask;

import javax servlet ServletContext;

public class MyTaker extends TimerTask {

private static boolean isRun = false;

private ServletContext context ;

private Calendar ca = Calendar getInstance();

public MyTaker(ServletContext context)

{

ntext = context;

}

@Override

public void run() {

if(!isRun){

if( ==ca get(Calendar MINUTE)){

isRun = true;

context log( 正在執行所載入的任務 );

UploadFile uf= new UploadFile();

uf upload();

isRun =false;

context log( 任務順利完成 );

}

}

else

{

System out println( 任務還沒有執行完畢 );

}

}

}

創建監聽器ContextListener

package sun time ;

import javax servlet ServletContextEvent;

import javax servlet ServletContextListener;

import sun time MyTaker;

import java util *;

public class ContexListener implements ServletContextListener{

private Timer timer = null;

@Override

public void contextDestroyed(ServletContextEvent event) {

timer cancel();

event getServletContext() log( 任務列表已經銷毀了 );

}

@Override

public void contextInitialized(ServletContextEvent event) {

timer = new Timer(true);

event getServletContext() log( 伺服器已經啟動了 );

timer schele(new MyTaker(event getServletContext()) );///每隔多長時間檢查掃描一次

event getServletContext() log( 已經載入了任務的列表 );

}

}

最後一步就是在web xml中配置監聽

<! Java定時器 >

<listener>

<listener class> sun time ContexListener</listener class>

lishixin/Article/program/Java/hx/201311/26450