我该如何解决Axon server Stream Error的问题答案

【问题标题】：How can i solve the problem Axon server Stream Error我该如何解决Axon server Stream Error的问题
【发布时间】：2020-06-08 05:45:35
【问题描述】：

我正在使用 Axon + Spring Boot 实现 CQRS。我的命令处理一个很长的计算，导致一个大的聚合。问题是几分钟后 Axon 服务器似乎取消了命令，并且在 axon 服务器中抛出了所有错误之后，请参阅下面的日志：

来自 AXON 服务器的日志：

io.netty.handler.codec.http2.Http2Exception$StreamException：收到未知流的 DATA 帧 11 在 io.netty.handler.codec.http2.Http2Exception.streamError(Http2Exception.java:129) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder$FrameReadListener.shouldIgnoreHeadersOrDataFrame(DefaultHttp2ConnectionDecoder.java:531) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder$FrameReadListener.onDataRead(DefaultHttp2ConnectionDecoder.java:183) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.Http2InboundFrameLogger$1.onDataRead(Http2InboundFrameLogger.java:48) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.DefaultHttp2FrameReader.readDataFrame(DefaultHttp2FrameReader.java:422) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.DefaultHttp2FrameReader.processPayloadState(DefaultHttp2FrameReader.java:251) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.DefaultHttp2FrameReader.readFrame(DefaultHttp2FrameReader.java:160) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.Http2InboundFrameLogger.readFrame(Http2InboundFrameLogger.java:41) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder.decodeFrame(DefaultHttp2ConnectionDecoder.java:118) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.Http2ConnectionHandler$FrameDecoder.decode(Http2ConnectionHandler.java:390) ~[netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.http2.Http2ConnectionHandler.decode(Http2ConnectionHandler.java:450) [netty-codec-http2-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502) [netty-codec-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441) [netty-codec-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278) [netty-codec-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1408) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:682) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:617) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:534) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:496) [netty-transport-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:906) [netty-common-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [netty-common-4.1.35.Final.jar!/:4.1.35.Final] 在 io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [netty-common-4.1.35.Final.jar!/:4.1.35.Final] 在 java.lang.Thread.run(Unknown Source) [na:1.8.0_181]

这就是我的全部，我不知道为什么...我正在使用最新版本的 axon 和 axon server (4.2.1)

【问题讨论】：

我只是意识到可能的问题是由较大的消息大小引起的。如果可能的话，我怎样才能增加它？
2020-02-26 10:25:00.935 WARN 15124 --- [MessageBroker-2] iaamessage.command.CommandCache：取消命令 pt.some.admtools.inhousecatalog.command.CheckoutAndParseCommand 发送16912@POR-5CG8271235，等待16912@POR-5CG8271235.default的回复

标签： spring-boot netty cqrs axon

【解决方案1】：

Axon 服务器的命令超时默认设置为 5 分钟（300_000 毫秒）。您可以通过设置属性 axoniq.axonserver.default-command-timeout 来增加此超时。该属性的值是以毫秒为单位的超时。默认情况下，最大消息大小为 4Mb。您可以通过在 axonserver.properties 中设置属性 axoniq.axonserver.max-message-size 来增加它。

希望这能解决您的问题。

马克

【讨论】：

即使增加消息大小，它似乎也有同样的问题。来自 axon 服务器的日志以：2020-02-26 10:25:00.935 WARN 15124 --- [MessageBroker-2] iaamessage.command.CommandCache ：取消命令 pt.some.admtools.inhousecatalog.command.CheckoutAndParseCommand 发送的开头16912@POR-5CG8271235，等待16912@POR-5CG8271235.default的回复

【解决方案2】：

AxonServer 在 5 分钟后取消命令时发送消息“正在取消命令 pt.some.admtools.inhousecatalog.command.CheckoutAndParseCommand 由 16912@POR-5CG8271235 发送，等待来自 16912@POR-5CG8271235.default 的回复”（ axoniq.axonserver.default-command-timeout）。你能检查一下你的命令处理程序中发生了什么，以及处理需要多长时间？

【讨论】：