基于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 {
    
  
    @Override
    public boolean createSystemLog(SystemLogBo systemLogBo) {
        String trackLog = LogGenerator.trackLog();
        log.info(trackLog
                + "createSystemLog=" + JSONUtil.toJsonStr(systemLogBo)
        );
        try{
            return null;

        }catch(Exception e){
            throw e;
        }
    }

    @Override
    public 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 {

    @Autowired
    private ISystemLogServcie iSystemLogServcie;

    @Override
    public 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());
        }
    }

    @Override
    public 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());
        }
    }
}

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Big-endian与Little-endian详尽说明

Big-endian与Little-endian详尽说明

大端与小端存储详尽说明 大端与小端存储详尽说明 大端与小端存储详尽说明一. 什么是字节序二. 什么是大端存储模式三. 什么是小端存储模式四. 大小端各自的特点五. 为什么会有大小端模式之分六. 为什么要注意大小端问题六. 大小端判定程序七. 大端小端的转换1&#xff09;16位大…
阅读更多...
华清远见作业第十八天——IO（第一天）

华清远见作业第十八天——IO（第一天）

思维导图&#xff1a; 使用fgets统计一个文件的行号 代码&#xff1a; #include<stdio.h> #include<string.h> #include<stdlib.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> int main(int argc, const char *a…
阅读更多...
【Java】JUC并发编程（重量锁、轻量锁、偏向锁）

【Java】JUC并发编程（重量锁、轻量锁、偏向锁）

JUC并发编程 预备&#xff1a; 创建一个maven工程&#xff0c;导入lombok和logback的依赖。 1、基础概念 1、进程与线程 **进程&#xff1a;**程序由指令和数据组成&#xff0c;但这些指令要运行&#xff0c;数据要读写&#xff0c;就必须将指令加载至 CPU &#xff0c;数…
阅读更多...
CRM客户关系管理系统

CRM客户关系管理系统

系统开发环境以及版本 操作系统&#xff1a; Windows_7集成开发工具&#xff1a; Eclipse EE_4.7编译环境&#xff1a;JDK_1.8Web服务器&#xff1a;Tomcat_9.0数据库&#xff1a;MySQL_5.7.23 系统框架 spring框架springmvc框架mybatis框架Logback日志框架安全验证框架maven框…
阅读更多...
第7课 利用FFmpeg将摄像头画面与麦克风数据合成后推送到rtmp服务器

第7课 利用FFmpeg将摄像头画面与麦克风数据合成后推送到rtmp服务器

上节课我们已经拿到了摄像头数据和麦克风数据&#xff0c;这节课我们来看一下如何将二者合并起来推送到rtmp服务器。推送音视频合成流到rtmp服务器地址的流程如下&#xff1a; 1.创建输出流 //初始化输出流上下文 avformat_alloc_output_context2(&outFormatCtx, NULL, &…
阅读更多...
Linux学习笔记(一)

Linux学习笔记(一)

如果有自己的物理服务器请先查看这篇文章 文章目录 网卡配置Linux基础指令ls:列出目录内容cd(mkdir.rmkdir): 切换文件夹(创建,删除操作)cp:复制文件或目录mv:文件/文件夹移动cat:查看文件vi:文件查看编辑man:查看命令手册more: 查看文件内容less : 查看文件内容 ps: 显示当前进…
阅读更多...
LangChain（0.0.340）官方文档十一：Agents之Agent Types

LangChain（0.0.340）官方文档十一：Agents之Agent Types

LangChain官网、LangChain官方文档 、langchain Github、langchain API文档、llm-universe《Agent Types》、《Examples using AgentType》 文章目录 一、快速入门1.1 概念1.2 基本示例1.2.1 配置LangSmith1.2.2 使用LCEL语法创建Agents1.2.3 使用自定义runtime执行1.2.4 使用A…
阅读更多...
分布式IO在工业自动化中的应用

分布式IO在工业自动化中的应用

传统的自动化产线及物流系统主要是利用PLC来处理数据&#xff0c;并将这些数据保存在PC当中。但是随着互联网技术的迅速发展&#xff0c;越来越多的系统集成商利用分布式IO模块&#xff0c;实现从控制器到自动化最底层之间的IO通信。 分布式IO在工业自动化中的应用 分布式IO是用…
阅读更多...
【Android】自定义View组件，并实现在 Compose、Kotlin、Xml 中调用

【Android】自定义View组件，并实现在 Compose、Kotlin、Xml 中调用

从事 Android 开发以来&#xff0c;很少有过自定义 View 的相关开发需求&#xff0c;大部分 UI 都是可以集成某些官方组件&#xff0c;在组件的基础上完成能够大大缩短开发时间。但今天我要讲的是&#xff1a;如何使用 Android 开发一个Compose、Xml都可以调用的组件&#xff1…
阅读更多...
[蓝桥 2023] 位乘积计数

[蓝桥 2023] 位乘积计数

