如何设置ActiveMQ Artemis重新交付策略以避免阻塞队列

Question

问题

在我看来不一致的是，如果您连续发布消息，Artemis似乎保留了顺序，而如果消息之间有轻微的延迟，那么队列不会阻塞，只有失败的消息被延迟调度（根据文档）。

我试图找到一个解决方案，这样如果一个消息失败，并需要在10分钟内重新传递，它不会阻止后续的消息。

@SpringBootApplication
public class ArtemisTestApplication
{

    private Logger logger = LoggerFactory.getLogger(ArtemisTestApplication.class);

    @Autowired
    private JmsTemplate jmsTemplate;

    @PostConstruct
    public void init()
    {
        send("Message1");
        send("Message2");
        send("Message3");
        send("Message4");
        send("Message5");
    }

    public void send(String msg)
    {
        logger.debug("Sending message :{}", msg);
        jmsTemplate.convertAndSend("jms.queue.TestQueue", msg);
    }

    public static void main(String[] args)
    {
        SpringApplication.run(ArtemisTestApplication.class, args);
    }

}

@Component
public class TestConsumer
{
    private Logger logger = LoggerFactory.getLogger(TestConsumer.class);

    @JmsListener(destination = "jms.queue.TestQueue")
    public void receive(TextMessage message) throws JMSException
    {
        logger.debug("Message received: {}", message.getText());
        throw new RuntimeException("Force redelivery policy");
    }
}

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-artemis</artifactId>
    </dependency>

spring.artemis.mode=native
spring.artemis.host=localhost
spring.artemis.port=61616
spring.artemis.user=
spring.artemis.password=

<address-settings>      
    <address-setting match="jms.queue.TestQueue">            
        <dead-letter-address>DLQ</dead-letter-address>                      
        <redelivery-delay>0</redelivery-delay>    
        <max-delivery-attempts>3</max-delivery-attempts>
    </address-setting>    
  </address-settings>

<addresses>     
    <address name="DLQ">            
        <anycast>               
          <queue name="DLQ" />            
        </anycast>         
      </address>       
      <address name="jms.queue.TestQueue">            
        <anycast>               
          <queue name="jms.queue.TestQueue" />            
        </anycast>         
      </address>                      
</addresses>

Answer 1

我已经得出结论，这是一个与阿尔特弥斯的bug。我为此提出了一张罚单，并留下了一条评论，其他人也遇到了同样的问题。

https://issues.apache.org/jira/browse/artemis-2417

与此同时，我不得不更改我们的客户端应用程序来处理重新交付策略本身。如果读取消息时出现错误，则在消息上增加一个计数器，并以所需的延迟将其作为新消息写入。然后确认正在使用的消息以解除阻塞队列并允许读取其他消息。我保留了在代理上配置的重新交付策略，以备出现此逻辑之外的错误或未捕获的错误时使用。这并不理想，但至少现在符合要求。