scala - 如何在 Scala Play 2.0 应用程序中异步使用 Java 库？

Question

我在 Play 2.0 Scala doc for calling web services 中看到惯用的方法是使用 Scala 的异步机制来调用 Web 服务。因此，如果我使用 Java 库，例如，从 S3 下载图像并上传到 Facebook 和 Twitter(restfb 和 twitter4j)，这是否会导致资源使用效率非常低下(什么资源？)，还是没有太大区别(或者根本没有区别)？

如果它有所不同，我将如何着手制作类似以下异步的东西？有没有快速的方法，或者我必须从头开始编写库？

注意这将在 heroku 上运行，如果这在本次讨论中很重要的话。

def tweetJpeg = Action(parse.urlFormEncoded) { request =>
  val form = request.body
  val folder = form("folder").head
  val mediaType = form("type").head
  val photo = form("photo").head
  val path = folder + "/" + mediaType + "/" + photo
  val config = Play.current.configuration;
  val awsAccessKey = config.getString("awsAccessKey").get
  val awsSecretKey = config.getString("awsSecretKey").get
  val awsBucket = config.getString("awsBucket").get
  val awsCred = new BasicAWSCredentials(awsAccessKey, awsSecretKey)
  val amazonS3Client = new AmazonS3Client(awsCred)
  val obj = amazonS3Client.getObject(awsBucket, path)
  val stream = obj.getObjectContent()    

  val twitterKey = config.getString("twitterKey").get
  val twitterSecret = config.getString("twitterSecret").get
  val token = form("token").head
  val secret = form("secret").head
  val tweet = form("tweet").head
  val cb = new ConfigurationBuilder();
  cb.setDebugEnabled(true)
    .setOAuthConsumerKey(twitterKey)
    .setOAuthConsumerSecret(twitterSecret)
    .setOAuthAccessToken(token)
    .setOAuthAccessTokenSecret(secret)
  val tf = new TwitterFactory(cb.build())
  val twitter = tf.getInstance()
  val status = new StatusUpdate(tweet)
  status.media(photo, stream)
  val twitResp = twitter.updateStatus(status)

  Logger.info("Tweeted " + twitResp.getText())
  Ok("Tweeted " + twitResp.getText())
}

def facebookJpeg = Action(parse.urlFormEncoded) { request =>
  val form = request.body
  val folder = form("folder").head
  val mediaType = form("type").head
  val photo = form("photo").head
  val path = folder + "/" + mediaType + "/" + photo
  val config = Play.current.configuration;
  val awsAccessKey = config.getString("awsAccessKey").get
  val awsSecretKey = config.getString("awsSecretKey").get
  val awsBucket = config.getString("awsBucket").get
  val awsCred = new BasicAWSCredentials(awsAccessKey, awsSecretKey)
  val amazonS3Client = new AmazonS3Client(awsCred)
  val obj = amazonS3Client.getObject(awsBucket, path)
  val stream = obj.getObjectContent()

  val token = form("token").head
  val msg = form("msg").head
  val facebookClient = new DefaultFacebookClient(token)
  val fbClass = classOf[FacebookType]
  val param = com.restfb.Parameter.`with`("message", msg)
  val attachment = com.restfb.BinaryAttachment`with`(photo + ".png", stream)
  val fbResp = facebookClient.publish("me/photos", fbClass, attachment, param)

  Logger.info("Posted " + fbResp.toString())
  Ok("Posted " + fbResp.toString())
}

我的猜测:

1. 是的，异步处理会更好；如果您同步执行所有操作，您将占用线程。线程是内存大户，所以你的服务器只能使用这么多；等待的越多，您的服务器可以响应的请求就越少。
2. 不，这不是一个大问题。对于 node.js(和 Rails？Django？)， 是一个大问题，因为只有一个线程，所以它会阻塞整个 Web 服务器。 JVM 服务器是多线程的，因此您仍然可以为新请求提供服务。
3. 您可以在将来轻松地包装整个事情，或者更细粒度地进行包装，但这并不能真正为您带来任何好处，因为您正在调用相同的方法，所以您只是将等待从一个线程转移到 do另一个。
4. 如果那些 Java 库提供异步方法，您可以在将来包装它们以获得异步的真正好处<-怎么做？。否则，是的，您正在考虑从头开始写作。
5. 真的不知道在 heroku 上运行是否重要。一个 dyno == 一个同时请求吗？

Answer 1

我认为最好异步执行这些请求，主要有两个原因:

• 高延迟(网络调用)
• 失败

使用 Play，您应该使用 Akka actors 来执行您的操作，它提供了处理这两个问题的好方法。 同步代码的问题在于它会阻塞 Web 服务器。所以它不能用于其他请求。这里我们将在与网络服务器无关的其他线程中等待。

你可以这样做:

// you will have to write the TwitterActor
val twitterActor = Akka.system.actorOf(Props[TwitterActor], name = "twitter-actor")

def tweetJpeg = Action(parse.urlFormEncoded) { request =>
    val futureMessage = (twitterActor ? request.body).map {
         // Do something with the response from the actor
         case ... => ...
     }
     async {
         futureMessage.map( message =>
             ok("Tweeted " + message)
         )
     }
}

您的 Actor 将接收正文并发回服务的响应。 此外，使用 Akka，您可以调整您的流程，让多个参与者可用，有一个断路器......

更进一步:http://doc.akka.io/docs/akka/2.1.2/scala/actors.html

Ps:我从未尝试过在 Heroku 上玩游戏，所以我不知道单个发电机的影响。