github：https://github.com/shawntime/shawn-native-rpc
需要自己實(shí)現(xiàn)一個(gè)簡(jiǎn)單rpc框架的闸婴，可以參考一下四濒，提供一點(diǎn)點(diǎn)小思路
RPC過(guò)程詳解
image.png
image.png
實(shí)現(xiàn)內(nèi)容
- json序列化
- zookeeper實(shí)現(xiàn)服務(wù)端服務(wù)注冊(cè)和客戶端的服務(wù)發(fā)現(xiàn)和負(fù)載均衡
- 自動(dòng)掃描服務(wù)端所提供的接口，并注冊(cè)到zookeeper中
- 自動(dòng)生成客戶端動(dòng)態(tài)代理對(duì)象
- socket實(shí)現(xiàn)通訊
模塊說(shuō)明
- native-core：公共包：注解把夸、異常定義灵嫌、通訊協(xié)議、序列化氛驮、zookeeper客戶端封裝以及包掃描腕柜，配置加載等工具類
- native-customer：調(diào)用方需引入的模塊，實(shí)現(xiàn)自動(dòng)生成客戶端動(dòng)態(tài)代理對(duì)象，zk的服務(wù)發(fā)現(xiàn)和負(fù)載均衡盏缤，以及通信實(shí)現(xiàn)
- native-provider：服務(wù)提供方需引入的模塊砰蠢，實(shí)現(xiàn)了接口客戶端請(qǐng)求并處理，zk的服務(wù)注冊(cè)
- native-interface：對(duì)外提供服務(wù)的接口定義
- shawn-test-provider：提供方demo
- shawn-test-customer：調(diào)用方demo
配置
provider配置
配置naive-rpc.properties文件
scanPackage=com.shawntime.rpc.api
servicePort=11001
- scanPackage: 包掃描路徑唉铜，自動(dòng)創(chuàng)建包路徑下接口動(dòng)態(tài)代理類
- servicePort: 服務(wù)端監(jiān)聽(tīng)端口號(hào)
配置spring
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:cache="http://www.springframework.org/schema/cache"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.1.xsd
http://www.springframework.org/schema/cache
http://www.springframework.org/schema/cache/spring-cache-4.1.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
<context:component-scan base-package="com.shawntime"/>
<context:annotation-config/>
<aop:aspectj-autoproxy proxy-target-class="true"/>
<!-- 配置消息格式化方式 -->
<bean id="jsonFormatter" class="com.shawntime.rpc.core.serialize.json.JsonFormatter" />
<bean id="jsonParse" class="com.shawntime.rpc.core.serialize.json.JsonParse" />
<!-- 配置服務(wù)類台舱，該處使用socket處理請(qǐng)求 -->
<bean id="rpcProvider" class="com.shawntime.rpc.provider.service.socket.SocketRpcProvider">
<property name="formatter" ref="jsonFormatter" />
<property name="parse" ref="jsonParse" />
</bean>
<!-- 配置zk服務(wù)器集群信息，作服務(wù)注冊(cè) -->
<bean id="zookeeperClient" class="com.shawntime.rpc.core.zookeeper.ZookeeperClient">
<constructor-arg value="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183" />
</bean>
</beans>
customer配置
配置naive-rpc.properties文件
scanPackage=com.shawntime.rpc.api
- scanPackage: 包掃描路徑潭流，自動(dòng)創(chuàng)建包路徑下接口動(dòng)態(tài)代理類
配置spring
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:cache="http://www.springframework.org/schema/cache"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.1.xsd
http://www.springframework.org/schema/cache
http://www.springframework.org/schema/cache/spring-cache-4.1.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
<context:component-scan base-package="com.shawntime"/>
<context:annotation-config/>
<aop:aspectj-autoproxy proxy-target-class="true"/>
<!-- 配置消息格式化方式 -->
<bean id="jsonFormatter" class="com.shawntime.rpc.core.serialize.json.JsonFormatter" />
<bean id="jsonParse" class="com.shawntime.rpc.core.serialize.json.JsonParse" />
<!-- 客戶端處理配置 -->
<bean id="socketInvoke" class="com.shawntime.rpc.customer.invoke.socket.SocketInvoke" />
<bean id="beanNameGenerator" class="org.springframework.context.annotation.AnnotationBeanNameGenerator" />
<!-- 客戶端動(dòng)態(tài)代理注冊(cè)類 -->
<bean id="customBeanDefinitionRegistryPostProcessor"
class="com.shawntime.rpc.customer.config.CustomBeanDefinitionRegistryPostProcessor">
<property name="invoke" ref="socketInvoke" />
<property name="formatter" ref="jsonFormatter" />
<property name="parse" ref="jsonParse" />
<property name="beanNameGenerator" ref="beanNameGenerator" />
<property name="serviceFindManager" ref="serviceFindManager" />
</bean>
<!-- 服務(wù)發(fā)現(xiàn)和負(fù)載均衡 -->
<bean id="serviceFindManager" class="com.shawntime.rpc.customer.ServiceFindManager">
<property name="zookeeperClient" ref="zookeeperClient" />
</bean>
<!-- 配置zk服務(wù)器集群信息竞惋，作服務(wù)注冊(cè) -->
<bean id="zookeeperClient" class="com.shawntime.rpc.core.zookeeper.ZookeeperClient">
<constructor-arg value="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183" />
</bean>
</beans>
Demo
- 接口定義，用RpcService注解
@RpcService
public interface IUserService {
UserOut getUserInfo(UserIn userIn, Integer level);
void addUserProvince(ProvinceIn in);
}
- 提供方
package com.shawntime.test.provider;
import com.shawntime.rpc.api.IUserService;
import com.shawntime.rpc.api.contract.ProvinceIn;
import com.shawntime.rpc.api.contract.UserIn;
import com.shawntime.rpc.api.contract.UserOut;
import org.springframework.stereotype.Component;
@Component
public class UserService implements IUserService {
public UserOut getUserInfo(UserIn userIn, Integer level) {
UserOut userOut = new UserOut();
if (level > 0) {
userOut.setUserId(1);
userOut.setAddress("安徽蕪湖");
userOut.setAge(18);
userOut.setUserName(userIn.getUserName());
} else {
userOut.setUserId(2);
userOut.setAddress("河北保定");
userOut.setAge(19);
userOut.setUserName(userIn.getUserName());
}
return userOut;
}
public void addUserProvince(ProvinceIn provinceIn) {
System.out.println(provinceIn);
}
}
- 調(diào)用方
@Component
public class LoginService implements ILoginService {
@Resource
private IUserService userService;
public boolean login(String userName, String password, Integer level) {
UserIn userIn = new UserIn();
userIn.setUserName(userName);
userIn.setPassword(password);
UserOut userInfo = userService.getUserInfo(userIn, level);
System.out.println("userId:" + userInfo.getUserId()
+ ", age:" + userInfo.getAge()
+ ", address:" + userInfo.getAddress());
return userInfo != null;
}
public int addUserProvince(ProvinceIn in) {
userService.addUserProvince(in);
return 1;
}
}
