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

2024-01-01 17:36
文章标签 实现 业务 逻辑 搭建 从零开始 生产 分布式应用 grpc 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。

相关文章

windos server2022里的DFS配置的实现

windos server2022里的DFS配置的实现

《windosserver2022里的DFS配置的实现》DFS是WindowsServer操作系统提供的一种功能,用于在多台服务器上集中管理共享文件夹和文件的分布式存储解决方案,本文就来介绍一下wi... 目录什么是DFS？优势：应用场景：DFS配置步骤什么是DFS？DFS指的是分布式文件系统（Distr
阅读更多...
NFS实现多服务器文件的共享的方法步骤

NFS实现多服务器文件的共享的方法步骤

《NFS实现多服务器文件的共享的方法步骤》NFS允许网络中的计算机之间共享资源,客户端可以透明地读写远端NFS服务器上的文件,本文就来介绍一下NFS实现多服务器文件的共享的方法步骤,感兴趣的可以了解一... 目录一、简介二、部署1、准备1、服务端和客户端：安装nfs-utils2、服务端：创建共享目录3、服
阅读更多...
C#使用yield关键字实现提升迭代性能与效率

C#使用yield关键字实现提升迭代性能与效率

《C#使用yield关键字实现提升迭代性能与效率》yield关键字在C#中简化了数据迭代的方式,实现了按需生成数据,自动维护迭代状态,本文主要来聊聊如何使用yield关键字实现提升迭代性能与效率,感兴... 目录前言传统迭代和yield迭代方式对比yield延迟加载按需获取数据yield break显式示迭
阅读更多...
Python实现高效地读写大型文件

Python实现高效地读写大型文件

《Python实现高效地读写大型文件》Python如何读写的是大型文件,有没有什么方法来提高效率呢,这篇文章就来和大家聊聊如何在Python中高效地读写大型文件,需要的可以了解下... 目录一、逐行读取大型文件二、分块读取大型文件三、使用 mmap 模块进行内存映射文件操作（适用于大文件）四、使用 pand
阅读更多...
python实现pdf转word和excel的示例代码

python实现pdf转word和excel的示例代码

《python实现pdf转word和excel的示例代码》本文主要介绍了python实现pdf转word和excel的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价... 目录一、引言二、python编程1，PDF转Word2，PDF转Excel三、前端页面效果展示总结一
阅读更多...
Python xmltodict实现简化XML数据处理

Python xmltodict实现简化XML数据处理

《Pythonxmltodict实现简化XML数据处理》Python社区为提供了xmltodict库,它专为简化XML与Python数据结构的转换而设计,本文主要来为大家介绍一下如何使用xmltod... 目录一、引言二、XMLtodict介绍设计理念适用场景三、功能参数与属性1、parse函数2、unpa
阅读更多...
C#实现获得某个枚举的所有名称

C#实现获得某个枚举的所有名称

《C#实现获得某个枚举的所有名称》这篇文章主要为大家详细介绍了C#如何实现获得某个枚举的所有名称,文中的示例代码讲解详细,具有一定的借鉴价值,有需要的小伙伴可以参考一下... C#中获得某个枚举的所有名称using System;using System.Collections.Generic;usi
阅读更多...
Go语言实现将中文转化为拼音功能

Go语言实现将中文转化为拼音功能

《Go语言实现将中文转化为拼音功能》这篇文章主要为大家详细介绍了Go语言中如何实现将中文转化为拼音功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 有这么一个需求：新用户入职 创建一系列账号比较麻烦，打算通过接口传入姓名进行初始化。想把姓名转化成拼音。因为有些账号即需要中文也需要英
阅读更多...
C# 读写ini文件操作实现

C# 读写ini文件操作实现

《C#读写ini文件操作实现》本文主要介绍了C#读写ini文件操作实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录一、INI文件结构二、读取INI文件中的数据在C#应用程序中，常将INI文件作为配置文件，用于存储应用程序的
阅读更多...
C#实现获取电脑中的端口号和硬件信息

C#实现获取电脑中的端口号和硬件信息

《C#实现获取电脑中的端口号和硬件信息》这篇文章主要为大家详细介绍了C#实现获取电脑中的端口号和硬件信息的相关方法,文中的示例代码讲解详细,有需要的小伙伴可以参考一下... 我们经常在使用一个串口软件的时候，发现软件中的端口号并不是普通的COM1，而是带有硬件信息的。那么如果我们使用C#编写软件时候，如
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2