代码: https://github.com/cyofeiyue/MyRPC
//Master
akka.actor.provider = "akka.remote.RemoteActorRefProvider"
akka.remote.netty.tcp.hostname = "$host"
akka.remote.netty.tcp.port = "$port"
//Worker
akka.actor.provider = "akka.remote.RemoteActorRefProvider"
akka.remote.netty.tcp.hostname = "$host"
akka.remote.netty.tcp.port = "$port"
上传到Linux(192.168.92.150)
服务器上,执行jar包
java -jar my-rpc-2.0.jar 192.168.92.150 8888
传入的主机名和IP端口:Master启动的主机和端口
在本地机器(192.168.92.3)执行jar包
java -jar my-rpc-2.0.jar 192.168.92.3 10000 192.168.92.150 8888
传入的第一组:Worker启动的主机与端口
传入的第二组: 要连接的Master主机与端口
Master和Worker编译打包.png
本地启动Worker.png
服务端启动Master.png
本地机器(192.168.92.3)启动的java进程(Worker)
C:\Program Files\Java\jdk1.7.0_80\bin>jps -l
59572 my-rpc-2.0.jar
12480 sun.tools.jps.Jps
服务端机器(192.168.92.150)启动的java进程(Master)
[hadoop@hadoop ~]$ jps -m
47666 jar 192.168.92.150 8888
47823 Jps -m