activeMq中消费者对于消息的接受是采用服务器推的方式还是客户端拉的方式。
我自己的理解是实现实现监听采用的是服务器推的方式,主动receive是客户端拉的方式。
但是我发现,消费者不论采用哪个方式,都会在mq的服务器上创建一个只有消费者,没有发送者的消息队列。
我想问一下。此时如果有发送者发送消息到了这个消息队列,消息是怎么传送给消费者的!可qq389283245详聊,北京地区的大牛,可以一起吃个饭,交个朋友,共同学习或者付费学习也可以
我自己的理解是实现实现监听采用的是服务器推的方式,主动receive是客户端拉的方式。
但是我发现,消费者不论采用哪个方式,都会在mq的服务器上创建一个只有消费者,没有发送者的消息队列。
我想问一下。此时如果有发送者发送消息到了这个消息队列,消息是怎么传送给消费者的!可qq389283245详聊,北京地区的大牛,可以一起吃个饭,交个朋友,共同学习或者付费学习也可以
解决方案 »
- java中如何实现含有中文字符的字符串的匹配
- servlet 3.0的注释
- struts2 标签问题
- 我正在找工作
- 请大家帮看看错误的原因
- struts传参数问题
- 谁有Hibernate3的包发给我一个,我这里的网下不了,谢谢了
- 请问在struts中调用action时出现一下错误是怎末办?在线等
- 在struts 的action 中我怎么使用mapping.findforward后new ActionForward()来是我的return的jsp界面在新的一业中显示啊????????急!!!!看
- 请大家畅所欲言:EJB1.1升级到2.0要改些什么东西.如何改?
- 为什么在linux的tomcat的conf目录配置应用程序无效?
- javaweb项目浏览器问题
如果是监听方式,如果注册了回调方法,此时应该会调用你的回调方法
如果是主动接收方式,应该需要自己主动去receive
http://www.oschina.net/p/activemq/
我在产品开发中接触过ActiveMQ,但没有遇过楼主说的问题,我们公司内部对ActiveMQ进行了一层封装,但封装部分只是限于图形界面对ActiveMQ进行配置。我们使用ActiveMQ的步骤是这样的:
1. 启动ActiveMQ服务器上的MQ服务,配置一个transportConnectors,通常默认的tcp://localhost:60101就可以了。
2. 通过ActiveMQ提供的连接工厂,和上述配置的IP,端口号创建一个MQ服务的连接工厂
3. 通过连接工厂创建一个会话Session
4. 通过会话和队列名创建队列。队列名在一个MQ服务器中时唯一存在的,如果已经存在同名队列,该方法直接返回这个队列。我们对于消息的发送和接受,是通过定时任务进行,发送端定时将消息发送到队列,接收端定时到队列中取数据即可。
ActiveMQ本身没有消息路由相关的配置吧,对于IBM的消息中间件,听说过有MB(Message Broker),起消息路由的功能。ActiveMQ没听说过。ActiveMQ配置中有一个Broker的概念,但和消息路由不是一个概念。