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 中避免 while 循环有什么好处吗？

阅读专家撰写的 Scala 文档可以得到这样的印象尾递归比 while 循环更好即使后者更简洁更清晰这是一个例子 object Helpers implicit class IntWithTimes val pip Int Recu
scala案例类复制实现

我找不到 scala 中案例类的复制是如何实现的我可以以某种方式检查一下吗我虽然 Intellij 可以指出我的实现但它不想跳转我不知道为什么您可以使用以下命令检查 scala 案例类输出scalac print ClassNam
在 Scala Spark 和 PySpark 之间传递 SparkSession

我的要求是从现有的 PySpark 程序调用 Spark Scala 函数将 PySpark 程序中创建的 SparkSession 传递给 Scala 函数的最佳方法是什么我将 scala jar 传递给 Pyspark 如下所示 s
将高度嵌套的列从字符串更新为结构

x array nullable true element struct containsNull true y long nullable true z array nullable true element struct contain
我什么时候应该使用 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
使用 Apache Commons File Upload 解析 multipart/form-data

Apache Commons File Upload 包是否提供了流解析的通用接口multipart form data块通过InputStream 附加Array
“特征”和“模板特征”有什么区别？

查看 Traversable 和 TraversableLike 的 scaladoc 我很难弄清楚它们之间的区别除了一个扩展了另一个文档中唯一明显的区别是它说 Traversable 是一种特征而 TraversableLike
为什么 SimpleDateFormat 解析错误的日期？

我有字符串格式的日期我想将其解析为实用日期 var date 03 11 2013 我将其解析为 new SimpleDateFormat MM dd yyyy parse date 但奇怪的是如果我通过 03 08 201309 hj
Scala 是一个更好的 println

我经常发现自己在做这样的事情 println foo 当我想做的时候 println foo 编译器不允许这样做还有 println很拗口我真的只想说 echo foo 因此在基础包对象中我创建了 println 的 echo 版本
输入spark-shell时找不到spark提交

我一直在按照本教程为 scala 安装 Spark https www tutorialspoint com apache spark apache spark installation htm https www tutorialspoi
在elastic4s上找不到值索引错误

我尝试使用以下方法将一些数据索引到弹性搜索弹性4s https github com sksamuel elastic4s API 但我收到编译错误not found value index 这是代码稍后我会将 js 对象字段映射到弹性搜
Scala 转换为变量类型

我有以下代码要投射value的类型default def fct T value Any default T T val result value asInstanceOf T println result result getClass
是否可以写一个不可变的双向链表？

我觉得问这个问题有点愚蠢但我目前正在学习函数式编程并完成了创建单链表的练习这让我开始思考是否有可能创建一个不可变的双链表假设列表 A B 在构造时 A 需要了解 B 但 B 也需要了解 A 我一直在 Scala 中这样做所以我不确
是否可以写一个不可变的双向链表？

我觉得问这个问题有点愚蠢但我目前正在学习函数式编程并完成了创建单链表的练习这让我开始思考是否有可能创建一个不可变的双链表假设列表 A B 在构造时 A 需要了解 B 但 B 也需要了解 A 我一直在 Scala 中这样做所以我不确
将元素添加到向量末尾

斯卡拉文档 http www scala lang org api current index html scala collection immutable Vector解释如何向 Vector 添加元素 def elem A Vecto
创建SparkContext失败

我正在用 scala 代码在 Spark shell 中测试 Spark 我正在构建使用 Kafka 和 Spark 的原型我跑了spark shell像下面这样 spark shell jars spark external kafka
Akka 2.0 RC2 中远程 Actor 部署出现错误

我正在尝试创建一个 actor 并将其部署到我的计算机的端口 1997 如下所示在application conf中 akka version 2 0 RC2 event handlers akka event Logging Defau
IntelliJ IDEA 10.5 的 Scala 案例类中的部分 EMMA 代码覆盖率

我正在使用 IntelliJ IDEA 10 5 以及 8 月 14 日更新的 Scala 插件 v0 4 1338 和 Scala 2 9 0 1 我最近开始使用 IDEA 中的 EMMA 测试覆盖率实用程序来生成覆盖率报告我无法确定为

随机推荐

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 部署出现错误的相关文章