8.4. 大型消息和 Java 客户端
有两个选项可供编写使用大型消息的客户端的 Java 开发人员使用。
种选择是使用 InputStream
和 OutputStream
的实例。例如,FileInputStream
可用于发送从物理磁盘上的大型文件中获取的消息。然后,接收器可以使用 文件OutputStream
将消息流传输到其本地文件系统中的位置。
另一个选择是直接流传输 JMS BytesMessage
或 StreamMessage
。例如:
BytesMessage rm = (BytesMessage)cons.receive(10000); byte data[] = new byte[1024]; for (int i = 0; i < rm.getBodyLength(); i += 1024) { int numberOfBytes = rm.readBytes(data); // Do whatever you want with the data }
其他资源
要了解在 AMQ Core Protocol JMS 客户端中使用大量信息,请参阅:
要了解在 AMQ OpenWire JMS 客户端中使用大量信息,请参阅:
-
有关使用大型信息的示例,请查看 AMQ Broker 安装的
<install-dir>/examples/features/standard/
目录中的large-message
示例。要了解更多有关运行示例程序的信息,请参阅 运行 AMQ Broker 示例程序。