java - 如何解决play framework 2.2.1 connect timeout异常问题

In lại 作者：行者123 更新时间：2023-11-29 08:52:17 26 4

class WS(sentenceList: List[String], queue: BlockingQueue[Future[Response]], filename: String) {

  val listofJson = new ListBuffer[(String, JsValue)]
  listofJson.clear

  def callWSProducer() = {

    sentenceList.foreach { name =>
      val data = Json.obj(
        "input_sent" -> name,
        "Filename" -> filename)

      val holder: Future[Response] = WS.url("http://0.0.0.0:8015/endpoint/").withHeaders("Content-Type" -> "application/json").post(data)
      implicit val context = scala.concurrent.ExecutionContext.Implicits.global
      queue.put(holder)
    }
  }

  def WSConsumer(): List[(String, JsValue)] = {

    sentenceList.foreach { name =>

      val result = Await.result(queue.take(), 100.second)

      val out = (result.json \ "sentence");

      listofJson += ((name, out));
    }

    return listofJson.toList

  }

}

ws.timeout=0

  object Application extends Controller {

     //using Scala global implicits is a bad practice
     //implicit val context = scala.concurrent.ExecutionContext.Implicits.global

     //use the play one or even better use a custom execution context read
     //http://www.playframework.com/documentation/2.1.0/ThreadPools
     implicit val context = play.api.libs.concurrent.Execution.Implicits.defaultContext

     def index = Action.async {
          invokeServices(send your sentence list).map { listOfPairs =>
             //do your transformation here to create the result
          }
     }
     //invokeServices hopefully capture all that you are doing inside the WS class but no blocking 
     //and mutation.  
     def invokeServices(sentenceList: List[String]): Future[List[(String, JsValue)]] = {
       val responses: List[Future[(String, JsValue)]] = sentenceList.map { name =>
          val data = Json.obj(
            "input_sent" -> name,
            "Filename" -> name)

            val response: Future[Response] = 
                WS.url("http://0.0.0.0:8015/endpoint/").withHeaders("Content-Type" -> "application/json").post(data)
            response.map(result => (name, result.json \ "sentence"))
        }
       //converts List[Future[A]] to Future[List[A]]
       Future.sequence(responses)
     }

   }

26 4 0

• ruby-on-rails - Heroku Timeout::timeout 不抛出错误

  我正在使用 heroku 来托管支持 iOS 应用程序的 ruby on rails 应用程序。我有一个可能会运行很长时间的请求，我需要能够在我的请求被终止之前捕获超时。我正在使用 Timeout

• ruby - 使用 Timeout::timeout(n) 缩短套接字超时似乎对我不起作用

  我在 https://stackoverflow.com/questions/517219?tab=oldest#tab-top 找到了我认为应该完美运行的东西但是，它对我不起作用。 我在 Windo

