Class: DbCircuitBreaker

DBが落ちた/重い時に、一定時間アクセス自体を止める（サーキットブレーカー）。

6Fields
1Constructors
6Methods
65Lines
Package
com.example.rankingplugin.db
Source
db/DbCircuitBreaker.java
Kind
class
Roles
DB / 永続化
このクラスにも章立て解説を追加しています。 自動抽出の一覧だけでなく、下の『重点クラスの詳細解説』で読む順番・内部サブシステム・変更時の注意点まで追えます。 全クラス章立てガイドを見る

クラス説明

DBが落ちた/重い時に、一定時間アクセス自体を止める（サーキットブレーカー）。
 - フラッシュ処理等の非同期DBアクセスで使用する想定
 - メインスレッドでの getConnection 待ちを発生させないことが目的

責務と見どころ

重点クラスの詳細解説

DBが落ちた/重い時に、一定時間アクセス自体を止める（サーキットブレーカー）。db パッケージの 小規模クラスで、運用中の主ループを確認する起点です。全面展開版では、他の重点クラスと同じ章立てで読めるように補強しています。

最初に追う読む順番

  1. DbCircuitBreaker
    依存オブジェクトと初期状態を束ね、このクラスが担当するランタイムの前提を固めます。
  2. onSuccess
    運用中の中心ループです。イベント受理から状態更新までの主経路を追えます。
  3. onFailure
    運用中の中心ループです。イベント受理から状態更新までの主経路を追えます。
  4. isOffline
    条件判定を行い、後続処理の分岐に使える真偽値を返します。
  5. canAttemptNow
    既存コード互換: DBアクセスを試みてよいか。
  6. offlineRemainingMs
    offlineRemainingMs の主要処理を担当します。

内部サブシステムの地図

起動・前提準備

初期テーブル、依存状態、定期処理の点灯など、このクラスが動き始める前提をまとめています。

主なメソッド
DbCircuitBreaker
主なフィールド
なし

代表フロー詳解

初期化と起動の流れ

  1. DbCircuitBreaker

このクラスが前提状態を揃え、外部から利用可能な形まで立ち上がる流れです。新規依存の追加や起動失敗の調査はまずここから追います。

通常運用の中心フロー

  1. onSuccess
  2. onFailure

イベント受理、判定、状態更新、通知までの主経路です。体感不具合や想定外の分岐はこの流れのどこで止まるかを見ると切り分けやすいです。

反映・保存・終了の流れ

  1. DbCircuitBreaker
  2. onSuccess
  3. onFailure
  4. isOffline
  5. canAttemptNow

結果を保持し、必要なら永続化し、最後に掃除まで行う出口です。画面更新だけ合って保存が壊れるケースや残骸が残るケースの確認に向きます。

変更時の注意点

  • 公開メソッドと内部補助メソッドの責務境界を保つと読みやすさが落ちにくく、後から責務分割しやすくなります。

フィールド

VisibilityTypeName役割
privatelongbaseCooldownMsbaseCooldownMs の状態を保持します。
privatelongmaxCooldownMsmaxCooldownMs の状態を保持します。
privatelonglogMinIntervalMslogMinIntervalMs の状態を保持します。
privateAtomicIntegerfailsfails の状態を保持します。
privatelongofflineUntilMsofflineUntilMs の状態を保持します。
privatelonglastLogMslastLogMs の状態を保持します。

コンストラクタ / 初期化

Signature説明主要呼び出し
public DbCircuitBreaker(long baseCooldownMs, long maxCooldownMs, long logMinIntervalMs)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。max

メソッド索引

NameVisibilityKind説明
DbCircuitBreakerpublicコンストラクタ依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
isOfflinepublicメソッド条件判定を行い、後続処理の分岐に使える真偽値を返します。
canAttemptNowpublicメソッド既存コード互換: DBアクセスを試みてよいか。
offlineRemainingMspublicメソッドofflineRemainingMs の主要処理を担当します。
onSuccesspublicメソッドonSuccess の主要処理を担当します。
onFailurepublicメソッドonFailure の主要処理を担当します。

メソッド詳細

DbCircuitBreaker

コンストラクタpublic
public DbCircuitBreaker(long baseCooldownMs, long maxCooldownMs, long logMinIntervalMs)

依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。

引数

  • long baseCooldownMs
  • long maxCooldownMs
  • long logMinIntervalMs

throws

なし

主要な呼び出し順

max

isOffline

メソッドpublic
public boolean isOffline()

条件判定を行い、後続処理の分岐に使える真偽値を返します。

引数

  • 引数なし

throws

なし

主要な呼び出し順

currentTimeMillis

canAttemptNow

メソッドpublic
public boolean canAttemptNow()

既存コード互換: DBアクセスを試みてよいか。

引数

  • 引数なし

throws

なし

主要な呼び出し順

isOffline

offlineRemainingMs

メソッドpublic
public long offlineRemainingMs()

offlineRemainingMs の主要処理を担当します。

引数

  • 引数なし

throws

なし

主要な呼び出し順

currentTimeMillismax

onSuccess

メソッドpublic
public void onSuccess()

onSuccess の主要処理を担当します。

引数

  • 引数なし

throws

なし

主要な呼び出し順

目立つ内部呼び出しは抽出されませんでした。

onFailure

メソッドpublic
public void onFailure(Throwable t, Logger logger, String tag)

onFailure の主要処理を担当します。

引数

  • Throwable t
  • Logger logger
  • String tag

throws

なし

主要な呼び出し順

minincrementAndGetmaxcurrentTimeMillisgetClassgetSimpleNamegetMessagewarning

代表的な処理フロー

  1. 初期化フロー
    DbCircuitBreaker → max
    依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
  2. onFailure フロー
    onFailure → min → incrementAndGet → max → currentTimeMillis → getClass
    onFailure の主要処理を担当します。
  3. offlineRemainingMs フロー
    offlineRemainingMs → currentTimeMillis → max
    offlineRemainingMs の主要処理を担当します。
  4. canAttemptNow フロー
    canAttemptNow → isOffline
    既存コード互換: DBアクセスを試みてよいか。
  5. isOffline フロー
    isOffline → currentTimeMillis
    条件判定を行い、後続処理の分岐に使える真偽値を返します。

外部との接点

Web ルート

このクラス内に目立つ Web ルート定義は見つかりませんでした。

SQL / テーブル

テーブル名の抽出はありませんでした。

関連クラス

補足