akka相关内容

Akka.net-如何等待子参与者在停止之前处理所有挂起的消息

我们有一个名为A的集群分片参与者，并且它有多个子参与者使用每实体模式创建的子项，如下所示。 当我们将100条消息从演员B告知D并且演员D花费比方说500毫秒来处理每条消息时，同时，当我们使用Context.Parent.Tell(new钝化(PoisonPill.Instance))将毒丸发送给演员A时； 它会立即停止所有子执行元(包括执行元D)，而不处理挂起的消息。 A | ..
发布时间：2022-02-27 18:53:22 C#/.NET

如何使用反压溢出策略创建Akka-Http客户端？

我有未定数量的Akka-http客户端流从http服务下载数据。我使用Akka-http主机级连接池，因为我希望自定义池，因为有长时间运行的请求通过它。 因为客户端的数量是未定义的和动态的，所以我不知道如何配置连接池(max-open-request/max-connections)。此外，我可能希望连接池较小(少于客户端数量)，以不损害带宽。 因此，我想设置一个客户端流，以便对池的新 ..
发布时间：2022-02-27 18:51:36 其他开发

使用 uberjar 部署时覆盖 Typesafe 配置中的多个配置值

我有一个 Akka 应用程序，它使用 resource/application.conf 中定义的多个配置值(IP 地址、端口号).我正在使用 sbt-assembly 插件创建一个 uber jar，然后部署这个 jar. 有没有办法通过使用 uber jar 之外的另一个文件来覆盖整个 application.conf 文件?(即使用新 conf 文件中的值) 解决方案 有多种方 ..
发布时间：2022-01-24 21:36:08 其他开发

Akka Camel - JMS 消息丢失 - 应该等待 Camel 的初始化吗?

我的实验应用程序非常简单，尝试使用 Actors 和 Akka 可以做什么. 在 JVM 启动后，它创建了带有几个普通 Actor 的 Actor 系统，JMS 消费者 (akka.camel.Consumer) 和 JMS 生产者 (akka.camel.Producer).它在参与者和 JMS 生产者 -> JMS 服务器 -> JMS 消费者之间发送一些消息.它基本上通过 JMS 服务 ..
发布时间：2022-01-19 08:52:56 其他开发

Akka、SQS 和 Camel 的消费者投票率

我正在进行的一个项目需要从 SQS 读取消息，因此我决定使用 Akka 来分发这些消息的处理. 由于 Camel 支持 SQS，并且在 Consumer 类中内置了供 Akka 使用的功能，我认为最好以这种方式实现端点并读取消息，尽管我没有看到很多人的例子这样做. 我的问题是我无法足够快地轮询队列以保持队列为空或接近空.我最初的想法是，我可以让消费者以 X/s 的速率通过 Camel ..
发布时间：2022-01-19 08:25:22 其他开发

Akka 是否淘汰了 Camel?

我对 Akka 的理解是它提供了一个模型，多个独立的线程可以通过这种模型以高度并发的方式相互通信.它使用“演员模型"，其中每个线程都是有特定工作要做的“演员".您可以协调在什么条件下将哪些消息传递给哪些参与者. 我以前使用过 Camel，对我来说，现在 Akka 如此成熟且有据可查，我觉得它有点失去了光彩/实用性.据我了解，Camel 是关于企业集成，即将多个不同的系统集成在一起，通常以某种 ..
发布时间：2022-01-19 08:21:45 其他开发

在 Heroku 上使用 Play Framework 的后台作业

在 Heroku 上，并使用 Play Framework，是否需要设置后台作业处理器(使用 Akka/RabbitMQ/等)才能执行繁重的任务*? 我知道 Play 提供了在请求中异步执行任务的能力，但这是否足以避免需要后台作业处理器?在非 Heroku 部署的独立 Play 应用程序上，异步功能可以在一个进程中完成所有操作，但在 Heroku 应用程序上，这似乎还不够:根据书 Profe ..
发布时间：2022-01-11 18:02:56 其他开发

Akka 的语言和产品替代品是什么?

现在我正在查看 Play Framework 并且非常喜欢它.在 Play 中提供的功能中，最重要的部分之一是 Akka. 为了更好地理解 Akka 以及如何正确使用它，能否告诉我在其他语言或产品中有哪些替代方案? RabbitMQ 与它相比如何?有很多重叠吗?一起使用它们实用吗?在哪些用例中? 解决方案 最好的起点是伟大的Akka 官方文档.我认为最接近 Akka 的产品/框 ..
发布时间：2022-01-11 17:37:41 其他开发

Scala、Play、Akka、Websocket:如何通过 websocket 传递 actor 消息

