基于grpc从零开始搭建一个准生产分布式应用(9) - Service业务逻辑层实现

本文主要是介绍基于grpc从零开始搭建一个准生产分布式应用(9) - Service业务逻辑层实现,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

开始前必读:​​基于grpc从零开始搭建一个准生产分布式应用(0) - quickStart​​ 

前面章节的GRPC内基本是一个空实现,本章就实现下service业务逻辑层代码,因例子比较简单代码量也不算大,本章代码任务:1、用spring实现服务层,熟悉各注解的使用;2、实现一个VO逻辑,巩固mapStruct框架的使用。

一、工程结构

本章只涉及【base-grpc-framework-core】工程的改动,需改动的代码如下图所示:

二、创建必要的实体类

2.1、MVC层VO类

package com.zd.baseframework.core.controller.core.vo;import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.databind.PropertyNamingStrategy;
import com.fasterxml.jackson.databind.annotation.JsonNaming;
import lombok.Data;import java.time.LocalDateTime;@Data
@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonNaming(PropertyNamingStrategy.SnakeCaseStrategy.class)
public class SystemLogVo {private Long id;private String bizId;private Long userId;private String trackUid;private String code;private String customCode;private Integer state;@JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")private LocalDateTime ctime;@JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")private LocalDateTime utime;
}

2.2、Service层BO类

package com.zd.baseframework.core.core.systemlog.model;import lombok.Data;
import java.time.LocalDateTime;@Data
public class SystemLogBo {private Long id;private String bizId;private Long userId;private String trackUid;private String code;private String customCode;private Integer state;private LocalDateTime ctime;private LocalDateTime utime;
}
package com.zd.baseframework.core.core.systemlog.model;import lombok.Data;@Data
public class SystemLogQueryBo {private String bizId;private Long userId;private String code;}

2.3、VO和BO的专换工具类

新增代码第16~20行,转换VO和BO

/*** @Title: com.zd.baseframework.core.controller.core.translator.SystemLogTranslator* @Description http层与grpc层对象转换工具* @author liudong* @date 2022/6/15 8:52 PM*/
@Mapper(collectionMappingStrategy = CollectionMappingStrategy.ADDER_PREFERRED,nullValueCheckStrategy = NullValueCheckStrategy.ALWAYS,imports = {MapStructMapperUtil.class},uses = BaseMapStructMapper.class)
public interface SystemLogTranslator {SystemLogTranslator INSTANCE = Mappers.getMapper(SystemLogTranslator.class);/*查询请求参数转换*/ListSystemLogRequest toGrpcQueryReqObject(SystemLogQueryRequest var);/*查询返回结果转换,这两个是一组,其中在生成源码时toQueryResultVos会调用toQueryResultVo*/SystemLogVo toQueryResultVo(SystemLogDto var);List<SystemLogVo> toQueryResultVos(List<SystemLogDto> var);
}
/*** @Title: com.zd.baseframework.core.core.systemlog.api.SystemLogDtoTranslator* @Description grpc与service层对象转换工具类* @author liudong* @date 2022/6/15 8:59 PM*/
@Mapper(collectionMappingStrategy = CollectionMappingStrategy.ADDER_PREFERRED,nullValueCheckStrategy = NullValueCheckStrategy.ALWAYS,imports = {MapStructMapperUtil.class},uses = BaseMapStructMapper.class)
public interface SystemLogDtoTranslator {SystemLogDtoTranslator INSTANCE = Mappers.getMapper(SystemLogDtoTranslator.class);/*查询请求参数转换*/SystemLogQueryBo toQueryBo(ListSystemLogRequest var);/*返回结果转换*/SystemLogDto toQueryResultDto(SystemLogBo var);List<SystemLogDto> toQueryResultDtos(List<SystemLogBo> var);
}

三、创建Service接口和实现

3.1、接口定义

package com.zd.baseframework.core.core.systemlog.service;public interface ISystemLogServcie {boolean createSystemLog(SystemLogBo systemLogBo);List<SystemLogBo> listByCondition(SystemLogQueryBo systemLogQueryBo);
}

