如何在Axon Framework中使用断点调试且不触发事件流关闭

问题根因 #

该报错由Axon Server与应用客户端之间的gRPC长连接超时检测机制触发：当你在EventHandler方法处设置断点挂起应用线程后，客户端无法正常响应Axon Server的心跳请求，超过预设阈值后Axon Server会主动断开事件拉取长连接，最终抛出The Event Stream has been closed以及gRPC CANCELLED: RST_STREAM closed stream错误。 #

调试适配配置方案 #

注意：以下配置仅适用于本地开发调试环境，禁止直接应用到生产环境，避免连接泄漏风险。

1. Spring应用（Axon客户端）配置 #

在项目的application.properties或application.yml中添加以下配置：

• 全局关闭Axon客户端心跳检测、延长超时阈值：

# 关闭心跳保活检测
axon.axonserver.enable-keep-alive=false
# 心跳超时调整为5分钟（单位：毫秒），如需更长调试时间可继续增大
axon.axonserver.keep-alive-timeout=300000
# 全局调整所有追踪事件处理器的事件读取超时
axon.eventhandling.processors.default.event-timeout=300000
# 嵌入式Axon Server专用：禁用事件流读取超时
axon.axonserver.event.read-timeout=0

如果只需针对特定事件处理器调整，将default替换为你的事件处理器名称即可。

2. 独立部署Axon Server配置 #

如果使用独立部署的Axon Server服务，需要修改Axon Server根目录下的axonserver.properties配置：

# 禁用事件流读取超时
axoniq.axonserver.event.read-timeout=0
# gRPC心跳超时调整为5分钟
axoniq.axonserver.grpc.keep-alive-timeout=300000

替代调试技巧 #

如果不想修改配置，可临时将事件处理器切换为订阅模式（SubscribingEventProcessor），该模式下应用不需要和Axon Server维持长连接拉取事件，不会触发流断开错误：

# 替换为你的事件处理器名称，也可设为default全局生效
axon.eventhandling.processors.[你的处理器名].mode=subscribing

内容的提问来源于stack exchange，提问作者L. Schilling