在ActiveMQ中延迟消息
在ActiveMQ中，延迟消息是指消息发送后不立即被消费者接收，而是在一定的延迟时间后才能被消费。延迟消息在某些场景下非常有用，比如需要在特定时间触发某些操作或者需要按照一定的时间间隔处理消息。
延迟消息的实现方式通常是通过设置消息的延迟属性来实现。在ActiveMQ中，可以通过设置消息的"AMQ_SCHEDULED_DELAY"属性来指定延迟的时间，单位是毫秒。当消息被发送到ActiveMQ后，它会被放置在延迟队列中，直到延迟时间到达后才会被移动到正常的消息队列中，供消费者进行消费。
延迟消息在很多实际应用中都有广泛的应用场景。例如，在电商系统中，可以使用延迟消息来实现订单超时未支付的自动取消功能；在社交应用中，可以使用延迟消息来实现定时发送消息的功能；在任务调度系统中，可以使用延迟消息来实现定时执行任务的功能等等。
腾讯云提供了一款消息队列产品，即腾讯云消息队列 CMQ。CMQ支持延迟消息功能，可以通过设置消息的延迟属性来实现延迟消息的发送。CMQ还提供了丰富的消息队列特性，如高可靠性、高并发、消息顺序保证等，适用于各种场景下的消息通信需求。
腾讯云消息队列 CMQ产品介绍链接地址：https://cloud.tencent.com/product/cmq
相关·内容
我有一个要求，当客户端应用程序在5秒的时间跨度内发送超过1000个请求时，我需要通过整形(排队)入站流量来限制。
我遵循的解决方案是:我有一个camel:throttle，将最大请求数设置为1000，timespan设置为5秒。当超过阈值时，我将捕获节流异常，并且在onException块中，我将节流消息发送到ActiveMQ请求队列，以便稍后进一步处理，因为根据1000请求/5秒配置，Camel过载。
我成功地实现了上述，但我希望骆驼消费者以后进一步处理不是所有来自ActiveMQ请求队列的消息，而是以10秒的延迟处理每个消息，例如
我不能在ActiveMQ中设置一个参数来延迟发送给消费者的
浏览 8提问于2016-03-07得票数 2
我已经将配置为使用来自队列的消息的ActiveMQ使用者。让我们称之为"Test.Queue“--我在4台不同的机器上部署了这段代码，所有机器都被配置到同一个ActiveMQ实例中，以处理来自同一个"Test.Queue”队列的消息。
当所有4台机器启动并运行时，我将最大使用者大小设置为20，我看到队列中的消费者数为80 (4 * max使用者大小= 80)。
当生成并发送到队列的消息越来越高时，一切都很好。
当有1000条消息时，在80个使用者中，假设其中一个被卡住了，就会冻结Active MQ以停止向其他使用者发送消息。
所有的消息都永远卡在ActiveMQ中。
由于我有4
浏览 4提问于2012-08-21得票数 6
回答已采纳
我正在开发一个应用程序，它要求我跟踪ActiveMQ主题的消息何时过期，以及由于客户端/消费者/订阅者未能及时确认消息而导致消息何时过期。
我知道，要找出某个主题的消息何时过期，我可以只听ActiveMQ咨询ActiveMQ.Advisory.Expired.Topic。但是，我还需要跟踪哪些消费者/客户端正在过期最多的消息，这意味着每当消息过期时，我都需要它们的消费者/客户端I等。有没有我可以使用的建议或方法来实现这一点？
我是新接触ActiveMQ的，所以我对JMS消息传递的工作原理的了解是有限的。我的理解是，生产者设置消息过期时间，如果消费者在特定时间段内没有消费消息，则消息过期并发送到
浏览 23提问于2018-09-10得票数 2
回答已采纳
我目前使用的是Artemis ActiveMQ 2.2.0，通过队列，我可以毫无问题地发送和接收消息。但是，我想知道如果队列中有多个消息，接收方如何才能检索最后一条消息？有没有我应该使用的特殊队列？谢谢,
浏览 4提问于2017-08-02得票数 0
2回答
如果有一个在ActiveMQ中创建的队列，它有一个生产者(这是客户端确认模式)和一个侦听器，在它的onMessage方法中，只有在成功处理消息之后，它才会被确认。假设存在异常，消息保持未确认状态，因此保留在队列中。是否会再次发送给消费者？或者这样的消息会发生什么？
浏览 1提问于2020-02-18得票数 1
我正在尝试使用apache从activemq队列中读取消息"AMQ:ORIGIN“。读取消息后，需要将其传递给两个不同的"AMQ队列“。但条件是。
消息应该立即传递到队列"AMQ:A“。
消息应在延迟一分钟后传递到排队"AMQ:B“。
为了达到上述目的，我创建了两条路线。在第一条路由中，我从AMQ队列中读取数据，并对"AMQ:A“和"seda:delay”队列执行多播操作。在第二条路线上，我正在读"seda:delay“队列，延迟一分钟，然后传递到"AMQ:B”队列。
如果将1条或10条信息传递给"AMQ:
浏览 1提问于2020-06-02得票数 0
2回答
在我的场景中，我有一个boroker，一个生产者，一个消费者。我使用activemq来编写我的应用程序。logs to db.As你知道将日志写入db是一个耗时的过程，这就是为什么消费者比producer.For ex更慢的原因。I send 100.000 message (大型对象).Producer在20 mins.But内完成发送消息当生产者完成时，消费者已经完成了4.000消息的处理。
我的问题是；有没有办法说procuder“如果代理中有x条消息等待消费，并尝试在一段时间后发送”？
怎样才能解决这个问题。
浏览 0提问于2013-09-18得票数 0
我有这样一个场景，我不知道兔子是否能支持:我有一个制作人，定期产生信息。有三个消费者。因为我想模仿RPC，所以每一轮我的生产者都会用相应的路由密钥向DirectExchange发送三条消息，而不是使用扇出Exchange。使用者将收到消息并回复临时回复队列。所以问题是，我的消费者并不总是在线的(我在执行RAFT协商一致算法)。但是当它在线时，之前由生产者发送的“陈旧”消息刚刚通过，而我的在线用户开始处理太多已经无效的RPC消息，这破坏了我的应用程序逻辑。我是否可以向DirectExchange发送消息，如果没有队列侦听路由密钥，消息就会被丢弃吗？我正在考虑在发送之前做一个时间戳，当收到时检查时
浏览 3提问于2016-06-02得票数 0
回答已采纳
我正在尝试实现以下场景，我可以真正地使用和欣赏一些帮助。我使用ActiveMQ 5.14和camel 2.21。
在队列中，每条消息对应于一台机器。这些机器通过一个轮询使用者连接到队列，并且对使用者来说是无法区分的。应该将消息保存在队列中，直到一台计算机确认它已通过单独的请求到达正确的计算机为止。每次获取消息后，所述消息应锁定一段时间。
我找不到任何ActiveMQ功能来解释我的问题。我的方法是在每个fetch之后将消息发送到第二个队列，该队列充当锁机制，并在指定的超时后将其发送回可取队列。
如果机器没有确认消息，那么一个更好的方法可能是在每次获取之后回滚会话。
你对这个问题的可行解决方案有什
浏览 1提问于2018-05-18得票数 0
回答已采纳
例如，我们有一个持久的主题消费者和一些该主题的代理。据我所知，代理将继续存储每条消息(在某些限制内)，即使持久消费者在很长一段时间内不是活动的。
在ActiveMQ中是否有一些代理策略来销毁(自动取消订阅)非活动(在一段指定时间内)持久消费者？这样我就不需要监控所有的消费者是否仍然有效并且确实存在。
浏览 1提问于2011-03-11得票数 3
回答已采纳
我有一个单节点ActiveMQ实例，其中有两个相互竞争的使用者连接到一个主题。主题订阅按照JMS 2.0规范进行共享。共享订阅不保证只有一个订阅者(使用相同的订阅名称)获得消息。但我注意到的是，它不能保证只有在第一条消息被确认的情况下才会传递第二条消息。在第一消费者花费时间确认消息的情况下，甚至在消费者将第一消息的确认发送到代理之前，第二消息就被传递给自由消费者。这是一种标准行为吗？有没有办法在确认第一条消息之前阻止代理传递第二条消息？
浏览 54提问于2021-03-11得票数 0
1回答
我对JAX-WS有一点小问题。我使用ActiveMQ作为妈妈和Spring。消息传递非常简单:一个jar应该向另一个jar发送包含一些数据的soap消息。
我在sender_beans.xml中是这样定义客户端的：
<bean id="jmsConfig-Manager" class="org.apache.cxf.transport.jms.JMSConfiguration"
p:connectionFactory-ref="jmsConnectionFactory"
p:targetDestination="ac
浏览 0提问于2012-11-29得票数 2
回答已采纳
如果我们在ActiveMQ中没有更多的消息，我们有什么方法可以阻止骆驼路线吗？我所需要的场景。
从ActiveMQ队列中获取所有消息并处理它们。
轮询2-3次以检查我们是否有其他新消息，是的执行步骤1。
如果目前没有消息，停止路由并在5分钟后重新启动它(我猜这可以通过轮询策略实现)。
浏览 7提问于2019-12-17得票数 0
2回答
我们目前正在开发一个使用JMS和activemq (5.5.1)的应用程序。我们希望为一些消息定义更高的优先级，这将使它们首先被消费。在设置生产者和消费者之后(通过spring (3.1) JMSTemplate)，优先级不能完全工作。事实上，当我们“关闭”消费者，并发送一些消息时，优先级是受尊重的，但当我们在消费者打开时添加消息时，消息的接收顺序与发送消息的顺序相同。
配置非常简单：
在activemq配置文件中激活了优先级：
<policyEntries>
<policyEntry queue=">" prioritizedMessages=&#
浏览 2提问于2012-01-13得票数 6
回答已采纳
2回答
分布式计时器服务
、、
我正在寻找一个分布式计时器服务。多个远程客户端服务应该能够在指定的时间间隔后注册回调(通过REST )。间隔的长度可以是1分钟。我可以忍受大约1分钟的误差。目前，这类回调的数量可以增加到10万，但我需要以后再扩大规模。我一直在研究像Quartz这样的调度程序，但我不确定它们是否适合这个问题。使用Quartz，我可能必须将回调请求保存在DB中，并每分钟轮询100,000行上的过期请求。我不确定这是否会扩大规模。有什么现成的解决方案吗？否则，我该怎么做呢？
浏览 1提问于2017-01-21得票数 7
2回答
我有一个消息队列，一个生产者和一个消费者，用于异步请求，并应用一些超时策略保证交付。这些消息的排序没有意义。每条消息都是相互隔离的，都有自己的业务场景。所以我不需要在消息队列中进行任何排序。但问题是队列被无法传递的第一个消息阻塞。其他消息是正确的，并准备以正确的方式进行处理，但它们必须等待“坏”消息的传递。
Java和JMS，在队列客户端使用Spring。
有没有可能让ActiveMQ在没有任何排序的情况下排队，但每条消息都有单独的重新传递超时？
浏览 0提问于2016-03-25得票数 1
我们使用activemq作为Java独立应用程序的消息队列。我的问题是，基于activemq web控制台，队列有一定数量的消息入队和出队。然而，根据我在代码中添加的sysout语句，应用程序消耗的消息似乎少于activemq web控制台上显示的消息数量。例如，在activemq控制台上，no。入队和出队的消息数约为1800。但是，在控制台上显示的出队消息数(我每收到一条消息就递增一个计数器)只有1700条左右。
我真的不知道大概在哪里。发送了100条消息。所以我在想，如果我知道如何让activemq记录由生产者入队和由消费者出列的消息，我可能会有一些想法。这个是可能的吗？若有，如何处理？
浏览 0提问于2013-11-06得票数 1
我正在尝试确定集群我的ServiceMix 3.3.1/Camel2.1/AMQ5.3应用程序的选项。我正在执行大容量的消息处理，我需要集群来实现高可用性和水平可伸缩性。
下面是我的应用程序的基本功能...HTTP->QUEUE->PROCESS->DATABASE->TOPIC
from("jetty:") .to("activemq:inboundQueue")；
from("activemq:inboundQueue?maxConcurrentConsumers=50") .process(decode()) .pr
浏览 3提问于2010-02-09得票数 11
回答已采纳
我在阅读ActiveMQ，它似乎是一个很好的服务总线实现，生产者可以发布消息，其他进程可以接收消息。
然而，在阅读文档时，看起来生产者在发送消息时必须给出“端点”。
我宁愿用另一种方式:我的生产者发布事件“导入作业开始”、“导入作业完成”等，任何对某些类事件感兴趣的消费者都可以订阅和接收这些事件。但是，使用者不应该使用该事件，因为它不再被发送到其他订阅者。
拥有这种属性的最好的产品是什么？
约束：-它应该至少有.Net和php的接口-它应该跨机器边界工作。
谢谢
浏览 5提问于2009-11-13得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
