在akka中系统Actor和用户Actor有什么区别？
在akka中，系统Actor和用户Actor是两种不同的角色。
系统Actor是akka框架内部提供的一种特殊类型的Actor，用于管理和控制整个系统的运行。系统Actor负责处理系统级别的任务，例如监控和管理其他Actor的生命周期、处理系统级别的消息等。系统Actor通常由akka框架自动创建和管理，开发者无需手动创建。
用户Actor是由开发者根据业务需求创建的普通Actor。用户Actor负责处理具体的业务逻辑，接收和处理来自其他Actor或外部系统的消息。用户Actor可以根据需要创建和销毁，具有更灵活的生命周期管理。
区别：
- 创建方式：系统Actor由akka框架自动创建和管理，而用户Actor由开发者手动创建。
- 职责：系统Actor负责处理系统级别的任务，如监控和管理其他Actor的生命周期；用户Actor负责处理具体的业务逻辑。
- 生命周期管理：系统Actor的生命周期由akka框架管理，用户Actor的生命周期由开发者手动管理。
- 可扩展性：系统Actor通常是全局唯一的，用于管理整个系统，而用户Actor可以根据业务需求创建多个实例，实现更好的并发和可扩展性。
推荐的腾讯云相关产品： 腾讯云提供了一系列云计算产品，包括云服务器、云数据库、云存储等，可以满足各种应用场景的需求。以下是一些相关产品的介绍链接：
- 云服务器（CVM）：提供弹性计算能力，支持多种操作系统和实例类型。链接：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版（TencentDB for MySQL）：提供高可用、可扩展的MySQL数据库服务。链接：https://cloud.tencent.com/product/cdb_mysql
- 云存储（COS）：提供安全可靠的对象存储服务，适用于存储和管理各种类型的数据。链接：https://cloud.tencent.com/product/cos
请注意，以上链接仅供参考，具体产品选择应根据实际需求进行评估和决策。
相关·内容
我发现还有一个Akka的actor模型，所以我想知道Akka的Actor和Scala的Actor模型有什么区别？
浏览 2提问于2012-02-20得票数 77
回答已采纳
我有以下演员：
val actor1 = context.actorOf(SorterActor.build
.withDispatcher("akka.actor.custom-dispatcher"), name = "actor_child1")
val actor2 = context.actorOf(SorterActor.build
.withDispatcher("akka.actor.custom-dispatcher"), name = "actor_child2")
和执行上下文
implici
浏览 4提问于2014-09-29得票数 2
回答已采纳
2回答
我正在学习本教程。
我一直在跟踪它，但我的程序没有运行，它会给我带来错误，我对这一行感到困惑：
val remote = context.actorFor("akka://HelloRemoteSystem@127.0.0.1:5150/user/RemoteActor")
我要写什么来代替“用户”？例如，当我写完完整的路径时：
val remote = context.actorFor("akka://HelloRemoteSystem@127.0.0.1:5150/sw/opt/programs/akka/akkaremoting/RemoteActor"
浏览 5提问于2014-10-27得票数 0
回答已采纳
1回答
我正在测试在两个游戏之间使用Akka遥控器！v2.1-RC4应用程序。
以下是我来自App1的代码
override def onStart( app: Application ) {
val system = ActorSystem("App1System", ConfigFactory.load.getConfig("app1"))
val remoteActor = Akka.system().actorFor("akka://App2System@127.0.0.1:9003/user/app2Actor")
println(s"
浏览 0提问于2013-02-06得票数 3
回答已采纳
1回答
我正在尝试实现一个基本的广播路由器，其中路由器在远程机器上。
守则如下：
localApp.conf
akka {
log-dead-letters = 10
log-dead-letters-during-shutdown = off
actor {
provider = "akka.remote.RemoteActorRefProvider"
serialize-messages = on
serializers {
java = "akka.serializati
浏览 0提问于2014-02-04得票数 2
回答已采纳
1回答
我正在使用Play 2.1和Scala来连续运行几个测试。我正在做一个Future.traverse(tests)(test => Future(runTest(test))。
我想限制并行运行的测试数量，因此我想限制默认分派程序中的线程数量。
我试着把
play {
akka {
event-handlers = ["akka.event.slf4j.Slf4jEventHandler"]
loglevel = WARNING
actor {
default-dispatcher = {
fork-join-exe
浏览 3提问于2013-06-19得票数 3
现在，我尝试在一个非常简单的用例中使用Akka。我想要一个特定的Actor来处理通过TCP获得的消息，但是我无法做到这一点，而且文档看起来还不够清楚。我现在拥有的是：
Application.conf:
akka {
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
remote {
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = "127.0.0.1
浏览 0提问于2014-07-22得票数 1
回答已采纳
为了实现可伸缩性，我希望在多个远程节点(如host1、host2和host3 )上分发Map actor实例(下面命名为host3)。我不知道在Akka application.conf怎么能做到这一点。
MapReduceSystem {
include "common"
akka {
actor {
deployment {
/mapActor {
router = round-robin
nr-of-instances = 48
remote = "akka.t
浏览 2提问于2013-10-23得票数 0
回答已采纳
我正在开发一个使用Akka持久性进行事件采购的服务。到目前为止，我们已经成功地将事件存储在Cassandra日志中。现在，我们希望通过利用Akka持久性查询来实现CQRS。作为第一种方法，我们尝试遵循集群单例模式，让参与者通过标记流式传输存储的事件。现在，我们有一个相当简单的角色被包装成一个单例： public class EventProcessor extends AbstractLoggingActor {
private static final Logger LOG = LoggerFactory.getLogger(EventProcessor.class);
priv
浏览 17提问于2020-04-01得票数 1
3回答
我只是跟踪akka样本，但无法运行程序。
我安装了akka，sbt(0.13)，scala(2.10.3)使用自制(OSX Mountail Lion)
创建名为akka_test的空目录
创建和文件
在akka_test目录下运行sbt，编译命令运行良好。
sbt的运行命令抱怨没有检测到主类
我该怎么做才能运行这个程序？
这是我的密码
build.sbt
name := "My Project"
version := "1.0"
scalaVersion := "2.10.2"
resolvers +=
浏览 2提问于2013-10-11得票数 8
回答已采纳
1回答
考虑到以下两个演员，Downloader和DownloadActor，后者有一个名为Router的router。
但是，当我运行sbt run时，会得到以下运行时异常：
由: akka.ConfigurationException:路由器akka://Downloader/user/DownloadActor/路由器在“akka.actor.deployment”部分缺少的配置引起。
这是我的密码：
Downloader.scala
object DownloadMain {
val system = ActorSystem("Downloader")
浏览 1提问于2015-01-08得票数 2
回答已采纳
我使用Akka创建了一个scala应用程序。
当我用：scala /Statistics.jar ./server.conf运行它时，它工作得很好。但是如果我把它放在一个服务器上，或者我把它放在一个docker镜像中，当我启动它的时候，应用程序启动后就会立即停止。
以下是我的日志：
...
[DEBUG] [02/01/2017 10:26:13.198] [webserver-akka.actor.default-dispatcher-11] [EventStream(akka://version)] logger log1-Slf4jLogger started
[DEBU
浏览 13提问于2017-02-01得票数 1
回答已采纳
1回答
我试图使用这个scala库，它在创建它的RedisClient对象时需要一个隐式akka.actor.ActorSystem。我在Behaviors.setup方法中使用了Behaviors.setup来提供所需的隐式。
这是我的密码
def apply(): Behavior[Command] = Behaviors.setup { context =>
implicit val system = context.system
implicit val classic = context.system.classicSystem
lazy val redis
浏览 6提问于2021-05-25得票数 0
回答已采纳
1回答
我需要为我的Play 2.1-snapshot使用Akka 2.1 (因为2.1已经被转换为scala.concurrent.Future，而不是来自Akka的旧的Future，所以我认为我将需要使用Akka 2.1的akka.pattern.Patterns.ask )。但是，Play 2.1-snapshot默认配置为2.0.2：
+-------------------------------------------------------------------+---------------------------------------------------------+----
浏览 2提问于2012-09-27得票数 2
回答已采纳
4回答
编辑通知，我需要做这个的反向更改，使接受的答案工作与AKKA2.1，这是稳定的分布发现在akkas主页！
我已经阅读了AKKA上的所有教程，但没有发现任何作品“开箱即用”。
使用eclipse，我想创建2个程序。
Program1:启动演员"joe“，并以某种方式使其在127.0.0.1:some_port上可用
Program2:在127.0.0.1:some_port获得对演员"joe“的引用。给“乔”打个招呼。
当接收到消息时，程序1应该打印一些内容。我想使用AKKA2.1在eclipse中运行这个示例。有人能列出2个程序(program1和program2)，以及一个
浏览 7提问于2013-02-18得票数 7
回答已采纳
1回答
子项目中的Akka消息？
、、、
我有一个消息，我正在通过Akka的集群发送。我有两个后端节点和一个前端节点。后端节点正常启动，但前端节点未启动(关联失败)。
我觉得我对此有一个提示:我有一个有效的配置(前端打开并发送和接收消息很好)，但前端、后端和常见消息都在同一个包中。当我将它们拆分成单独的子项目(通用、前端和后端)时，代码就中断了。为什么会这样，有什么显而易见的原因吗？另外，stacktrace：
[INFO] [10/08/2014 17:00:32.385] [ClusterSystem-akka.actor.default-dispatcher-14] [Cluster(akka://ClusterSystem)]
浏览 1提问于2014-10-09得票数 0
2回答
假设actorRefList是一个可迭代对象，它包含5个元素。每个元素下面的注释行是它的类类型(不包括在可迭代中)。
Actor[akka.tcp:/ /ServerSystem@127.0.0.1:5555/user/ServerActor#318394851]
//class akka.remote.RemoteActorRef
Actor[akka.tcp:/ /Server2System@127.0.0.1:5556/user/Server2Actor#1747632436]
//class akka.remote.RemoteActorRef
Actor[akka:/ /Clie
浏览 1提问于2014-05-04得票数 0
回答已采纳
1回答
我试图向一个远程演员发送消息，但失败了。
我的主要代码是：
RemoteActorDemo.scala
import akka.actor.{Actor, ActorSystem, Props}
object RemoteActorDemo extends App {
val system = ActorSystem("RemoteActorSystem")
val actor = system.actorOf(Props[RemoteActor], name = "RemoteActor")
actor ! "Remote Actor i
浏览 6提问于2015-10-05得票数 0
回答已采纳
我面临着向集群提交作业的问题，无论是通过星星之交还是从java代码。作业不断失败，stderr日志(在SPARK_HOME/work/app_id下)始终显示相同的错误：
15/10/08 23:04:39 WARN ReliableDeliverySupervisor: Association with remote system [akka.tcp://sparkDriver@masternode:53411] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp
浏览 2提问于2015-10-08得票数 0
我创建了一个简单的Actor，它接收来自发件人的消息，并处理该消息，处理后的结果需要发送回发送方。
我试图通过Actor模型和发件人来实现上述需求。
演员守则：
import akka.actor.Actor
import akka.actor.Props
class HelloWorld extends Actor {
var result:Int =0
def receive = {
case dataStr:String =>result =process(dataStr)
sender ! result
}
def process(str
浏览 1提问于2016-10-08得票数 0
回答已采纳
1回答
我试图在我的本地主机上使用AKKA运行远程actors，但每次我都得到这个错误。它说遇到了死信。我在互联网上搜索了一下，发现这个错误是在actors在线程停止后收到消息时出现的。因此，我正在寻找一种方法来保持远程机器上的演员存活。我使用的是akka角色，而不是scala角色。
[INFO] [09/16/2013 18:44:51.426] [run-main] [Remoting] Starting remoting
[INFO] [09/16/2013 18:44:51.688] [run-main] [Remoting] Remoting started; listening on
浏览 2提问于2013-09-17得票数 7
回答已采纳
3回答
下面的类在新的HelloWorld行导致错误：
Exception in thread "main" akka.actor.ActorInitializationException: You cannot create an instance of [HelloWorld] explicitly using the constructor (new). You have to use one of the 'actorOf' factory methods to create a new actor. See the documentation.
at ak
浏览 1提问于2013-08-03得票数 5
回答已采纳
我有一个，它涉及将参与者远程部署到一个单独的进程中。
我要得到的Akka.Remote.EndpointDisassociatedException：
ger/reliableEndpointWriter-akka.tcp%3A%2F%2Fsystem2%40localhost%3A8080-1#1408457 663]与远程系统akka.tcp:// system 2@localhost关联:8080具有faile d；地址现在为5000 ms。原因是: Akka.Remote.EndpointWriter.PublishAndThrow(Exception edException:在Ak
浏览 2提问于2017-03-24得票数 2
回答已采纳
下面是演员，我已经定义了(试图让我的头围绕着坚持的演员！！)
public class Country : ReceivePersistentActor
{
public override string PersistenceId => GetType().Name + state.Id;
private CountryState state;
public Country()
{
Command<CreateCountry>(CreateCountry);
}
private bool CreateCou
浏览 0提问于2016-08-25得票数 0
回答已采纳
有人能解释一下为什么失败吗？它是将Akka文档示例直接复制到规范中的一个副本。我遗漏了什么？
import akka.actor.{ActorSystem, Props, ActorKilledException, Kill}
import akka.testkit.{ TestKit, EventFilter}
import org.scalatest.{FlatSpecLike, BeforeAndAfterAll}
import com.typesafe.config.ConfigFactory
class MySpec()
extends TestKit(ActorSystem
浏览 5提问于2015-11-21得票数 1
回答已采纳
1回答
我的环境是scala akka和play！框架。我想知道是否有任何方法可以控制角色系统的创建或任何其他可以控制的想法。
我的想法是创建当用户点击buy时处理授权的远程actors。
def payment = Action { implicit request =>
var actorObject: Array[String] = new Array[String](23)
val system = ActorSystem("RemoteSystem", ConfigFactory.load.getConfig("remotecreation")
浏览 0提问于2012-09-22得票数 1
2回答
我有一个Actor，它被设计为与akka-io acking一起工作，这样当它向上游(向网络)发送消息时，它将等待Ack。此参与者是后端异步应用程序的接口。
我希望有一个包装层，它允许我将这个Actor转换成一个akka流Flow[Incoming, Outgoing, ???]，这样它就可以与预期有这样一个签名的新库集成起来。
(来自上游的消息很少，所以我们不太在意向后施压，但拥有它并不是一件坏事。)
sealed trait Incoming //... with implementations
sealed trait Outgoing //... with implementation
浏览 3提问于2015-05-27得票数 0
我在和akka.net开玩笑，试着理解监督。我以为我明白了，但它不像我期望的那样起作用。
我试图获得一个带有监视器和子角色的小示例，在该示例中，监视器应该在子进程中的异常情况下重新启动子程序。子程序似乎正在重新启动，但我不明白为什么，因为代码似乎没有执行我的SupervisorStrategy。我改变了我的策略返回Directive.Stop，以检查我是否可以阻止演员，但这也不起作用。所以现在看来，我有一个不可阻挡的演员，这是一件好事，只要我不想杀死它:)。运行示例的代码如下：
open Akka
open Akka.Actor
open Akka.Tools
open Akka.FSharp
浏览 4提问于2016-02-28得票数 3
回答已采纳
我有一个剧本应用程序，一些演员位于另一个ActorSystem中。我试图从play应用程序访问ActorSystem中的参与者(基本上，我将他们连接到REST，即当play应用程序收到帖子时向他们发送消息)。
我正在开始创建这个ActorSystem，我可以从日志中确认它确实正在启动。
让我们假设这个独立系统中的参与者的路径是akka://my- system /user/my- an。我该怎么向那个演员传达信息？
我试过：
Akka.system.actorSelection("akka://my-system/user/my-actor") ! SomeMessage(..
浏览 4提问于2013-11-06得票数 0
回答已采纳
1回答
akka文档()显示camel过程是一个参与者：
class Orders extends Actor with Producer with Oneway {
def endpointUri = "jms:queue:Orders"
}
val sys = ActorSystem("some-system")
val orders = sys.actorOf(Props[Orders])
骆驼生产者和普通演员有什么区别，例如，生产者有邮箱和分派器吗，我可以在我的代码中设置？
浏览 0提问于2013-02-06得票数 0
在Akka 2.10下，我的日志配置在关机期间被重置...导致潜在重要的消息被写入标准输出，而不是日志记录机制。
例如，下面的代码：
String settings =
"akka.event-handlers = [\"akka.event.slf4j.Slf4jEventHandler\"]\n" +
"akka.actor.provider = \"akka.cluster.ClusterActorRefProvider\"";
Config config = ConfigFactory.pa
浏览 1提问于2013-04-13得票数 0
回答已采纳
2回答
我对Akka在创建一个演员系统时承担的责任感到有点困惑。我想要有一个简单的应用程序，其中有一个父actors和两个子actors，每个子actors驻留在不同的进程上(因此驻留在不同的节点上)。现在我知道我可以使用具有远程配置的路由器，或者只是启动一个远程参与者，但是(如果我错了，请纠正我)在创建这个远程参与者时，Akka期望该进程已经存在，并且节点已经在该进程上运行，然后将该子参与者部署到该节点。有没有办法让Akka替我们产卵？
这是不起作用的代码，因为我不是自己创建进程的：
application.conf：
akka {
remote.netty.tcp.port = 2552
浏览 33提问于2017-01-12得票数 1
2回答
我正在尝试通过以下方式运行AKKA远程示例
1. Running the remote actor in a machine with IP 192.168.1.7
2. Running the local from my machine
远程执行元在机器中启动( ip地址为192.168.1.7)；但是当我从我的机器启动本地执行元时，它无法连接到远程执行元。请查找本地和远程执行元系统配置：
本地：
akka {
//loglevel = "INFO"
actor {
provider = "akka.remote.RemoteActorRefProvi
浏览 5提问于2016-02-15得票数 2
1回答
我试着在上运行喷雾模板。
我在第5步得到错误(启动应用程序)
[ERROR] [04/26/2015 12:49:18.613] [on-spray-can-akka.actor.default-dispatcher-4] [akka://on-spray-can/user/IO-HTTP/listener-0] 762
akka.actor.ActorInitializationException: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:164)
浏览 2提问于2015-04-26得票数 3
1回答
我正在用akka库在java中创建参与者来实现Chord系统。我的目标是让两个演员互相发送信息。但是，当我这样做时，我会得到以下错误消息：
[INFO] [12/24/2015 15:27:33.521] [globalSystem-akka.actor.default-dispatcher-5] [akka://globalSystem/user/ChordActor3] Message [messages.SuccessorFoundMessage] from Actor[akka://globalSystem/user/ChordActor0#1781934127] to Actor[a
浏览 0提问于2015-12-24得票数 0
回答已采纳
下面是一个简单的参与者，它需要进行HTTP调用才能从API接收数据。根据，只需要ActorSystem和ActorMaterializer。
class MyActor extends Actor {
import context.system
implicit val materializer = ActorMaterializer()
override def receive: Receive = {
case _ => {
val responseFuture: Future[HttpResponse] = Http().singleReques
浏览 2提问于2015-08-27得票数 7
回答已采纳
从Akka获取序列化错误，如下面所示，如何对您的Akka消息中冒犯的不可序列化成员/字段进行包装？异常确实指出了不能序列化的成员值(在com.our.member.object下面)，但该对象包含许多嵌套成员本身，错误消息似乎对不能序列化的违规嵌套对象没有什么线索：
2018-05-24T06:30:51.897Z错误VCA-akka.actor.default-dispatcher-4 akka.remote.EndpointWriter -未能使用序列化器类akka.remote.EndpointWriter序列化远程消息类akka.actor.ActorSelectionMessage
浏览 1提问于2018-05-24得票数 0
回答已采纳
1回答
我有一个问题，在关于Akka Streams和Akka Actors的文档中，我感到非常困惑。
因为docs说Akka流不能集群，并且它们运行在ActorSystem和Materializer上。所以..。
ActorSystem("some-actor-system")实现是否是集群的？
我看到了一些ActorSystem的集群实现，但是如何或者如何实现非集群ActorSystem？
浏览 3提问于2018-02-06得票数 0
回答已采纳
1回答
线程计数过多问题
、、
我有一些关于PlayFramework中线程名称的问题。我已经在游戏上开发了大约5个月的Rest-API服务。该应用程序只需访问MySQL，并将json格式的数据发送回客户端。我已经理解了“阻塞io”的缺陷，所以我创建了一个用于阻塞io的线程池，并在阻塞线程执行的所有Future块中使用它。线程池的定义如下。
akka {
actor-system = "myActorSystem"
blocking-io-dispatcher {
type = Dispatcher
executor = "thread-pool-executor"
浏览 3提问于2018-06-01得票数 0
1回答
我正在使用Akka HTTP和java开发一个简单的REST API。在成功完成请求-响应周期后，获得如下信息。 [INFO] [01/30/2019 10:35:04.176] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/2] Message [akka.io.TcpConnection$Unregistered$] from Actor[akka://default/system/IO-TCP/selectors/$a/2#-1193182068] to Ac
浏览 33提问于2019-01-30得票数 3
1回答
是否有可能和/或有必要关闭阿克卡的一个远程演员？
我可以将akka.actor.ActorSystem作为“服务器”启动(在scala中)：
val actorSystem = ActorSystem("TestServer")
val actor = actorSystem.actorOf(..., name = "TestActor")
然后从运行在独立JVM上的“客户端”ActorSystem连接到它：
remote = context.actorSelection("akka.tcp://TestServer@localhost:1234/us
浏览 4提问于2015-04-01得票数 1
回答已采纳
我正在处理类型化的akka应用程序，出于某种原因，我需要使用来自类型化上下文的非类型化角色。
我编写了一个简单的测试来尝试BehaviorTestKit，并输入了BehaviorTestKit。对于类型化的参与者，它可以工作，但是对于一个具有非类型化子角色的演员，我会得到“只有适应的非类型化的ActorContext允许的”错误。
下面是家长演员：
public class AppGuardianTest extends AbstractBehavior<String> {
private ActorContext context;
public AppGuard
浏览 1提问于2019-02-11得票数 1
我正在用Scala和Akka建模一个简单的P2P：
class Node() extends Peer with Actor {
var peers: List[ActorRef] = List()
def receive = {
case _register(peer: ActorRef, p: Option[Int]) => {
println("registering [" + peer + "] for [" + this + "]")
peers = peer :: peers
浏览 3提问于2012-04-10得票数 6
回答已采纳
嗨，我正在用Play Framework测试压力测试工具。每当我用不同的坡道运行测试时，在达到大约5k请求后，就会出现以下错误，请求总数为10k。是否有限制有多少请求播放可以处理每一段时间？下面的错误是什么？
java.net.SocketException: Too many open files in system
at sun.nio.ch.Net.socket0(Native Method) ~[na:1.7.0_25]
at sun.nio.ch.Net.socket(Net.java:423) ~[na:1.7.0_25]
at sun.nio.ch.Net.socket(Net.
浏览 5提问于2014-06-08得票数 1
回答已采纳
1回答
我正在尝试使用alpakka消费来自kafka的消息。我没有从akka参与者那里得到任何消费者已经停止的错误，但它没有消费任何消息。下面是我的代码
val consumerSettings = ConsumerSettings(GatewaySettings.DataPlatformKafkaConsumer.kafkaConsumer, new StringDeserializer, new StringDeserializer)
.withBootstrapServers(bootstrapServers)
.withGroupId(groupId)
.
浏览 19提问于2019-10-27得票数 0
我编写了一个实现设备管理的Akka应用程序。每个设备都是一个Akka Actor，我实现了Akka有限状态机来控制设备的生命周期，比如FUNCTIONAL，BROKEN，IN_REPAIRS，RETIRED，etc...and I Persistence the Device with Akka Persistence to Cassandra。
每件事都像一个梦，但我有两难的境地，我想问一下处理Akka的模式是什么。
我将有近1,000,000个设备，Akka是管理这些单个实例的理想选择，但我如何实现，如果用户一个看到所有设备系统并选择一个，更改它是状态...
我不能从Akka日志表中显示它
浏览 7提问于2021-11-27得票数 0
1回答
我有一个Scala + Akka + Gradle应用程序和以下测试：
class UserCRUDSpec() extends TestKit(ActorSystem("UserCRUDSpec"))
with ImplicitSender
with WordSpecLike
with Matchers
with Mockito
with DomainSuit {
val userDao: UserDao = mock[UserDao]
val actor: ActorRef = system.actorOf(UserCRUD.props(sel
浏览 12提问于2018-08-13得票数 2
通过在网络上搜索，我可以进行单向对话，但是当接收者在其控制台中输入任何东西时，它会给出如下错误，并且还想知道分布式akka系统是如何在java上工作的，我从那里得到了一些帮助，但它是在.net中。
请帮助我创建一个基于java的distrebute系统。
[ERROR] [12/10/2015 11:04:41.414] [default-akka.remote.default-remote-dispatcher-8] [NettyTransport(akka://default)] failed to bind to /10.208.19.135:8091, shutting down Ne
浏览 0提问于2015-12-10得票数 0
回答已采纳
1回答
我已经创建了一个Actor，它可以执行一些基本的操作，并且看起来工作正常-不过，我经常在日志中看到下面的内容
[INFO] [05/28/2014 14:24:00.673] [application-akka.actor.default-dispatcher-5] [akka://application/deadLetters] Message [akka.actor.Status$Failure] from Actor[akka://application/user/trigger_worker_supervisor#-2119432352] to Actor[akka://applica
浏览 2提问于2014-05-28得票数 14
回答已采纳
1回答
我运行了一个scala / play 2.0.4应用程序。在本地一切正常，我可以通过"play run“启动服务。现在，我想将应用程序导出到prod服务器。我使用播放命令"dist"，并解压服务器上的文件。但是如果我启动这个服务，我会在几个操作上得到一个异常：
play.core.ActionInvoker$$anonfun$receive$1$$anon$1: Execution exception [[RuntimeException: java.lang.NoSuchMethodError: com..webapp.services.Backend.getCiti
浏览 1提问于2012-12-05得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
