运行 Aeron 样本时如何设置 Aeron 订阅者和发布者数量限制

Question

我正在运行按照给定的方式对 Aeron 样本进行采样 here。

运行测试的步骤：

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 个订阅和发布事件。

所以我的问题是如何限制互动次数。使用一些标志这样做会很棒。

Answer 1

您可以使用 aeron.sample.messages 系统属性配置 BasicPublisher 发送的消息数量，如下所示：

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

运行 Aeron 样本时如何设置 Aeron 订阅者和发布者数量限制

How to set limit on Aeron subscriber and publisher count while Running Aeron Samples

java

testing

gradle

limit

aeron

所以我的问题是如何限制互动次数。使用一些标志这样做会很棒。