こんにちは。Redisの世界へようこそ。
多くのエンジニアがRedisを「ただの速いキャッシュ」だと思っていますが、それは宝の山を文鎮として使っているようなものです。Redisには「Stream（ストリーム）」という、データの流れを完璧に管理するための強力な武器があります。
今日は、システムにおける「やり取りの取りこぼし」を防ぐための、最も重要で、かつ少しだけ奥深い「メッセージの承認と管理」について解説します。
難しい専門用語は使いません。ある「宅配便の業務」を想像しながら読み進めてみてください。
—
1. なぜ「承認」が必要なのか？
あなたがオンラインショップの店長だとします。注文データが届いたとき、サーバーがその処理の途中で電源が落ちてしまったらどうなるでしょう？ その注文は「消滅」してしまいますよね。
RedisのStreamは、まさにこの「注文管理」を担います。
「送ったから終わり」ではなく、「相手が確実に受け取り、処理を終えたことを確認する」。この信頼性を担保するのが、今日学ぶ3つのコマンドです。
—
2. 信頼を支える「3つの武器」
① XACK：仕事終わりの「完了報告」
作業員（コンシューマー）が注文を受け取ったら、処理が終わった後に必ず「終わりました！」と報告します。これが `XACK` です。
「注文ID 167253…」の処理が終わったことを報告（グループ名：team-A）
XACK orders-stream team-A 1672531234567-0
これを受け取ると、Redisは「あ、この仕事は無事に完了したんだな」と記録を整理します。
② XPENDING：放置されている「未完了リスト」の確認
時々、トラブルで作業員が途中で倒れてしまうことがあります。その時、まだ報告が来ていない仕事をチェックするのが `XPENDING` です。
team-Aグループの未完了リストをチェック
XPENDING orders-stream team-A
実行すると、「誰が何個の仕事を抱えたまま報告していないか」が数字で見えます。まるで、「配送中の荷物がどれだけあるか」をリストアップする台帳ですね。
③ XCLAIM：責任の「引き取り」
もし作業員が急病で倒れてしまったら、その荷物は宙に浮いてしまいます。それを別の作業員が「代わりにやるよ！」と奪い取るのが `XCLAIM` です。
10秒以上放置されている仕事（167253…）を、別の作業員が引き取る
XCLAIM orders-stream team-A new-worker 10000 1672531234567-0
これで、仕事の取りこぼしはゼロになります。
—
3. 日常の例えで整理する「業務フロー」
この仕組みを、職場のタスク管理に例えてみましょう。
1. Streamへの書き込み: 伝言板に付箋（メッセージ）を貼る。
2. 読み込み: 作業員が付箋を手に取る。
3. XACK: 作業が終わったら、伝言板の「完了」スタンプを押す。
4. XPENDING: 定期的に「まだスタンプがない付箋」をチェックする。
5. XCLAIM: 放置された付箋を見つけたら、他の人が「私がやる！」と自分の名前に書き換える。
どうでしょう？ 非常に人間味のある、堅実な仕組みだと思いませんか？
—
伝説のエンジニアからのアドバイス
初心者のうちは、これらを「コードを書くためのコマンド」として覚えようとします。でも、達人は違います。「データが消失するリスクをどうやってゼロにするか」という設計思想としてこれを捉えます。
- XACK は、データの整合性を守るための「約束」。
- XPENDING は、システムの健康状態を知るための「眼」。
- XCLAIM は、システムが止まらないようにするための「責任のバトン」。
この3つを使いこなせれば、あなたの作るシステムは、少々のトラブルではビクともしない「鉄壁の信頼性」を手に入れることになります。
ここをクリアできれば、Redisの扱いはもう初心者レベルを超えています。胸を張ってください。次は、この仕組みをどうやって自動化していくか、一緒に深掘りしていきましょう。
もし詰まったら、いつでも戻ってきてくださいね。あなたのコードが、世界をより良く動かすことを楽しみにしています。
コメント