day3-Akka实现RPC通信框架

代码：
https://github.com/cyofeiyue/MyRPC

1.Akka配置信息

//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"

2.编译，打包，运行Master

上传到Linux（192.168.92.150）服务器上，执行jar包
java -jar my-rpc-2.0.jar 192.168.92.150 8888
传入的主机名和IP端口：Master启动的主机和端口

3.编译，打包，运行Worker

在本地机器（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

4.jps命令查看启动的java进程

本地启动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