/daijie-example

基于spring-cloud系列整合的分布式项目的例子，监控管理、配置中心、注册中心、分布式锁、分布式事务、多数据源、工作流、单点登录、oauth2授权、接口文档、路由跳转、第三方集成等等

Primary LanguageJava

目录

工程简介

架构拓朴图

架构拓朴图

项目说明

搭建java分布式微服务架构系统，集成第三方框架应用及实现初步的简单实例，跟进时代潮流，尽可能的用到项目中所有热门技术，从中学习与实现解决实际问题。

结构介绍：

控制层：控制层提供互联网访问，控制层的义务是控制访问请求跳转到接口业务层，监控用户状态，角色权限的拦截处理。
接口业务层：利用防火墙限制只允许指定的内网机器访问，接口业务层的义务是处理具体业务实现，对数据层进行数据维护。
业务层：利用防火墙限制只允许指定的内网机器访问，业务层的义务与接口业务层一样，它可以从某种特定的技术方案来更好的实现业务需求。
数据层：利用防火墙限制只允许指定的内网机器访问，数据层的义务是接收业务层的业务处理对数据库增删改查。
数据模型：sdk包，通常是一些实体类映射数据库表，及一些单表基础操作增删改查的接口方法。
feign接口：sdk包，提供微服务提供者实现接口和微服务消费者调用接口，微服务与微服务之间的数据通信。
服务治理：对所有微服务监控、配置、权限、文档和日志统一管理。
数据库：缓存数据库和持久化数据库的数据存储及查询。

这样搭建的优点：

1、随着越来越大的业务量，分散在很多的机器上运行，对性能和容量是一个很大的提升。
2、解决高并发的问题。
3、系统的可用性提升，不会因为单点故障影响到整个系统。
4、模块细分对系统重用性更高。
5、模块细分对人员任务分配比较明确。
6、模块细分解耦性对代码可维护性提高。
7、单个模块重启只需要部署极少的服务。
8、项目可灵活性的伸缩。
9、项目开发、测试、部署可以同时进行，完全独立互不影响，提升生产效率。
10、接口抽离成pom依赖调用，减少提供者与消费者编写重复代码。

这样搭建的缺点：

1、项目之间的接口服务调用沟通成本提高。
2、项目部署与维护难度提高。
3、架构设计技术难度提高。
4、在业务量小时响应时间会稍慢一些，且会增加系统的吞吐量。
5、故障排查难度提高。
6、需要对服务进行治理和调度维护。

根据业务需求适当的伸缩搭建微服务，当一块业务不依赖或极少依赖其它服务，有独立的业务语义，为超过2个的其他服务或客户端提供数据， 那么它就应该被拆分成一个独立的服务模块。如果你的项目业务够大，就可以分的这么细。

配置目录

  • config

配置中心集中式配置文件管理目录。

服务应用

  • eureka-server

提供注册服务监控中心。

  • config-server

提供分布式服务集中式属性配置中心。

  • seluth-server

提供监控分布式服务状态情况。

  • admin-server

提供微服务监控与管理。

提供shiro自定义配置用户角色权限，访问路径统一管理的安全节点服务，所有被拦截的服务提供集中式swagger文档，通过跳转访问api登录接口授权， 授权完成后再验证跳转api接口访问服务，验证失败直接返回错误数据。

提供shiro自定义配置用户角色权限，访问路径统一管理的安全节点服务，通过oauth2协议访问授权接口， 其中主要授权需要配置api登录接口，授权完成后再验证跳转api接口访问服务，验证失败直接返回错误数据。

项目模块

  • mybatis-model

1、集成mybatis-generator工具自动生成model和mapper文件的实例。
2、与数据库对应实体统一管理，利于数据库结构变动只需重新生成即可。
3、此项目不做人工代码修改，对数据库尽可能的单表操作，利用了缓存机制在多表连查时可以大大提升查询效率。

1、实现了数据库crud操作的实例，mybatis与jpa多数源配置，且实现了分布式事务，其中shardingjdbc官方自带实现了这些功能。
2、三个项目用了三个不同的ORM框架实现，可以启用任意一个服务，因服务名配置一致，全部启动会起到微服务集群的效果。
3、此项目可根据产品模块化细分为分布式的拆分为多个子项目，处理数据层的业务逻辑及数据库操作，做为资源服务的微服务提供者。

  • elasticsearch-cloud

1、提供数据库elasticsearch存储的搜索引擎实例。
2、此项目可根据产品模块化细分为分布式的拆分为多个子项目，处理数据层的业务逻辑及数据库操作，做为资源服务的微服务提供者。

1、实现了简单的分布式锁实例。
2、实现了生成二维码实例。
3、实现了redis访问实例。
4、实现了hadoop与fastdfs文件上传实例。
5、提供单点登录接口，shiro sesssion+redis+kisso技术缓存用户状态。
6、此项目可根据产品模块化细分为分布式的拆分为多个子项目，处理用户交互层的业务逻辑，调用所有的微服务提供者，提供对外资源接口调用。

  • rabbit-cloud

1、实现了消息生产与消费实例。
2、处理高并发，复杂算法，无需即时回馈的业务。
3、此项目可根据产品模块化细分为分布式的拆分为多个子项目，也可以拆分为生产消息的生产者和消费消息的消费者，调用资源服务的微服务提供者处理数据层的业务逻辑，做为消息服务的微服务提供者。

  • quaryz-cloud

