1回答
我正在尝试使用带有akka-http的scala启动REST API。我是akka和角色模型范例的新手，所以我想实现一个类型化的角色系统，但我遇到了这个sbt编译错误：
could not find implicit value for parameter system:akka.actor.ActorSystem (implicit ActorRefFactory require
浏览 13提问于2020-06-07得票数 0
我有一个演员系统“主”可能永远运行。这位主要演员理解“快照”或“停止”消息(由我定义)。我希望创建一个bash脚本，在主参与者运行时，启动第二个(短暂的)系统或参与者，或者其他什么，并向主参与者发送快照或停止消息。与阿克卡经典，这是非常容易与actorSelection从第二个演员
ActorRef mainActorRef = Await.result(system.actorSelection("akka.main.actor.pathresolveOne
浏览 3提问于2022-06-01得票数 0
回答已采纳
我有一个使用akka定义的Route，它使用内部的一个参与者发送消息。val result: Future[Message] = mainActor.ask { val manualTime: ManualTime = ManualTime()
// my tests here ...
浏览 0提问于2020-03-29得票数 3
1回答
如何扩容？
、、
要扩展(水平扩展)使用Akka编写的应用程序，需要做哪些工作？粗略地说，要在集群中添加一个新节点，我是否只需要在它上安装一个JRE，并使用我的Akka客户端应用程序运行.jar文件？
浏览 1提问于2013-05-14得票数 2
1回答
我们在应用程序中使用了Akka actors。参与者调用服务，在某些情况下，这些服务调用由第三方公开的rest API。现在第三方API需要很长时间才能响应。由于这一点，在高峰时间，系统吞吐量受到影响，因为线程在等待客户端API响应时被阻塞。
有时在高峰期，因为线程正在等待，消息只会在akka邮箱中等待很长时间，一旦阻塞的线程可用，消息就会被提取。我正在寻找一些解决方案，其中我可以提高系统<
浏览 10提问于2020-05-22得票数 0
2回答
我想使用akka的调度器，例子是：但是，没有真正的信息来源于“系统”。文档有点肤浅，有很多变化(akka移出核心scala)。如果我写我将拥有一个ActorSystem，但它将是一个新的独立ActorSystem，大约有8个新线程。我认为，对于一个小的调度程
浏览 1提问于2015-05-08得票数 9
回答已采纳
我正在尝试使用类型化角色版本2.6.3和akka http版本10.1.11，而所有这些在非类型化角色中都正常工作，现在我得到了编译错误
def当我收到消息时，我想要创建http服务器，即标识是计算出来的，在实例器创建过程中，我是如何得到编译错误的。Main.scala:19:50:隐式ActorRefFactory必需:如果在Actor外部需要隐式ActorSystem，则在参与者内部应该是
浏览 1提问于2020-02-16得票数 0
我有兴趣实现: 1.向事件流发送消息的akka参与者A；2.侦听已在事件流上发布的某种类型的消息的akka参与者L。我知道如何做2。我知道如何使A向另一个参与者(Ref)发送消息，但我不想将消息发送给任何特定的参与者(Ref)
浏览 0提问于2018-03-17得票数 0
回答已采纳
我有两个问题：
下面的代码创建了多少个参与者？如何同时创建1000个演员？
浏览 3提问于2020-07-07得票数 0
8回答
我正在尝试使用Java和Akka创建我自己的基于REST的API。我已经使用Akka创建了我的主要算法实现。我的困惑是如何实现剩下的部分。我所见过的大多数示例和库都是专门针对Scala的，而我目前正试图远离Scala。
我知道Scala是个不错的选择，但我认为它应该是Scala的</e
浏览 1提问于2013-01-29得票数 11
1回答
我刚刚从Akka Http (和Scala)开始，我想知道是否有任何定义良好的模式来构造Akka代码。特别是，我正在寻找用于动态组合/聚合路由的结构模式。//route definition for this trait然后，在我的主服务器中，只需混合这些特性就可以自动获得参与者和路由：
class HttpServer extends SomeTraitHttpServer类本身成为一个参与者，不能由new HttpServer()
浏览 4提问于2017-03-05得票数 4
对于Akka来说，我有三个不同的例子，这三个例子都使用非常不同的类来实现一个参与者，UntypedActor：前两个看起来非常简单和简单，类似于我在Erlang上使用和看到的参与者模型实现。官方文档里的那个看起来是最复杂的。
所以我有点搞不懂该用哪一种，什么时候用？
浏览 0提问于2019-12-20得票数 0
回答已采纳
1回答
使用EventStream创建源
、、、、
我正在使用PlayFramework 2.5.3，并希望从akka.event.EventStream创建一个akka.stream.scaladsl.Source ( eventstream是参与者系统的一部分事件流将从特定类型生成事件，因此我需要订阅该特定类型的事件并使用play.api.mvc.Results.chunked推送它们。有什么简单的方法可以使用
浏览 5提问于2016-05-19得票数 6
2回答
我是Akka的初学者，我喜欢它为异步编程提供的许多功能，比如Actor、Agents或Futures。Akka的一个强大卖点是，当一个角色崩溃时，角色系统会重新创建一个等效的角色，并将其插入到旧角色的位置，从而保证强大的稳定性。其他一些系统(我被告知JMS就是其中之一)更进一步，持续持久化参与者之间发送的消息。这样，如果机器在物理上崩溃--比如说由于硬件故障--仍然可以将状态恢复到
浏览 0提问于2012-10-05得票数 4
回答已采纳
1回答
我有一个带有非类型化角色系统的akka集群。现在我必须将一个节点更改为使用类型化的参与者，问题是:如何从非类型化的参与者系统创建类型化的shardregion？基本上我需要这样的smth：
import akka.cluster.sharding.typed.scaladsl.Cluster
浏览 1提问于2018-09-06得票数 2
根据文档，使用参与者的更容易的方法是：
但文档还表示，对于Java，它将始终使用相同的线程池文件说，也有一个阿克卡的演员池。如何将此参与者任务发送到Akka线程池，而不是阻止常见的用户操作？因此，我可以调优Akka池，并保持默认池
浏览 0提问于2013-05-13得票数 5
回答已采纳
2回答
如何最好地实现阻塞/等待参与者？
、、、、
我对Akka和编写并发应用程序是相当陌生的，我想知道有什么好方法来实现一个参与者，它将等待redis列表，一旦项目可用，它将处理它，或者将其发送到不同的参与者进行处理？使用阻塞函数BRPOPLPUSH是更好，还是让参与者每秒轮询redis的调度程序是更好的方式？
另外，在一个正常的系统上，在不消耗系统必须提供的所有资源的情况下，
浏览 2提问于2012-12-02得票数 1
2回答
我在IIS中使用RESTful API创建了一个服务，该服务托管在ASP.NET中。在这个服务中，我想用Akka.NET创建一个参与者系统。”类型的第一次异常发生在System.Web.dll附加信息中:此时无法启动异步操作。参与者系统本质上是一个并发系统，在参与者之间交换异步消息。正如所解释的那样，这个参与者系统将无法生存IIS删除AppDom
浏览 5提问于2014-12-24得票数 13
回答已采纳
2回答
质量保证视角下的Akka系统
、、、、
我已经测试了一个多月的基于Akka的应用程序。但是，如果我仔细考虑一下，我有以下结论：
只有阿克卡演员才能实现很多并发性。我已经达到了100,000多条信息每秒。这很好，只是消息传递而已。现在，如果一端有网络层连接，或者最终由akka参与者执行DB调用、REST调用和文件写入，那么整个系统就不再有意义了。参与者的邮箱变得满了，他们的吞吐量(这里，接收消息的能力/秒)变
浏览 3提问于2015-03-24得票数 3
回答已采纳
我正在使用Java+Akka创建一个演员系统。特别是，我通过提供onReceive()方法的实现来定义非类型化的参与者。public void onReceive(Object msg) throws Exception {
if(msg instanceof MsgType
浏览 3提问于2013-08-27得票数 1
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
