Axon 4.10.0事件处理器注册后自动注销问题求助

核心现象分析 #

从日志可见，SpringApplicationShutdownHook线程正在执行应用终止流程，包括等待Tracking Event Processor终止、释放token、注销命令处理器。这说明应用在启动完成前就触发了关闭逻辑，而非EventHandler注册后主动注销。

排查步骤 #

• 检查应用启动阶段的错误日志：重点搜索ERROR或WARN级别日志，定位是否存在Bean初始化失败、数据库连接异常、配置加载错误等问题——这些是触发ShutdownHook的最常见原因。
• 验证Kubernetes健康检查配置：查看livenessProbe和readinessProbe的参数，若initialDelaySeconds过短，应用未完成Axon组件初始化就被判定为不健康，K8s会重启Pod，导致应用提前关闭。
• 确认Axon Server禁用配置的完整性：Axon 4.10.0中禁用Axon Server需设置axon.axonserver.enabled=false，同时必须配置替代的事件存储（如JPA事件存储axon.eventhandling.eventstore.jpa.enabled=true）和本地命令总线，缺失这些配置会导致Axon初始化失败，触发应用关闭。
• 检查Tracking Event Processor（TEP）配置：查看TEP的线程池、token存储（如数据库表是否存在）配置，若TEP初始化失败，会导致应用上下文启动异常，进而触发ShutdownHook。
• 查看Spring上下文初始化日志：确认是否存在依赖Bean无法加载、EventHandler Bean创建失败等情况，这些会直接导致应用启动终止。

解决建议 #

• 优先定位启动失败根源：先解决启动阶段的错误（如配置错误、资源不可达），这是解决EventHandler注销问题的核心。
• 调整K8s健康检查参数：延长initialDelaySeconds至足够覆盖Axon组件初始化的时间（例如30-60秒），避免过早触发重启。
• 完善Axon无Server配置：确保已配置本地事件存储和命令总线，避免依赖Axon Server的组件初始化失败。
• 启用Axon DEBUG日志：添加配置logging.level.org.axonframework=DEBUG，查看Axon组件注册、初始化的详细过程，精准定位注销触发点。
• 检查TEP状态存储：确认TEP的token存储表（如tracking_token）已正确创建，且应用有读写权限。

相关日志（格式化后） #

org.axonframework.eventhandling.TrackingEventProcessorcluster_name: xxx-xxxfile: TrackingEventProcessor.javakubernetes: { [+]}line: 758
logger: org.axonframework.eventhandling.TrackingEventProcessor
logtag: F
message: Processor 'orderinfo' awaiting termination...
method: awaitTerminationservice: xxx-order-service
severity: INFO
stream: stdout
thread: SpringApplicationShutdownHook
time: 2024-08-08T11:42:13.286525436Z
timestamp: 2024-08-08T11:42:13.286298724Z

----------

host = splunk-fluentd-0
source = fluentd
sourcetype = http:
event8/8/2411:42:14.575 AM  { [-]
class: org.axonframework.eventhandling.TrackingEventProcessorcluster_name:
file: TrackingEventProcessor.javakubernetes: { [+]}line: 374logger: org.axonframework.eventhandling.TrackingEventProcessor
logtag: F
message: Released claim
method: releaseToken
service: xxx-order-service
severity: INFO
stream: stdout
thread: EventP

host = splunk-fluentd-0
source = fluentdsourcetype = http:
event8/8/2411:42:14.575 AM  { [-]
class: io.axoniq.axonserver.connector.command.impl.CommandChannelImplcluster_name:
file: CommandChannelImpl.javakubernetes: { [+]}
line: 288
logger: io.axoniq.axonserver.connector.command.impl.CommandChannelImpl
logtag: F
message: Deregistered handler for command 'com.xxx.xxx.order.control.manual.command.CreateManualOrderCommand' in context 'default'
method: unsubscribe
service: xxx-order-service
severity: INFO
stream: stdout
thread: SpringApplicationShutdownHook
time: 2024-08-08T11:42:13.909849444Z
timestamp: 2024-08-08T11:42:13.909430347Z}

内容的提问来源于stack exchange，提问作者Jithin Eapen