单线程与多线程JMS生产者

Question

我想看看使用多线程生产者而不是单线程生产者会有多少时间差异。我在本地计算机上设置了ActiveMQ，编写了生产者类，该类将初始化并在其构造函数中启动JMS连接。我将消息限制设置为3M，将所有消息推送到ActiveMQ大约花费了50秒。我只发送了一个字符串“
hello world” 3M次。

然后，我使用了相同的生产者对象（一个连接但有多个会话），并使用线程大小为8的ExecutorService运行它。在此run方法中，我将3M除以8只是为了确保每个线程发送的邮件不超过375000条。在这种情况下，推送所有消息大约需要60秒。

ExecutorService service = Executors.newFixedThreadPool(8);

    for (int i = 0; i < 8; i++) {

        service.execute(producer);
    }

然后，我创建了八个生产者，每个生产者都有自己的连接，并使用ExecutorService或线程大小为八的线程运行它们。这次花了大约68秒来推送所有3M消息。

for (int i = 0; i < 8; i++) {
        service.execute(new Producer());
    }

我想知道，为什么单线程生产者在这里表现更好？我运行每个方案大约10次，但结果保持不变。

Answer 1

从JMS应用程序的角度来看，您已将应用程序编写为多线程。多个会话，每个会话都有各自的JMS生产者对象，这些对象由单独的线程驱动。假设您的应用程序对资源（例如锁等）没有争用，那是好的。

从客户端和服务器端的角度看，发送消息的效率取决于JMS提供程序的实现效率。JMS实现中是否存在任何锁定或争用？也许它试图通过同一个套接字发送所有内容-
在这种情况下存在争用。也许还有其他锁。

底层队列数据结构服务器端可能有一个锁服务器端。

要回答您的问题，确实需要特定JMS提供程序的详细知识。