草庐IT

akka-remote-actor

全部标签

Java WebSockets : The remote endpoint was in state [TEXT_FULL_WRITING]

我正在尝试实现一些基于websockets的应用程序,它将与JS客户端进行非常密集的通信。发送消息的代码非常原始:synchronized(session){if(session.isOpen()){session.getBasicRemote().sendText(message);}}对于罕见的发送它工作得很好,但是当少数线程试图通过同一个session(套接字)发送一些消息时,会抛出下一个异常(请注意这不是多线程问题,因为代码块是由session同步的):java.lang.IllegalStateException:Theremoteendpointwasinstate[TEX

java - Jenkins 生成错误 java.lang.ClassNotFoundException : hudson. remoting.Launcher

我正在尝试将jenkins与svn集成。我已经配置了maven_home、java_home(java1.5update22)。我正在使用jenkins版本1.459。我的一位同事成功地使用svn配置了jenkins。但现在我们使用的是不同的分支,我想添加一个新的工作,以便它从新的分支结帐并持续集成项目。Jenkins在一台远程linux机器上运行,我使用vpn连接到服务器并设置这些东西。我错过了什么。Moduleschanged,recalculatingdependencygraph[workspace]$/usr/lib/jvm/jdk1.5.0_22/bin/java-cp/h

java - 在 Java 中向 Actor 发送 PoisonPill

我开始通过将现有的JavaSE应用程序迁移到Akka来学习它。我正在使用Akka2.0.3。有一次我需要通过消息队列发送一个PoisonPill来停止actors。我的Actor是这样实例化的:ActorRefmyActor=actorSystem.actorOf(newProps(MyActor.class),"myActor");我尝试向其发送PoisonPill:myActor.tell(PoisonPill.getInstance());但我得到以下编译器错误:'tell(java.lang.Object)'in'akka.actor.ActorRef'cannotbeappl

java - Akka 中的轻量级线程

我最近读到Quasar它为JVM提供“轻量级”/类似Go的“用户模式”线程(它也有一个Erlang启发的Actor系统,比如Akka但这不是主要问题)例如:packagejmodern;importco.paralleluniverse.fibers.Fiber;importco.paralleluniverse.strands.Strand;importco.paralleluniverse.strands.channels.Channel;importco.paralleluniverse.strands.channels.Channels;publicclassMain{publ

java - 在 java 中为 actorsystem 禁用 akka.jvm-exit-on-fatal-error

我正在使用akkaactor系统进行多线程处理。它在正常用例中运行良好。但是,Akka会在发生fatalerror时关闭JVM。请告诉我如何配置Akka以禁用java中的“akka.jvm-exit-on-fatal-error”。下面是代码。publicclassQueueListenerimplementsMessageListener{privateString_queueName=null;publicstaticbooleanisActorinit=false;publicstaticActorSystemsystem=null;privateActorRefmyActor;

java - akka actors 工具包 - context.actorOf 与 system.actorOf

你能给我解释一下之间的区别吗context.actorOf和system.actorOf? 最佳答案 这个问题的答案很容易在Akka文档中找到:AnactorsystemistypicallystartedbycreatingactorsbeneaththeguardianactorusingtheActorSystem.actorOfmethodandthenusingActorContext.actorOffromwithinthecreatedactorstospawntheactortree.使用System.actorOf

java - 分布式系统中的参与者(Akka)和代理(JADE)有什么区别?

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭5年前。ImprovethisquestionAkkaactor和Jadeagent的概念有什么本质区别吗?据我所知,两者都通过创建独立的实体(具有系统逻辑block)来实现系统分发,这些实体可以通过在它们之间发送消息进行通信。是否有其他因素使它们不同(例如性能或预期用途)?

无法在Git Remote服务器上结帐?

我使用gitinit--bare并添加以下post-receive钩子#!/bin/shdest=/home/git/apirm-rf$destmkdir-p$destGIT_WORK_TREE=$destgitcheckout--force问题是我不断出现错误远程:致命:此操作必须在工作树上运行我不明白这个错误在哪里出错?看答案裸露的存储库中没有工作树。因此,您必须克隆回购并添加钩子。

java - 知道akka actor存在的三种方法

我正在研究akkaactors(JAVA),最近了解到有3种方法(可能更多)可以了解actor的存在。发送身份信息:ActorSelectionsel=actorSystem.actorSelection("akka://test/user/TestActor");AskableActorSelectionasker=newAskableActorSelection(sel);Futurefuture=asker.ask(newIdentify(1),newTimeout(5,TimeUnit.SECONDS));ActorIdentityidentity=(ActorIdentity

java - Akka.io,在类 Actor 上找不到匹配的构造函数

我正在尝试设置Akkaactor来处理游戏中的网络套接字。我已经定义了一个简单的actor来通过网络套接字发送消息:packageactors;importakka.actor.*;publicclassMyWebSocketActorextendsUntypedActor{publicstaticPropsprops(ActorRefout){returnProps.create(MyWebSocketActor.class,out);}privatefinalActorRefout;publicMyWebSocketActor(ActorRefout){this.out=out;}