如何利用MQ实现大文件传输和交换具有可靠，安全

由于JMS Streams的种种不足，限制了其用于传输大文件的功能。因此，ActiveMQ在JMS的基础上创建了一种新的消息类型------BlobMessage。

因为派生与JMS的Message对象，通过BlobMessage传输大文件可以利用ActiveMQ消息Broker的所有特性，如高可靠性、事务支持、发布订阅......

Blob Messages是通过带外传输（out-of-band transport）的机制来实现大文件传输的，在文件传输的过程中，通过http、ftp、scp或其他点对点的协议来进行文件的传输，同时，通过BlobMessage来传送控制信息以及文件的验证信息。其结构图如下：  

由于JMS可以可靠的将控制信息传送到ActiveMQ Broker，同时ftp协议本身就支持断点续传，所以，文件简单的就可以发送到服务端，并且保存在服务端，当文件的消费端监听队列的队列就可以轻松的下载文件了，如果存在多个消费端，则可以通过JMS的发布订阅模式实现。 

通过比较三种方案，第一种通过JMS Streams传输存在断点续传的问题，第二种方式则引入了额外的复杂度------分割文件和合并文件，复杂度相对较高，第三种Blob Messages对于开发者来说就和发送普通消息是一样的，只是服务端它依赖FTP Server来上传下载文件。经过比较可以发现，Blob Messages的方式更具备可用性。 

按照JMS规范，为了保证可靠性，所有的消息都应该是发送到broker，然后交由broker来投递的。也即是说其实JMS是不建议或不支持传输文件的。

对于比较小的文件，简单的处理方式是先读取所有的文件成byte[]，然后使用ByteMessage，把文件数据发送到broker，像正常的message一样处理。对于大文件，例如1GB以上的文件，这么搞直接把client或是broker给oom掉了。

这种方式仅仅适用于小文件的传输。特别是如果broker端使用数据库作为存储，message序列化以后存放于blob字段，文件传输频繁或是稍微有点大，写入效率极低。

直接传输文件

为了解决传输大文件的问题，ActiveMQ在jms规范之外引入了jms streams的概念。PTP模式下，连到同一个destination的两端，可以通过broker中转来传输大文件。

发送端使用connection.createOutputStream打开一个输出流，往流里写文件。

OutputStream out =connection.createOutputStream(destination)

接收端则简单的使用connection.createInputStream拿到一个输入流，从中读取文件数据即可。

InputStream in = connection.createInputStream(destination)