0

Finagle アプリケーションで memcached コーデックを使用しています。しかし、パフォーマンスは非常に悪く、spymemcached クライアントを使用するよりもはるかに悪いです。spymemached で 8k req/s、finagle の memcached コーデックで 10 req/s を取得しました。memcached も私のマシンで実行されています。何か不足していますか？ストレス テスト中のエラーの例:

Mar 05, 2014 10:22:10 AM com.twitter.finagle.builder.SourceTrackingMonitor handle
SEVERE: A server service httpserver threw an exception
com.twitter.finagle.ChannelWriteException: org.jboss.netty.channel.ConnectTimeoutException: connection timed out: localhost/127.0.0.1:11211
at com.twitter.finagle.NoStacktrace(Unknown Source)
Caused by: org.jboss.netty.channel.ConnectTimeoutException: connection timed out: localhost/127.0.0.1:11211
at org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137)
at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83)
at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)

クライアントの構成方法:

 def client = Client( ClientBuilder()
    .hosts(parseHosts())
    .hostConnectionLimit(10)
    .codec(Memcached())
    .retries(2)
    .daemon(true)
    .build() )

簡単な取得操作:

def getUserTries(username: String): Future[Int] = {
   client.get(s"${username}_tries") flatMap { v => v match {
      case Some(c:ChannelBuffer) => Future.value( UserCache.fromChannelBuffer(c).toInt )
      case _ => Future.value(0)
   }
}

そして設定操作：

def saveUserTries(username: String, tries: Int): Future[Unit] = {
   client.set( s"${username}_tries", UserCache.toChannelBuffer(tries.toString) )
}
4

1 に答える 1

0

Finagle でも同様のパフォーマンスが得られるはずですが、貼り付けたコードに問題はありません。このfinagle memcached ベンチマークを見て、使用法に合わせてください。

于 2014-03-06T17:40:38.677 に答える