1、实现了定时任务实例。
2、此项目可根据产品模块化细分为分布式的拆分为多个子项目，处理业务层的业务逻辑，调用资源服务的微服务提供者。

1、实现了请假、文物备案流程的实例。
2、此项目可根据产品模块化细分为分布式的拆分为多个子项目，调用资源服务的微服务提供者处理流程业务逻辑，做为流程服务的微服务提供者。

1、实现了第三方登录实例。
2、此项目可根据产品模块化细分为分布式的拆分为多个子项目，调用第三方接口及数据回调，做为第三方服务调用的微服务提供者。

相关文档

环境搭建

项目环境

  • 安装jdk1.8
  • 安装maven
  • 安装eclipse、myeclise或idea等编辑器
  • 导入maven项目等下载完daijie-parent-spring-boot-starter的依赖包到本地库，最新版本的代码需要从github下载源码

项目部署

启动eureka-server步骤

启动config-server步骤

启动seluth-server步骤

  • 安装mysql
  • 创建zipkin库，相关表会在启动时自动创建
  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行seluth-server的main方法
  • 访问地址http://localhost:12809

启动admin-server步骤

  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行admin-server的main方法
  • 访问地址http://localhost:12812

启动shiro-server步骤

  • 安装redis3.0以上版本
  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行shiro-server的main方法
  • 配置host：127.0.0.1 daijie.org（因采用的是kisso cookie管理，访问localhost则不生效，或者在配置中关闭kisso）
  • 访问地址http://daijie.org:12802/swagger-ui.html
  • 分别启动mybatis-cloud和shiro-api
  • 通过swagger文档在线调用登录注册接口

启动oauth2-server步骤

  • 安装redis3.0以上版本
  • 安装mysql
  • 创建oauth2库，执行oauth2.sql脚本（在执行oauth2-server时会自动创建oauth2相关表，这里手动初始化了client_id数据）
  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行oauth2-server的main方法
  • 配置host：127.0.0.1 daijie.org（因采用的是kisso cookie管理，访问localhost则不生效，或者在配置中关闭kisso）
  • 分别启动mybatis-cloud和shiro-api
  • 通过访问接口的方式进行角色授权(用户注册可以访问shiro-api的swagger-ui.html调用注册接口进行注册，appid为test，密钥为daijie.org，同时client_id与client_secret在数据库oauth2.oauth_client_details表维护，密码存储用的是BCrypt加密)

授权访问流程：

1、http://daijie.org:12813/oauth/token?username=《你的用户名》&password=《你的密码》&grant_type=password&scope=select&client_id=《你的appid》&client_secret=《你的密钥》
2、得到access_token
3、访问资源接口http://daijie.org:12813/api/user?access_token=《你的回调access_token》

在实际开发中outh2授权访问流程：

1、http://daijie.org:12813/oauth/authorize?client_id=《你的appid》&redirect_uri=《你的回调地址》&response_type=code&state=《你的其它标识，用于回调接口接收》
2、跳转登录页，输入用户名密码点登录（没有用户先调注册接口注册账号）
3、得到code和state
4、http://daijie.org:12813/oauth/token?client_id=《你的appid》&client_sercet=《你的密钥》&code=《你的回调code值》&grant_type=authorization_code
5、得到access_token
6、拿着access_token就可以有权限请求资源接口了

mybatis-model生成实体类和生成数据结构文档步骤

  • 安装mysql
  • 创建demo库，执行demo.sql脚本
  • 配置generatorConfig.xml
  • 生成java文件执行maven命令：mvn mybatis-generator:generate
  • 生成数据结构文档执行maven命令：mvn daijie-jdbc:doc

启动mybatis-cloud & jpa-cloud & mybatis-shardingjdbc-cloud步骤 (mybatis-shardingjdbc-cloud暂不支持spring boot2.0，1.1.X版本会启动失败)

  • 安装mysql
  • 创建demo1和demo2库，执行demo1.sql与demo2.sql脚本
  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行mybatis-cloud或jpa-cloud或mybatis-shardingjdbc-cloud的main方法
  • 访问地址http://localhost:12808/swagger-ui.html

启动elasticsearch-cloud步骤

  • 安装mysql
  • 安装elasticsearch
  • 创建demo库，执行demo.sql脚本
  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行elasticsearch-cloud的main方法
  • 访问地址http://localhost:12807/swagger-ui.html

启动shiro-api步骤

  • 安装mysql
  • 安装redis3.0以上版本
  • 创建demo1和demo2库，执行demo1.sql与demo2.sql脚本
  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行mybatis-cloud或jpa-cloud或mybatis-shardingjdbc-cloud的main方法
  • 执行shiro-api的main方法
  • 访问地址http://localhost:12803/swagger-ui.html

启动rabbit-cloud步骤

启动quaryz-cloud步骤

启动activiti-cloud步骤

  • 安装mysql
  • 创建activiti库，相关表会在启动时自动创建
  • 执行eureka-server的main方法
  • 执行config-server的main方法
  • 执行activiti-cloud的main方法
  • 访问地址http://localhost:12806/swagger-ui.html

启动social-cloud步骤