8.4. 大消息和 Java 客户端
Java 开发人员可使用两种选项来编写使用大型消息的客户端。
种选择是使用 输入流和
。例如,file 输出流
的实例InputStream
可用于发送从物理磁盘上的大型文件获取的消息。然后,接收方可以使用 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 核心协议 JMS 客户端中使用大型信息,请参阅:
要了解如何在 AMQ OpenWire JMS 客户端中使用大型信息,请参阅:
-
有关使用大信息的示例,请参阅 AMQ Broker 安装的
<install_dir>/examples/features/standard/
目录中的large-message
示例。要了解更多有关运行示例程序的信息,请参阅 运行 AMQ Broker 示例程序。