ActiveMQ

Question

我有一台服务器，在这台服务器上，我有一个将消息发送到单个队列的发布服务器。从这个队列中，我有5个消费者，每个消费者都有自己的JVM。其理念是，无论哪位消费者是免费的，出版商的信息都应该尽快被他们使用。有时所有5个都是空闲的，然后ActiveMQ可能会选择一个来接收/退出消息（？）。

所有消息都是非持久的。我使用ActiveMQ几乎开箱即用，只有一个队列和零修补任何配置文件。我也没有使用交易。

发布者在返回时间后立即以毫秒为单位记录时间：

public void sendMessage(String text) {
    TextMessage message = null;
    try {
        message = session.createTextMessage(text);
        producer.send(message);
        System.out.println("JUST FINISHED SENDING MESSAGE " + System.currentTimeMillis());
    } catch (JMSException e) {
        e.printStackTrace();
    }
}

每个消费者（运行自己的JVM）都在监听队列，每次监听时间为2分钟：

        Message message = consumer.receive(120000);
        if (message instanceof TextMessage) {
            TextMessage textMessage = (TextMessage) message;
            text = textMessage.getText();
            System.out.println("MESSAGE RECEIVED " + System.currentTimeMillis());
        }

通常情况下，消费者会在与“刚刚发送完的消息”完全相同的时间（以毫秒为单位）记录“收到的消息”，这很完美。但有时，发布和消费之间会有15毫秒左右的莫名其妙的延迟，即使所有消费者都闲着。考虑到所有进程都在同一台服务器上，而且延迟是绝对关键的，我对有时会出现这种延迟感到沮丧。

1. 当从一个队列中运行多个使用者时，这是预期的结果，还是与此无关
2. 我能做些什么来减轻延误吗

提前感谢您提供的有用建议。

Answer 1

在与网络消费者和中央代理打交道时，出现这种短暂延迟的原因有很多。代理或消费者的CPU调度以及管理网络接口的工作可能会导致小问题。当消费者或代理上的JVM清理时，您可能还会看到GC暂停，这可能会延迟分派或消费。当然，线程间信号有时可能会有短暂的延迟，这取决于并行运行的各种事情，所以这些短暂的暂停确实是我要投入大量时间的事情，除非你到了最后一个问题，你需要解决的所有其他可能的事情，你还没有处理。