akka相关内容

我的 Akka 演员的属性是否应该标记为 @volatile?

这个问题看起来类似于是否应该标记我的 Scala 演员的属性@volatile? 但不确定答案是否相同. 例如，如果配置了 fork-join 调度程序并且参与者的状态没有被 @volatile 标记，是否可以保证参与者的状态将通过缓存层次结构从一个内核(或处理器)传播到另一个如果 fork/join 工作线程在不同的内核(或处理器)上运行? 附言在 JSR133 之后，仅对任何易失性 ..
发布时间：2021-09-20 18:37:58 其他开发

在 Scala 中使用 Akka 进行相互认证

我将使用 Akka 在 Scala 中创建一个 TLS 会话，并在客户端和服务器之间进行相互身份验证.我创建了两个 CA 证书，它们必须信任从另一部分传入的相应证书.你能给我一个如何实施的例子吗?谢谢. 解决方案 我创建了一个 github 项目，该项目演示了与不同类型客户端(包括 Akka)的相互身份验证.请看这里:https://github.com/Hakky54/mutual-tl ..
发布时间：2021-09-08 20:07:10 其他开发

Akka onReceive 方法是否并发执行?

这是我的场景: 我有一个主actor，它接收来自多个子actor的消息.这些消息包含要聚合的数据.在这个聚合逻辑中，如果我使用共享数据结构来收集聚合，我是否需要处理同步问题? else if(arg0 instanceof ReducedMsg){ReducedMsg 减少 = (ReducedMsg)arg0;counter.decrementAndGet();同步(最终结果){fina ..
发布时间：2021-09-03 20:18:15 其他开发

如何从文件系统获取文件属性流?

我正在编写一个 Web 服务器，并试图确保我尽可能高效，尽量减少文件系统调用.问题在于返回 Streams 的方法，例如 java.nio.file.Files.list 返回 Paths 的 Stream，我想要 BasicFileAttributes，以便我可以返回每个路径的创建时间和更新时间(比如返回 LDP 容器). 当然，一个简单的解决方案是使用一个函数来map Stream 的每 ..
发布时间：2021-07-15 20:54:01 Java开发

Akka Stream 连接到多个接收器

我在 akka 流中实现了一个自定义组件，它将元素作为输入，根据一个键对它们进行分组和合并，然后通过十几个出口之一将它们发送出去.您可以将此组件视为一种 GroupBy 组件，它不会将流划分为子流，而是实际的流.除了对传入元素进行分区之外，它还将它们合并为一个元素，即在组件内部发生了一些缓冲，使得 1 个元素进入并不一定意味着 1 个元素通过出口传出. 以下是所述组件的简化实现. clas ..
发布时间：2021-07-15 20:50:18 其他开发

只有在所有事件都被持久化后才更新actor状态

在持久化actor的receive方法中，我收到一堆我想持久化的事件，只有在所有事件都持久化后，再更新我的状态.我该怎么做? def 接收:接收 = {...case NewEvents(events) =>坚持(事件){ singleEvent =>//使用这个单一事件更新状态}//在每个事件都被持久化之后，再做一件事} 请注意，persist() 调用不会阻塞，因此我不能在此之后放置代码. ..
发布时间：2021-07-15 20:38:14 其他开发

使用密封特征和密封抽象类作为基类的区别

在尝试学习 Akka 的过程中，我经常发现类层次结构与此类似的示例: 密封性状消息case class TextMessage(user: String, text: String) extends Messagecase class StatusMessage(status: String) extends Message 但是，即在 Scala 文档 中有以下示例: 抽象类通知case ..
发布时间：2021-07-15 20:19:10 其他开发

Akka Streams:流中的状态

我想使用 Akka Streams 读取多个大文件来处理每一行.想象一下，每个键都包含一个 (identifier -> value).如果找到一个新的标识符，我想把它和它的值保存在数据库中；否则，如果在处理行流时已经找到标识符，我只想保存该值.为此，我认为我需要某种递归状态流来保留已经在 Map 中找到的标识符.我想我会在这个流程中收到一对 (newLine, contextWithIdenti ..
发布时间：2021-07-15 20:14:42 其他开发

Akka HTTP“每个请求的参与者"图案

目前我正在尝试实施 "actor-per-request" 模式由 NET-A-PORTER devs 在 Akka HTTP 中提出.我面临的问题是文档中的任何地方都没有记录这种模式.似乎没有办法做到以下几点: IO(Http) !Http.Bind(serviceActor, "localhost", port = 38080) 如何在不使用 Spray 的情况下为每个请求使用一个 Akk ..
发布时间：2021-07-03 19:46:32 其他开发

如何获取导致 Akka Streams 失败的对象?

根据 akka 流文档 可以通过定义将 Throwable 映射到 Strategy 的决策器来处理流失败: val 判定器:Supervision.Decider = {case _: ArithmeticException =>监督.简历案例_ =>监督.停止} 我想知道是否有办法访问导致错误的元素.当然，这个元素的类型是未知的，但是有没有办法把它作为Object的实例来获取? 解决 ..
发布时间：2021-07-03 19:42:29 其他开发

如何从 ActorFlow 获取演员参考 (ActorRef)?

根据 在 WebSockets 上播放文档 建立 WebSocket 的标准方法是使用 ActorFlow.actorRef，它接受一个函数返回我的演员的 Props.我的目标是获得对这个底层 ActorRef 的引用，例如为了发送第一条消息或将 ActorRef 传递给另一个演员的构造函数. 就文档中的最小示例而言，我正在努力实现这一目标: class WebSocketControll ..
发布时间：2021-06-18 18:51:26 其他开发

Lightbend 列出的示例项目之一不适用于较大的文件

我确实在 LightBend 的讨论组中发布了同样的问题 这里，但无法得到解决我的问题的答案.由于我真的很想知道这里的问题是什么，让我再次在这里发布这个问题，希望大量的受众群体可能意味着更好的获得答案的机会. 所以基本上，在这个页面上，https://developer.lightbend.com/start/?group=play，我们可以找到示例播放列表！项目.在这些例子中，有一个项目是 ..
发布时间：2021-06-18 18:48:29 其他开发

MongoDB Reactive Streams 运行时依赖错误与 Alpakka Mongo 连接器 ClassNotFoundException

我正在尝试将 Alpakka Mongo Connector 集成到严重依赖 Akka 库进行流处理的应用程序.该应用程序也使用 Akka HTTP. 我在运行时遇到依赖问题.特别是，当我尝试使用 Mongo 连接器提供的 MongoSink.insertOne 方法时，我得到了一个 NoClassDefFoundError 的某种成功/失败包装器.完整的堆栈跟踪: java.lang.NoC ..
发布时间：2021-06-03 19:31:04 其他开发

反向HList并转换为类?

我正在使用Shapeless将Akka中的物化值累积为HList，并将其转换为case类. (您不必对Akka知道太多的问题，但是默认方法将物化值累积为递归嵌套的2元组，这并不有趣，因此Shapeless HLists似乎是一种更明智的方法-并且可以工作很好，但是我不知道如何正确地重用这种方法.在这里，我将简化Akka产生的价值类型.) 例如，假设我们有两种实体化类型，"A"和"B": ..
发布时间：2021-05-15 20:47:39 其他开发

Docker Akka-Http应用程序端点无法访问

我有一个非常基本的Akka-http应用程序，基本上只不过是一个Hello-world设置而已-我已经定义了一个端点，并将其简单地绑定到"localhost"和端口"8080": object Main通过Routes扩展了应用程序{私有隐式val系统= ActorSystem()受保护的隐式val执行程序:ExecutionContext = system.dispatcher受保护的隐式v ..
发布时间：2021-05-02 19:17:32 其他开发