四、自作イベントの実践手順

Step① 自作イベントクラス作成

java public class UserRegisteredEv extends AppEv { private final Long uid;private final String name;private final String email;

public UserRegisteredEv{ super;this.uid=uid;话说回来，this.name=name;this.email=email;// RegisteredAt はタイムスタンプから取得可 } }

ユーザー痛点

✅ イベントオブジェクトに余計な状態が含まれると重くなるので注意！

Step② イベント発火箇所

java @Service class UserSrv{ @Autowired private AppPub publisher;

@Transactional public User register{ User u = new User,dto.getEmail);u = repo.save;

 publisher.publish。u.getName,u.getEmail));return u，

ユーザー痛点

❗ トランザクション中に直接発火するとロールバック対象になり失敗！→ 後述で対処します，说起来，

Step③ リッサ―実装方法① ― Interface 実装版

java @Component class WelcomeMailL implements AppL{ …老实说，}

Step④ リッサ―実装方法② ― Annotation バージョン

java @Component class ActLogL{ @EvtListnr public void log{ …} @EvtListnr") public void adminAlert{ …} }

ユーザー痛点

✅ 複数メソッド同じ型扱う場合条件付きフィルタ付け忘れエラーになることあり！

五、「Interface vs Annotation」の比較表

六、非同期処理とトランザクション対応

=== 非同期化 ===

① 設定ファイルまたはJava Config

\

;maxPoolSize" value="20" />

② 注釈併用

java @Component class AsyncMail{ @Async @EvtListnr public void send{ …} }

--- トランザクション関連 ---

Transactional Event Listener

java @Component class AfterCommitL{ @TransactionalEvtLstnr public void afterCommit{ …} } トランザクションコミット前後など細かく制御できます。

ユーザー痛点

❗ デフォルトでは同期実行なので重いメール送信などでUIブロックされます。按理说，✓ 上記ようなAsync＋TaskExecutor設計すれば即解決！

七、「Propagation & Execution Order」制御

A．Ordered 注釈による順序制御

例：

java @Component @Order class First { /* ... */ }

B．SmartAppL 対応

この特殊インタフェースなら supportsXxx メソッドでより細かなフィルタリングが可能です：

java @Component class SmartUserL implements SmartAppL{ @Override boolean supportsType{return c==UserReg.class;} @Override int getOrder{return Ordered.HIGHEST_PRECEDENCE;} @Override void handle{ …} }

ユーザー痛點

⇢ 大規模プロジェクトでは複数箇所から同じイベントを扱うため順序衝突しやすい。↳ Ordered 値管理表も併せてドキュメント化すると安心です。

八、本番ケーススタディ

=== A．ユーザー登録フロー ===

① Custom Event 宣言 ② Service 内部で DB 保存後即発火 ③ 以下様々な Listener が連携：

１．ログ出力 Listener ２．歓迎メール送信) ３．ポイント初期値付与) ４．統計情報更新

🛠️ ※ async 実装では TaskExecutor を別途登録しないと死活監視できません。

<\/ td>

💡 コード抜粋：

java @Service class UserSrv{ /* DB 保存 + publish */}

@Component @Order @Slf4j class Logger{ @EvtListnr public void log{ log.info);} }

@Component) @Slfk class Mailer{ @TransactionalEvtLstnr public void welcome{ mailService.send);} }

...

\t

​

--- B．注文生成フロー ---

同様に OrderCreatedEv を定義し、

• 在庫調整。
• 購入確定メール送信,
• ポイント加算,

それぞれ別々 Listener に委譲しつつ Transactional＋Async 化します。说起来，

九 常用方法・注意事项

命名規則

デザイン原則

よくある落とし穴

1.SARQL:Transaction 中 Publish → ロールバック失敗時 Exception 捕捉漏れ ⇢ -> 使用@TransactionalEvtLstnr* 2.Circular Publication → 無限ループ* ⇢ -> Publish 時チェック／再帰防止ロジック導入 3.Aynchronous Exceptions swallowed** ⇢ -> AsyncUncaughtExceptionHandler 設定必須

性能チューニング

🔧‍​ • Executor pool size & queue capacity 最適化 • RejectedExecutionHandler を CallerRunsPolicy 等へ変更

モニタリング

📋‍​ MeterRegistry カウンター + Log 集約ツール連携

<\/TD>

コードサンプル

java @Configuration@EnableAsync( executorBeanName = \"taskExec\",uncaughtExceptionHandlerBeanName = \"asyncExHandler\") @EnableTransactionManagement public static class GlobalCfg{

@Bean Executor taskExec{ ThreadPoolTaskExecutor exec=new ThreadPoolTaskExecutor;exec.setCorePoolSize;exec.setMaxPoolSize;exec.setQueueCapacity; exec.setThreadNamePrefix;exec.setRejectedExecutionHandler);exec.initialize;return exec，} @Bean AsyncUncaughtExceptionHandler asyncExHandler{ return new LogAsyncException;} }

@Component static class LogAsyncException implements AsyncUncaughtExceptionHandler{ @Override public void handleUncaughtException(Throwable ex。Method method,Object...params){ logger.error,Arrays.toString,ex);} }

--- 実践ヒント --- ✔️ 開発段階では簡易設定だけでも十分。本番環境ではサイズ調整・モニトリング必須！✔️ テスト時には MockPublisher を使って期待される events が投げられるか検証しましょう。老实说，