如果您正在使用ActiveMQ Artemis,可能会遇到无法传递大消息的问题。这很可能是由于默认配置中MaxMessageSize设置较小而导致的。以下是如何解决此问题的示例代码:
vm://0
tcp://localhost:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576
tcp://localhost:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576
byte[] messagePayload = new byte[1024 * 1024]; // 1MB payload
BytesMessage message = session.createBytesMessage();
message.writeBytes(messagePayload);
producer.send(message);
在此示例中,发送的消息大小为1MB,因此必须将MaxMessageSize设置为大于或等于1MB:
vm://0
tcp://localhost:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;maxFrameSize=1048576
tcp://localhost:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;maxFrameSize=1048576
通过这些步骤,ActiveMQ Artemis应该可以成功传递大消息了。