Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Akka设计原则
在开发一个相当大的 Akka 应用程序时 我在使用普通方法和非 Akka 类时遇到了一个非常简单的结构 但在使用 Akka 时实际上很难确定 这就是为什么我来这里问你什么建议是解决此问题的最佳方法 所以问题是这样的 我有一个父角色 我们称他
Java
scala
akka
Actor
使用 ScalaTest 测试时,为什么 Akka 会失败并显示“IllegalStateException:在终止或终止时无法创建子项”?
这是我从 Akka 收到的错误 debug Running TaskDef com suredbits core util time TimeUtilUnitTest org scalatest tools Framework anon 1
scala
akka
Akka/Java getContext().become 带参数?
在 Akka Scala 中 可以将参数传递给自定义接收函数 因此可以通过 params 传递整个 actor 状态 而无需使用可变变量 context become myCustomReceive param1 param2 但在 Jav
Java
scala
akka
Akka 和 Typesafe 配置版本问题
我尝试在 Tomcat 服务器上使用 akka 2 1 0 但我收到一个错误 要求我将配置库也放在类路径上 好吧 这不是问题 我将 Typesafe 的配置库 版本 1 0 0 最新 放在 lib 文件夹中 但是 我总是收到错误 8d315
scala
version
config
akka
反转 HList 并转换为类?
我使用 Shapeless 在 Akka 中累积物化值作为 HList 并将其转换为案例类 对于这个问题 您不必了解 Akka 太多 但默认方法将物化值累积为递归嵌套的 2 元组 这并不是很有趣 因此 Shapeless HLists 似乎
scala
akka
implicit
shapeless
用于 REST 轮询的 Akka
我正在尝试将大型 Scala Akka PlayMini 应用程序与外部 REST API 连接起来 这个想法是定期轮询 基本上每 1 到 10 分钟 根 URL 然后爬取子级 URL 以提取数据 然后将其发送到消息队列 我想出了两种方法来
scala
REST
akka
polling
play2mini
Akka Actor 带有 TimeoutException 的“询问”和“等待”
我正在使用 Scala 和 Akka 建模一个简单的 P2P class Node extends Peer with Actor var peers List ActorRef List def receive case register
scala
Actor
akka
Play/Akka 与 Java OutputStreams 集成
我正在写剧本 该应用程序公开了 REST API 允许用户生成 PDF 报告 我受到使用旧 Java API 来生成实际报告的要求的限制 那个库有一个方法generate OutputStream out 即需要一个java io Outp
Java
scala
playframework20
akka
outputstream
在 Scala 中存储特定类类型的序列?
尝试找到一种有效且灵活的方法来在 Scala 中存储一系列类类型 稍后我可以使用它来启动该类型的新实例 class Event val name String val channels Seq String val processors S
scala
akka
Kafka重启时如何让Kafka Source重新连接
我创建一个Source使用 Reactive Kafka 的消费者记录如下 val settings ConsumerSettings system keyDeserializer valueDeserializer withBootstr
Java
scala
akka
ApacheKafka
kafkaconsumerapi
我应该使用 Java 中的哪个线程池?
有大量的任务 每个任务都属于一个组 要求是每组任务应该像在单线程中执行一样串行执行 并且在多核 或多CPU 环境中吞吐量应该最大化 注意 组的数量也与任务数量成正比 最简单的解决方案是使用 ThreadPoolExecutor 并同步 或锁
Java
scala
ThreadPool
Actor
akka
Akka-http:如何从请求中获取自定义标头?
我在请求中将以下标头发送到我的 akka http api Content type application json Accept application json AppId some id 如何在我的 akka http 路由中获取
akka
spray
akkahttp
Akka 消息传递保证
我正在尝试找出 Akka 支持哪些消息传递保证 我得出以下结论 最多一次 默认支持 至少一次 由 Akka Persistence 支持 恰好一次 Akka支持exactly once吗 如果不这样做 我怎样才能实现这一目标 正如您所发现的
akka
当 akka actor 在测试线程之外抛出异常时,scalatest 失败
我曾经遇到过这样的情况 在我测试一个 Actor 时 Actor 意外抛出异常 由于错误 但测试仍然通过 现在 大多数情况下 Actor 中的异常意味着无论测试正在验证什么 都不会正确显示 因此测试失败 但在极少数情况下 情况并非如此 异常
scala
akka
scalatest
Akka 远程 `system.shutdown()` 导致 EndpointDisociatedException?
我有简单的客户端和服务器设置 在发送所有异步请求并在服务器确认后的某个时刻 客户端调用system shutdown 这导致服务器akka remote EndpointDisassociatedException和一堆日志错误 如下所示
xml
akka
Actor 系统无响应:ThreadPoolExecutor 调度程序仅创建核心线程池,显然忽略最大线程池大小
更新 我发现如果我设置ThreadPoolExecutor s核心池大小与最大池大小相同 29 个线程 但是 如果我将核心池大小设置为 11 最大池大小设置为 29 那么 Actor 系统只会创建 11 个线程 我该如何配置ActorSys
Java
Multithreading
scala
akka
Blocking
相当于 Akka,但适用于 .NET(并发框架)
有没有相当于Akka http akka io 但对于 NET http doc akka io use cases http doc akka io use cases 这是 我的 正在进行的 NET Akka actor 端口 编辑 该
NET
frameworks
concurrency
akka
Scala 与 Akka 中的相互身份验证
我将使用 Akka 在 Scala 中创建一个 TLS 会话 并在客户端和服务器之间进行相互身份验证 我创建了两个 CA 证书 它们必须信任来自另一部分的相应证书 您能给我一个如何实现这一点的例子吗 谢谢 我创建了一个 github 项目
scala
SSL
akka
tls12
mutualauthentication
OLP CLI 错误:java.base 未将 sun.security.util 导出到 JDK 16 下的未命名模块
在 MacOS Big Sur 11 4 最新的 OLP 10 0 9 和最新的 Java 16 0 1 下 在 akka 中遇到 olp 目录列表 错误 如果切换到 Java 8 相同的命令也可以工作 但这不是重点 根据用户指南 Java
Java
SSL
akka
hereapi
hereolp
应该如何创建一个可能抛出异常的 akka actor?
我正在将一个项目从 scala Actor 迁移到 Akka Actor 我曾经有过类似的情况 如果某个系统资源不可用 MyActor 的构造函数可能会抛出异常 var myActor MyActor null try myActor ne
scala
akka
Actor
«
1
2
3
4
5
6
7
...10
»