activemq jms程序

activemq发送消息，直接传输文件。为了解决传输大文件的问题，ActiveMQ在规范之外引入了jms streams的概念，activemq是JMS消息通信规范的一个实现，ActiveMQ的DestinationWildcard用于支持名称层次结构，它不是JMS规范的一部分，而是ActiveMQ的扩展。

filter filterserverstringuiduid . random uuid()。tostring()；msg.setStringProperty(uuid，uuid)；StringfilterJMSCorrelationID“ uuid ”；queuereceiverreceiversession . create receiver(response queue，

JMS提供了两种消息模型，peer2peer和publishsubscribe。当采用对等模型时，消息将被发送到一个队列中，该队列中的消息只能被一个消费者消费。当采用发布-订阅模型时，消息可以被多个消费者使用。在发布订阅模式下，生产者和消费者是完全独立的，不需要感知对方的存在。

1.2使用ActiveMQ:为什么，早在2003年，一群开源开发者聚在一起，成立了ApacheGeronimo。后来他们发现没有好的消息代理使用BSDstyle许可协议。Geronimo需要JMS实现来兼容javaEE。于是一些开发商开始讨论可能性。这些拥有丰富MOMs经验，甚至自己创建了一些MOMs的开发者开始创建下一个伟大的开源消息代理。

市面上的MOMs已经被广泛使用，但是一些商业活动却无力负担如此昂贵的软件。这使得创建开源MOMs的需求更大了。显然，有一个市场急需一个使用ApacheLicense的开源MOM。最终导致了ApacheActiveMQ的诞生。ActiveMQ遵循JMS规范，是为分布式应用程序的远程通信而创建的。为了理解这个目的，最好看看一些分布式应用的设计和交互。

引言上一篇文章讨论了应用系统集成的几种方式，发现面向消息队列的集成方案其实是一个相对合理的选择。这里，我们首先讨论特定消息队列Activemq的基本通信模式。activemq是JMS消息通信规范的一个实现。一般来说，消息规范中定义的最常见的消息通信方式主要有发布订阅和点对点通信。此外，通过结合这些模式的具体应用，我们还在处理一些应用场景时，导出了一个请求响应模式。

基本流程在讨论具体方法的时候，我们先来看看使用activemq启动服务的主要流程。根据JMS的规范，我们首先需要得到一个JMSconnectionfactory。通过这个connectionfactory，我们可以创建一个连接。在此基础上，我们可以创建一个会话、一个目的地、一个生产者和一个消费者。

关于ActiveMQ的配置，常用的消息队列构造不外乎MSMQ和ActiveMQ。至于他们的异同，我不想在这里做太多的比较。简单来说，MSMQ内置在微软操作系统中，其部署包含一个隐含条件:服务器需要是微软操作系统。我没有调查MSMQ是否可以部署在非微软系统中，比如Linux。我只是拍着脑袋想了想，觉得不太可能。

从功能上看，最常用的是:消息的接收/发送差别不大。性能方面，一般说ActiveMQ略高。就稳定性而言，个人认为MSMQ更好。对于用过这两种常见队列的同学来说，最大的区别应该是MSMQ如果要访问一个远程队列(比如A机器上的程序B机器上的队列)会很恶心。在数据量较大的情况下，一般来说会有一个或多个专用队列服务器(如果不止一个，使用程序进行热备 负载更方便，不需要额外的硬件成本。

您正在监听错误的端口。tcp侦听端口应该是61616。先测试端口是否被占用！官方faq上没有找到你的情况。你这种情况不罕见吗？既然连不上10.30.174.19，那就ping服务器看看能不能连上；然后查看端口是否被占用！我把这里的官方faq错误发给你，你自己看看吧！。

问题最近在项目中使用了activemq来异步传输消息。只有一个消费者时，系统可以正常运行，但增加多个消费者时，只有一个消费者消费，其他消费者不消费。原因activemq有一种机制叫消息预读。默认情况下，该机制将读取1000条消息，并将它们发送给一个消费者。当累积超过1000条消息时，它将继续读取剩余的消息，并将它们发送给另一个消费者。

作为消息发送根据JMS规范，为了保证可靠性，所有的消息都要发送给broker，然后由broker交付。也就是说，其实JMS并不推荐也不支持文件的传输。对于相对较小的文件，简单的处理方法是将所有文件读入byteWildcard，以支持名称层次结构，这不是JMS规范的一部分，而是ActiveMQ的扩展。ActiveMQ支持以下三种通配符:例如，假设有两个目的地:price.stock.nasdaq.ibm和price。然后通配符配置如下:路径符号替换，"/而不是。"，并添加了以下插件:Compositedestinations，一个组合队列，允许一个虚拟目的地代表多个目的地。

有两种方法可以实现这一点:当创建客户端连接的目的地时，多个目的地由。如下:如果想要不同的目的地，需要加上前缀“队列://”或者“主题://”，下面是一个客户端发送的例子:当客户端向“comQueue”发送消息时，该消息将被发送到两个队列。FOO和“主题，FOO”。