Как установить ограничение на количество подписчиков и подписчиков Aeron при запуске образцов Aeron - PullRequest
Новая
       30

Как установить ограничение на количество подписчиков и подписчиков Aeron при запуске образцов Aeron

0 голосов
/ 28 апреля 2020

Я запускаю образцы Aeron, как указано здесь .

Шаги для запуска теста: 

git clone --branch 1.27.0 https://github.com/real-logic/aeron.git
gradle --console='plain' --stacktrace assemble
$JAVA_HOME/bin/java -cp /src/aeron-all/build/libs/aeron-all-1.27.0.jar -Daeron.dir=/dev/shm/aeron-root io.aeron.driver.MediaDriver &
$JAVA_HOME/bin/java -cp /src/aeron-all/build/libs/aeron-all-1.27.0.jar io.aeron.samples.BasicSubscriber &
$JAVA_HOME/bin/java -cp /src/aeron-all/build/libs/aeron-all-1.27.0.jar io.aeron.samples.BasicPublisher &

Вывод теста 

Offering 53747/10000000 - yay!
Message to stream 1001 from session -1579104823 (18@3439776) <<Hello World! 53747>>
Offering 53748/10000000 - yay!
Message to stream 1001 from session -1579104823 (18@3439840) <<Hello World! 53748>>
Offering 53749/10000000 - yay!
Message to stream 1001 from session -1579104823 (18@3439904) <<Hello World! 53749>>
Offering 53750/10000000 - yay!
Message to stream 1001 from session -1579104823 (18@3439968) <<Hello World! 53750>>
Offering 53751/10000000 - yay!
Message to stream 1001 from session -1579104823 (18@3440032) <<Hello World! 53751>>
Offering 53752/10000000 - yay!
Message to stream 1001 from session -1579104823 (18@3440096) <<Hello World! 53752>>

Как показано в выходных данных, будут происходить события 1000000 Subscribe и Publi sh.

Поэтому мой вопрос заключается в том, как я могу ограничить количество взаимодействий. Делать это с помощью некоторых флагов было бы здорово.

1 Ответ

0 голосов
/ 03 мая 2020

Количество сообщений, отправляемых BasicPublisher, можно настроить с помощью системного свойства aeron.sample.messages следующим образом: 

$JAVA_HOME/bin/java -cp /src/aeron-all/build/libs/aeron-all-1.27.0.jar -Daeron.sample.messages=100 io.aeron.samples.BasicPublisher &
...