基于grpc从零开始搭建一个准生产分布式应用 - Service业务逻辑层实现
Posted 生而为人我很遗憾
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了基于grpc从零开始搭建一个准生产分布式应用 - 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;
(JsonInclude.Include.NON_NULL)
(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;
(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")
private LocalDateTime ctime;
(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;
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;
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
*/
(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
*/
(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;
public class SystemLogServcieImpl implements ISystemLogServcie
public boolean createSystemLog(SystemLogBo systemLogBo)
String trackLog = LogGenerator.trackLog();
log.info(trackLog
+ "createSystemLog=" + JSONUtil.toJsonStr(以上是关于基于grpc从零开始搭建一个准生产分布式应用 - Service业务逻辑层实现的主要内容,如果未能解决你的问题,请参考以下文章基于grpc从零开始搭建一个准生产分布式应用 - QuickStart