今天就跟大家聊聊有關(guān)Java中怎么利用多機(jī)器部署解決大量定時(shí)任務(wù)問(wèn)題，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

為羅源等地區(qū)用戶(hù)提供了全套網(wǎng)頁(yè)設(shè)計(jì)制作服務(wù)，及羅源網(wǎng)站建設(shè)行業(yè)解決方案。主營(yíng)業(yè)務(wù)為網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、羅源網(wǎng)站設(shè)計(jì)，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專(zhuān)業(yè)、用心的態(tài)度為用戶(hù)提供真誠(chéng)的服務(wù)。我們深信只要達(dá)到每一位用戶(hù)的要求，就會(huì)得到認(rèn)可，從而選擇與我們長(zhǎng)期合作。這樣，我們也可以走得更遠(yuǎn)！

需求: 有兩臺(tái)服務(wù)器同時(shí)部署了同一套代碼， 代碼中寫(xiě)有spring自帶的定時(shí)任務(wù)，但是每次執(zhí)行定時(shí)任務(wù)時(shí)只需要一臺(tái)機(jī)器去執(zhí)行。

當(dāng)拿到這個(gè)需求時(shí)我腦子中立馬出現(xiàn)了兩個(gè)簡(jiǎn)單的解決方案：

• 利用ip進(jìn)行判斷， 兩臺(tái)機(jī)器ip肯定不一樣， 指定某一臺(tái)機(jī)器的ip運(yùn)行。

• 只在一臺(tái)機(jī)器上部署定時(shí)任務(wù)的代碼。

最后兩個(gè)方案又都被自己否決了。 第一條，如果指定ip的機(jī)器出現(xiàn)了問(wèn)題怎么辦？ 例如說(shuō)宕機(jī)了， 那么該制定ip的機(jī)器上的定時(shí)任務(wù)是不是就無(wú)法運(yùn)行了？如果以后該服務(wù)器遷移導(dǎo)致ip變化怎么辦？

第二條， 同上， 還有就是要維護(hù)兩套代碼很不方便。

因?yàn)樯厦鎯蓚€(gè)假設(shè)都不成立， 只能另找他法。 于是便想到利用MySQL去解決， 之前了解過(guò)一點(diǎn)mysql的鎖機(jī)制， 知道如果有同時(shí)的兩個(gè)任務(wù)去寫(xiě)數(shù)據(jù)庫(kù)中同一條記錄， 只有一條會(huì)成功， 這是利用了mysql的排他鎖。

下面就開(kāi)始代碼演示， 這里主要想給大家的是一個(gè)思路的提示， 代碼還是很簡(jiǎn)單的。

首先需要單獨(dú)創(chuàng)建一張表

