8.4. 大消息和 Java 客户端
有两个选项可供 Java 开发人员使用大型消息编写客户端。
一个选项是使用 InputStream
和 OutputStream
的实例。例如,FileInputStream
可用于发送从物理磁盘上的大文件中获取的消息。然后,接收器可以使用 FileOutputStream
将消息流传输到其本地文件系统中的位置。
另一种选择是直接流传输一个 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 Broker 示例。