akka-zeromq

0열

1답변

scala에서 zeromq 확장을 사용하려고하지만 sbt로 컴파일이 실패합니다. import akka.zeromq._ 여기 오류가 있습니다. object zeromq is not a member of package akka build.sbt 파일은 아래와 같다; name := "Akka Test" version := "1.0" scalaVer

0열

1답변

게시자가 무한 루프에서만 메시지를 전송합니다.

다음 제어 흐름이 있습니다. for 루프에서 문자열 배열을 만듭니다. 배열의 각 행 (문자열)을 게시자 함수로 보냅니다. 그런 다음 게시자 함수는 문자열을 전송해야합니다. 게시자가 무한 루프에 게시하는 경우 구독자가 메시지를 수신하는 경우에만 문제가 발생합니다. 지속적으로 게시자 기능을 호출하여 데이터를 보내지 못하는 이유는 무엇입니까? 무한 루프에서만 작

1열

2답변

Akka - ZMQ 가입자 만들기 오류 (여론 조사)

나는 성공적으로 출판사를 만들었지 만 다음을 사용하여 가입자를 작성하는 데 실패 : public static void main(String [] args) { ActorSystem system = ActorSystem.create("System"); ActorRef subscriber = system.actorOf(new Pr

0열

2답변

Zeromq 클라이언트 요청을 기다리지 못하게하는 C++ 서버 프로그램을 작성하는 방법

Zeromq Hello world 예제를 서버 및 클라이언트에 사용하려고합니다. 아래의 예제 코드 // // Hello World client in C++ // Connects REQ socket to tcp://localhost:5555 // Sends "Hello" to server, expects "World" back // #include

0열

1답변

Akka - zeromq 소켓/배우 내가 akka-zeromq를 사용하여 zeromq에서 메시지를 수신하는 간단한 배우를 구현하기 위해 노력하고있어 메시지

Questuion 를받을 수 없습니다. import akka.actor._ import akka.zeromq._ class PullActor extends Actor { def receive = { case x => println("M: " + x.toString) } } object Main extends App {

1열

1답변

ZeroMQ로 Akka MapReduce 구성을 할 수 있습니까?

저는 Akka를 처음 접했고 여러 분산 패턴을 허용하는 작은 프레임 워크를 만들고 싶습니다. MapReduce, Publish-Subscribe 등 저는 ZeroMQ를 Akka의 네트워킹 제공 업체로 사용하는 것이 가능하다는 것을 알고 있으며 실제로 그것을 선호합니다. 그러나 MapReduce examples 중 일부는 네트워킹 용 netty.io 프레임

1열

1답변

Akka ZeroMQ 게시/하위 생성 주문

게시자 및 구독자 생성과 관련하여 주문이 중요한가요? 게시자 및 여러 클라이언트 응용 프로그램 X1 - Xn (응용 프로그램 A의 구독자) 역할을하는 응용 프로그램 A가있는 경우 먼저 하위 응용 프로그램을 시작하고 구독자로 등록한 다음 나중에 응용 프로그램 A를 시작할 수 있습니까? 이 운동을 시작하거나 응용 프로그램 A를 시작해야합니까? 연결이 있었다 또

0열

1답변

Akka 라우터 여러 배우받지 못한 메시지가 제대로 여기

전 루프 내가 38 배우 for(int i=0;i <38;i++) { ruleStandardActorRouter?.tell(new StandardActorMessage(standard: standard, responseVO: responseVO, report: report), getSelf()); } 각 배우 논리 처리 할를 생성하고를 반환

1열

1답변

ZeroMQ 및 액터 모델

액터 모델 및 zeromq를 사용하는 응용 프로그램을 확장하는 데 문제가 있습니다. 간단히 말해서 : 소켓을 통해 통신하는 수천 개의 스레드를 생성하려고합니다. Erlang 형식의 메시지 전달과 관련이있는 것과 유사합니다. 멀티 코어/퍼포먼스의 이유로이 작업을 수행하지는 않지만 이런 식으로 프레임을 작성하면 매우 깨끗한 코드를 얻을 수 있기 때문입니다. z