基于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

相关文章

NameNode内存生产配置

Hadoop2.x 系列,配置 NameNode 内存 NameNode 内存默认 2000m ,如果服务器内存 4G , NameNode 内存可以配置 3g 。在 hadoop-env.sh 文件中配置如下。 HADOOP_NAMENODE_OPTS=-Xmx3072m Hadoop3.x 系列,配置 Nam

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯,先赞后看哦~🎈🎈 🏆 作者简介:景天科技苑 🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,CSDN全栈领域优质创作者,掘金优秀博主,51CTO博客专家等。 🏆《博客》:Python全栈,前后端开发,小程序开发,人工智能,js逆向,App逆向,网络系统安全,数据分析,Django,fastapi

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现,因为rasa本身是带有remindschedule模块的。不过经过一番折腾后,忽然发现,chatbot上实现的定时,语音助手不一定会有响应。因为,我目前语音助手的代码设置了长时间无应答会结束对话,这样一来,chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢? 我最后选择的方法是用threading.Time

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

搭建Kafka+zookeeper集群调度

前言 硬件环境 172.18.0.5        kafkazk1        Kafka+zookeeper                Kafka Broker集群 172.18.0.6        kafkazk2        Kafka+zookeeper                Kafka Broker集群 172.18.0.7        kafkazk3

业务中14个需要进行A/B测试的时刻[信息图]

在本指南中,我们将全面了解有关 A/B测试 的所有内容。 我们将介绍不同类型的A/B测试,如何有效地规划和启动测试,如何评估测试是否成功,您应该关注哪些指标,多年来我们发现的常见错误等等。 什么是A/B测试? A/B测试(有时称为“分割测试”)是一种实验类型,其中您创建两种或多种内容变体——如登录页面、电子邮件或广告——并将它们显示给不同的受众群体,以查看哪一种效果最好。 本质上,A/B测

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注,收藏不迷路💖 Kubernetes的PodSecurityPolicy(PSP)是一个关键的安全特性,它在Pod创建之前实施安全策略,确保P