activemq 监听器多久执行一次,求知道

activemq有2部分,一部分是将消息放入队列,这个是主动的,程序去做
还有一部分是mq去消息队列里面查看消息,然后处理,这个是多久执行一次?

0

3个回答

消费并不是定时的,而是基于消息驱动的。
就像js的事件驱动一样,你点击一个按钮,这个点击的操作就能触发一个事件,而activemq是消息驱动的,你可以理解为有消息入队了,在线消费者就能在第一时间知道。

-1

在上面代码中我们定义了一个SessionAwareMessageListener,在这个Listener中我们在接收到了一个消息之后,利用对应的Session创建了一个到destination的生产者和对应的消息,然后利用创建好的生产者发送对应的消息。
接着我们在Spring的配置文件中配置该消息监听器将处理来自一个叫sessionAwareQueue的目的地的消息,并且往该MessageListener中通过set方法注入其属性destination的值为queueDestination。这样当我们的SessionAwareMessageListener接收到消息之后就会往queueDestination发送一个消息。

0

这个可以在手册中查到,ActiveMQ许多值市可以设定的,参考下表:
ActiveMQ Messages支持以下默认消息属性

-1
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
ActiveMQ与spring集成实例之使用消息监听器
        在EJB世界里,JMS消息最常用的功能之一是用于实现消息驱动Bean(MDB)。Spring提供了一个方法来创建消息驱动的POJO(MDP),并且不会把用户绑定在某个EJB容器上。         通常用消息监听器容器从JMS消息队列接收消息并驱动被注射进来的MDP。消息监听器容器负责消息接收的多线程处理并分发到各MDP中。一个消息侦听容器是MDP和消息提供者之间的一个中介,...
