MySQL を使用した分散ロックの実装

CREATE TABLE `globallocktable` (
 `id` int(11) NOT NULL AUTO_INCREMENT,
 `lockKey` varchar(60) NOT NULL COMMENT 'ロック名',
 `createTime` datetime NOT NULL COMMENT '作成時刻',
 主キー (`id`)、
 ユニークキー `lockKey` (`lockKey`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC COMMENT='グローバルロック';

@成分
パブリッククラス GlobalLockComponent {
 @リソース
 グローバルロックテーブルDAO グローバルロックDAO;
 /**
  * ロックを取得しようとします。成功した場合は true、失敗した場合は false
  */
 パブリックブール型tryLock(文字列キー) {
  GlobalLockUtil.tryLock(this.globalLockDAO, キー) を返します。
 }
 /**
  * 別のプログラムがロックを占有していて、timeoutMs (ミリ秒) を超えると、ロックは強制的に解除されます。 * つまり、最初にキーに従ってレコードを削除し、次にレコードを追加します */
 パブリックブール型 tryLockWithClear(文字列キー、Long timeoutMs) {
  GlobalLockUtil.tryLockWithClear(this.globalLockDAO、キー、timeoutMs) を返します。
 }
 /**
  * ロックを解除し、キーに従ってレコードを削除します */
 パブリック void releasesLock(文字列キー) {
  GlobalLockUtil.releasLock(this.globalLockDAO、キー);
 }
}

パブリッククラス GlobalLockTable {

 プライベート整数ID;
 プライベート文字列 lockKey;
 プライベート日付createTime;
 // get メソッドと set メソッドを省略}

GlobalLockTableDAOは以下のように定義されます。public interface GlobalLockTableDAO {
 int deleteByPrimaryKey(整数ID);
 int deleteByLockKey(文字列 lockKey);
 GlobalLockTable selectByLockKey(文字列キー);
 int insertSelectiveWithTest(GlobalLockTable レコード);
}

パブリッククラス GlobalLockUtil {
 プライベート静的 Logger ロガー = LoggerFactory.getLogger(GlobalLockUtil.class);
 プライベート静的GlobalLockTable tryLockInternal(GlobalLockTableDAO lockDAO, 文字列キー) {
  GlobalLockTable を挿入 = 新しい GlobalLockTable();
  新しい日付を挿入します。
  insert.setLockKey(キー);
  // 注1
  int count = lockDAO.insertSelectiveWithTest(挿入);
  カウント == 0 の場合
   GlobalLockTable 準備完了 = lockDAO.selectByLockKey(キー);
   logger.warn("キーをロックできません: {}, {}, {}", insert.getLockKey(), ready.getCreateTime(),
     準備完了。
   返却準備完了。
  }
  logger.info("はい、キーによってロックを取得しました: {}", insert.getId(), insert.getLockKey());
  null を返します。
 }
 /** ロックを解除して再ロックするまでのタイムアウト**/
 パブリック静的ブール型 tryLockWithClear(GlobalLockTableDAO lockDAO、文字列キー、Long timeoutMs) {
  GlobalLockTable ロック = tryLockInternal(lockDAO, キー);
  lock == null の場合は true を返します。
  System.currentTimeMillis() - lock.getCreateTime().getTime() <= timeoutMs の場合 {
   logger.warn("申し訳ありませんが、キーを取得できません。: {}, {}, {}", key, lock.getId(), lock.getCreateTime());
   false を返します。
  }
  logger.warn("キーは既にタイムアウトしています: {}, {}, はクリアされます", key, timeoutMs);
  // 注2
  int count = lockDAO.deleteByPrimaryKey(lock.getId());
  カウント == 0 の場合
   logger.warn("申し訳ありませんが、キーは既に他のキーによってプリエンプトされています: {}、{}", lock.getId()、lock.getLockKey());
   false を返します。
  }
  ロック = tryLockInternal(lockDAO、キー);
  ロック!= null ? false : true を返します。
 }
 /** ロック **/
 パブリック静的ブール型tryLock(GlobalLockTableDAO lockDAO, 文字列キー) {
  tryLockInternal(lockDAO, key) == null を返します。true の場合、false になります。
 }
 /** ロック解除 **/
 パブリック静的void releasesLock(GlobalLockTableDAO lockDAO、文字列キー) {
  lockDAO.deleteByLockKey(キー);
 }
}

<挿入 id="insertSelectiveWithTest" useGeneratedKeys="true" keyProperty="id" パラメータタイプ="com.javashitang.middleware.lock.mysql.pojo.GlobalLockTable">
 `globallocktable` (`id`, に挿入
 `lockKey`、`createTime` )
  #{id,jdbcType=INTEGER}、#{lockKey,jdbcType=VARCHAR}、#{createTime,jdbcType=TIMESTAMP} を選択します
  存在しない二重から
  (lockKey = #{lockKey,jdbcType=VARCHAR} の globallocktable から 1 つを選択)
</挿入>

if (!globalLockComponent.tryLock(name)) {
 // ロックが取得されていない場合は戻ります。
}
試す {
 // ここでビジネスロジックを記述します} catch (Exception e) {
ついに
 globalLockComponent.releasLock(名前)