Avro实现RPC

Posted 2020-10-05 李飞21

场景：一个客户端，一个服务端（创建两个avro工程）。客户端向服务端发送数据，服务端根据算法算出结果，返回给客户端。

Http主外，RPC主内。（解决分布式环境下，节点间的数据通信或远程过程调用）

 

实现步骤

1.创建两个maven工程

2.引入pom文件

3.更改maven工程结构（src/main/avro)

4.创建模式文件（协议文件）

5.根据avro插件生成文件对应的接口类

6.利用API实现rpc

具体实现：

1、 创建两个maven项目，修改jdk版本和编译的版本  1.5->1.7

2、 拷贝pom.xml文件

3、 创建资源文件夹src/main/avro

4、 创建模式文件（协议文件），在客户端项目和服务器端项目都要有一份协议文件。

@namespace("rpc.service") protocol AddService{ int add(int x,int y); }

5、 选择项目右键->Run->Maven generate-sources

 

6、 在服务器端的项目中添加一个实现类

public class AddServiceImpl implements AddService { public int add(int x, int y) throws AvroRemoteException { return x+y; } }

 

7、 在服务器端项目中，开发Server类

package cn.tedu.avro_server;   import java.net.InetSocketAddress; import org.apache.avro.ipc.NettyServer; import org.apache.avro.ipc.specific.SpecificResponder; import rpc.service.AddService; import rpc.service.AddServiceImpl; public class Server { public static void main(String[] args) { NettyServer server = new NettyServer( new SpecificResponder(AddService.class, new AddServiceImpl()), new InetSocketAddress(6666)); } }

8、 在客户端项目中开发Client类

public class Client { public static void main(String[] args) throws Exception { //指定rpc服务器端的ip地址和端口号 Transceiver transciever = new NettyTransceiver( new InetSocketAddress("127.0.0.1", 6666)); //获取rpc服务器端接口实现类的对象 AddService proxy = SpecificRequestor.getClient( AddService.class, transciever); //调用对象的方法 int result = proxy.add(3, 5); System.out.println(result); } }