问题描述 给定两个正整数 n 和 m&#xff0c;请你计算出&#xff0c;从 1到 n 的所有整数中&#xff0c;满足每一位上的数字乘积小于等于 m 的数字的个数。 例如&#xff0c;当 n12&#xff0c;m3 时&#xff0c;满足条件的数字有 1,2,3,10,11,12 共 6 个。 输入格式 输出格…
阅读更多...
[LLM]大模型训练(二)--DeepSpeed使用

[LLM]大模型训练(二)--DeepSpeed使用

安装DeepSpeed与集成 DeepSpeed可以通过pip安装&#xff0c;无需指定PyTorch和CUDA的版本。DeepSpeed内包含需要自定义的CUDA算子&#xff0c;将通过即时编译的方式在运行时构建。 pip install deepspeed DeepSpeed与HuggingFace Transformers直接集成。使用者可以通过在模型…
阅读更多...
使用WAZUH检测LD_PRELAOD劫持、SQL注入、主动响应防御

使用WAZUH检测LD_PRELAOD劫持、SQL注入、主动响应防御

目录 1、检查后门 使用工具检测后门 1.chkrootkit 2.rkhunter 手动检查文件 检查ld.so.preload文件 2、检测LD_PRELOAD ubuntu配置 wazuh配置 3、检测SQL注入 ubuntu配置 攻击模拟 4、主动响应 wauzh的安装以及设置代理可以参考本篇&#xff1a;WAZUH的安装、设置…
阅读更多...
自行车服务PEDALWAYS 网站bootstrap5模板

自行车服务PEDALWAYS 网站bootstrap5模板

一、需求分析 自行车服务网站的作用是为骑行爱好者和自行车用户提供便捷的信息、工具和服务&#xff0c;以满足他们的需求。以下是一些常见的自行车服务网站的功能&#xff1a; 自行车租赁&#xff1a;提供自行车租赁服务&#xff0c;用户可以在线预订自行车并选择租赁期限&am…
阅读更多...
【Java 数组解析：探索数组的奇妙世界】

【Java 数组解析：探索数组的奇妙世界】

数组的引入 我们先通过一段简单的代码引入数组的概念。 import java.util.Scanner; public class TestArray01{public static void main(String[] args){//功能&#xff1a;键盘录入十个学生的成绩&#xff0c;求和&#xff0c;求平均数&#xff1a;//定义一个求和的变量&…
阅读更多...
C语言与人生：数组交换和二分查找

C语言与人生：数组交换和二分查找

少年们&#xff0c;大家好。我是博主那一脸阳光&#xff0c;今天和分享数组交换和二分查找。 前言&#xff1a;探索C语言中的数组交换操作与二分查找算法 在计算机编程领域&#xff0c;特别是以C语言为代表的低级编程语言中&#xff0c;对数据结构的理解和熟练运用是至关重要的…
阅读更多...
【小白专用】winform启动界面+登录窗口 更新2024.1.1

【小白专用】winform启动界面+登录窗口 更新2024.1.1

需求场景&#xff1a;先展示启动界面&#xff0c;然后打开登录界面&#xff0c;如果登录成功就跳转到主界面 首先在程序的入口路径加载启动界面&#xff0c;使用ShowDialog显示界面&#xff0c; 然后在启动界面中添加定时器&#xff0c;来实现显示一段时间的效果&#xff0c;等…
阅读更多...
Spring 是如何解决循环依赖问题的方案

Spring 是如何解决循环依赖问题的方案

文章目录 Spring 是如何解决循环依赖问题的&#xff1f; Spring 是如何解决循环依赖问题的&#xff1f; 我们都知道&#xff0c;如果在代码中&#xff0c;将两个或多个 Bean 互相之间持有对方的引用就会发生循环依赖。循环的依赖将会导致注入死循环。这是 Spring 发生循环依赖…
阅读更多...
电机（一）：直流有刷电机和舵机

电机（一）：直流有刷电机和舵机

声明&#xff1a;以下图片来自于正点原子&#xff0c;仅做学习笔记使用 电机专题&#xff1a; 直流电机&#xff1a;直流有刷BDC&#xff08;内含电刷&#xff09;&#xff0c;直流无刷BLDC&#xff08;大疆的M3508和M2006&#xff09;,无刷电机有以下三种形式&#xff1a;&a…
阅读更多...
超市订单管理系统

超市订单管理系统

比较简单的超市订单管理系统
阅读更多...
十大排序的个人总结之——选择排序

十大排序的个人总结之——选择排序

一、选择排序&#xff1a; 选择排序是所以用到它的时候&#xff0c;数据规模越小越好。 时间复杂度&#xff1a;无最好最坏&#xff0c;永远都是O(n) 不占用额外空间&#xff08;唯一好处&#xff09; 还不稳定&#xff08;几乎已经被淘汰了的排序算法&#xff09; 1. 算法…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站