activemq消息队列-使用监听器来接收消息(常用)
//点对点-使用监听器接收消息 public class ConsumerListener { // tcp 地址 服务器器端地址 //public static final String BROKER_URL =ActiveMQConnection.DEFAULT_BROKER_URL; // 其值为 "tcp://localhost:61616"; public...
activeMq多个监听配置
activeMq多个监听配置: 集群或者zookeeper分布式集群分发处理只能到一个节点,即active的多个订阅端不会因此产生,除非一个系统配置了对个监听,监听一个发送通道(toptip) 在只有一个监听配置的时候,toptip就相当于queuen 配置多个监听客户端和配置一个一样只是clientId不同即可,当用的是下面的topic时有几个监听端就有会调用几次接收方法,(发送永远只...
ActiveMQ 点对点-使用监听器接收消息
public class ConsumerListener {//默认连接用户名 private static final String USERNAME = ActiveMQConnection.DEFAULT_USER; //默认连接密码 private static final String PASSWORD = ActiveMQConnection.DEFAULT_...
Java ActiveMQ简介以及springboot集成activeMQ实现消息队列监听以及实现MQ延迟
上篇文章我们提到了如何在Linux下安装activeMQ,环境已经准备好了。我们来学习如何将mq与java进行结合来实现功能。 1.简介1.1 什么是ActiveMQ ActiveMQ 是 Apache 出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个 完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现,尽管 JMS 规范出台已经是很久的事 情了
ActiveMQ 监听器
监听器,由消息的消费者注册监听,去监听消息队列(queue)中的消息,监听到有消息未处理,即自动调用onMessage方法处理消息,监听器可以注册多个,ActiveMQ自动循环调用注册的监听器,处理队列中的消息。 在消息的消费者方,使用setMessageListener方法注册监听,传入匿名参数new MessageListener(),复写onMessage(...
ActiveMQ中消费者是如何接收消息的(一)
       事先说明,本博客关于ActiveMQ的文章都是基于ActiveMQ5.10版本。        初步用过ActiveMQ但又没去研究过源码的朋友肯定有些好奇ActiveMQ中消费者是如何接收消息的呢?本文我就和大家一起从源码角度来初步探讨消费者接收消息的过程。        我们知道,消息传送有两种模型:点对点(P2P)和发布订阅(PUB/SUB),队列模式中,消息生产者叫做发送...
ActiveMQ中的消息重发时间间隔和重发次数吗?
首先,我们得大概了解下,在哪些情况下,ActiveMQ服务器会将消息重发给消费者,这里为简单起见,假定采用的消息发送模式为队列(即消息发送者和消息接收者)。       1.如果消息接收者在处理完一条消息的处理过程后没有对MOM进行应答,则该消息将由MOM重发.       2.如果我们队某个队列设置了预读参数(consumer.prefetchSize),如果消息接收者在处理第一条消
activemq与spring整合,配置消费者监听器设置sessionAcknowledgeMode问题
最近在研究activemq的ack消息确认机制,在activemq与spring整合时遇到的了一个问题。JMS规范的ack消息确认机制有一下四种,定于在session对象中:AUTO_ACKNOWLEDGE = 1 :自动确认CLIENT_ACKNOWLEDGE = 2:客户端手动确认 DUPS_OK_ACKNOWLEDGE = 3: 自...
2.5、 使用监听器容器自动获取 ActiveMQ中的消息
文章目录前言往期回顾化繁为简的表述监听器容器代码自定义监听器Bean 集合:各位看注释xml 配置文件测试类 前言 体能状态先于精神状态,习惯先于决心,聚焦先于喜好。 往期回顾 ActiveMQ 的系列文章已经搁置很久没有继续了,https://blog.csdn.net/bestcxx/column/info/23061 之前已经测试了queue类型和topic类型的消息的发送和接收,但是...
在spring使用activeMQ订阅多个topic并实现监听器监听
最近有个需求,在spring上集成activeMQ且订阅多个topic,并且需要实现监听器监听多个topic。一、maven依赖配置pom.xml<!-- activemq --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>4
消息队列监听器无法注入bean的问题解决
在使用ActiveMq或者其他消息队列的过程中,第一步对ActiveMq进行初始化的过程是放在ContextListener的初始化的时候的; 然而当mq接收到消息的时候触发getMqMsg方法的时候报错null,调试发现MqManageService根本没有获取到,我的想法是获取的方式不对,@Autowired这种方式获取bean不成功,但是bean肯定是已经存在于spring容器中的,如
ActiveMq实践之排他性消费者
[code=&quot;java&quot;]activemq支持的功能:排他性消费者 背景: 这个功能主要是为了解决jms集群的问题而提出的 当你使用product 产生一个消息并且放置到一个queue中的时候 如果说你使用了集群,并且每一个集群里面消费的队列都是刚才的那个队列 那么这个时候就会出现并发的时候 这么多集群 同时都消费了这个队列里面产生的消息,出现了重复的消费 一般的情况下碰到这个请求时...
使用监听器实现在事务提交后发送消息
用rocketmq构造事件中心 之前说了用消息队列实现了事件中心(不知道算不算),现在虽然换成rabbitmq了但是原理是一样的,这时候就出现了一个问题,就是消息消费的时候,之前的事务还没提交就会有错误。比如编辑机器名称,发送机器编辑事件,在消费消息时把用到机器名称的地方修改机器名称(我们称为冗余字段,这样就减少了关联查询)。但是机器编辑的事务还没有提交。 @Resource Machine...
spring集成activemq--监听多个消息队列
目前采用一个配置文件里,配置多个消息队列,如果有更好的方式,请指教 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schem
ActiveMQ-监听和确认
生产 public class Producer { public static void main(String[] args) throws JMSException { ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "admin", "tcp://localho...
如何知道mcu执行某一段程序用了多长时间?
作者:李大闯 2017/09/09 17:54 在编写单片机程序的过程中,我们经常遇到想要知道某段程序执行花费了系统的多长时间,而且想知道的尽可能精确,本文给出一种方法: 上电之后初始化一个gpio引脚,比如为低电平。 在目标程序段开始之前将这个引脚拉高,在拉行完成后,将引脚拉低,那么引脚高电平持续的这段时间就是程序执行所要花费的时间。那么如休知道引脚的高电平持续了多长时间呢?可
ActiveMQ之发布/订阅实现(监听模式MessageListener)
一.模式图 二.相关概念 1,主题(Topic) 2,发布者(Publisher) 3,订阅者(Subscriber) 客户端将消息发送到主题。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。 三.特点 1,每个消息可以有多个消费者 2,发布者和订阅者之间有时间上的依赖性。针对某个主题(Topic)的订阅者,它必须创建一个订阅者之后,
JVM 菜鸟进阶高手之路六(JVM每隔一小时执行一次Full GC)
上次分析详细地址在:http://blog.csdn.net/lirenzuo/article/details/76257526 以为结束了上次那个知识才想rmi问题,其实本次问题不是该问题但是也会有sys.gc fullgc问题。 查看GC统计汇总情况: jstat -gcutil pid  3s 30 参考gc,发现大概一小时运行一次FGC,特别奇怪,笨神一看这样的问题
JMS 监听器容器
   消息监听器容器是一个用于查看JMS目标等待消息到达的特殊bean,一旦消息到达它就可以获取消息,并通过onMessage()方法将消息传递给一个MessageListener实现。Spring中消息监听器容器的类型如下: 1. SimpleMessageListenerContainer:最简单的消息监听器容器,只能处理固定数量的JMS会话,且不支持事务。 2. DefaultMessa...
JVM每小时执行一次FULL GC问题
最近分析系统中部分机器内存使用率偏高报警问题,发现这部分机器堆内存使用率持续增长,当堆内存接近上限的时候才会触发一次FULL GC;其余机器内存使用率整体波动比较稳定,且FULL GC频率大致是1个小时。
active mq 多个消费者实战(发布订阅模式)
注意:所有的配置文件都在src文件下            声明:  在这里不讲activemq 是什么,本人只是根据平时用到的东西整理一下希望对大家有所帮助。         首先是生产者的配置文件 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springfra
ActiveMQ中消费者是如何接收消息的(二)
       上篇文章大致讲述了同步消费者和异步消费者接收消息的异同(详见《ActiveMQ中消费者是如何接收消息的(一)》http://manzhizhen.iteye.com/blog/2094130 ),但我们还未讲到消息是在什么时候放入消费者ActiveMQMessageConsumer类的“消息容器”unconsumedMessages中的,这很关键,因为为了解耦,消费者类不需要知道...
.net 封装的ActiveMq消息列队
可直接调用即可,适用方法参考https://blog.csdn.net/zhaobao110/article/details/80354350
spring与activemq(三种消息监听方式)
   1.3     消息监听器MessageListener        在Spring整合JMS的应用中我们在定义消息监听器的时候一共可以定义三种类型的消息监听器,分别是MessageListener、SessionAwareMessageListener和MessageListenerAdapter。下面就分别来介绍一下这几种类型的区别。 1.3.1  MessageList...
Spring+ActiveMQ,实现负载均衡以及实现JMS监听
实验要求:  1、 1个apache作为负载均衡器、3个以上的tomcat作为web应用服务器  2、 分别采用session sticky和session replication进行配置实验  3、 要求能实现3个及以上tomcat应用服务器节点的负载均衡,并支持节点热拔插  4、模拟用户注册时候发送通知邮件的应用场景,用ActiveMQ的Topic方式实现异步的邮件发送和接收消息。 突然爱上写...
FULL GC耗时问题
记录一次full gc 耗时很长的情况:           后续看了一下,netty管理了400多个socket,估计是这个原因。
java web使用监听器实现定时周期性执行任务的功能
java web使用监听器实现定时周期性执行任务的功能,定时邮件发送、文件删除等自定义功能可自行添加
activeMQ集成SpringMVC,三种方式监听
activeMQ集成SpringMVC,三种方式监听
客户端监控连接ActiveMQ状态
1、spring配置文件中配置exceptionListener &amp;lt;bean id=&quot;exceptionListener&quot; class=&quot;test.TempExceptionListener&quot;&amp;gt; &amp;lt;/bean&amp;gt; &amp;lt;bean id=&quot;listenerContainer&quot; class=&quot;org.springframework.jms.listener.Defau.
ActiveMQ学习总结(10)——ActiveMQ采用Spring注解方式发送和监听
对于ActiveMQ消息的发送,原声的api操作繁琐,而且如果不进行二次封装,打开关闭会话以及各种创建操作也是够够的了。那么,Spring提供了一个很方便的去收发消息的框架,spring jms。整合Spring后,代码不仅变得非常优雅,而且易用性和扩展性更好。 1. maven依赖 &lt;!-- activemq --&gt; &lt;dependency&gt; &lt;groupI...
Active MQ 整合Spring(不开监听,手动接收)
接收的配置文件 :   1.导入配置文件,上面, &amp;lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?&amp;gt; &amp;lt;beans xmlns=&quot;http://www.springframework.org/schema/beans&quot; xmlns:xsi=&quot;http://www.w3.org/2001/XMLSchema-instance&quot; xmlns:aop=...
activemq 消息消费失败之后如何重新消费
在不开启事物的情况下 采用的是应答模式4(ActiveMQSession.AUTO_ACKNOWLEDGE)消费一次 应答一次 这时候消费失败了,由于没有配置死亡队列,消息就不会被消费堆积在队列中,那么怎么才可以让消息再被消费呢? 由于项目中的应用场景,有个方案启动和停止的功能,项目启动启动监听,项目停止,停止监听 具体实现代码如下 public class MqService { p
SpringBoot+ActiveMQ多消息队列监听
其实springboot多消息队列监听和spring基本一样,只是配置上稍有区别' 1.在有@Configuration注解的java类中加如下配置 @Bean public DefaultMessageListenerContainer listenerContainer(){ DefaultMessageListenerContainer m =new DefaultMessageL
ActiveMQ三种监听
1.MessageListener    它是JMS规范中定义的一个接口,一个用于处理接收到的消息的方法onMessage,该    方法只接收一个Message参数2.SessionAwareMessageListener    spring提供给我们用的,它只是用来接收消息然后通知对方已经收到消息,它为我们提    供处理消息的onMessage方法,这个方法接收两个参数;一个是当前接收到的消...
从ActiveMQ原理到实例
在介绍activemq之前,先简单介绍JMS,它是J2EE的13个规范之一,提供的是消息中间件的规范。JMS包括以下基本构件: 连接工厂,是客户用来创建连接的对象,ActiveMQ提供的是ActiveMQConnectionFactory; 连接connection 会话session,是发送和接收消息的上下文,用于创建消息生产者,消息消费者,相比rocketMQ会话session是提供事务
activemq中的订阅模式以及消息时长和确认机制
直接上代码 发布主题 package com.activemq; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicPub { public static void main(String[] args) throws JMSException {
以SpringMVC框架为中心疯狂扩展-06、MessageListener实时监听ActiveMQ中的消息
1、在spring-activemq.xml中新加入listenerContainer和syxTopicDest等配置,实现消息监听容器,在connectionFactory中加入clientId。 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XM
java监听器+quartz实现每天动态时间执行任务的功能
最近工作遇到一个需求:每天都要在某个时间执行一个任务 这个时间是 动态的 从数据库取的 比如今天是要在22点45分15秒执行一个任务 明天的这个时间是  23点45分11秒 以此类推 每天都会有一个动态的时间任务 网上找了很多资料 看了很多博客 ,此时深深感到国内it技术界的丑恶,好多博客都写的残全不全,浪费了我一天多的时间一直网上看资料 下demo跑起来都不是我想要的,经过思考终于解决这个
HttpSession监听器的执行顺序
Servlet标准中指定了4个用于监听HttpSession中的各种事件的监听器接口,它们分别是: HttpSessionListener HttpSessionAttributeListener HttpSessionBindingListener HttpSessionActivationListener 下面对这几个接口里面的方法用户进行简要的描述1. HttpSessionListener