sorry,my company can't upload code,only use the words here. first,my client and server in the same host node .
when i call the actor in local mode,the tps is 2m.but call the actor in remote mode is only 20k... when i deploy the client and server in two host ,the result is same ... the dispatcher is the default. one message is about 100 byte. the message is only a string ,so i use the java serializer. when i use the jvisualvm to look the thread status,the dispatcher threads status most is waiting... but whean call the actor in local mode ,the dispatcher threads most is running.. why?? the akka version is 2.1.2. can you help me ?? 在 2014年2月13日星期四UTC+8下午7时26分14秒，rkuhn写道： > > Hi chen ke, > > unfortunately I can’t read Chinese, would you mind translating your > message into English? > > Regards, > > Roland > > 13 feb 2014 kl. 12:13 skrev chen ke <[email protected] <javascript:>>: > > 顺便咨询下，你两台机器互发消息，吞吐量能达到多少？我只能到2万条消息/每秒。。。。 > > 在 2014年2月13日星期四UTC+8下午1时47分16秒，闫冬写道： >> >> help >> 求助 >> >> only machine： >> >> *tomcat akka <--> akka* >> >> >> qa: >> >> use akka remote configure? >> >> Akka 2.2.1 version >> >> client error info ↓ >> >> org.jboss.netty.channel.ChannelException: Failed to bind to: >> /192.168.8.155:2552 >> >> ..... >> >> Caused by: java.net.BindException: Address already in use: bind >> >> ..... >> >> >> >> 求助，在一台服务器上，如何实现可以本地调用，又可以远程调用？ >> >> 怎么来实现才可以client端以及其他电脑的akka client端都可以调用此机器上的 akka server >> >> >> 按照网上找的例子：使用akka2.0.5版本的没问题。 >> >> 但使用2.2.1版本的，启动server后，再同一台电脑上启动client会报端口占用错误。 >> >> 配置如下： >> >> ServerSys { >> include "common" >> akka { >> actor { >> provider = "akka.remote.RemoteActorRefProvider" >> } >> remote { >> transport = "akka.remote.netty.NettyRemoteTransport" >> netty { >> hostname = "127.0.0.1" >> port = 2552 >> } >> } >> } >> } >> >> ClientSys { >> include "common" >> akka { >> actor { >> provider = "akka.remote.RemoteActorRefProvider" >> >> deployment { >> /remoteServerActor { >> remote = "akka.tcp://[email protected]:2552" >> } >> } >> } >> } >> } >> >> >> Server： >> >> public ServerActorSystem() { >> // load the configuration >> system = ActorSystem.create("ServerSys", ConfigFactory.load() >> .getConfig("ServerSys")); >> >> // create the actor >> ActorRef actor = system.actorOf(new Props(ServerActor.class), >> "serverActor"); >> } >> >> Client： >> >> public ClientActorSystem() { >> system = ActorSystem.create("ClientSys", ConfigFactory.load() >> .getConfig("ClientSys")); >> >> } >> >> >> 谢谢 >> >> thinks >> >> >> >> >> >> >> >> > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: http://akka.io/faq/ > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [email protected] <javascript:>. > To post to this group, send email to [email protected]<javascript:> > . > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/groups/opt_out. > > > > > *Dr. Roland Kuhn* > *Akka Tech Lead* > Typesafe <http://typesafe.com/> – Reactive apps on the JVM. > twitter: @rolandkuhn > <http://twitter.com/#!/rolandkuhn> > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out.
