QiuRPC
QiuRPC 参考手册
RPC常见功能
一个通用的网络RPC框架,它应该包括如下元素:
1.具有服务的分层设计,借鉴Future/Service/Filter概念
2.具有网络的分层设计,区分协议层、数据层、传输层、连接层
3.独立的可适配的codec层,可以灵活增加HTTP,Memcache,Redis,MySQL/JDBC,Thrift等协议的支持。
4.将多年各种远程调用High availability的经验融入在实现中,如负载均衡,failover,多副本策略,开关降级等。
5.通用的远程调用实现,采用async方式来减少业务服务的开销,并通过future分离远程调用与数据流程的关注。
6.具有状态查看及统计功能
7.当然,最终要的是,具备以下通用的远程容错处理能力,超时、重试、负载均衡、failover……
QiuRPC特点
QiuRPC是一个采用JAVA实现的小巧的RPC框架,一共3K多行代码,实现了RPC的基本功能,开发者也可以自定义扩展,可以供大家学习探讨或者在小项目中使用,目前QiuRPC具有如下特点:
1. 服务端基于注解,启动时自动扫描所有RPC实现,基本零配置
2. 客户端实现Filter机制,可以自定义Filter
3. 基于netty的Reactor IO多路复用网络模型
4. 数据层提供protobuff和hessian的实现,可以扩展ISerializer接口自定义实现其他
5. 负载均衡算法采用最少活跃调用数算法,可以扩展ILoadBlance接口自定义实现其他
6. 客户端支持服务的同步或异步调用
系统改进点
1. 增加注册中心功能,在大项目中,一个项目可能依赖成百上千个服务,如果基于配置文件直接指定服务地址会增加维护成本,需要引入注册中心
2. 目前用的是反射和java代理实现的服务端存根和客户端代理,为了提高性能,可以把这些用javassit,asm等java字节码工具实现
3. 增加一些监控功能,为了增强服务的稳定性和服务的可控性,监控功能是不可或缺的
4. 目前应用协议采用的是最简单的协议,仅仅一个魔数+序列化的实体,这些需要增强,比如增加版本号以解决向前兼容性
5. 增加High availability的一些手段,目前只有负载均衡,其他的比如failover,多副本策略,开关降级等,过载保护等需要自己实现
6. 目前只支持java语言,后续可能会增加其他语言的支持
参考例子
1. The service inteface:
public interface IServer1 {
public Message echoMsg(String msg);
}
2. The service inteface implement:
@ServiceAnnotation(name="myserver1")
public class MyServer1 implements IServer1{
private static final Log log=LogFactory.getLog(MyServer1.class);
@Override
public Message echoMsg(String msg) {
Message result=new Message();
result.setMsg(msg);
result.setData(new Date());
return result;
}
}
3. The service main class:
public static void main(String[] args) {
RpcServerBootstrap bootstrap=new RpcServerBootstrap();
bootstrap.start(8080);
}
4. The client main class:
public class Client1 {
public static void main(String[] args) {
try {
final IServer1 server1=RpcClientProxy.proxy(IServer1.class,"server1" , "myserver1");
long startMillis=System.currentTimeMillis();
for(int i=0;i<10000;i++)
{
final int f_i=i;
send(server1,"hello"+f_i);
}
long endMillis=System.currentTimeMillis();
System.out.println("spend time:"+(endMillis-startMillis));
} catch (Throwable e) {
e.printStackTrace();
}
}
public static void send(IServer1 server1,int f_i)
{
Message msg = null;
try
{
//Client config file used async="true",so we used future to get the async result,
//if configured async="false",used msg=server1.echoMsg(f_i) instead
server1.echoMsg(f_i);
Future future = RpcContext.getContext().getFuture();
msg=future.get();
System.out.println("msg:"+msg.getMsg()+","+msg.getData());
}
catch(Throwable e)
{
e.printStackTrace();
}
}
}
5. The config file at client side:
<application maxThreadCount="100">
<service name="server1" connectStr="127.0.0.1:9090;127.0.0.1:8080" maxConnection="100" async="true"></service>
</application>
摘自: https://github.com/i1see1you/QiuRPC 轻量级学习RPC
摘自:https://github.com/wenbo2018/fox
分享到:
相关推荐
## 用Python构建分布式高并发的RPC框架 ------ ### 一、为什么要写一个RPC框架? > + 不是想要造轮子,Dubbo、gRPC、Thift...下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。 --------
【资源说明】 1、该资源包括项目的全部源码,下载可以直接使用!...基于 Connect UDP 和自定义网络协议(简单请求响应协议) 、Reactor 网络模型(one loop per thread + 线程池) 的轻量RPC框架(源码+项目说明).zip
1、该资源内项目代码经过严格调试,下载即用确保可以运行!...基于 Connect UDP 和自定义网络协议(简单请求响应协议) 、Reactor 网络模型(one loop per thread + 线程池) 的轻量RPC框架(源码+项目说明).zip
主要介绍了JAVA中几种常用的RPC框架的相关知识点,对此有兴趣的朋友参考学习下吧。
免责声明:资料部分来源于合法的互联网渠道收集和整理,部分自己学习积累成果,供大家学习参考与交流。收取的费用仅用于收集和整理资料耗费时间的酬劳。 本人尊重原创作者或出版方,资料版权归原作者或出版方所有,...
主要介绍了Java RPC框架熔断降级机制原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
计划或参加电赛的同学可以用来学习提升和参考。程序均是实战案例,经过测试可直接运行。 全国大学生电子设计竞赛(National Undergraduate Electronics Design Contest),试题,解决方案及源码。计划或参加电赛的...
主要介绍了Java RPC框架过滤器机制原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
EasyRpc EasyRpc是基于Netty,ZooKeeper和ProtoStuff开发的一个简单易用,便于学习的RPC框架。 1特性简单易用;注释完善,方便学习;低延迟,基于Netty 4;解决TCP粘包/拆包问题;支持非双向的同步/异步调用;基于...
计划或参加电赛的同学可以用来学习提升和参考。程序均是实战案例,经过测试可直接运行。 全国大学生电子设计竞赛(National Undergraduate Electronics Design Contest),试题,解决方案及源码。计划或参加电赛的...
- 不懂运行,下载完可以私聊问,可远程教学 该资源内项目源码是个人的毕设,代码都测试ok,都是运行成功后才上传资源,答辩评审...下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。 --------
开源框架之手写系列,主要手写了springmvc,mybatis,rpc框架的实现,目前是跟着简书上一位的博客进行练习,先学习一下后期在做功能性的扩展。有兴趣的同学可以参考博主的博客学习一下,加深一下自己对开源框架底层...
主要介绍了Java RPC框架如何实现客户端限流配置,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
本文主要介绍了Dubbo框架的基本原理和使用方法,以及如何手动模拟Dubbo。首先,我们解释了什么是RPC(远程过程调用),它是一种允许一个程序调用另一个...最后,我们提供了一份手写模拟Dubbo的代码,供读者参考和学习。
工作分享:Hession是Java的一种rpc框架,本资源为Java中利用Hession进行RPC调用代码示例,可以参考代码学习。HessionDemo为服务端,HessionClient为客户端。
工作分享:Hession是Java的一种RPC框架,本资源为Java中利用Hession进行RPC调用代码示例,可以参考代码学习。hessianRPC为服务端,hessianRPCclient为客户端。 Hessian-rpc支持在不同的JVM版本之间传递复杂对象,...
创作Glue主要目的是为了巩固jdk8,netty知识点,掌握整个MVC框架、RPC框架设计流程。 将Glue定位为一个简约高效的Web框架。 本项目计划分几个步骤实施: 基于netty框架支持http、https、websocket请求; 实现IOC,...
学习Python作者: 关于Python的学习教程,可以参考 。人生苦短,我用Python!本项目创建于2020年9月11日。最近一次更新时间为2021年4月6日。0x01-Python资源一,基础入门 @骆昊 @骆昊 二,高级进阶三,算法学习 四,...
有关Dubbo服务框架的简单使用,可以参考我的其他两篇文章(《基于Dubbo的Hessian协议实现远程调用》,《Dubbo实现RPC调用使用入门》,后面参考链接中已给出链接),这里主要围绕Dubbo分布式服务相关配置的使用来说明...