0
我试图通过ClusterClient
发送简单字符串"Dummy string"
到Akka集群。设置正常,我得到前端和集群连接,但发送到消息发送到DistributedPubSub
调解员从ClusterReceptionist
发送到DeadLetters
。来自`ClusterReceptionist`的消息没有达到`DistributedPubSubMediator`
如果我安排另一个Send
消息在一段时间之后从集群内发送到中介器,它将起作用。
请帮忙,提前谢谢。
前端日志:
22:51:34,645 DEBUG akka.remote.EndpointWriter - sending message RemoteMessage: [Send(user/UserServiceProxy,Dummy string,true)] to [Actor[akka.tcp://[email protected]:2552/system/receptionist#-1744655285]]<+[akka.tcp://[email protected]:2552/system/receptionist] from [Actor[akka://PvpFrontend/deadLetters]]
22:51:34,646 DEBUG akka.serialization.Serialization(akka://PvpFrontend) - Using serializer [akka.cluster.pubsub.protobuf.DistributedPubSubMessageSerializer] for message [akka.cluster.pubsub.DistributedPubSubMediator$Send]
群集日志:
22:51:34,626 DEBUG akka.remote.EndpointWriter - sending message RemoteMessage: [ActorIdentity([[email protected],Some(Actor[akka://PvpCluster/system/receptionist#-1744655285]))] to [Actor[akka.tcp://[email protected]:3000/user/cluster-client#-2107174838]]<+[akka.tcp://[email protected]:3000/user/cluster-client] from [Actor[akka://PvpCluster/deadLetters]]
22:51:34,654 DEBUG akka.remote.EndpointWriter - received local message RemoteMessage: [Send(user/UserServiceProxy,Dummy string,true)] to [Actor[akka://PvpCluster/system/receptionist#-1744655285]]<+[akka://PvpCluster/system/receptionist] from [Actor[akka.tcp://[email protected]:3000/deadLetters]()]
22:51:34,657 DEBUG akka.cluster.client.ClusterReceptionist$Internal$ClientResponseTunnel - started (akka.c[email protected]476348f0)
22:51:34,657 DEBUG akka.cluster.client.ClusterReceptionist - now supervising Actor[akka://PvpCluster/system/receptionist/akka.tcp%3A%2F%2FPvpFrontend%40localhost%3A3000%2FdeadLetters#552013204]
22:51:34,657 INFO akka.actor.RepointableActorRef - Message [java.lang.String] from Actor[akka://PvpCluster/system/receptionist/akka.tcp%3A%2F%2FPvpFrontend%40localhost%3A3000%2FdeadLetters#552013204] to Actor[akka://PvpCluster/system/distributedPubSubMediator#-1480760039] was not delivered. [5] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
22:51:34,892 DEBUG akka.serialization.Serialization(akka://PvpCluster) - Using serializer [akka.serialization.JavaSerializer] for message [akka.remote.Ack]
22:51:36,439 DEBUG akka.remote.EndpointWriter - received local message RemoteMessage: [Heartbeat] to [Actor[akka://PvpCluster/system/receptionist#-1744655285]]<+[akka://PvpCluster/system/receptionist] from [Actor[akka.tcp://[email protected]:3000/user/cluster-client#-2107174838]()]
22:51:36,440 DEBUG akka.cluster.client.ClusterReceptionist - Received new contact from [akka.tcp://[email protected]:3000/user/cluster-client]
22:51:36,440 DEBUG akka.remote.EndpointWriter - sending message RemoteMessage: [HeartbeatRsp] to [Actor[akka.tcp://[email protected]:3000/user/cluster-client#-2107174838]]<+[akka.tcp://[email protected]:3000/user/cluster-client] from [Actor[akka://PvpCluster/system/receptionist#-1744655285]]
22:51:36,837 DEBUG akka.remote.transport.ProtocolStateActor - stopped