HornetQ 性能分析

Question

我正在使用 hornetq-core-client api 2.4.0.Final，使用此代码添加消息：

            ClientMessage clientMessage = _producerClientSession.createMessage(true);
            clientMessage.putStringProperty(MESSAGE_KEY, message);
            _clientProducer.send(clientMessage);

我正在重用文档中提到的 ClientSession 和 ClientProducer。在分析期间，我们看到这平均需要 400 多毫秒。这看起来对吗？似乎很慢。我们还安装了 AIO 并在 ubuntu 上运行。

编辑： 这是“iostat -d -x 1”的输出，而排队平均需要 600 毫秒

Device:         rrqm/s   wrqm/s     r/s     w/s    rkB/s    wkB/s avgrq-sz avgqu-sz   await r_await w_await  svctm  %util
sda               0.00     0.00    0.00  596.00     0.00  2568.00     8.62     1.20    2.01    0.00    2.01   0.04   2.40

Device:         rrqm/s   wrqm/s     r/s     w/s    rkB/s    wkB/s avgrq-sz avgqu-sz   await r_await w_await  svctm  %util
sda               0.00    44.00    0.00  611.00     0.00 12904.00    42.24     0.10    0.17    0.00    0.17   0.05   2.80

Device:         rrqm/s   wrqm/s     r/s     w/s    rkB/s    wkB/s avgrq-sz avgqu-sz   await r_await w_await  svctm  %util
sda               0.00     0.00    0.00  642.00     0.00  2916.00     9.08     0.02    0.03    0.00    0.03   0.03   2.00

Device:         rrqm/s   wrqm/s     r/s     w/s    rkB/s    wkB/s avgrq-sz avgqu-sz   await r_await w_await  svctm  %util
sda               0.00     0.00    0.00  648.00     0.00  2900.00     8.95     0.03    0.04    0.00    0.04   0.04   2.80

编辑 #2 我们更新了配置以包括：

    Configuration configuration = new ConfigurationImpl();
    configuration.setPersistenceEnabled(true);
    configuration.setJournalSyncTransactional(false);

对于创建 ClientSessionFactory 来：

ClientSessionFactory sf = null;
  try {
    hornetQServer.start();
    ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(InVMConnectorFactory.class.getName()));
    serverLocator.setBlockOnDurableSend(false);
    serverLocator.setProducerWindowSize(100000);

    serverLocator.setBlockOnAcknowledge(false);
    ClientSessionFactory sf = serverLocator.createSessionFactory();

发送时间现在不到一毫秒。这些设置是否不安全，或者不推荐用于典型情况？

Answer 1

当您只有一个生产者时，必须将持久消息持久保存在磁盘上，并同步到您的磁盘。

客户端将一直阻塞，直到所有这些都发生。

服务器被编程为管理多个生产者并使用您的大部分硬件，但如果您只有一个生产者，您的性能将因网络延迟 + 磁盘同步速度而最大化。

因此，对于单个生产者而言，以非事务方式发送持久消息（每次发送都是同步）听起来不错。

编辑：还要查看 ConfigurationImpl 中的 set/getJournalBufferTimeout_AIO 和 set/getJournalBufferTimeout_NIO。这些是在服务器同步磁盘上的数据等待其他客户端同时同步之前发送到 TimedBuffer 的值。