Skip to content

Latest commit

 

History

History
71 lines (52 loc) · 2.25 KB

README.md

File metadata and controls

71 lines (52 loc) · 2.25 KB

track-rpc

rpc远程调用

使用方式:

主要包含:服务端(server)、客户端(client)、共用包(common)、测试包(test)

1、配置服务端(在服务端的spring.xml文件中添加如下配置): <context:property-placeholder location="server-rpc.properties"/>/服务器配置文件/

<context:component-scan base-package="com.track.test.server"> /其中的com.track.test.server是服务端扫描的包/

server-rpc.properties内容:

ZooKeeper 服务器

registry.address=hadoop01:2181,hadoop02:2181,hadoop03:2181

RPC 服务器

server.address.port=8000 2、启动服务端: new ClassPathXmlApplicationContext("classpath:server-spring.xml");

3、配置客户端(在客户端的spring.xml文件中添加如下配置): <context:property-placeholder location="client-rpc.properties"/>

client-rpc.properties文件配置:

ZooKeeper 服务器

registry.address=hadoop01:2181,hadoop02:2181,hadoop03:2181

4、在spring的客户端使用rpc远程调用: 方式一: @Autowired private RpcProxy proxy;

func(){ Service service = proxy.newProxy(Service.class);// 提供服务的接口 service.xxx();// 调用Service中的方法即可 }

方式二: @RpcAutowired private Service service;

func(){ service.xxx();// 直接调用service的方法即可 }