스프레이 클라이언트 Json 응답에서 String을 반환하고 싶습니다.

Question

죄송합니다. 그러나 Scala를 처음 사용했습니다. Futures와 Akka에 대해 읽었지 만, 여전히 메서드에 문자열을 반환하는 데 문제가 있습니다.

인증 문자열 (또는 토큰)을 반환해야하는 getAuthString 메서드가 있습니다. 나는 스프레이 Jsonsupport을 사용하고 난이이 JSON을 비 정렬 화 결과

def getToken(url: String, username: String , password: String) = Future[String]{ 

import MyJsonProtocol._ 
import spray.httpx.SprayJsonSupport._ 

val pipeline: HttpRequest => Future[AuthTokenResult[Entry]] = (addCredentials(BasicHttpCredentials(username, password)) 
    ~> sendReceive 
    ~> unmarshal[AuthTokenResult[Entry]] 
) 
val myfutureResponse: Future[AuthTokenResult[Entry]] = pipeline(Get(url)) 

myfutureResponse onComplete { 
     case Success(AuthTokenResult(Entry(Content(authString)):: _)) => println(authString) 
     case Failure(error) => println("An error has occured: " + error.getMessage) 
    } 

를 인쇄하고 원하는 authString를 인쇄 할 수 있습니다. 그러나 인쇄는 나에게 좋지 않습니다. 나는 onComplete 리턴 유닛을 안다. 다른 요청으로 다른 곳에서 사용할 수 있도록 authString을 반환하고 싶습니다. 플랫 맵이나 맵을 사용해야 할 것 같지만 어떻게 확신 할 수없는 것입니다. authString 또는 오류를 반환하는 내 메서드가 필요합니다.

Answer 1

String을 반환하고 싶지 않으신 경우 Future[String]을 반환하고 싶습니다. 일단 비동기가 아닌 것이 비동기가 아닌 것을 차단하는 유일한 방법은 차단하는 것이며, 이는 일반적으로 낭비이므로 전체 async- 끝장이 없다.

나는 왜 Future에 모든 것을 포함하고 있는지 알지 못합니다. 계산의 작은 부분은 독자적으로 발생할 수 있습니다. 별도의 스레드에 강제로 적용하는 데는 가치가 없습니다.

def getToken(url: String, ...): Future[String] = { 
    ... 
    val myFutureResponse: Future[AuthTokenResult[Entry]] = ... 
    myFutureResponse map { 
    case AuthTokenResult(Entry(Content(authString))::_) => authString 
    } 
} 

그래서 당신이 계산과 다른 Future에 Future를 변환하는 map를 사용 : 그래서 당신이 뭔가를 할 수 있습니다. 이것은 "통과"오류가 발생하지만 특정 방식으로 처리하려는 경우 recover 또는 recoverWith과 같은 것을 사용할 수 있습니다.

그런 다음 당신은 당신이 onSuccess 또는 onComplete 지시어를 사용할 수 있습니다, 스프레이 경로에 Future[String]를 사용하고자 할 때 : 이것은 차단하지 않고, 적절한 비동기, 반응 방식으로 Future를 사용합니다

val myRoute = (path("/somewhere") & parameter("authData") { 
    authData => 
    onSuccess(getToken(authData)) { 
     authToken => 
     complete("Authed as " + authToken) 
    } 
    } 

.