JarCasting一个mini的RPC框架
安装
maven
<dependency>
<groupId>com.github.hwywl</groupId>
<artifactId>mini-rpc</artifactId>
<version>1.0.1-RELEASE</version>
</dependency>
Gradle
implementation 'com.github.hwywl:mini-rpc:1.0.1-RELEASE'
说明
这是一个实验性的RPC框架，麻雀虽小但是五脏俱全，基本上RPC的有的功能基础功能都实现了，比如注册发现，反向代理调用等。
在使用上也非常简单只需几行的代码： 我们先定义一个接口是实现
public interface CalcService {
/**
* 获取IP地址
*
* @return
*/
String getIp();
/**
* 打招呼
*
* @param name 名称
* @return
*/
String hi(String name);
}
然后实现它
public class CalcServiceImpl implements CalcService {
@Override
public String getIp() {
String ip = null;
try {
InetAddress ip4 = Inet4Address.getLocalHost();
ip = ip4.getHostAddress();
} catch (UnknownHostException e) {
e.printStackTrace();
}
return ip;
}
@Override
public String hi(String name) {
return "Hi " + name;
}
}
现在就可以写我们的生产者和消费者了 生产者
public class Server {
public static void main(String[] args) {
RpcServerConfig config = new RpcServerConfig();
config.setPort(8080);
RpcServer server = new RpcServer(config);
server.register(CalcService.class, new CalcServiceImpl());
server.start();
}
}
消费者
public class Client {
public static void main(String[] args) {
List<Peer> servers = Collections.singletonList(new Peer("127.0.0.1", 8080));
RpcClientConfig config = new RpcClientConfig();
config.setServers(servers);
RpcClient client = new RpcClient(config);
CalcService service = client.getProxy(CalcService.class);
String ip = service.getIp();
String hi = service.hi("美女");
System.out.println(hi + " 我顺着 " + ip + " 去找你！");
}
}
启动生产者
运行消费者
具体实现可以参考源码。
缺陷
- 没有使用成熟的注册中心，现在的注册都是手动写死，不能做到动态发现
- 使用JDK动态代理，只能注册接口
- 没有错误处理机制，只有日志报错
问题建议
- 联系我的邮箱：[email protected]
- 我的博客：https://www.hwy.ac.cn
- GitHub：https://github.com/HWYWL