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

21Fields
1Constructors
33Methods
772Lines
Package
com.example.rankingplugin.events
Source
events/EventRuntimeService.java
Kind
class
Roles
イベント駆動DB / 永続化非同期 / スケジューラ初期化 / ブートストラップサービス層
このクラスにも章立て解説を追加しています。 自動抽出の一覧だけでなく、下の『重点クラスの詳細解説』で読む順番・内部サブシステム・変更時の注意点まで追えます。 全クラス章立てガイドを見る
サブシステム横断ガイドもあります。 このクラスを含む上位の流れは こちらの処理遷移図ページ から読むと把握しやすいです。

クラス説明

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

責務と見どころ

重点クラスの詳細解説

Event Runtime Service に関するサービス層・業務処理を担当します。events パッケージの中でも 772 行規模の中核クラスで、運用中の主ループ・永続化境界・スケジューラが一か所に集まっています。中規模クラス群の中では変更影響が広く、章立てで読む価値が高いため重点解説へ追加しています。

最初に追う読む順番

  1. EventRuntimeService
    依存オブジェクトと初期状態を束ね、このクラスが担当するランタイムの前提を固めます。
  2. ensureEventScoreTable
    不足テーブル・設定・内部状態を先に揃える入口です。変更を入れる前提条件の確認地点になります。
  3. ensureAdminEventsPayoutColumns
    不足テーブル・設定・内部状態を先に揃える入口です。変更を入れる前提条件の確認地点になります。
  4. ensureBarsForPlayer
    不足テーブル・設定・内部状態を先に揃える入口です。変更を入れる前提条件の確認地点になります。
  5. buildRankMap
    表示用または出力用のデータを組み立てます。
  6. pollAndAnnounce
    DBから running を読み直して差分を放送
  7. onQuit
    運用中の中心ループです。イベント受理から状態更新までの主経路を追えます。
  8. onJoin
    運用中の中心ループです。イベント受理から状態更新までの主経路を追えます。
  9. updateBossBars
    結果を反映・永続化する境界です。表示だけ直って保存が壊れる系の切り分けに向きます。

内部サブシステムの地図

代表フロー詳解

反映・保存・終了の流れ

  1. notifyPlayerJoin
  2. removeBarsForEvent
  3. updateBossBars
  4. shutdown

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

変更時の注意点

外部接点

外部ルート

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

GET multiplierGET entitiesGET mobsGET entityGET mobGET materialsGET blocksGET materialGET blockGET no_silk_touchGET noSilkTouchGET fish

主な永続化テーブル

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

event_scoresadmin_events

フィールド

VisibilityTypeName役割
privateBukkitTaskpollTask非同期処理やスケジューラ制御に使うハンドルです。
privateBukkitTaskbarTask非同期処理やスケジューラ制御に使うハンドルです。
publicStringTYPE_NO_DEATH_PENALTYTYPE_NO_DEATH_PENALTY の状態を保持します。
privateJavaPluginpluginプラグイン本体参照です。
privateDataSourcedsDB 接続元を保持します。
privateGsongsongson の状態を保持します。
privateScoreServicescoreService関連サービスへの参照です。
privateMap<Integer, Ev>runningrunning の状態を保持します。
privateMap<UUID, Map<Integer, BossBar>>barsbars の状態を保持します。
privateMap<Integer, RankCache>rankCacheキャッシュまたは直近計算結果を保持します。
privatelongRANK_CACHE_MILLISキャッシュまたは直近計算結果を保持します。
privateList<Ev>lastRunningSnapshotlastRunningSnapshot の状態を保持します。
privateList<Ev>upcomingSnapshotupcomingSnapshot の状態を保持します。
privateintUPCOMING_LIMITUPCOMING_LIMIT の状態を保持します。
privateDateTimeFormatterJPJP の状態を保持します。
privatebooleanfishingActivefishingActive の状態を保持します。
privateMap<Integer, Map<UUID, Long>>deathSeendeathSeen の状態を保持します。
privatelongDEATH_DEDUP_MSDEATH_DEDUP_MS の状態を保持します。
privateBukkitTaskscoreFlushTask非同期処理やスケジューラ制御に使うハンドルです。
privateMap<Integer, Map<String, LongAdder>>pendingEventScorespendingEventScores の状態を保持します。
privateAtomicBooleanscoreFlushRunningscoreFlushRunning の状態を保持します。

