关于AKKA Remoting方式发送message大小限制

 1 package cn.wanda.local
 2 
 3 import akka.actor.Actor
 4 import module.{ListType, JsonType, SeqType}
 5 
 6 import java.util.ArrayList
 7 /**
 8  * Created by Administrator on 2014/11/17.
 9  */
10 class LocalActor extends Actor {
11 
12   val remote = context.actorSelection("akka.tcp://HelloRemoteSystem@localhost:8000/user/RemoteActor")// create the remote actor
13   var counter = 0
14   //val seq:IndexedSeq[Int] = for(i <- 0 to 12335) yield i
15   val list = List(1 to 100000:_*)
16 
17   def receive = {
18     case "START" => {
22       remote ! new ListType(list)
23     }
24     case msg: String =>{
25       println(s"LocalActor received message: ‘$msg‘")
26     }27   }
28 }

 1 package cn.wanda.remote
 2 
 3 import akka.actor.Actor
 4 import module.{ListType, SeqType}
 5 /**
 6  * Created by Administrator on 2014/11/17.
 7  */
 8 class RemoteActor extends Actor {
 9   def receive = {
10     case msg: String => {
11       println(s"RemoteActor received message ‘$msg‘")
12       println(sender().toString())
13       //sender ! Future.successful("Hello from the RemoteActor")
14     }
15     case seq: SeqType => {
16       print(seq)
17     }
18     case list: ListType => {
19       //println("hello")
20       println(list)
21     }
22   }
23 }

[DEBUG] [12/03/2014 16:45:32.173] [main] [EventStream(akka://LocalSystem)] logger log1-Logging$DefaultLogger started
[DEBUG] [12/03/2014 16:45:32.176] [main] [EventStream(akka://LocalSystem)] Default Loggers started
[INFO] [12/03/2014 16:45:32.260] [main] [Remoting] Starting remoting
[INFO] [12/03/2014 16:45:32.821] [main] [Remoting] Remoting started; listening on addresses :[akka.tcp://LocalSystem@127.0.0.1:53304]
[INFO] [12/03/2014 16:45:32.825] [main] [Remoting] Remoting now listens on addresses: [akka.tcp://LocalSystem@127.0.0.1:53304]
----ActorSelection[Anchor(akka.tcp://HelloRemoteSystem@localhost:8000/), Path(/user/RemoteActor)]
[DEBUG] [12/03/2014 16:45:33.204] [LocalSystem-akka.remote.default-remote-dispatcher-6] [akka.tcp://LocalSystem@127.0.0.1:53304/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FHelloRemoteSystem%40localhost%3A8000-0/endpointWriter] Associated [akka.tcp://LocalSystem@127.0.0.1:53304] -> [akka.tcp://HelloRemoteSystem@localhost:8000]
[DEBUG] [12/03/2014 16:45:33.211] [LocalSystem-akka.remote.default-remote-dispatcher-6] [akka.serialization.Serialization(akka://LocalSystem)] Using serializer[akka.serialization.JavaSerializer] for message [module.ListType]
[ERROR] [12/03/2014 16:45:33.340] [LocalSystem-akka.remote.default-remote-dispatcher-6] [akka.tcp://LocalSystem@127.0.0.1:53304/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FHelloRemoteSystem%40localhost%3A8000-0/endpointWriter] Transient association error (association remains live)
akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor[akka.tcp://HelloRemoteSystem@localhost:8000/]: max allowed size 128000 bytes, actual size of encoded class akka.actor.ActorSelectionMessage was 1000508 bytes.

[DEBUG] [12/03/2014 16:45:33.341] [LocalSystem-akka.remote.default-remote-dispatcher-6] [akka.tcp://LocalSystem@127.0.0.1:53304/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FHelloRemoteSystem%40localhost%3A8000-0/endpointWriter] Drained buffer with maxWriteCount: 50, fullBackoffCount: 1, smallBackoffCount: 0, noBackoffCount: 0 , adaptiveBackoff: 1000

[DEBUG] [12/03/2014 16:45:33.191] [HelloRemoteSystem-akka.remote.default-remote-dispatcher-5] [Remoting] Associated [akka.tcp://HelloRemoteSystem@localhost:8000] <- [akka.tcp://LocalSystem@127.0.0.1:53304]