问题标签 [aeron]

实际逻辑的 Aeron可以处理的最大消息大小是多少？

我意识到 Aeron 擅长处理小消息，但是我希望在我们的堆栈中使用单一协议，并且我们的一些消息很容易达到 100Mb 的大小。

文档不清楚哪些设置会影响此问题的答案。我担心的是默认缓冲区设置不允许这种大小的消息。还是缓冲区设置对最大应用程序消息大小没有影响？

早上好，

我正在尝试了解低延迟库 aeron，我有一个发布类的实例：

在哪里：

和

创建实例后，要发送消息，它的作用是：

我想了解最后一行代码是如何工作的，方法 offer() 在以下文件中：https ://github.com/real-logic/aeron/blob/master/aeron-client/src/main/java/ io/aeron/Publication.java

在第 373 行有以下方法：

这将返回一个函数，如果我在 Publication.java 文件中搜索此函数，我只会找到以下内容：

这是一种抽象方法，我不知道在哪里可以找到它的定义。

如果有人可以帮助我，我将非常感谢了解这个库是如何工作的。

我无法在 Aeron 的 LowLatencyMediaDriver 示例中设置新的 Threadfactory()。有关 VisualVM 中线程名称的代码和快照，请参见下面的代码。

在此处输入图像描述

我正在尝试使用 Multi-Destination-Cast 传输，但我不知道如何配置它，我正在尝试使用SimplePublisher.java和SimpleSubscriber.java实现此处解释的示例 URI

我有一个发布者和两个订阅者。

在带有 SimplePublisher.java 和 SimpleSubscriber.java 的默认 aeron 参数中，我已更改：

来自 SimplePublisher.java

并来自 SimpleSubscriber.java：

我复制了 SimpleSubcriber1.java 和 SimpleSubcriber2.java 类，并更改了以下配置：

简单订阅者1：

和

简单订阅者2：

我为发布者和订阅者得到的错误几乎相同：

对于发布者：

并且，对于订阅者：

如果你需要，我可以给你更多的细节。

PD：我有运行 LowLatencyMediaDriver 的 MediaDriver，这不是问题

先感谢您

I want to implement data distribution application using zeromq or nanomsg or aeron.net or OpenDDS or OpenMAMA, I am little confused , which one is suitable as my requirement is to support 500 to 1000 users and each user can subscribe for atleast 100 topics

this can be handled by using pub/sub pattern or I have to use UDP multicast ?

Also I need to deploy this application on Amazon EC2

我似乎在RSocket上找不到任何资源/教程，除了在 GitHub 上阅读他们的代码，我不明白。

我的服务器上有一个文件的路径：String serverFilePath;

我希望能够从我的客户端下载它（最好使用RSocket 的 Aeron 实现）。有谁知道如何使用 RSocket 做到这一点？

提前致谢。

我正在研究akka集群。akka 每次创建 Actor 系统实例时，都会在临时目录下创建巨大的 aeron-{user}-clustersystem 文件，占用大量空间。

用于自动清理的 akka aeron 设置是什么？

请帮忙。

我目前正在研究关于 Aeron MQ 的 PoC。根据 PoC，我有 2 个订阅和 1 个发布者用于具有嵌入式媒体驱动程序的本地频道。发布的消息在两个订阅中都收到，而我希望以循环方式分发消息。有没有属性或方法可以实现这一目标？

早上好，

我正在尝试在 Aeron 传输协议之上使用 RSocket。但是，似乎没有关于该主题的文档 - 有没有人成功地将这两种技术集成在一起？它准备好使用还是仍在进行中？

非常感谢。

我想指示 Aeron 集群中的任何节点成为领导者，没有选举。前任领导者自动成为追随者，从不尝试担任领导职务（除非受到外部指示）。

我看了看Cluster/Role，ClusterToolAPIAeronCluster 似乎没有任何帮助。我也检查了一下AppointedLeaderTest，归结为最初用 指定领导者ConsesusModule.Context.appointedLeaderId，但之后没有办法动态更改它？

这个怎么做？