Twitter-Finagle을 사용하여 서버를 만듭니다. 서버의 각 RPC 기능에서 Finagle 클라이언트를 사용하여 다른 서버의 RPC를 호출하면됩니다. 같은 : 나는 lsof -p를 사용하여 다른 서버에 너무 많은 연결이 있다는 것을 발견, org.jboss.netty.channel.socket.nio.AbstractNioSelector: Failed
저는 Twitter Finagle의 초보자입니다. Finagle은 scala의 RPC와 마이크로 서비스에 매우 유용하다고 들었습니다. 하지만 트위터의 doc은 거의 모두 비동기 HTTP 서버 (netty 이상)와 관련이 있습니다. Finagle 사용 범위를 설명하십시오.
나는 항상 새로운 값을 확인해야하는 HTTP API 끝점이 있습니다. 운좋게도 긴 폴링을 지원합니다. 따라서 아이디어를 요청할 때 (최대 10 분) 응답을 기다리고 응답에서 값을 얻고 어딘가에 저장하여 부작용을 일으켜 다른 요청을하는 '무한 루프'를 구현해야한다는 생각입니다. 이 함수를 호출하면이 '무한 루프'가 시작되어 Finagle API를 만족시키기
저는 Finagle 및 Thrift를 플랫폼으로 사용하여 Scala에서 구현되는 마이크로 서비스 시스템에서 작업하고 있습니다. 아무도 잠시 동안 만진 서비스가 없기 때문에 더 이상 사용되지 않는지 (또는 오히려 어떤 부분이 더 이상 사용되지 않는지) 알아야합니다. 이를 위해, IMHO는 각 메소드에 대한 간단한 호출 수만으로 충분합니다 (서비스가 시작되었거
Json이 필요한 Finch 엔드 포인트를 작성 중입니다. URL - 내가 형 JSON으로 몸을 지정하려면 어떻게 또는 어떻게 할 내가 LogBundles 및 프로세스 사이의 JSON 값을 전달 구문 분석 JSON에 대한 LogBundles/긴 JSON 메시지/프로세스 내가 json4s 사용하고 라이브러리 ? Json의 정확한 구조를 알지 못해서 body.
Futures를 사용하고 타사 lib를 통해 Redis에 액세스하지 않고 서비스가 구현 된 Finagle HTTP 응용 프로그램에서 작업하고 있습니다. 어떤 점에서 우리가 미래에 새로운 서비스를 개발하기 시작 - class SampleOldService extends Service[Request, Response] {
def apply(req: R
버그로 인해 NPE를 던지는 Future.respond 내부에서 일부 코드가 실행되고 있습니다. 문제는 NPE가 루트 모니터 (RootMonitor)에 의해 삼켜 졌기 때문에 유닛 테스트가 완전히 빠져서 행복하게 전달된다는 것입니다. 그럼 내 질문은 단위 테스트를 위해 RootMonitor 동작을 재정 의하여 예외를 삼키기보다는 테스트 실패가 발생하는 경우