20.4. 处理大型消息
20.4.1. 处理大型消息
即使客户端或服务器的内存有限,HornetQ 也支持大型消息。大型消息可以流化(streamed)或进行压缩以更高效地传输。用户可以设置消息主体里的
InputStream
以发送发想消息。当消息被发送时,HornetQ 读取这个 InputStream
并以片段形式将数据传输到服务器。
客户或服务器从不会将大型消息的主体全部存储在内存里。消费首先会接收到具有空主体的大型消息,然后设置消息上的
OutputStream
来将数据流分割成片段并存储在磁盘文件里。