Finagle 没有异步执行

Question

我有一个简单的 finagle thrift 服务器：

import com.twitter.finagle.Thrift
import scala.concurrent.Future

import com.twitter.util.{ Await, Future }
object Main{

  def main(args: Array[String]) {

    var count = 0

    val myserver = Thrift.serveIface("0.0.0.0:9090", new RealTimeDatabasePageImpressions[com.twitter.util.Future] {

      def saveOrUpdate(pageImpression: PageImpressions):
      com.twitter.util.Future[Boolean] = {
    count += 1
    println(count)
    com.twitter.util.Future.value(true)
      }
    }

   Await.ready(myserver)
  }

}

这个服务器可以工作，但我有一个大问题：我写了一个带有 for 循环的节俭 nodejs 客户端。它执行 10.000 个节俭请求。但它不是异步的。它执行 500 个请求并停止。一段时间后，2 或 3 秒后，将执行 300 多个请求。现在的问题是：为什么会发生这种情况？我的服务器或客户端有问题吗？我只使用 apache thrift 生成的 nodejs 代码。没有包装。该函数执行了 10.000 次。我认为 nodejs 不是问题：

function callFunc(i){
    console.log("started executing: " + i);
    var connection = thrift.createConnection("IP", 9090, {
    transport: transport,
    protocol: protocol
    });

    connection.on('error', function (err) {
    console.log(err);
    });

    // Create a Calculator client with the connection
    var client = thrift.createClient(Realtime_pageImpressions, connection);


    var rand = Math.random() * (20000 - 1);

    var trackId = trackIds[Math.round(Math.random() * 10)];
    var values = new PageImpressions({
    trackId: trackId,
    day: 4,
    hour: 4,
    minute: 13,
    pageId: 'blabla',
    uniqueImpressions: Math.random() * (13000 - 1),
    sumImpressions: Math.random() * (1000450 - 1)
    });

    client.saveOrUpdate(values, function (error, message) {
    if (message) {
        console.log("Successful, got Message: " + message);
    } else {
        console.log("Error with Message: " + error);
    }
    });
    return true;
}
for(var i = 0; i < 10000; i++){
    callFunc(i);
}

Answer 1

您的var count 未同步。这是一个非常大的问题，但可能与您的性能问题无关。 您还阻塞了 finagle 线程，这也是一个大问题，但在您的模拟案例中并不重要，因为没有等待时间。

这样想。假设您有一个 cpu（您可能有多个，但机器上还有其他事情），并且您要求它同时执行 10000 个操作所有。 p>

这如何工作？它必须执行其中一个请求，保存上下文，堆栈，刷新所有缓存，切换到下一个请求，执行那个......

2 秒内 500 个请求是每个请求 4 毫秒。听起来没那么糟糕，是吗？

另外，您是否打开了 GC（在服务器和客户端上）？如果请求在突发处理后出现长时间的停顿，这可能是 Full GC 开始的标志