• ruby-on-rails - Ruby Timeout::timeout 不会触发异常并且不会返回记录的内容

  我有这段代码: begin complete_results = Timeout.timeout(4) do results = platform.search(artist,

• timeout - Unity3D 部署到安卓设备 : how to bypass 10 minute timeout

  我正在开发一个音乐训练游戏，我使用 Unity 3D 来创建它。 它会发出随机音符。 问题是，我的 android 设备只有五个“屏幕熄灭前的时间”选项，其中最长的是 10 分钟。 所以 10 分钟后

• sql - 为什么 Timeout.timeout(sec) 不适用于 activerecord

  我运行以下代码来捕获任何可能挂起的 SQL 语句。在尝试对此进行测试时，我编写了一个非常优化的 sql 语句，它需要一分钟的时间才能运行。我在 activerecord execute sql 语句周

• ruby - 法拉第的 "timeout"和 "open timeout"是什么？

  由于 Faraday 没有文档，我无法在任何地方找到它。法拉第什么是“timeout”，什么是“open timeout”？ 最佳答案 如果您在 https://github.com/lostisla

• angularjs - Jasmine 单元测试 $timeout (expect($timeout).toHaveBeenCalledWith(n);)

  我想对 Angular.js $timeout 进行单元测试，以检查是否已使用正确的持续时间/延迟值调用它。 断言看起来像这样: expect($timeout).toHaveBeenCalledWi

• python - 无法使用 python eventlet 库超时(eventlet.timeout.Timeout)

  我正在循环一个列表并对列表中的每个成员执行一些操作。如果某个成员花费了太多时间(在本例中为 1 秒)，我打算跳过它。但是，try 语句内的 block 始终处于处理状态，并且永远不会超时。我不明白为什

• Linux 庆典 : timeout a program if the program hangs in there and echo 'timeout'

  我有一个程序可以打印出通过或失败。我想检测卡在那里的程序并回显“超时” 我写了这样一个脚本: #!/bin/bash echo -n 'test' && timeout 5 ./mytest | gr

• ruby - 在 Rack 应用程序中模拟 Ruby 的 Timeout::timeout

  我有一个 Sinatra 应用程序。我正在使用 Rack::Test 对其进行测试。我想确保将查询字符串参数传递给 Timeout::timeout()。 我认为 expect_any_instanc

• ruby - '在 rbuf_fill 中救援':Timeout::Error (Timeout::Error)

  相同的脚本不同的错误。这可能更多地与我的网络有关，而不是我的代码。脚本如下: #!/usr/bin/env ruby -rubygems require File.join(File.dirname(

• javascript - Jasmine : Timeout - Async callback was not invoked within timeout

  我需要测试一个从 url 加载图像的 AngularJs 服务。这是我的服务: /*global angular, Image*/ (function () { 'use strict'; f

• c# - MySqlException : Timeout expired - Increasing Connection Timeout Has Had No Effect

  随着数据库大小的增加，我有一个查询需要更长的时间来执行。查询已优化并且是必要的，但我的 C# 控制台应用程序最近给我这个错误: Unhandled Exception: MySql.Data.MySq

• linux - 为什么 `timeout 2 timeout 1 bash`卡住了

  我正在研究 Linux shell 中的 timeout 命令。 当我尝试 timeout 1 bash 时，bash 将运行并在 1 秒后终止。 当我尝试 timeout 2 timeout 1 y

• c# - MySqlException : Timeout expired - Increasing Connection Timeout Has Had No Effect

  随着数据库大小的增加，我有一个查询需要更长的时间来执行。查询已优化并且是必要的，但我的 C# 控制台应用程序最近给我这个错误: Unhandled Exception: MySql.Data.MySq

• java - spring.session.timeout 与 server.servlet.session.timeout

  我希望使用 Spring boot 和 Tomcat 扩展 Spring MVC 应用程序中的用户 session 。查看文档似乎有 2 个相关 properties : server.servlet

• Ruby 1.9 const_defined？ ("Timeout") 当 Timeout 不在常量列表中时返回 true

  我正在尝试升级 Puppet 以使用 Ruby 1.9，但遇到了常量问题。 const_defined?("Timeout") 返回真，即使 :Timeout 不在常量列表中。这不会发生在 Ruby

• Java 监视器 : How to know if wait(long timeout) ended by timeout or by Notify()?

  首先，这是一个几乎重复的: How to differentiate when wait(long timeout) exit for notify or timeout? 但这是一个新的后续问题。

• java - 如果 wait(timeout) 和 notifyAll() 被同一个对象锁定，timeout 是什么意思

  对于下面的代码，notifyAll() 会一直持有锁直到完成，即使超时了，这个 block 也不持有锁，必须等待notifyAll() block 完成。那么wait(timeout)中的timeou

• c# - Thread.Sleep(timeout) 和 ManualResetEvent.Wait(timeout) 有什么区别？

  Thread.Sleep(timeout) 和resetEvent.Wait(timeout) 都会导致执行暂停至少timeout 毫秒，那么它们之间有区别吗？我知道 Thread.Sleep 导致线