使用 HTTPBuilder 池化连接

Question

我有一个 Grails/Groovy 应用程序，它使用 HTTPBuilder 库来调用我们的应用程序服务器。随着资源利用率的提高，我们正在寻找一种方法来池化我们的 HTTP 连接。我发现的唯一支持池的 HTTPBuilder 版本是 AsyncHTTPBuilder，但我们的调用必须同步进行。有没有人有使用 HTTPBuilder 池化连接的经验，或者我们应该使用其他库来使用池化连接发出请求？

以下是我们使用 HTTPBuilder 库的示例：

def get(event, request) {    
    def http = new HTTPBuilder(appServerURL)
    def result = ""
    http.client.cookieStore.addCookie
    sessionHolderService.getVPMClientUser().apiSessionCookie
    http.request(GET, TEXT) {
        uri.path = "/path/on/appserver"
        uri.query = [event: event, request: request, responseFormat: 'text/xml']

        response.success = { resp, text ->
            result = text.text                
        }

        response.failure = { resp, text ->
            result = text.text
            throw new VPMClientException(resp.status, resp.message, text.text)
        }
    }
    result
}

Answer 1

我们的应用程序也有类似的问题（但仅限于一个客户端实例）。以下解决方案基于 Gpars。操作被放入发送队列，然后被任务使用。

final def http = ...

final DataflowQueue sendQueue = new DataflowQueue()
final DataflowVariable finished = new DataflowVariable<Boolean>()

def sendQueueTask = task {
    while(!finished.isBound()){
            def sendAction = sendQueue.getVal(1, TimeUnit.SECONDS)
            if(sendAction)
                  sendAction()
        }
}

然后这些动作被封装在一个添加到 sendQueue 中的闭包中：

def get(event, request) { 
  sendQueue << {
       // your get implementation
    }
}