CREATE TABLE `t_schedule_cluster` (
 `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '@cname:主鍵',
 `execute` int(1) NOT NULL COMMENT '@cname:執(zhí)行狀態(tài)',
 `version` int(11) NOT NULL COMMENT '@cname:版本號(hào)\r\n      ',
 `task_name` varchar(128) NOT NULL COMMENT '@cname:任務(wù)名稱(chēng)\r\n      ',
 `execute_ip` varchar(32) DEFAULT NULL COMMENT '@cname:執(zhí)行ip\r\n      ',
 `update_time` datetime DEFAULT NULL COMMENT '@cname:修改時(shí)間\r\n      ',
 PRIMARY KEY (`id`),
 KEY `Index_series_id` (`execute`)
) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8 COMMENT='@cname:多機(jī)定時(shí)任務(wù)調(diào)度';

看一下建成后的表結(jié)構(gòu)， 注釋寫(xiě)的已經(jīng)很清楚了， 初始化時(shí)需要添加一些定時(shí)任務(wù)的名稱(chēng)（task_name）， 這個(gè)要和你代碼中保持一致， 后面會(huì)提到：

代碼

首先看下我代碼中用到的spring定時(shí)任務(wù)：

  使用Spring的 Scheduled的定時(shí)任務(wù)配置
  
  
  
  
    
    
    
  

相信大家都是用過(guò)這種定時(shí)任務(wù)的設(shè)置方法， 因?yàn)樗莝pring自帶的， 所以使用起來(lái)很方便， 這里我指定了兩個(gè)定時(shí)任務(wù)來(lái)模擬兩臺(tái)機(jī)器的情況， 兩個(gè)定時(shí)任務(wù)都是項(xiàng)目啟動(dòng)后每隔一分鐘執(zhí)行一次。

然后看看這個(gè)listCar中的代碼：

//定時(shí)任務(wù)的名稱(chēng)， 這個(gè)和數(shù)據(jù)庫(kù)中的task_name是保持一致的， 保證要執(zhí)行該定時(shí)任務(wù)。
public static final String LIST_CAR_TASK = "listCarTask";
private ScheduleClusterTask scheduleClusterTask;
//這個(gè)時(shí)間是根據(jù)spring-scheduler.xml中配置的定時(shí)刷新時(shí)間, 比如說(shuō)我們以后要設(shè)置這個(gè)定時(shí)任務(wù)時(shí)4小時(shí)刷新一次
public static final long maxExpireTime = 4 * 3600;

public void listCar() {
    if (scheduleClusterTask.isValidMachine(maxExpireTime, CommonConstants.ScheduleTaskName.LIST_CAR_TASK)) {
      //執(zhí)行具體的task方法， 
      doTask();
      //將execute狀態(tài)更新為0
      scheduleClusterTask.end(LIST_CAR_TASK);
    }
  }

最后看下最核心的代碼：ScheduleClusterTask.java

/**
 * 多機(jī)定時(shí)任務(wù)工具類(lèi)
 * Created by WangMeng on 2017/4/12.
 */
@Service
public class ScheduleClusterTask {

  private ScheduleClusterEntityService scheduleClusterEntityService;

  /**
   * 這里因?yàn)閮膳_(tái)機(jī)器都有同樣的定時(shí)任務(wù)， 會(huì)同時(shí)執(zhí)行這個(gè)方法，只有一臺(tái)機(jī)器可以執(zhí)行成功，返回true。
   * @param maxExpireTime 最大的檢查時(shí)間。
   * @param taskName 任務(wù)名稱(chēng)。
   * @return
   */
  public boolean isValidMachine(long maxExpireTime, String taskName) {
    boolean isValid = false;
    try {
      //通過(guò)taskName去數(shù)據(jù)庫(kù)中查找到該條記錄， 如果大家使用的是mybatis這里需要改一下， 就是一個(gè)簡(jiǎn)單的查詢(xún)操作
      ScheduleClusterEntity carIndexEntity = scheduleClusterEntityService.findOne(ScheduleClusterEntity.Fields.taskName.eq(taskName));
      int execute = carIndexEntity.getExecute();
      String ip = InetAddress.getLocalHost().getHostAddress();
      long currentTimeMillis = System.currentTimeMillis();
      long time = carIndexEntity.getUpdateTime().getTime();
      if (execute == 0 && time + maxExpireTime - 1000 < currentTimeMillis) {
        isValid = checkMachine(taskName, carIndexEntity, ip);
      } else if (time + maxExpireTime - 1000 < currentTimeMillis){
        //這里要判斷下， 如果上一次執(zhí)行出現(xiàn)異常導(dǎo)致execute沒(méi)有更新為0， 那么這里要判斷上一次更新時(shí)間的間隔。
        isValid = checkMachine(taskName, carIndexEntity, ip);
      }
    } catch (UnknownHostException e) {
      e.printStackTrace();
    }
    return isValid;
  }

  /**
   * end方法主要是將excute(是否正在執(zhí)行的標(biāo)志位，0:沒(méi)有執(zhí)行， 1:正在執(zhí)行)更新為0
   * @param taskName
   * @return
   */
  public boolean end (String taskName) {
    ScheduleClusterEntity carIndexEntity = scheduleClusterEntityService.findOne(ScheduleClusterEntity.Fields.taskName.eq(taskName));
    //將execute狀態(tài)更新為0
    return scheduleClusterEntityService.end(carIndexEntity);
  }

  private boolean checkMachine(String taskName, ScheduleClusterEntity carIndexRefresh, String ip) {
    return scheduleClusterEntityService.start(taskName, carIndexRefresh.getVersion(), ip);
  }

  @Autowired
  public void setScheduleClusterEntityService(ScheduleClusterEntityService scheduleClusterEntityService) {
    this.scheduleClusterEntityService = scheduleClusterEntityService;
  }
}

這里還有start方法， 看看怎樣的操作：

@Repository
public class DefaultScheduleClusterEntityDao extends AbstractDao implements ScheduleClusterEntityDao {
  @Override
  public boolean start(String taskName, int version, String ip) {
    String sql = "update t_schedule_cluster set execute = 1, " +
        "version = ?, execute_ip = ?, update_time = ?" +
        " where task_name = ? and version = ?";
    Sql s = new Sql(sql);
    s.addParam(version + 1);
    s.addParam(ip);
    s.addParam(SqlTimeUtils.nowTimestamp());
    s.addParam(taskName);
    s.addParam(version);
    return 1 == executeUpdate(s);
  }
}

看完上述內(nèi)容，你們對(duì)Java中怎么利用多機(jī)器部署解決大量定時(shí)任務(wù)問(wèn)題有進(jìn)一步的了解嗎？如果還想了解更多知識(shí)或者相關(guān)內(nèi)容，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。