Camel中邮件的自动过期

Question

我有一个实现Camel和ActiveMQ的系统，用于某些服务器之间的通信。我想知道是否有一种方法可以在X时间段后自动过期并清除发送到队列的消息。由于始发服务器（填充队列）不知道是否有人正在接收消息，因此我不希望我的队列增长直到其大到崩溃。奖励业力指向可以帮助并提供java dsl方式来实现此功能的人。

解

// expire message after 2 minutes
long ttl = System.currentTimeMillis() + 120000;
// send our info one-way to the group topic
camelTemplate.sendBodyAndHeader("jms:queue:stats", ExchangePattern.InOnly, stats, "JMSExpiration", ttl);

Answer 1

JMS提供了一种机制，可以设置消息的到期日期。请看以下两个参考文献

1. setJMSExpiration(long expiration)：每条消息
2. qazxsw poi：宠物目的地/每条消息

Answer 2

还要注意客户端 - 代理之间的时钟需要同步，以使到期工作正常。如果时钟不同步，则当在代理上接收到消息时，从客户端设置的到期时间可能已经过期。或者客户时间超过经纪人，因此到期时间超过10秒。

它有点打败了我为什么到期是基于客户时间。所以AMQ提供了一个插件，通过重新调整时间来解决这个问题，只能基于经纪人。见ActiveMQ: How do I set the message expiration

Answer 3

在我们这边，我们选择使用ActiveMQ服务本身部署的camel路由将到期时间添加到特定目的地。

唯一要做的就是创建一个XML文件，例如以下名称，例如： https://activemq.apache.org/timestampplugin.html：

setJMSExpiration.xml

并在您的

<beans xmlns="http://www.springframework.org/schema/beans"  
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="
     http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

  <camelContext id="camel-set-expiration" xmlns="http://camel.apache.org/schema/spring">
    <!-- Copy route for each destination to expire -->
    <route id="setJMSExpiration.my.queue.dlq">
      <from uri="broker:queue:MY.QUEUE.DLQ"/>
        <setHeader headerName="JMSExpiration">
          <!-- Message will expire after 1 day -->
          <spel>#{T(java.lang.System).currentTimeMillis() + 86400000}</spel>
        </setHeader>
      <to uri="broker:queue:MY.QUEUE.DLQ"/>
    </route>
    <route id="setJMSExpiration.another.queue">
      <from uri="broker:queue:ANOTHER.QUEUE"/>
        <setHeader headerName="JMSExpiration">
          <!-- Message will expire after 5 days -->
          <spel>#{T(java.lang.System).currentTimeMillis() + 432000000}</spel>
        </setHeader>
      <to uri="broker:queue:ANOTHER.QUEUE"/>
    </route>
  </camelContext>
</beans>

配置中导入它：

activemq.xml

或者，如果您不希望过期的消息到达ActiveMQ.DLQ队列，您也可以提供特定的

<!-- Add default Expiration (file in the same directory) -->
<import resource="setJMSExpiration.xml"/>

。

per destination policies

这种方式的唯一限制是你不能轻易使用通配符，因为它在这里编码（你可以，但它需要通过在camel路由中使用JMS目标头进行一些调整）。

我们试图让生产者定义timeToLive（并尽可能地强制它们），但并不总是强迫他们改变他们的代码，这样可以最大限度地减少这些路径的数量。

Answer 4

那么setJMSExpiration（长期到期）：

当你是客户时，你不能打电话。在ActiveMQ论坛上看到我对此的一些看法。

<policyEntry queue="MY.QUEUE.DLQ">
    <deadLetterStrategy>
        <sharedDeadLetterStrategy processExpired="false" />
    </deadLetterStrategy>
</policyEntry>
<policyEntry queue="ANOTHER.QUEUE">
    <deadLetterStrategy>
        <sharedDeadLetterStrategy processExpired="false" />
    </deadLetterStrategy>
</policyEntry>

Answer 5

端点选项timeToLive（https://apache-qpid-developers.2158895.n2.nabble.com/MRG-Java-JMS-Expiration-td7171854.html）对我来说是一个解决所述问题的解决方案，消息在300000毫秒后从队列中删除。例如“ActiveMQ的：Q.QUEUE disableReplyTo =真传输TimeToLive = 300000”

设置标头JMSExpiration，在我的情况下不会自动从队列中删除消息。但是这个文件http://camel.apache.org/jms.html给了我一个暗示。