Балансировка нагрузки ActiveMQ после того, как сообщения уже помещены в очереди - PullRequest
Новая
       1

Балансировка нагрузки ActiveMQ после того, как сообщения уже помещены в очереди

0 голосов
/ 18 сентября 2018

У нас есть кластер ActiveMQ с 4 узлами.
Я использую Jmeter для отправки многих сообщений в виртуальную тему activemq VirtualTopic.queue1 .Затем сообщения будут автоматически помещены в Consumer.X.VirtualTopic.queue1
Балансировщик нагрузки будет доставлять сообщения в очереди различных узлов.
Вопрос 1: Я ожидаю, что сообщения будут доставлены в равной степеникаждая очередь но это не так.Зачем?Может быть, наша ошибка при настройке кластера ActiveMQ?
Вопрос 2: Прекратить отправку сообщений в очередь.В очереди узла 1 нет ожидающих сообщений, но позже кажется, что ActiveMQ берет сообщения из другой очереди (например, очередь узла 2) и повторно доставляет их в очередь узла 1.Это особенность ActiveMQ? 

{
    "node1": {
        "Consumer.X.VirtualTopic.queue1": 35
    },
    "node2": {
        "Consumer.X.VirtualTopic.queue1": 267553
    },
    "node3": {
        "Consumer.X.VirtualTopic.queue1": 14
    },
    "node4": {
        "Consumer.X.VirtualTopic.queue1": 14
    }
}
...