问题标签 [akka.net-streams]

当我一般使用 Giraffe 或 ASP.Net Core 时，我可以创建一个演员系统，将其添加为服务，然后让它认为请求处理程序选择任何演员并询问/告知消息。

无论是使用 Cluster.Sharding 还是普通的user/actor，我都知道它将是整个系统中处理多条消息的参与者的单个实例。

如何与 Streams 进行相同的通信？它们似乎不是路由器中的引用，也不是作为参与者路径的参与者系统：参与者引用、路径和地址。

这应该以不同的方式进行吗？

从 IO 部分复制，我可以具体化一个图来处理每个请求，但一般来说，我与“单例”（如域驱动设计聚合根）进行通信以处理域逻辑（这就是分片模块的原因），我不确定如何做可用于请求处理程序中新物化图中的单例接收器，因为所有请求必须只有一个接收器。

在 Akka.Net 中，我们可以从 Tcp actor 派生 TcpStream actor 吗？

我使用创建了一个 Tcp 演员

然后我将自己注册为处理程序

端点代表一个普通的远程 Tcp 套接字，而不是一个 Tcp 流参与者。

然后我订阅收到的消息

如何通过定义自定义框架逻辑的 Flow 将 Received 消息作为流使用？

我可以使用创建连接吗

嗨，我正在学习使用 Akka.net，我想做的是创建一个简单的 TCP 服务器，它会定期将数据发送到 tcp 连接。（然后将由 processingjs 客户端获取并显示在输出中）

不知道我在这里缺少什么。你们中的任何一位专家都可以对这个问题有所了解吗？

这些是我的演员：

我的印象是，当我SensorReader在Tcp.Connected消息上注册时，我需要做的就是向SensorData流发送消息。像这样：_sys.EventStream.Publish(new SensorData("sensor-data[x]"));

但是，这似乎不起作用。我收到以下日志消息：

这就是我将 Tcp.Bind 消息发送到我的服务器的方式。

如您所见，我将 指定server为 Bound 消息的处理程序。还是我完全错了？

另外，我必须提到，当我启动我的 processingjs 客户端时，我确实收到一条Tcp.Connected消息到 my ProcessingServer，这反过来创建SensorReader并注册为处理程序。

我还想知道我EventStream是否正确使用了发布？

对此的任何帮助都将受到高度赞赏。谢谢你。

我们将 EventStore 用于我们的事件源解决方案。我们想将事件导出到 Kafka 并使用 Kafka 进行流处理。在 EventStore 中，每种类型的流都属于一个类别，例如 Order、Customer、Payment 等。在每个类别下，您都有单独的流，例如 Order-123、Order-124 等。
现在这些事件在所有流中维护全局顺序，并且可以按该顺序消费。
我的问题是，是否可以在保持事件顺序的同时获取这些流并在 Kafka 中创建一个新的投影流。例如，获取这 3 个类别流，并创建一个新的类别流，例如 CustomerActivity。鉴于 Order 和 Payment 具有 CustomerId，它将作为 CustomerAcivity 分区中新流的分区键。

同样的 Q，对于 Akka.Net 流。