Akka 2.0 RC2 中远程 Actor 部署出现错误

2024-07-04

我正在尝试创建一个 actor 并将其部署到我的计算机的端口 1997，如下所示：

在application.conf中：

akka {
    version = "2.0-RC2"
    event-handlers = ["akka.event.Logging$DefaultLogger"]
    loglevel = "DEBUG"
    actor {
        provider = "akka.remote.RemoteActorRefProvider"
        timeout = 60m
        deployment {
            /bar {
                remote = "akka://[email protected] /cdn-cgi/l/email-protection:1997"
            }
        }
    }

    remote {
        transport = "akka.remote.netty.NettyRemoteTransport"
    }
}

在主要方法中：

val system = ActorSystem("Foo")
system.actorOf(Props[BarActor], "bar")

启动应用程序后，我收到以下错误：

[DEBUG] [02/28/2012 18:17:43.917] [Foo-akka.actor.default-dispatcher-2] [RemoteActorRefProvider(null)] [akka://Foo/] Instantiating Remote Actor [akka://[email protected] /cdn-cgi/l/email-protection:1997/remote/[email protected] /cdn-cgi/l/email-protection:2552/user/bar]
[DEBUG] [02/28/2012 18:17:43.933] [Foo-akka.actor.default-dispatcher-2] [RemoteClient(akka://Foo)] Starting remote client connection to [akka://[email protected] /cdn-cgi/l/email-protection:1997|/127.0.0.1]
[ERROR] [02/28/2012 18:17:45.136] [Foo-akka.actor.default-dispatcher-2] [ActorSystem(Foo)] REMOTE: RemoteClientError@akka://[email protected] /cdn-cgi/l/email-protection:1997: Error[java.net.ConnectException:Connection refused: no further information
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:701)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:400)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:362)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:284)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
]
[ERROR] [02/28/2012 18:17:45.136] [Foo-6] [ActorSystem(Foo)] REMOTE: RemoteClientError@akka://[email protected] /cdn-cgi/l/email-protection:1997: Error[java.net.ConnectException:Connection refused: no further information
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:701)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:400)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:362)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:284)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
]
[DEBUG] [02/28/2012 18:17:45.152] [Foo-akka.actor.default-dispatcher-2] [akka.serialization.Serialization(akka://Foo)] Using serializer[akka.serialization.JavaSerializer] for message [akka.remote.DaemonMsgCreate]
[ERROR] [02/28/2012 18:17:45.198] [Foo-7] [ActorSystem(Foo)] REMOTE: RemoteClientError@akka://[email protected] /cdn-cgi/l/email-protection:1997: Error[java.nio.channels.ClosedChannelException:null
at org.jboss.netty.channel.socket.nio.NioWorker.cleanUpWriteBuffer(NioWorker.java:637)
at org.jboss.netty.channel.socket.nio.NioWorker.writeFromUserCode(NioWorker.java:364)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:119)
at org.jboss.netty.channel.Channels.write(Channels.java:626)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:65)
at org.jboss.netty.channel.Channels.write(Channels.java:626)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:65)
at org.jboss.netty.handler.execution.ExecutionHandler.handleDownstream(ExecutionHandler.java:165)
at org.jboss.netty.channel.Channels.write(Channels.java:605)
at org.jboss.netty.channel.Channels.write(Channels.java:572)
at org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:245)
at akka.remote.netty.RemoteClient.send(Client.scala:75)
at akka.remote.netty.RemoteClient.send(Client.scala:62)
at akka.remote.netty.NettyRemoteTransport.send(NettyRemoteSupport.scala:136)
at akka.remote.RemoteActorRef.$bang(RemoteActorRefProvider.scala:247)
at akka.remote.RemoteActorRefProvider.useActorOnNode(RemoteActorRefProvider.scala:202)
at akka.remote.RemoteActorRefProvider.actorOf(RemoteActorRefProvider.scala:173)
at akka.actor.ActorCell._actorOf(ActorCell.scala:237)
at akka.actor.ActorCell.actorOf(ActorCell.scala:254)
at akka.actor.LocalActorRefProvider$Guardian$$anonfun$receive$1.liftedTree1$1(ActorRefProvider.scala:406)
at akka.actor.LocalActorRefProvider$Guardian$$anonfun$receive$1.apply(ActorRefProvider.scala:406)
at akka.actor.LocalActorRefProvider$Guardian$$anonfun$receive$1.apply(ActorRefProvider.scala:404)
at akka.actor.Actor$class.apply(Actor.scala:292)
at akka.actor.LocalActorRefProvider$Guardian.apply(ActorRefProvider.scala:400)
at akka.actor.ActorCell.invoke(ActorCell.scala:489)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:178)
at akka.dispatch.Mailbox.run(Mailbox.scala:160)
at akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec(AbstractDispatcher.scala:479)
at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259)
at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:997)
at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1495)
at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
]
[WARN] [02/28/2012 18:17:45.198] [Foo-akka.actor.default-dispatcher-2] [ActorSystem(Foo)] REMOTE: RemoteClientWriteFailed@akka://[email protected] /cdn-cgi/l/email-protection:1997: MessageClass[scala.Tuple3] Error[java.nio.channels.ClosedChannelException:null
at org.jboss.netty.channel.socket.nio.NioWorker.cleanUpWriteBuffer(NioWorker.java:637)
at org.jboss.netty.channel.socket.nio.NioWorker.writeFromUserCode(NioWorker.java:364)
at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:119)
at org.jboss.netty.channel.Channels.write(Channels.java:626)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:65)
at org.jboss.netty.channel.Channels.write(Channels.java:626)
at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:65)
at org.jboss.netty.handler.execution.ExecutionHandler.handleDownstream(ExecutionHandler.java:165)
at org.jboss.netty.channel.Channels.write(Channels.java:605)
at org.jboss.netty.channel.Channels.write(Channels.java:572)
at org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:245)
at akka.remote.netty.RemoteClient.send(Client.scala:75)
at akka.remote.netty.RemoteClient.send(Client.scala:62)
at akka.remote.netty.NettyRemoteTransport.send(NettyRemoteSupport.scala:136)
at akka.remote.RemoteActorRef.$bang(RemoteActorRefProvider.scala:247)
at akka.remote.RemoteActorRefProvider.useActorOnNode(RemoteActorRefProvider.scala:202)
at akka.remote.RemoteActorRefProvider.actorOf(RemoteActorRefProvider.scala:173)
at akka.actor.ActorCell._actorOf(ActorCell.scala:237)
at akka.actor.ActorCell.actorOf(ActorCell.scala:254)
at akka.actor.LocalActorRefProvider$Guardian$$anonfun$receive$1.liftedTree1$1(ActorRefProvider.scala:406)
at akka.actor.LocalActorRefProvider$Guardian$$anonfun$receive$1.apply(ActorRefProvider.scala:406)
at akka.actor.LocalActorRefProvider$Guardian$$anonfun$receive$1.apply(ActorRefProvider.scala:404)
at akka.actor.Actor$class.apply(Actor.scala:292)
at akka.actor.LocalActorRefProvider$Guardian.apply(ActorRefProvider.scala:400)
at akka.actor.ActorCell.invoke(ActorCell.scala:489)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:178)
at akka.dispatch.Mailbox.run(Mailbox.scala:160)
at akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec(AbstractDispatcher.scala:479)
at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259)
at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:997)
at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1495)
at akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
]
[DEBUG] [02/28/2012 18:17:45.198] [Foo-akka.actor.default-dispatcher-3] [RemoteClient(akka://Foo)] Shutting down remote client [ActiveRemoteClient@akka://[email protected] /cdn-cgi/l/email-protection:1997]
[INFO] [02/28/2012 18:17:45.198] [Foo-akka.actor.default-dispatcher-3] [ActorSystem(Foo)] REMOTE: RemoteClientShutdown@akka://[email protected] /cdn-cgi/l/email-protection:1997
[DEBUG] [02/28/2012 18:17:45.198] [Foo-akka.actor.default-dispatcher-3] [RemoteClient(akka://Foo)] [ActiveRemoteClient@akka://[email protected] /cdn-cgi/l/email-protection:1997] has been shut down

我一定做错了什么，但我只是不明白我所做的与 Akka 2.0 RC2 文档所说的不同。帮助！

无论我使用配置文件方法还是 Akka 2.0 RC2 文档中提到的编程部署方法，都会出现同样的问题。

None

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

scala

akka

Akka 2.0 RC2 中远程 Actor 部署出现错误的相关文章

在 Scala 中实现“.clone”

我正在想办法 clone我自己的对象在 Scala 中这是为了模拟因此可变状态是必须的由此产生了克隆的全部需要在提前模拟时间之前我将克隆整个状态结构这是我目前的尝试 abstract trait Cloneable A See
IntelliJ、Akka 和配置文件

使用时akka http akka io 我放置akka conf in src main resources 当我run通过 sbt akka conf被正确识别但当我运行 IntelliJ 时却没有即使在gen idea 实现这一目
如何创建独立的电梯 Web 应用程序？

如何制作独立的电梯应用程序使用哪些工具库与在某些应用程序服务器中使用 lift 应用程序作为战争相比性能如何使用 onejar maven 插件http onejar maven plugin googlecode com svn
我什么时候应该使用 Scala 的数组而不是其他集合之一？

这更多的是风格和偏好的问题但这里是我什么时候应该使用 scala Array 我一直使用 List 偶尔会遇到 Seq Map 等但我从未在野外使用或见过 Array 仅仅是为了兼容 Java 吗我错过了一个常见的用例吗首先我们
FSC 每次都会重新编译

即使没有必要 FSC 每次都会重新编译我的 scala 文件我可以编译它两次而无需在尝试之间编辑任何内容并且它会重新编译它们例如我有2个文件你好 scala class Hello print hello 和 Tokens sca
在特征中定义值比定义有什么优势吗？

在 Scala 中一个val可以覆盖一个def 但是一个def不能覆盖val 那么声明一个特质有什么好处吗像这样 trait Resource val id String 而不是这个 trait Resource def id Str
Akka Stream Kafka 与 Kafka Streams

我目前正在与Akka 流卡夫卡 http doc akka io docs akka stream kafka current home html与卡夫卡互动我想知道与卡夫卡有什么区别卡夫卡流 https kafka apache org
Scala 中的预期开始定义错误

我正在尝试运行中提供的 Scala 代码这个 math stackexchange 帖子 https math stackexchange com questions 1233656 albert bernard and cheryl po
“特征”和“模板特征”有什么区别？

查看 Traversable 和 TraversableLike 的 scaladoc 我很难弄清楚它们之间的区别除了一个扩展了另一个文档中唯一明显的区别是它说 Traversable 是一种特征而 TraversableLike
Scala 中的 JSON 模式验证器

我需要验证收到的某些 JSON 输入的架构我不清楚如何处理整个事情但这是我迄今为止收集到的我需要使用类似的东西为各种输入准备一个模式http json schema org implementations html http json
如何在 Spark 2.1 中保存分区的 parquet 文件？

我正在尝试测试如何使用 Spark 2 1 在 HDFS 2 7 中写入数据我的数据是一个简单的虚拟值序列输出应按属性进行分区 id and key Simple case class to cast the data case cla
udf 没有可用于字符串类型的 TypeTag

我不明白火花的行为我创建一个 udf 它返回一个如下所示的整数 import org apache spark sql SQLContext import org apache spark SparkConf SparkContext o
为什么 Scala 类型推断在这里失败？

I have 这个班 http jamesgolick com 2010 2 8 monkey patching single responsibility principle and scala implicits html在斯卡拉中 o
输入spark-shell时找不到spark提交

我一直在按照本教程为 scala 安装 Spark https www tutorialspoint com apache spark apache spark installation htm https www tutorialspoi
输入spark-shell时找不到spark提交

我一直在按照本教程为 scala 安装 Spark https www tutorialspoint com apache spark apache spark installation htm https www tutorialspoi
将元素添加到向量末尾

斯卡拉文档 http www scala lang org api current index html scala collection immutable Vector解释如何向 Vector 添加元素 def elem A Vecto
如何迭代scalawrappedArray？（火花）

我执行以下操作 val tempDict sqlContext sql select words pName token collect set words pID as docids from words group by words p
Scala：如何按元组的第二个元素对元组数组进行排序？

Scala 有没有办法使用任意比较函数对元组数组进行排序特别是我需要按元组的第二个元素对元组进行排序和数组但我想知道对元组数组进行排序的通用技术 Thanks 在scala 2 8中有一个方法sortBy 这是一个简单的用例 sca
如何使用 Spark SQL 解析 JSON 对象数组

现在 JSON 数据如下 Id 11 data package com browser1 activetime 60000 package com browser6 activetime 1205000 package com browse
为什么Scala 支持影子变量？ [关闭]

就目前情况而言这个问题不太适合我们的问答形式我们希望答案得到事实参考资料或专业知识的支持但这个问题可能会引发辩论争论民意调查或扩展讨论如果您觉得这个问题可以改进并可能重新开放访问帮助中心 help reopen questi

随机推荐

Haskell Stack 构建特定的可执行文件

如何构建特定的堆栈可执行文件即那些指定的projectname cabal like executable executable name hs source dirs tools main is ExecutableModule hs
确定 Node js 中读取流的长度

我想知道是否有一种简单的方法来确定节点js中readStream的长度我正在编写一个工作程序来将 PDF 上传到 S3 但它出现错误无法确定 object PDFDocument 的长度 pdf 是一个可读流我可以将其传输到当前内存中
在 Rails 中，如何在使用 javascript_include_tag 之前检查 javascript 文件是否存在

在 Rails 3 2 应用程序中我想在将 javascript include tag 包含在文件中之前检查资产管道中是否存在 javascript 文件就像是我想这样做这样没有 javascript 文件就不会导致错误有没有办
渲染 Drupal 节点

我想显示另一个节点内的一个节点因此我检索第二个节点的节点 ID 并且我想在另一个节点内渲染打印它但我不知道该怎么做我试过了drupal render node view print 但没有结果有什么建议吗 nid node g
在 MATLAB 中选择矩阵的对角线元素

考虑 MATLAB 中的以下矩阵 01 02 03 04 05 06 07 08 09 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 3
为什么设置表的 RecNo 属性不会移动到该记录？

我有一个 TTable 组件它使用 BDE 访问 DBase 表表上没有索引因此排序顺序是表中记录的物理顺序如果我读取 RecNo 属性它包含当前记录的预期编号我的印象是使用这个星座 BDE DBase 还可以设置 RecNo
Web 配置文件中的连接字符串出现问题

我正在尝试在 Web 配置文件中设置 mysql 连接这是连接字符串代码
Jackson 使用枚举键、POJO 值反序列化为 Map

我正在尝试使用 Jackson 将 JSON 反序列化为 Java POJO 在不泄露机密信息的情况下下面是 ObjectMapper 反序列化失败时的堆栈跟踪示例 org codehaus jackson map JsonMapping
构建高效的数独求解器

是的我知道这不是什么新鲜事而且已经有很多问题了它甚至有自己的标签但我想用 Java 创建一个数独求解器仅仅是为了训练自己编写更多的代码高效的在程序中执行此操作的最简单方法可能是使用大量 for 循环解析每一列和行收集每个单元格
在超级构造函数运行之前初始化字段？

在Java中有什么方法可以在超级构造函数运行之前初始化字段吗即使是我能想到的最丑陋的黑客也会被编译器拒绝 class Base Base String someParameter System out println this clas
TypeScript 项目中的 TypeORM 应该如何配置才能在任何地方工作？

我正在努力寻找适用于所有环境中 TypeScript 项目中的 TypeORM 的配置例如从这个开始ormconfig js var dotenv require dotenv dotenv config var connectionO
Maven 将辅助文件部署到存储库

我希望与我的 jars wars 等一起部署 XML 文件我可以使用分类器手动执行此操作 mvn deploy deploy file DgroupId GROUP ID DartifactId ARTIFACT ID Dversion
Android 小部件中的可编辑文本视图

嗨我是 android 编程新手我正在尝试使用输入文本框创建主屏幕小部件我四处搜索到目前为止发现 EditText 不适用于主屏幕我还发现 TextView 可以使其可编辑但我仍然不知道它是如何工作的所以我想让 TextVi
如何使用 ColdFusion ORM 映射基类？

我有两个组件一个基础Entity成分
Java EE 7 - @Decorator、@Stateless 和 @PersistenceContext = nullpointerException

我在 java ee 7 glassfish 4 中使用装饰器模式我有这个装饰器 Decorator public class FooIndexer implements FooService Inject Delegate FooSer
Swift：根据日期对获取的核心数据子实体进行排序

介绍我正在制作一个日历应用程序在其中使用核心数据存储事件其组成为 DateKey作为父级具有一对多关系 CalendarEventModel 这个概念是DateKey包含 yyyy dd MM 日期字符串当天发生的所有事件都作为子
什么是无操作系统裸机 Cortex M3 的开源数据存储

我正在寻找有关用 C 编写的数据存储的建议该数据存储将在没有任何操作系统的情况下为 ARM Cortex M3 进行编译我希望它是用C写的最好是免费和或开源的可以用GCC编译适用于裸机处理器无需操作系统或文件系统支持可以是
如何更改 PostgreSQL 中的“REFERENCES”？

当表名更改时如何更改对 PostgreSQL 中表的引用假设我有 CREATE TABLE example1 id serial NOT NULL PRIMARY KEY name varchar 100 CREATE TABLE ex
pytest 中的分组测试：类与普通函数

我正在使用 pytest 来测试我的应用程序 pytest 支持两种据我所知编写测试的方法在课堂上 test feature py gt 类 TestFeature gt def test feature sanity 在函数中 te
Akka 2.0 RC2 中远程 Actor 部署出现错误

我正在尝试创建一个 actor 并将其部署到我的计算机的端口 1997 如下所示在application conf中 akka version 2 0 RC2 event handlers akka event Logging Defau

Akka 2.0 RC2 中远程 Actor 部署出现错误

Akka 2.0 RC2 中远程 Actor 部署出现错误 的相关文章

随机推荐

热门标签

Akka 2.0 RC2 中远程 Actor 部署出现错误的相关文章