akka

2열

2답변

Java에서 AKKA를 사용하여 게시/가입 시스템 (서버 푸시)을 구현하려면 어떻게해야합니까?

http://akka.io/에 익숙해지면서 서버 푸시를 수행하는 방법을 알 수 없습니다. 클라이언트가 서버에 연결 한 후 서버가 클라이언트에 메시지를 푸시하는 방법은 무엇입니까? 예를 들어, 고객이 견적 서버에서 주식 시세를 수신하기 위해 구독 한 경우. 또는 서버가 한 채팅 클라이언트에서 다른 채팅 클라이언트로 채팅 메시지를 라우팅하는 경우 잘못된 아이디

2열

1답변

답장이 'client'-actor에게 전송되지 않습니다.

원격 액터를 사용할 때 예기치 않은 동작이 있습니다. 나는 서버와 '클라이언트'를 가지고있다. 클라이언트는 서버 액터로 메시지를 보내고 서버는 응답합니다. 내가 '?' 연산자는 모두 예상대로 작동합니다. 나는 대답을 서버에서 다시 얻는다. 서버 : class HelloWorldActor extends Actor { def receive = {

4열

1답변

간단한 스칼라 원격 액터 예제를 Akka 액터로 이식합니다

"Ping"및 "Pong"을 스칼라 액터에서 Akka 액터로 전송하는 포트 this simple actor example을 계속 시도하지만 오류가 계속 발생하며 단순한 오류인지 또는 일부 오류인지 궁금합니다. 근본적인 잘못. import akka.actor.Actor._ import akka.actor.Actor case class Message(te

0열

1답변

Akka, 스레드 발신자, 에이전트 모범 사례

저는 스칼라에서 한동안 다뤄 보았고 멀리에서 Akka를 배웠고 마침내 급증했습니다. FSM 특성이 나를 위해 거래를 봉인했습니다. 나에게 우려되는 점은 데이터가 부적절하게 공유되는 방식을 생각해 냈기 때문에 Akka 모범 사례에 맞춰 이벤트 처리 루프를 잘못 생각했을 수 있습니다. 제 문제에는 들어오는 작업 요청을 Finite State Machines 인

9열

3답변

액터 (scala/akka) : receive 메소드가 threadsafe 방식으로 액세스된다는 것을 암시하고 있습니까?

메시지를 수신하고 스레드 세이프 방식으로 처리한다고 가정합니다. 그러나, 나는 (일부) akka/scala 문서를 읽고 있었지만 아직 'threadsafe'라는 키워드를 접하지 못했습니다.

0열

2답변

보다 간결한 스칼라 함수를 정의하는 방법

나는 akka 라이브러리를 사용하고 런타임에 액터가 핫스왑을 통해 구현할 부분 함수를 제공하고 있습니다. akka 핫 스왑은 PartialFunction [Any, Unit] 형식의 인수를 취합니다. 나는 다음과 같이 정의했다. class Fake1Reader extends AbstractReader { def read: PartialFuncti

2열

1답변

두 개의 로컬 인스턴스가 Akka 액터와 통신하는 데 필요한 최소 코드는 무엇입니까?

컴퓨터에서 응용 프로그램의 두 인스턴스를 시작하는 데 필요한 최소한의 코드가 무엇인지 궁금합니다.이 코드는 서로간에 메시지를주고받을 수 있습니다. 는 지금까지 내가 이해, 나는 메시지를 처리 할 수있는 배우를 시작 가 필요합니다. 이 인스턴스에 메시지를 보낼 수있는 다른 인스턴스가 있음을 알리십시오. Akka에서 어떻게해야합니까? Akka's home

5열

1답변

Akka 기반 웹 응용 프로그램 아키텍처

Scala Akka 서비스를 기반으로 웹 응용 프로그램의 다이어그램/토론/예제는 어디에서 찾을 수 있습니까? UI 통합 방법 등이 궁금합니다. 클라우드 지원 변종만을 살펴 봅니다.

3열

1답변

Akka - 리플렉션을 사용하여 액터 만들기

구성 파일에서 런타임에 정확한 유형 만 읽는 액터를 만들어야합니다. 해당 액터의 생성자는 중요하지 않습니다. 즉 구성 파일에 정의 된 일부 매개 변수가 필요합니다. 불행하게도 val actor = actorOf(constructor.newInstance(parameters: _*).asInstanceOf[T]).start 이는 "akka.actor.Ac

6열

1답변

Akka에서 '자기'란 무엇입니까?

Akka 샘플을 통해 읽는 것만으로 self.reply이 정의 된 방법을 이해할 수 없습니까? 멀리 볼 수있는 한, 블록 안에 메시지에 회신 할 때 self reply이 사용됩니다. 그러나까지 reply은 self의 방법이고, 그 다음에 self은 무엇입니까? 추신 : 당신은 스칼라로 Akka 기초와 원격 배우에 대한 좋은 빠른 기사를 추천 해 주시겠습니까