在docker实例上使用akka与动脉远程处理的错误
首先，对不起我的英文。 谷歌翻译帮助我很多，哈哈。
我的问题是这样的：
我有两个使用akka和java开发的示例项目：example-remote-client.jar和example-remote-server.jar
我正在使用动脉序列化，和我试图通过akka远程发送消息从客户端到服务器。
这样做的客户端演员是：
public class ClientActor extends AbstractActor { public static Props props() { return Props.create(ClientActor.class); } public ClientActor() { ActorSelection selection = getContext().system().actorSelection("akka://server@localhost:5001/user/server-process"); selection.tell(new MessageRequest(), getSelf()); } public Receive createReceive() { return receiveBuilder().match(MessageResponse.class, msg -> { System.out.println(msg.getMessage()); }).build(); } }
我的客户端configuration：
akka { loglevel = "DEBUG" actor { provider = remote allow-java-serialization = off serializers { java = "akka.serialization.JavaSerializer" myown = "serializers.ExampleByteBufSerializer" } serialization-bindings { "java.lang.String" = myown "protocol.MessageRequest" = myown "protocol.MessageResponse" = myown "java.lang.Boolean" = myown } } remote { artery { enabled = on canonical.hostname = "192.168.0.250" # external (logical) hostname canonical.port = 5000 # external (logical) port bind.hostname = "localhost" # internal (bind) hostname bind.port = 10000 # internal (bind) port } } }
服务器的演员是非常虚拟的，我不认为有必要粘贴在这里。 但其configuration是：
akka { loglevel = "DEBUG" actor { provider = remote allow-java-serialization = off serializers { java = "akka.serialization.JavaSerializer" myown = "serializers.ExampleByteBufSerializer" } serialization-bindings { "java.lang.String" = myown "protocol.MessageRequest" = myown "protocol.MessageResponse" = myown "java.lang.Boolean" = myown } } remote { artery { enabled = on canonical.hostname = "192.168.0.250" # external (logical) hostname canonical.port = 5001 # external (logical) port bind.hostname = "localhost" # internal (bind) hostname bind.port = 10001 # internal (bind) port } } }
这两个jar都部署在通过相同的“192.168.0.250机器”运行的docker实例，如下所示：
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES d2970bd20371 openjdk:alpine "sh" 34 minutes ago Up 34 minutes 0.0.0.0:5001->10001/tcp ex-remoting-server 36a67fea8590 openjdk:alpine "sh" 34 minutes ago Up 34 minutes 0.0.0.0:5000->10000/tcp ex-remoting-client
服务器启动正常，使用以下日志：
[DEBUG] [07/04/2017 13:46:18.473] [main] [EventStream(akka://server)] logger log1-Logging$DefaultLogger started [DEBUG] [07/04/2017 13:46:18.473] [main] [EventStream(akka://server)] Default Loggers started [DEBUG] [07/04/2017 13:46:18.495] [main] [akka.serialization.Serialization(akka://server)] Replacing JavaSerializer with DisabledJavaSerializer, due to `akka.actor.allow-java-serialization = off`. [INFO] [07/04/2017 13:46:18.628] [main] [akka.remote.artery.ArteryTransport(akka://server)] Started embedded media driver in directory [/dev/shm/aeron-root-server-efd42dec-452d-406c-8d1d-807e0d8ff7fc] [INFO] [07/04/2017 13:46:18.693] [main] [akka.remote.artery.ArteryTransport(akka://server)] Remoting started; listening on address: [akka://server@192.168.0.250:5001] with UID [-2663186266051514585]
但是，当我尝试启动客户端时，出现以下错误：
[ERROR] [07/04/2017 14:09:05.250] [client-akka.actor.default-dispatcher-10] [akka://server@192.168.0.250:5001/] swallowing exception during message send io.aeron.exceptions.RegistrationException: Insufficient usable storage for new log of length=50332096 in /dev/shm (shm) at io.aeron.ClientConductor.onError(ClientConductor.java:285) at io.aeron.DriverListenerAdapter.onMessage(DriverListenerAdapter.java:79) at org.agrona.concurrent.broadcast.CopyBroadcastReceiver.receive(CopyBroadcastReceiver.java:100) at io.aeron.DriverListenerAdapter.pollMessage(DriverListenerAdapter.java:59) at io.aeron.ClientConductor.doWork(ClientConductor.java:422) at io.aeron.ClientConductor.awaitResponse(ClientConductor.java:447) at io.aeron.ClientConductor.addPublication(ClientConductor.java:177) at io.aeron.Aeron.addPublication(Aeron.java:165) at akka.remote.artery.AeronSink$$anon$1.<init>(AeronSink.scala:103) at akka.remote.artery.AeronSink.createLogicAndMaterializedValue(AeronSink.scala:100) at akka.stream.impl.GraphStageIsland.materializeAtomic(PhasedFusingActorMaterializer.scala:627) at akka.stream.impl.PhasedFusingActorMaterializer.materialize(PhasedFusingActorMaterializer.scala:458) at akka.stream.impl.PhasedFusingActorMaterializer.materialize(PhasedFusingActorMaterializer.scala:420) at akka.stream.impl.PhasedFusingActorMaterializer.materialize(PhasedFusingActorMaterializer.scala:415) at akka.stream.scaladsl.RunnableGraph.run(Flow.scala:439) at akka.remote.artery.Association.akka$remote$artery$Association$$runOutboundOrdinaryMessagesStream(Association.scala:570) at akka.remote.artery.Association.runOutboundStreams(Association.scala:510) at akka.remote.artery.Association.associate(Association.scala:502) at akka.remote.artery.AssociationRegistry.association(Association.scala:763) at akka.remote.artery.ArteryTransport.association(ArteryTransport.scala:932) at akka.remote.artery.ArteryTransport.send(ArteryTransport.scala:918) at akka.remote.RemoteActorRef.$bang(RemoteActorRefProvider.scala:563) at akka.actor.ActorRef.tell(ActorRef.scala:124) at akka.actor.ActorSelection$.rec$1(ActorSelection.scala:250) at akka.actor.ActorSelection$.deliverSelection(ActorSelection.scala:254) at akka.actor.ActorSelection.tell(ActorSelection.scala:45) at actors.ClientActor.<init>(ClientActor.java:21) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at java.lang.Class.newInstance(Class.java:442) at akka.util.Reflect$.instantiate(Reflect.scala:44) at akka.actor.NoArgsReflectConstructor.produce(IndirectActorProducer.scala:105) at akka.actor.Props.newActor(Props.scala:213) at akka.actor.ActorCell.newActor(ActorCell.scala:563) at akka.actor.ActorCell.create(ActorCell.scala:589) at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:462) at akka.actor.ActorCell.systemInvoke(ActorCell.scala:484) at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282) at akka.dispatch.Mailbox.run(Mailbox.scala:223) at akka.dispatch.Mailbox.exec(Mailbox.scala:234) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
我也尝试用这些“ActorSelectionpath”发送消息：
“akka：//server@192.168.0.250：5001 / user / server-process”“akka：// server @ localhost：5001 / user / server-process”“akka：//server@192.168.0.250：10001 / user / server-process“”akka：// server @ localhost：10001 / user / server-process“
但错误仍然出现。
服务器angular色的angular色path是：
阿卡：//服务器/用户/服务器处理
什么不见了？ 我正在使用akka 2.5.3版本…
谢谢。
我不太确定Akka规范与绑定解决scheme的工作方式。 但我的猜测是bind.hostname是实际的IP或parsingIP的主机名，它将监听。 在这种情况下， localhost转换为127.0.0.1 ，这意味着容器将只接受127.0.0.1连接。
尝试将bind.hostname设置为0.0.0.0 。 这将允许来自容器外部的IP地址（从主机到端口5001）的连接。
尝试将/dev/shm卷的大小设置得更大。 在shm_size: 500M -compose文件中，你可以简单的添加这个选项： shm_size: 500M 。 这个卷是aeron用来缓冲消息的共享内存空间。