# springrain **Repository Path**: dingjunjun_codeSpace/springrain ## Basic Information - **Project Name**: springrain - **Description**: 云原生微服务实现 - **Primary Language**: Java - **License**: Apache-2.0 - **Default Branch**: master - **Homepage**: https://www.jiagou.com - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 559 - **Created**: 2022-06-01 - **Last Updated**: 2022-06-01 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README ## 说明 * springrain是spring/springboot的开发范例.基于K8S + Istio 实现云原生微服务. * springrain自带代码生成器,能够生成对表的增删改查的逻辑代码. * springrain是标准Maven项目,只依赖springboot,没有hibernate,struts,ibatis,数据库调优可以使用druid输出慢sql,比分析xml中的语句更直观,springrain所有的sql语句都使用Finder封装管理,只要查看Finder的引用即可. ## 前后分离 前后端分离,使用jwt认证,前端项目是[front-springrain](https://gitee.com/chunanyong/front-springrain) ## 微服务 入口项目是[springrain-system-web](https://gitee.com/chunanyong/springrain/tree/master/springrain-system/springrain-system-web),基于K8S + Istio 实现云原生微服务,正在整理文档. ## 实现了什么? * 不增加学习成本,像单体一样开发分布式微服务. * 不修改业务代码,可以实现单体,分层,微服务多种部署模式切换. * 集成seata分布式事务实现. * 子项目module的前后端可以独立运行,也可以被无感知集成,实现前后端按需打包. ## 实现思路 * 启动加载springbean时,先检查本地是否有实现,如果没有就启动GRPC远程调用.开发人员无感知. * 基于seata分布式事务实现.支持有注解和无注解(开发人员无感知,理论上有不同步风险,个人感觉做好日志,风险不大)混合使用. * 基于K8S的Service实现服务注册和发现,ConfigMap实现配置中心.开发人员无感知. * 基于Istio实现微服务的发现,监控,熔断,限流.开发人员无感知. 架构设计详细思路:[https://www.jiagou.com/post/58-cloud-native-service-mesh](https://www.jiagou.com/post/58-cloud-native-service-mesh/) ## 限制 * 接口和实现的命名强制规范. * 一个RPC接口只能有一个实现. * 分布式事务,一定要避免A服务update表t,RPC调用B服务,B服务也update表t.这样A等待B结果,B等待A释放锁,造成死锁. * 分布式无注解比较方便,理论上有不同步风险,个人感觉做好日志,风险不大 * Service层不可以使用Servlet API,例如 HttpRequest * 建议每个前后端module/子项目,都有各自的前缀,方便nginx根据路径解析 * 如果module依赖包的特定版本(例如netty,Grpc)和根项目版本冲突,module不能无感知集成,暂时只能独立运行 ## 体验单体到分层切换 * 修改springrain-system-web依赖springrain-system-service,不再依赖springrain-system-serviceimpl. * springrain-system-serviceimpl添加springrain-grpc-server依赖,启用org.springrain.SystemServiceImplApplication的@SpringBootApplication注解 * 启动seata-server服务端.seata客户端的配置在项目的resources/file.conf里,默认配置是 default.grouplist = "127.0.0.1:8091" * 启动springrain-system-serviceimpl * 启动springrain-system-web * 访问http://127.0.0.1:8080/system/api/checkHealth ## 文档 https://gitee.com/chunanyong/springrain/tree/master/springrain-system/springrain-system-web/doc ## 代码生成器 https://gitee.com/chunanyong/springrain/tree/master/springrain-gencode ## sql脚本 https://gitee.com/chunanyong/springrain/tree/master/springrain-system/springrain-system-web/sql ## 测试用例 ```java //就极简而言,一个数据库只需要一个Service,就可以管理这个数据库的任意一张表 //@Test 查询基本类型 public void testObject() throws Exception{ // Finder finder=new Finder("select id from t_user where 1=1 "); Finder finder=Finder.getSelectFinder(User.class,"id").append(" WHERE 1=1 "); finder.append("and id=:userId ").setParam("userId", "admin"); String id = baseDemoService.queryForObject(finder, String.class); System.out.println(id); } //@Test 查询一个对象 public void testObjectUser() throws Exception{ //Finder finder=new Finder("select * from t_user where id=:userId order by id"); Finder finder=Finder.getSelectFinder(User.class).append(" WHERE id=:userId order by id desc "); finder.setParam("userId", "admin"); User u = baseDemoService.queryForObject(finder, User.class); System.out.println(u.getName()); } //@Test 查询分页 public void testMsSql() throws Exception{ //Finder finder=new Finder("select * from t_user order by id"); Finder finder=Finder.getSelectFinder(User.class).append(" order by id desc "); Listlist = baseDemoService.queryForList(finder, User.class, new Page(2)); System.out.println(list.size()); for(User s:list){ System.out.println(s.getName()); } } //@Test 调用数据库存储过程 public void testProc() throws Exception{ Finder finder=new Finder(); finder.setParam("unitId", 0); finder.setProcName("proc_up"); Map queryObjectByProc = (Map) baseDemoService.queryObjectByProc(finder); System.out.println(queryObjectByProc.get("#update-count-10")); } //@Test 调用数据库函数 public void testFunction() throws Exception{ Finder finder=new Finder(); finder.setFunName("fun_userId"); finder.setParam("userId", "admin"); String userName= baseDemoService.queryForObjectByByFunction(finder,String.class); System.out.println(userName); } ```