अक्का Http: [32]

Question

के पार हो गई कॉन्फ़िगर किया गया अधिकतम-खुले अनुरोधों मूल्य मैं निम्नलिखित कोड

def post(endpoint: String, entity: Strict) = { 
    Http().singleRequest(HttpRequest(uri = Notifier.notificationUrl + endpoint, method = HttpMethods.POST, 
     entity = entity)) onComplete { 
     case Success(response) => response match { 
     case HttpResponse(StatusCodes.OK, _, _, _) => 
      log.info("communicated successfully with Server") 
     } 
     case Failure(response) => 
     log.error("communicated failed with Server: {}", response) 
    } 
    } 

यह

निम्नलिखित के रूप में हर 10 seconds जब Notifier अभिनेता को मिलने वाले संदेश में कहा जाता है का उपयोग कर सर्वर से कुछ डेटा पोस्ट

case ecMonitorInformation: ECMonitorInformation => 
    post("monitor", httpEntityFromJson(ecMonitorInformation.toJson)) 

समस्या?

मुझे लगता है कि प्रारंभ में (लगभग 5 सर्वर पर जाने का अनुरोध) लेकिन फिर यह लटका हुआ है, मुझे कोई लॉगिंग नहीं दिखाई दे रही है, सर्वर को कोई डेटा प्राप्त नहीं होता है। क्लाइंट साइड पर थोड़ी देर के बाद, मुझे निम्नलिखित

ERROR c.s.e.notification.Notifier - communicated failed with Server: java.lang.RuntimeException: Exceeded configured max-open-requests value of [32] 

क्या चल रहा है? मैं यह समस्या कैसे हल करूं?

Answer 1

मैं docs माध्यम से चला गया और निम्नलिखित

val connectionFlow: Flow[HttpRequest, HttpResponse, 
     Future[Http.OutgoingConnection]] = 
     Http().outgoingConnection(host = "localhost", port = 8080) 

और फिर

def httpPost(uri: String, httpEntity:Strict) { 
    val responseFuture: Future[HttpResponse] = 
     Source.single(HttpRequest(uri = "/monitor", method = HttpMethods.POST, entity=httpEntity)) 
     .via(connectionFlow) 
     .runWith(Sink.head) 

    responseFuture onComplete { 
     case Success(response) => log.info("Communicated with Server: {}", response) 
     case Failure(failure) => log.error("Communication failed with Server: {}", failure) 
    } 

की कोशिश की और इस

Answer 2

आप बार-बार अपने विधि बुला होने जा रहे हैं, तो आप को यहां बताए गए कनेक्शन पूल आधारित क्लाइंट एक विधि का उपयोग पर विचार करना चाहते हो सकता है: http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/http/client-side/index.html

तुम भी अक्का में कनेक्शन पूल सेटिंग्स सेट कर सकते हैं -http क्लाइंट कॉन्फ़िगरेशन: http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/http/configuration.html#akka-http-core

होस्ट-कनेक्शन-पूल के लिए खोजें।

Answer 3

आप Source.single के बजाय Source.queue का उपयोग बफरिंग और अतिप्रवाह प्रदान करने के लिए कर सकता है मेरे लिए काम किया रणनीति। https://stackoverflow.com/a/35115314/1699837