キャッシュとロック#

3つの実装から選ぶ#

cache {
	type = "db"        # db | memory | redis
}

知らない値を書いても落ちません。警告を出して db になります。 いま何で動いているかは起動ログに出ます（cache=db）。

読み書き#

ICache cache = Cache.instance(db);

cache.set("top:posts", json, "application/json");
String json = cache.getString("top:posts");

cache.remove("top:posts");

グループでまとめて消す#

「記事を1本直したら、その記事に関わるキャッシュを全部捨てたい」ときに使います。

cache.set("key-4", "値", "text/plain", "group");
cache.set("key-5", "値", "text/plain", "group");
cache.set("key-6", "値", "text/plain", "keep");

cache.removeGroup("group");

jimble 自身もこれを使っています。スケジューラは台ごとの生存情報を同じグループに入れ、 getStringGroup(group) で全台ぶんをまとめて読み出します。

SQL の結果をキャッシュする#

ICache は「入れた側が消す」ものでした。 SQL 結果キャッシュは、更新を見て自分で消えます。

既定では無効です。 使うアプリだけ 1 行書いてください。

sql_cache.enabled = true

Data customer = db.selectCached(
	SQL.select()
		.from(Customer.instance())
		.inner(Shop.instance()).on(Customer.shop_id.eq(Shop.id))
		.where(Customer.id.eq(1)));

// 更新は今までどおり書くだけ。関係するキャッシュだけが消えます
db.update(SQL.update(Customer.instance()).set(Customer.name, "name1").where(Customer.id.eq(1)));

読むほうは明示、消すほうは自動です。 逆にすると、消し忘れが黙って古いデータになります。

どう判断しているか#

キャッシュ 1 件に依存タグを付けます。

タグは 2 つの材料から作ります。

• SELECT の結果行から、テーブルごとに主キーと一意キーの値を拾う。 結果はテーブル名でネストしている（Data のネスト）ので、結合先のキーもそのまま拾えます
• UPDATE / DELETE の WHERE から、主キー・一意キーの等値と IN を読む。 読めたらその行タグだけ、読めなければテーブルごと消します

一意キーは codegen が SHOW INDEX から拾って生成します。codegen を流し直してください。

一覧のキャッシュ#

行を 1 つに特定していない SELECT には、customer#* も付きます。

// shop_id で絞った一覧。顧客が増えたら結果が変わる
db.selectListCached(SQL.select().from(Customer.instance()).where(Customer.shop_id.eq(1)));

「特定している」と見なすのは次の場合です。

• WHERE が主キー・一意キーの全列を値で縛っている（WHERE id = 1、WHERE id IN (1, 2)）
• 結合条件が、すでに特定できているテーブルの列とキーの全列を縛っている （ON (customer.shop_id = shop.id) で customer が特定できていれば、shop も 1 行に決まる）

トランザクション#

トランザクションの中では読みも書きもしません。 まだ確定していない値をキャッシュに残さないためです。 消すほうは溜めておいて、コミットでまとめて消します。ロールバックしたら消しません。

効かないところ#

設定#

sql_cache {
	enabled = true       # 既定は false
	store   = "memory"   # memory | redis | db
	ttl     = 300        # 秒。0 で無期限
	max     = 10000      # memory のときだけ。持つ件数の上限
}

既定が false なのは、使っていないアプリに代金を払わせないためです。 有効だと、selectCached を 1 度も呼んでいなくても、 すべての insert / update / delete で「どの行に当たるか」を組み立てます （WHERE を読み、テーブルのキーを引く）。 false のあいだはその処理が 1 行も走りません。

書き忘れても気づけるようにしてあります。

• 起動時の構成ログに sql_cache=off と出ます
• 切ったまま selectCached を呼ぶと、初回だけ警告が出ます（毎回は出しません）

jimble 構成: env=local / session=none / cache=db / sql_cache=off / redis=なし / ...

ローディングキャッシュ#

「無ければ作る」を1か所に書く形です。

LoadingCache<List<Data>> cache = Cache.loadingCache(
	"top:posts", db, Duration.ofMinutes(5), loaderDb -> loaderDb.selectList(...));

List<Data> posts = cache.get();

分散ロック#

Redis を使います。「複数台のうち1台だけに処理させたい」ときのものです。

RedisLockResult result = RedisLock.lock(key);

assertEquals(RedisLockStatus.Success, result.status());

closeQuietly(result);

// 100ms 待って取れなければあきらめる。取れたら 30 秒保持する
try (RedisLockResult lock = RedisLock.tryLock("batch:daily", 100, 30000)) {

	if (lock.status() != RedisLockStatus.Success) {
		return;   // 誰かが動かしている
	}

	// ここが1台だけになる

} catch (IOException ignore) {
}

Redis を設定していないときは、黙って成功させずに例外になります（要件 F-U-10）。 「ロックが無いのに進んでしまった」を作らないためです。

DB だけでロックする#

Redis が無い場所では DBLock を使えます。トランザクションの中で、 先に行を作ってから取ります。

DBLock.create(db, "daily");           // 1回だけ
...
if (DBLock.lock(db, "daily")) {       // SELECT ... FOR UPDATE
	// トランザクションが終わるまで1つだけ
}

行が無ければ false です。解放はトランザクションの終わりで、明示的に外す口はありません。

設定キー#

cache {
	type          = "db"     # db | memory | redis
	temp_dir      = ""       # 大きい値を落とす場所。空なら一時ディレクトリ
	memory.expire = 0        # memory のときだけ。秒。0 で無期限
}

redis {
	host = ""                # 空なら「Redis 無し」
	port = 6379
	ssl  = false
}