Chat Service に関するサービス層・業務処理を担当します。

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

クラス説明

クラス直前の Javadoc は見つかりませんでした。ソースとメソッド構成から責務を補完しています。

責務と見どころ

重点クラスの詳細解説

Chat Service に関するサービス層・業務処理を担当します。web パッケージの 小〜中規模クラスで、Web 導線・スケジューラを確認する起点です。全面展開版では、他の重点クラスと同じ章立てで読めるように補強しています。

最初に追う読む順番

  1. ChatService
    依存オブジェクトと初期状態を束ね、このクラスが担当するランタイムの前提を固めます。
  2. ensureTable
    不足テーブル・設定・内部状態を先に揃える入口です。変更を入れる前提条件の確認地点になります。
  3. startCleaner
    定期処理や公開 API の起動地点で、外部から見える挙動がここから立ち上がります。
  4. installRoutes
    定期処理や公開 API の起動地点で、外部から見える挙動がここから立ち上がります。
  5. shutdown
    後片付けと停止の出口です。残骸や再ログイン後の不整合はここを確認します。
  6. resolvePlayer
    resolvePlayer の主要処理を担当します。
  7. getClientIp
    必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
  8. firstHeader
    firstHeader の主要処理を担当します。

内部サブシステムの地図

代表フロー詳解

反映・保存・終了の流れ

  1. shutdown

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

変更時の注意点

外部接点

外部ルート

このクラス内で直接見つかる主な Web ルート/項目名です。

POST /api/chat/pingPUT mePUT visitorsGET /api/chat/listPUT ipPUT playerPUT displayPUT messagePUT atPOST /api/chat/postGET messageGET message

主な永続化テーブル

SQL 文字列から抽出できた主要テーブルです。スキーマ変更時の確認用です。

chat_messagesfailed

フィールド

VisibilityTypeName役割
privateDataSourcedsDB 接続元を保持します。
privateIpLinkServiceipLinkService関連サービスへの参照です。
privateStringserverIdserverId の状態を保持します。
privateGsongsongson の状態を保持します。
privateMap<String, Long>presencepresence の状態を保持します。
privatelongPRESENCE_TTL_MSPRESENCE_TTL_MS の状態を保持します。
privateMap<String, Long>lastPostAtlastPostAt の状態を保持します。
privatelongCOOLDOWN_MSCOOLDOWN_MS の状態を保持します。
privatejava.util.concurrent.atomic.AtomicBooleaninstalledinstalled の状態を保持します。
privateMap<String,String>ipCacheキャッシュまたは直近計算結果を保持します。
privateMap<String,Long>ipCacheAtキャッシュまたは直近計算結果を保持します。
privatelongCACHE_MSキャッシュまたは直近計算結果を保持します。
privateintMAX_LENMAX_LEN の状態を保持します。
privateAtomicBooleanclosedclosed の状態を保持します。
privatePatternLINK_PATTERNLINK_PATTERN の状態を保持します。
privateScheduledExecutorServicecleanercleaner の状態を保持します。

コンストラクタ / 初期化

Signature説明主要呼び出し
public ChatService(DataSource ds, IpLinkService ipLinkService, String serverId)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。ensureTable → startCleaner

メソッド索引

NameVisibilityKind説明
ChatServicepublicコンストラクタ依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
ensureTableprivateメソッド必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。
startCleanerprivateメソッド初期化と各種登録を行い、機能を有効化します。
resolvePlayerprivateメソッドresolvePlayer の主要処理を担当します。
installRoutespublicメソッド初期化と各種登録を行い、機能を有効化します。
getClientIpprivateメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
firstHeaderprivateメソッドfirstHeader の主要処理を担当します。
shutdownpublicメソッド動作中の処理やリソースを安全に停止・解放します。

メソッド詳細

ChatService

コンストラクタpublic
public ChatService(DataSource ds, IpLinkService ipLinkService, String serverId)

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

引数

throws

なし

主要な呼び出し順

ensureTablestartCleaner

ensureTable

メソッドprivate
private void ensureTable()

必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。

引数

throws

なし

主要な呼び出し順

getConnectioncreateStatementexecuteUpdatechat_messagesidx_chat_server_timeidx_chat_server_ip_timeprintlngetMessage

startCleaner

メソッドprivate
private void startCleaner()

初期化と各種登録を行い、機能を有効化します。

引数

throws

なし

主要な呼び出し順

scheduleAtFixedRategetConnectionprepareStatementsetStringexecuteUpdateprintlngetMessageprintStackTrace

resolvePlayer

メソッドprivate
private String resolvePlayer(String rawIp)

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

引数

throws

なし

主要な呼び出し順

normalizeisEmptycurrentTimeMillisfindLatestPlayerByIpisBlank

installRoutes

メソッドpublic
public void installRoutes()

初期化と各種登録を行い、機能を有効化します。

引数

throws

なし

主要な呼び出し順

compareAndSetposttypegetClientIpnormalizeisBlankstatuscurrentTimeMillis

getClientIp

メソッドprivatestatic
private static String getClientIp(Request req)

必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

引数

throws

なし

主要な呼び出し順

firstHeaderisBlanksplittrimipnormalize

firstHeader

メソッドprivatestatic
private static String firstHeader(Request req, String... names)

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

引数

throws

なし

主要な呼び出し順

headersisBlank

shutdown

メソッドpublic
public void shutdown()

動作中の処理やリソースを安全に停止・解放します。

引数

throws

なし

主要な呼び出し順

shutdownNowawaitTerminationclear

代表的な処理フロー

  1. 初期化フロー
    ChatService → ensureTable → startCleaner
    依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
  2. installRoutes フロー
    installRoutes → compareAndSet → post → type → getClientIp → normalize
    初期化と各種登録を行い、機能を有効化します。
  3. startCleaner フロー
    startCleaner → scheduleAtFixedRate → getConnection → prepareStatement → setString → executeUpdate
    初期化と各種登録を行い、機能を有効化します。
  4. ensureTable フロー
    ensureTable → getConnection → createStatement → executeUpdate → chat_messages → idx_chat_server_time
    必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。
  5. shutdown フロー
    shutdown → shutdownNow → awaitTermination → clear
    動作中の処理やリソースを安全に停止・解放します。
  6. getClientIp フロー
    getClientIp → firstHeader → isBlank → split → trim → ip
    必要な状態を取得し、呼び出し側で利用しやすい形へ返します。

外部との接点

Web ルート

POST /api/chat/pingPUT mePUT visitorsGET /api/chat/listPUT ipPUT playerPUT displayPUT messagePUT atPOST /api/chat/postGET messageGET messageGET /api/debug/resolve-ip

SQL / テーブル

chat_messagesfailed

関連クラス

補足