コンストラクタ / 初期化

Signature説明主要呼び出し
public EventRuntimeService(JavaPlugin plugin, DataSource ds, ScoreService scoreService)依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。ensureEventScoreTable → ensureAdminEventsPayoutColumns → run → pollAndAnnounce → runTaskTimerAsynchronously → updateBossBars

メソッド索引

NameVisibilityKind説明
firstNonNullprivateメソッドfirstNonNull の主要処理を担当します。
nameEqprivateメソッドnameEq の主要処理を担当します。
EventRuntimeServicepublicコンストラクタ依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
truthyprivateメソッドtruthy の主要処理を担当します。
ensureEventScoreTableprivateメソッド必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。
ensureAdminEventsPayoutColumnsprivateメソッド必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。
nodeIdprivateメソッドnodeId の主要処理を担当します。
tryClaimPayoutprivateメソッドDB への問い合わせまたは更新処理を担当します。
isFantasiaWorldprivateメソッド条件判定を行い、後続処理の分岐に使える真偽値を返します。
getScoreMultiplierForMobKillpublicメソッドスコア倍増(モブ討伐用)の倍率。
isNoDeathPenaltyActivepublicメソッド条件判定を行い、後続処理の分岐に使える真偽値を返します。
addMobKillIfActivepublicメソッドMOB_KILLイベントが動作中なら、討伐数を +1 する
addOreGatherIfActivepublicメソッドORE_GATHERイベントが動作中なら、採掘数を +1 する
addFishingCatchIfActivepublicメソッド釣りイベントが動作中なら、対象アイテムなら +1 する
notifyPlayerJoinpublicメソッドプレイヤーが入ってきた時に、開催中のイベント一覧を案内&BossBar表示
pollAndAnnounceprivateメソッドDBから running を読み直して差分を放送
broadcastStartprivateメソッドbroadcastStart の主要処理を担当します。
isRankingEventprivateメソッド条件判定を行い、後続処理の分岐に使える真偽値を返します。
broadcastEndprivateメソッドbroadcastEnd の主要処理を担当します。
fetchTopRowsprivateメソッドDB への問い合わせまたは更新処理を担当します。
announceTopAndPayoutprivateメソッドannounceTopAndPayout の主要処理を担当します。
ensureBarsForPlayerprivateメソッド必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。
removeBarsForEventprivateメソッド対象データや登録状態を削除・解除します。
updateBossBarsprivateメソッド状態を永続化または更新し、最新状態へ反映します。
formatRemainprivateメソッドformatRemain の主要処理を担当します。
getRankAndScoreCachedprivateメソッド必要な状態を取得し、呼び出し側で利用しやすい形へ返します。
buildRankMapprivateメソッド表示用または出力用のデータを組み立てます。
addEventScoreprivateメソッドaddEventScore の主要処理を担当します。
flushPendingEventScoresprivateメソッドDB への問い合わせまたは更新処理を担当します。
markEndedInDbprivateメソッドDB への問い合わせまたは更新処理を担当します。
onQuitpublicイベント処理イベント発生時の分岐と後続処理を担当します。
onJoinpublicイベント処理イベント発生時の分岐と後続処理を担当します。
shutdownpublicメソッド動作中の処理やリソースを安全に停止・解放します。

メソッド詳細

firstNonNull

メソッドprivatestatic
private static Object firstNonNull(Object a, Object b)

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

引数

throws

なし

主要な呼び出し順

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

nameEq

メソッドprivatestatic
private static boolean nameEq(Object o, String expect)

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

引数

throws

なし

主要な呼び出し順

equalsIgnoreCasevalueOf

EventRuntimeService

コンストラクタpublic
public EventRuntimeService(JavaPlugin plugin, DataSource ds, ScoreService scoreService)

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

引数

throws

なし

主要な呼び出し順

ensureEventScoreTableensureAdminEventsPayoutColumnsrunpollAndAnnouncerunTaskTimerAsynchronouslyupdateBossBarsrunTaskTimerflushPendingEventScores

truthy

メソッドprivatestatic
private static boolean truthy(Object v)

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

引数

throws

なし

主要な呼び出し順

intValueparseBooleanvalueOf

ensureEventScoreTable

メソッドprivate
private void ensureEventScoreTable()

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

