8.3. 配置 STOMP acceptor 用于处理大量信息
以下流程演示了如何配置 STOMP acceptor 来处理大于指定大小的 STOMP 消息。
流程
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。代理配置文件中的默认 AMQP 接受器如下所示:
<acceptors> ... <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true</acceptor> ... </acceptors>
<acceptors> ... <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true</acceptor> ... </acceptors>
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 在默认的 STOMP acceptor (或其他您配置的 STOMP acceptor )中,添加
stompMinLargeMessageSize
属性并指定值。例如:<acceptors> ... <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true;stompMinLargeMessageSize=204800</acceptor> ... </acceptors>
<acceptors> ... <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true;stompMinLargeMessageSize=204800</acceptor> ... </acceptors>
Copy to Clipboard Copied! Toggle word wrap Toggle overflow
在上例中,代理被配置为接受端口 61613 上的 STOMP 信息。根据 stompMinLargeMessageSize
的值,如果 acceptor 收到一个大于或等于 204800 字节的 STOMP 消息(即 200 KB),代理会将消息存储为大消息。如果您没有为此属性显式指定值,代理将使用默认值 102400 (即 100 KB)。
注意
为了向 STOMP 消费者发送大消息,代理会在将消息发送到客户端前自动将消息从大型消息转换为正常消息。如果压缩大型消息,代理会在将其发送到 STOMP 客户端前解压缩它。