内容简介:02:业务架构设计,系统分层管理服务的架构设计决定软件的业务支撑能力,清晰的业务设计可以帮助开发人员理解系统。在业务架构设计过程中,需要根据用户需求作为核心方向,根据用户需求确定产品设计、框架搭建、服务划分、数据库规划。如果需求比较单一,单个应用服务可以支撑,则不需要设计复杂的微服务系统,如果根据对业务的判断,会在一段时间内出现业务并发,则最好开始的时候就考虑业务的扩展性,架构的支撑能力。
更新进度(共6节):
02:业务架构设计,系统分层管理
一、业务架构设计
1、基础概念
服务的架构设计决定软件的业务支撑能力,清晰的业务设计可以帮助开发人员理解系统。在业务架构设计过程中,需要根据用户需求作为核心方向,根据用户需求确定产品设计、框架搭建、服务划分、数据库规划。如果需求比较单一,单个应用服务可以支撑,则不需要设计复杂的微服务系统,如果根据对业务的判断,会在一段时间内出现业务并发,则最好开始的时候就考虑业务的扩展性,架构的支撑能力。
2、案例架构图
基于该项目的架构设计,下面逐个描述一下业务设计。
二、业务流程
1、数据入库服务
-
流程图解
-
流程描述
1. 请求入库服务接口;
2. 搜索数据,通过搜索服务Feign接口写入ES服务器;
3. 相同的搜索数据,写入用户数据库;
-
程序入口
所属代码包:mopsz-data-form
@RestController
@RequestMapping("/search/data")
public class SearchDataController {
// 调用搜索服务Feign接口
@Resource
private BookInfoEsFeign bookInfoEsFeign ;
@Resource
private BookInfoService bookInfoService ;
@RequestMapping("/batchSave")
public String batchSave (){
// 省略业务代码
}
}
2、用户API服务
-
流程图解
-
流程描述
1. 用户请求进入,网关服务拦截;
2. 调用Token管理服务,验证用户的身份令牌,使用 Redis 存储Token;
3. 如果身份验证通过,则网关放行用户请求;
4. 执行用户搜索请求处理;
5、根据搜索条件,调用ES搜索服务,返回结果;
6、将用户的搜索动作进行封装,请求MQ服务;
7、MQ服务请消息转发到数据分析服务 ;
8、数据分析服务安装策略分析用户请求,存储分析结果;
-
程序入口
(1)、网关拦截
所属代码包:mopsz-cloud-gateway
@Component
public class FilterConfig extends ZuulFilter {
public static final Logger LOGGER = LoggerFactory.getLogger(FilterConfig.class) ;
private static final String GET_TOKEN = "/token/getToken";
private static final String VERIFY_TOKEN = "/token/verifyToken";
private static final String REFRESH_TOKEN = "/token/refreshToken";
/**
* 拦截处理
*/
@Override
public Object run() throws ZuulException {
RequestContext requestContext = RequestContext.getCurrentContext() ;
try {
doTokenProcess (requestContext);
} catch (Exception e){
LOGGER.info("异常:{}",e.getMessage());
throw new ZuulException(e.getMessage(), 403, e.getMessage());
}
return null ;
}
public void doTokenProcess (RequestContext requestContext) throws Exception {
HttpServletRequest request = requestContext.getRequest() ;
String reqUri = request.getRequestURI() ;
if (!reqUri.contains(GET_TOKEN)) {
String token = request.getHeader("token") ;
boolean flag = userTokenFeign.refreshToken(token) ;
if (!flag){
throw new ServiceException("Token 校验失败") ;
}
LOGGER.info("Token 校验通过");
}
}
}
(2)、Token管理
所属代码包:mopsz-basis-token
@RestController
@RequestMapping("/token")
public class UserTokenController implements UserTokenFeign {
@Resource
private UserTokenService tokenService ;
/**
* 获取Token
*/
@Override
@RequestMapping("/getToken")
public RespObject getToken (@RequestParam("userName") String userName,
@RequestParam("passWord") String passWord){
try {
String token = tokenService.getToken(userName,passWord) ;
return RespObject.ok().put(Constant.MAP_KEY,token) ;
} catch (Exception e){
e.printStackTrace();
return RespObject.error() ;
}
}
/**
* 校验Token
*/
@Override
@RequestMapping("/verifyToken")
public RespObject verifyToken(String token) {
try {
Integer userId = tokenService.verifyToken(token) ;
return RespObject.ok().put(Constant.MAP_KEY,userId) ;
} catch (Exception e){
e.printStackTrace();
return RespObject.error() ;
}
}
/**
* 刷新Token
*/
@Override
@RequestMapping("/refreshToken")
public boolean refreshToken(String token) {
try {
return tokenService.refreshToken(token) ;
} catch (Exception e){
e.printStackTrace();
return false ;
}
}
}
(3)、搜索接口
所属代码包:mopsz-user-client
@RestController
@RequestMapping("/search/book/")
public class BookSearchController {
@Resource
private BookInfoEsFeign bookInfoEsFeign ;
@Resource
private UserSearchFeign userSearchFeign ;
/**
* 关键字全文搜索
*/
@RequestMapping("/getByKeyWord")
public List<EsBookInfo> getByKeyWord (@RequestParam("keyWord") String keyWord,
@RequestParam("userId") Integer userId){
// 搜索引擎执行
List<EsBookInfo> esBookInfoList = bookInfoEsFeign.getByKeyWord(keyWord) ;
// 执行异步分析
if (StringUtils.isNotEmpty(keyWord) && esBookInfoList != null){
KeySearchModel keySearchModel = new KeySearchModel() ;
keySearchModel.setUserId(userId);
keySearchModel.setKeyWord(keyWord);
keySearchModel.setSearchResult(esBookInfoList);
userSearchFeign.sendBookSearch(JsonUtil.objToJson(keySearchModel));
}
return esBookInfoList ;
}
}
(4)、请求分析
所属代码包:mopsz-data-analy
@RestController
public class BookEsDataController implements BookEsAnalyFeign {
@Resource
private BookEsDataService bookEsDataService ;
@Override
public void sendBookEsMsg(String msgBody) {
bookEsDataService.saveBookEsData(msgBody);
}
}
3、系统管理服务
-
流程图解
-
流程描述
整合流程基础SpringSecurity,JWT等组件开发。所属代码包:mopsz-admin-client。
1. 系统用户登录,安全配置:SecurityConfig ;
2. 登录成功处理:LoginSuccessHandler ;
3. 登录失败处理:LoginFailHandler ;
4. 系统服务具备管理:业务数据库,缓存数据,ES服务等功能 ;
4、数据分析服务
-
流程图解
-
流程描述
所属代码包:mopsz-data-analy
1. 接收MQ服务转发数据分析请求 ;
2. 按照指定策略,分析数据,分析结果存储 ;
三、系统分层管理
1、分层示意图
2、结构层次描述
-
公共代码块层
管理系统 工具 类、数据表结构实体类、Mapper层、Service服务层等,按照数据库服务规划划分,作为整个系统的公共依赖代码块。
-
数据管理层
管理数据入库服务API,数据分析服务API两个模块。
-
客户端接口层
管理用户服务API,后台系统服务API。
-
微服务接口层
微服务之间的调用采用Feign接口的方式,按照不同服务提供的Feign接口进行封装,在该层统一管理,进行服务间的请求调用。
-
通用业务服务层
管理通用Token服务,消息发送服务,作为系统共用的业务服务层。
-
中间件服务层
管理RocketMQ消息队列服务、Redis缓存服务、Quart定时器服务、ES搜索服务,提供统一的Feign服务接口。
-
微服务组件层
管理整个系统的网关拦截服务、Eureka服务注册和发现 等微服务基础组件。
四、源代码地址
GitHub·地址
https://github.com/cicadasmile/husky-spring-cloud
GitEE·地址
https://gitee.com/cicadasmile/husky-spring-cloud
以上所述就是小编给大家介绍的《微服务架构案例(二):业务架构设计,系统分层管理》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Java 8函数式编程
[英] Richard Warburton / 王群锋 / 人民邮电出版社 / 2015-3 / 39.00元
通过每一章的练习快速掌握Java 8中的Lambda表达式 分析流、高级集合和其他Java 8类库的改进 利用多核CPU提高数据并发的性能 将现有代码库和库代码Lambda化 学习Lambda表达式单元测试和调试的实践解决方案 用Lambda表达式实现面向对象编程的SOLID原则 编写能有效执行消息传送和非阻塞I/O的并发应用一起来看看 《Java 8函数式编程》 这本书的介绍吧!
JSON 在线解析
在线 JSON 格式化工具
html转js在线工具
html转js在线工具