引数

throws

なし

主要な呼び出し順

getConnectioncreateStatementexecuteUpdateevent_scoresgetLoggerseveregetMessage

ensureAdminEventsPayoutColumns

メソッドprivate
private void ensureAdminEventsPayoutColumns()

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

引数

throws

なし

主要な呼び出し順

getConnectioncreateStatementexecuteUpdategetLoggerwarninggetMessage

nodeId

メソッドprivate
private String nodeId()

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

引数

throws

なし

主要な呼び出し順

getConfiggetStringtrimisEmptygetenvisBlankgetServergetPort

tryClaimPayout

メソッドprivate
private boolean tryClaimPayout(int eventId)

DB への問い合わせまたは更新処理を担当します。

引数

throws

なし

主要な呼び出し順

getConnectionsetAutoCommitprepareStatementnodeIdsetStringgetNamesetIntexecuteUpdate

isFantasiaWorld

メソッドprivatestatic
private static boolean isFantasiaWorld(World w)

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

引数

throws

なし

主要な呼び出し順

getNametoLowerCasecontainsgetKeygetNamespace

getScoreMultiplierForMobKill

メソッドpublic
public double getScoreMultiplierForMobKill()

スコア倍増(モブ討伐用)の倍率。

引数

throws

なし

主要な呼び出し順

valuesequalsdoubleValue

isNoDeathPenaltyActive

メソッドpublic
public boolean isNoDeathPenaltyActive()

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

引数

throws

なし

主要な呼び出し順

valuesequals

addMobKillIfActive

メソッドpublic
public void addMobKillIfActive(org.bukkit.entity.Entity killed, String playerName)

MOB_KILLイベントが動作中なら、討伐数を +1 する

引数

throws

なし

主要な呼び出し順

getWorldisFantasiaWorldgetTypenamegetUniqueIdcurrentTimeMillisvaluesequals

addOreGatherIfActive

メソッドpublic
public void addOreGatherIfActive(Block block, Player player)

ORE_GATHERイベントが動作中なら、採掘数を +1 する

引数

throws

なし

主要な呼び出し順

getTypenamevaluesequalsfirstNonNullnameEqequalsIgnoreCasestream

addFishingCatchIfActive

メソッドpublic
public void addFishingCatchIfActive(org.bukkit.Material caughtItem, String playerName)

釣りイベントが動作中なら、対象アイテムなら +1 する

引数

throws

なし

主要な呼び出し順

valuesequalsstreamanyMatchnameequalsIgnoreCasevalueOfaddEventScore

notifyPlayerJoin

メソッドpublic
public void notifyPlayerJoin(Player p)

プレイヤーが入ってきた時に、開催中のイベント一覧を案内&BossBar表示

引数

throws

なし

主要な呼び出し順

isEmptysendMessageformatensureBarsForPlayergetUniqueIdnowmaxbetween

pollAndAnnounce

メソッドprivate
private void pollAndAnnounce()

DBから running を読み直して差分を放送

引数

throws

なし

主要な呼び出し順

getConnectionprepareStatementexecuteQuerynextgetIntgetTimestamptoLocalDateTimegetString

broadcastStart

メソッドprivate
private void broadcastStart(Ev ev)

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

引数

throws

なし

主要な呼び出し順

getSchedulerrunTaskformatbroadcastMessageisRankingEventrewardConfigvalueOflongValue

isRankingEvent

メソッドprivatestatic
private static boolean isRankingEvent(Ev ev)

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

引数

throws

なし

主要な呼び出し順

typeequals

broadcastEnd

メソッドprivate
private void broadcastEnd(Ev ev)

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

引数

throws

なし

主要な呼び出し順

broadcastMessageisRankingEventtryClaimPayoutannounceTopAndPayoutgetLoggerinfoskippedremoveBarsForEvent

fetchTopRows

メソッドprivate
private List<Row> fetchTopRows(int eventId, int limit)

DB への問い合わせまたは更新処理を担当します。

引数

throws

なし

主要な呼び出し順

getConnectionprepareStatementsetIntexecuteQuerynextgetStringgetIntgetLogger

announceTopAndPayout

メソッドprivate
private void announceTopAndPayout(Ev ev)

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

引数

throws

なし

主要な呼び出し順

getSchedulerrunTaskAsynchronouslyfetchTopRowsplayerformatscoreisEmptyrewardConfig

