Question

如何访问ActiveMQ接收消息

Answer 1

作消息发送
按照JMS规范保证靠性所消息都应该发送broker交由broker投递即说其实JMS建议或支持传输文件
于比较文件简单处理式先读取所文件byte[]使用ByteMessage文件数据发送broker像message处理于文件例1GB文件搞直接client或broker给oom掉
种式仅仅适用于文件传输特别broker端使用数据库作存储message序列化存放于blob字段文件传输频繁或稍微点写入效率极低
直接传输文件
解决传输文件问题ActiveMQjms规范外引入jms streams概念PTP模式连同destination两端通broker转传输文件
发送端使用connection.createOutputStream打输流往流写文件
OutputStream out =connection.createOutputStream(destination);
接收端则简单使用connection.createInputStream拿输入流读取文件数据即
InputStream in = connection.createInputStream(destination)