3.2、接口实现

package com.zd.baseframework.core.core.systemlog.service.impl;@Service
@Slf4j
@Primary
public class SystemLogServcieImpl implements ISystemLogServcie {@Overridepublic boolean createSystemLog(SystemLogBo systemLogBo) {String trackLog = LogGenerator.trackLog();log.info(trackLog+ "createSystemLog=" + JSONUtil.toJsonStr(systemLogBo));try{return null;}catch(Exception e){throw e;}}@Overridepublic List<SystemLogBo> listByCondition(SystemLogQueryBo systemLogQueryBo) {String trackLog = LogGenerator.trackLog();try{return null;}catch(Exception e){throw e;}}
}

四、建立GRPC与SERVICE调用关系

4.1、Contoller集成VO

修改com.zd.baseframework.core.controller.core.SystemLogController类的如下方法,新增第5~8行。

@PostMapping("/v1/list_systemlog")public BaseResponse listSystemLog(@RequestBody SystemLogQueryRequest systemLogRequest){try{//构建查询参数ListSystemLogRequest listSystemLogRequest  = SystemLogTranslator.INSTANCE.toGrpcQueryReqObject(systemLogRequest);ListSystemLogResponse listSystemLogResponse = iSysRecordServiceBlockingStub.listSystemLogByCondition(listSystemLogRequest);List<SystemLogVo> vos = SystemLogTranslator.INSTANCE.toQueryResultVos(listSystemLogResponse.getDataList());return BaseResponse.success(vos);}catch(StatusRuntimeException e){log.error("ErrorCode : " + e.getStatus().getCode());return BaseResponse.error(e.getMessage());}catch(Exception e){e.printStackTrace();return BaseResponse.error(e.getMessage());}}

4.2、Grpc调用Service逻辑

修改com.zd.baseframework.core.core.systemlog.api.impl.SystemLogServiceApiImpl类,完整代码如下:

@GrpcService
@Slf4j
public class SystemLogServiceApiImpl extends ISystemLogServiceGrpc.ISystemLogServiceImplBase {@Autowiredprivate ISystemLogServcie iSystemLogServcie;@Overridepublic void createSystemLog(CreateSystemLogRequest request, StreamObserver<SystemLogOperatorResponse> responseObserver)  {String bizId = request.hasBizId()?request.getBizId().getValue():null;Long userId  = request.hasUserId()?request.getUserId().getValue():null;String code = request.hasCode()?request.getCode().getValue():null;String customCode = request.hasCustomCode()?request.getCustomCode().getValue():null;String trackLog = LogGenerator.trackLog();try{//打印原始入参log.info(trackLog+ " grpcReqParam=" + JsonFormat.printer().omittingInsignificantWhitespace().print(request));//入参验证if(StrUtil.isEmpty(bizId)|| null==userId|| StrUtil.isEmpty(code) ){throw new AppException("非法参数");}SystemLogBo systemLogBo = new SystemLogBo();systemLogBo.setCode(code);systemLogBo.setCustomCode(customCode);systemLogBo.setBizId(bizId);systemLogBo.setUserId(userId);systemLogBo.setTrackUid("10000");boolean result = iSystemLogServcie.createSystemLog(systemLogBo);if(result){SystemLogOperatorResponse response  = SystemLogOperatorResponse.newBuilder().setStatus(ResponseConst.SUCCESS).setMessage(ResponseConst.Msg.SUCCESS).build();responseObserver.onNext(response);}else{log.info(trackLog+ " grpcReqParam=" + JsonFormat.printer().omittingInsignificantWhitespace().print(request)+ " result=fail" );responseObserver.onError(Status.INVALID_ARGUMENT.asException());}responseObserver.onCompleted();}catch (AppException e) {log.error(e.getMessage());responseObserver.onError(Status.INVALID_ARGUMENT.withDescription(e.getMessage()).asException());}catch(Exception e){log.error(e.getMessage());responseObserver.onError(Status.INTERNAL.withDescription(e.getMessage()).asException());}}@Overridepublic void listSystemLogByCondition(ListSystemLogRequest request, StreamObserver<ListSystemLogResponse> responseObserver) {String trackLog = LogGenerator.trackLog();try{//打印原始入参log.info(trackLog+ " grpcReqParam=" + JsonFormat.printer().omittingInsignificantWhitespace().print(request));SystemLogQueryBo systemLogQueryBo = SystemLogDtoTranslator.INSTANCE.toQueryBo(request);List<SystemLogBo> systemLogBoList = iSystemLogServcie.listByCondition(systemLogQueryBo);log.info(trackLog+ " systemLogBoListSize=" + CollUtil.size(systemLogBoList));List<SystemLogDto> dtos = SystemLogDtoTranslator.INSTANCE.toQueryResultDtos(systemLogBoList);ListSystemLogResponse response = ListSystemLogResponse.newBuilder().addAllData(dtos).build();responseObserver.onNext(response);responseObserver.onCompleted();}catch (AppException e) {log.error(e.getMessage());responseObserver.onError(Status.INVALID_ARGUMENT.withDescription(e.getMessage()).asException());}catch(Exception e){log.error(e.getMessage());responseObserver.onError(Status.INTERNAL.withDescription(e.getMessage()).asException());}}
}

这篇关于基于grpc从零开始搭建一个准生产分布式应用(9) - Service业务逻辑层实现的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/560019

相关文章

Qt使用QSqlDatabase连接MySQL实现增删改查功能

《Qt使用QSqlDatabase连接MySQL实现增删改查功能》这篇文章主要为大家详细介绍了Qt如何使用QSqlDatabase连接MySQL实现增删改查功能,文中的示例代码讲解详细,感兴趣的小伙伴... 目录一、创建数据表二、连接mysql数据库三、封装成一个完整的轻量级 ORM 风格类3.1 表结构

基于Python实现一个图片拆分工具

《基于Python实现一个图片拆分工具》这篇文章主要为大家详细介绍了如何基于Python实现一个图片拆分工具,可以根据需要的行数和列数进行拆分,感兴趣的小伙伴可以跟随小编一起学习一下... 简单介绍先自己选择输入的图片,默认是输出到项目文件夹中,可以自己选择其他的文件夹,选择需要拆分的行数和列数,可以通过

Python中将嵌套列表扁平化的多种实现方法

《Python中将嵌套列表扁平化的多种实现方法》在Python编程中,我们常常会遇到需要将嵌套列表(即列表中包含列表)转换为一个一维的扁平列表的需求,本文将给大家介绍了多种实现这一目标的方法,需要的朋... 目录python中将嵌套列表扁平化的方法技术背景实现步骤1. 使用嵌套列表推导式2. 使用itert

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

在Linux中改变echo输出颜色的实现方法

《在Linux中改变echo输出颜色的实现方法》在Linux系统的命令行环境下,为了使输出信息更加清晰、突出,便于用户快速识别和区分不同类型的信息,常常需要改变echo命令的输出颜色,所以本文给大家介... 目python录在linux中改变echo输出颜色的方法技术背景实现步骤使用ANSI转义码使用tpu

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库:CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

golang版本升级如何实现

《golang版本升级如何实现》:本文主要介绍golang版本升级如何实现问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录golanwww.chinasem.cng版本升级linux上golang版本升级删除golang旧版本安装golang最新版本总结gola

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具

Mysql实现范围分区表(新增、删除、重组、查看)

《Mysql实现范围分区表(新增、删除、重组、查看)》MySQL分区表的四种类型(范围、哈希、列表、键值),主要介绍了范围分区的创建、查询、添加、删除及重组织操作,具有一定的参考价值,感兴趣的可以了解... 目录一、mysql分区表分类二、范围分区(Range Partitioning1、新建分区表:2、分