ensureBarsForPlayer

メソッドprivate
private void ensureBarsForPlayer(UUID uuid)

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

引数

throws

なし

主要な呼び出し順

computeIfAbsentvaluesequalscreateBossBargetPlayeraddPlayerkeySetremoveIf

removeBarsForEvent

メソッドprivate
private void removeBarsForEvent(int eventId)

対象データや登録状態を削除・解除します。

引数

throws

なし

主要な呼び出し順

valuesremoveremoveAllsetVisible

updateBossBars

メソッドprivate
private void updateBossBars() throws SQLException

状態を永続化または更新し、最新状態へ反映します。

引数

throws

SQLException

主要な呼び出し順

isEmptynowentrySetgetPlayergetKeygetValuebetweentoMillis

formatRemain

メソッドprivate
private String formatRemain(long millis)

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

引数

throws

なし

主要な呼び出し順

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

getRankAndScoreCached

メソッドprivate
private int[] getRankAndScoreCached(int eventId, String player) throws SQLException

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

引数

throws

SQLException

主要な呼び出し順

currentTimeMillisbuildRankMap

buildRankMap

メソッドprivate
private Map<String,int[]> buildRankMap(int eventId) throws SQLException

表示用または出力用のデータを組み立てます。

引数

throws

SQLException

主要な呼び出し順

getConnectionprepareStatementsetIntexecuteQuerynextgetLonggetString

addEventScore

メソッドprivate
private void addEventScore(int eventId, String player, int delta)

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

引数

throws

なし

主要な呼び出し順

isBlankcomputeIfAbsent

flushPendingEventScores

メソッドprivate
private void flushPendingEventScores()

DB への問い合わせまたは更新処理を担当します。

引数

throws

なし

主要な呼び出し順

compareAndSetentrySetgetKeygetValueisEmptysumThenResetgetConnectionprepareStatement

markEndedInDb

メソッドprivate
private void markEndedInDb(int eventId)

DB への問い合わせまたは更新処理を担当します。

引数

throws

なし

主要な呼び出し順

getConnectionprepareStatementsetIntexecuteUpdate

onQuit

イベント処理public
public void onQuit(PlayerQuitEvent e)

イベント発生時の分岐と後続処理を担当します。

引数

throws

なし

主要な呼び出し順

getPlayergetUniqueIdremovevaluesforEachremoveAllsetVisible

onJoin

イベント処理public
public void onJoin(PlayerJoinEvent e)

イベント発生時の分岐と後続処理を担当します。

引数

throws

なし

主要な呼び出し順

notifyPlayerJoingetPlayer

shutdown

メソッドpublic
public void shutdown()

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

引数

throws

なし

主要な呼び出し順

cancelflushPendingEventScoresvaluesremoveAllsetVisibleclearisEnabledisPrimaryThread

代表的な処理フロー

  1. 初期化フロー
    EventRuntimeService → ensureEventScoreTable → ensureAdminEventsPayoutColumns → run → pollAndAnnounce → runTaskTimerAsynchronously
    依存オブジェクトや初期状態を受け取り、このクラスの動作を開始できる状態へ組み立てます。
  2. onQuit フロー
    onQuit → getPlayer → getUniqueId → remove → values → forEach
    イベント発生時の分岐と後続処理を担当します。
  3. onJoin フロー
    onJoin → notifyPlayerJoin → getPlayer
    イベント発生時の分岐と後続処理を担当します。
  4. updateBossBars フロー
    updateBossBars → isEmpty → now → entrySet → getPlayer → getKey
    状態を永続化または更新し、最新状態へ反映します。
  5. ensureBarsForPlayer フロー
    ensureBarsForPlayer → computeIfAbsent → values → equals → createBossBar → getPlayer
    必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。
  6. ensureEventScoreTable フロー
    ensureEventScoreTable → getConnection → createStatement → executeUpdate → event_scores → getLogger
    必要なテーブル・状態・前提条件が揃っているかを確認し、不足分を補います。

外部との接点

Web ルート

GET multiplierGET entitiesGET mobsGET entityGET mobGET materialsGET blocksGET materialGET blockGET no_silk_touchGET noSilkTouchGET fishGET topGET top

SQL / テーブル

event_scoresadmin_eventsscore

関連クラス

補足