我有一个随应用程序一起启动的actor，在后台运行，观察某些更改以及是否有任何报告.目前它只是一个 println 到控制台.我需要做的是每当有新消息时 - 使用 Websocket 将其发送到前端. 这是我的 Play Global 对象，监控/监听actor在其中启动: object Global extends GlobalSettings {覆盖 def onStart(app: ..
发布时间：2022-01-02 22:19:00 其他开发

执行上下文和调度程序 - 最佳实践、有用的配置和文档

Scala 执行上下文和调度程序 - 列表和比较:为什么? 关于什么/如何/什么是在 Scala 中执行期货的最佳执行上下文以及如何配置调度程序存在很多问题.我仍然无法找到更长的列表，其中包含优缺点和配置示例. 我能找到的最好的是 Akka 文档:http://doc.akka.io/docs/akka/snapshot/scala/dispatchers.html 和 Play 文档 ..
发布时间：2022-01-02 22:18:03 其他开发

Akka 的语言和产品替代品有哪些?

现在我正在看 Play Framework 并且非常喜欢它.Play 提供的功能中最重要的部分之一是 Akka. 为了更好地理解 Akka 以及如何正确使用它，能否告诉我其他语言或产品有哪些替代方案? RabbitMQ 与它相比如何?有很多重叠吗?将它们一起使用是否实用?在什么用例中? 解决方案 最好的起点是 很棒的Akka 官方文档.我认为最接近 Akka 的产品/框架是 e ..
发布时间：2022-01-02 22:17:53 其他开发

在 Scala 中调用播放 WebSocket 中的方法

我是 Scala、Play 框架和 Akka 的新手.我的函数定义为 def socket = WebSocket.accept[String, String] { request =>ActorFlow.actorRef(out => MyWebSocketActor.props(out))} 这个我想从其他班级调用.我不清楚如何调用这个函数，因为我不能调用这个 objectName.so ..
发布时间：2022-01-02 22:16:28 Java开发

scala - 如何每天晚上 11 点运行任务

使用 playframework，我尝试运行一个函数来每天晚上 11 点发送邮件，但我不知道该怎么做.我在互联网上找到了很多答案，但我还没有适应 Scala 语言，你有教程的例子吗? 解决方案 看看 Akka Scheduler 和 玩！预定作业 编辑: 我个人更喜欢玩！使用 cron 的调度程序.因此，在示例(复制/粘贴)中，您可以创建一个类似于以下内容的 Scala 类: ..
发布时间：2022-01-02 22:14:30 其他开发

异步操作 api 如何在 Scala 的 play 框架 2.2.x 中工作?

我正在尝试创建异步 API.但响应显示顺序执行.完成的步骤:在 chrome 的两个选项卡中打开 url.并迅速将他们击中.url ex:- localhost:9000/getStar. 但是执行日志就像:- [info] play - 在/0:0:0:0:0:0:0:0:9000 上监听 HTTP(服务器已启动，使用 Ctrl+D 停止并返回控制台...)[成功] 107ms编译[信 ..
发布时间：2022-01-02 22:14:01 其他开发

播放 2.4:在应用程序启动时使用依赖注入安排重复性任务

我需要在应用程序启动时安排一个重复性任务，任务本身非常简单，只需向应用程序发送一个即发即弃的 HTTP 调用即可.我不是游戏专家，买我会假设简单的解决方案就像在 Global.onStart 中使用 play.api.libs.concurrent.Akka.system.schedule代码>.自 Play 2.4 起，Global 配置在某种程度上已被弃用，以支持新的 Guice DI.破解 ..
发布时间：2022-01-02 22:10:58 其他开发

使用 play 进行 akka 演员测试

我想测试我的 akka 演员.是否可以测试每个接收函数的情况? def 接收 = {case msg: 字符串 =>println("成功" + msg)案例用户:VerifyIfUserExistActor =>隐式 val 超时 = 超时(30 秒)val 未来 = platActor ?用户val 结果 = Await.result(future, timeout.duration).as ..
发布时间：2022-01-02 22:04:20 其他开发

玩 ！2.2.4/Akka:一起运行时测试失败，但单独运行时可以

我有一个控制器，在回答之前询问是一个演员和两个测试用例: 当我运行 play test 时，第二个测试失败 当我运行 play testOnly ApplicationSpec 和 play testOnly IntegrationSpec 时，都成功 我认为 Akka 系统在第一次测试时关闭，而在第二次测试时没有再次启动，但为什么呢?我该如何解决这个问题? 控制器: obj ..
发布时间：2022-01-02 21:53:25 其他开发