基于DDD的微服务落地

　　DDD四层架构
　　对实时性要求高的强一致性业务场景，可采取分布式事务。分布式事务有性能代价，在设计时需要平衡考虑业务拆分、数据一致性、性能和实现的复杂度，尽量避免分布式事务的产生。
　　领域事件驱动的异步方式是分布式架构常用的设计方式，可以解决非实时性场景下的数据最终一致性问题。基于消息中间件的领域事件发布和订阅，可以很好的解耦微服务。通过削峰填谷，实现读写分离、减轻数据库实时访问压力，提高业务吞吐量和业务处理能力。
　　DDD设计思想和方法
　　DDD设计思想和方法
　　聚合根
　　聚合根包括聚合根属性、关联的实体和值对象以及自身的业务行为等。通过引用实体和值对象，协调聚合内的多个实体，在聚合根类方法中完成多实体的复杂业务逻辑。
　　充血模型：即领域模型模式。有自己的业务行为（方法），如下充血模型中提供getDuration、addHistoryApprovalInfo等方法。
　　贫血模型：即事务脚本模式。只有对象属性和settergetter。DatapublicclassLeave｛Stringid；Applicantapplicant；Approverapprover；LeaveTypetype；Statusstatus；DatestartTime；DateendTime；longduration；审批领导的最大级别intleaderMaxLevel；ApprovalInfocurrentApprovalInfo；ListhistoryApprovalInfos；publiclonggetDuration（）｛returnendTime。getTime（）startTime。getTime（）；｝publicLeaveaddHistoryApprovalInfo（ApprovalInfoapprovalInfo）｛if（nullhistoryApprovalInfos）historyApprovalInfosnewArrayList（）；this。historyApprovalInfos。add（approvalInfo）；returnthis；｝publicLeavecreate（）｛this。setStatus（Status。APPROVING）；this。setStartTime（newDate（））；returnthis；｝publicLeaveagree（ApprovernextApprover）｛this。setStatus（Status。APPROVING）；this。setApprover（nextApprover）；returnthis；｝publicLeavereject（Approverapprover）｛this。setApprover（approver）；this。setStatus（Status。REJECTED）；this。setApprover（null）；returnthis；｝publicLeavefinish（）｛this。setApprover（null）；this。setStatus（Status。APPROVED）；this。setEndTime（newDate（））；this。setDuration（this。getEndTime（）。getTime（）this。getStartTime（）。getTime（））；returnthis；｝｝
　　实体
　　实体有自己的属性和关联的值对象。DatapublicclassApprovalInfo｛StringapprovalInfoId；Approverapprover；ApprovalTypeapprovalType；Stringmsg；longtime；｝
　　值对象publicenumStatus｛APPROVING，APPROVED，REJECTED｝DataAllArgsConstructorNoArgsConstructorBuilderpublicclassApprover｛StringpersonId；StringpersonName；intlevel；publicstaticApproverfromPerson（Personperson）｛ApproverapprovernewApprover（）；approver。setPersonId（person。getPersonId（））；approver。setPersonName（person。getPersonName（））；approver。setLevel（person。getRoleLevel（））；returnapprover；｝｝
　　领域对象
　　如果一个业务行为由多个实体对象参与完成，就将该业务逻辑放在领域服务中实现。
　　实体方法：完成单一实体自身的业务逻辑，是相对简单的原子业务逻辑。
　　领域服务：由多个实体组合的相对复杂的业务逻辑。ServiceSlf4jpublicclassLeaveDomainService｛AutowiredEventPublishereventPublisher；AutowiredILeaveRepositoryiLeaveRepository；AutowiredLeaveFactoryleaveFactory；TransactionalpublicvoidcreateLeave（Leaveleave，intleaderMaxLevel，Approverapprover）｛leave。setLeaderMaxLevel（leaderMaxLevel）；leave。setApprover（approver）；leave。create（）；iLeaveRepository。save（leaveFactory。createLeavePO（leave））；LeaveEventeventLeaveEvent。create（LeaveEventType。CREATEEVENT，leave）；iLeaveRepository。saveEvent（leaveFactory。createLeaveEventPO（event））；eventPublisher。publish（event）；｝TransactionalpublicvoidupdateLeaveInfo（Leaveleave）｛LeavePOpoleaveRepositoryInterface。findById（leave。getId（））；if（nullpo）｛thrownewRuntimeException（leave不存在）；｝iLeaveRepository。save（leaveFactory。createLeavePO（leave））；｝TransactionalpublicvoidsubmitApproval（Leaveleave，Approverapprover）｛LeaveEventevent；if（ApprovalType。REJECTleave。getCurrentApprovalInfo（）。getApprovalType（））｛leave。reject（approver）；eventLeaveEvent。create（LeaveEventType。REJECTEVENT，leave）；｝else｛if（approver！null）｛leave。agree（approver）；eventLeaveEvent。create（LeaveEventType。AGREEEVENT，leave）；｝else｛leave。finish（）；eventLeaveEvent。create（LeaveEventType。APPROVEDEVENT，leave）；｝｝leave。addHistoryApprovalInfo（leave。getCurrentApprovalInfo（））；iLeaveRepository。save（leaveFactory。createLeavePO（leave））；iLeaveRepository。saveEvent（leaveFactory。createLeaveEventPO（event））；eventPublisher。publish（event）；｝publicLeavegetLeaveInfo（StringleaveId）｛LeavePOleavePOiLeaveRepository。findById（leaveId）；returnleaveFactory。getLeave（leavePO）；｝publicListLeavequeryLeaveInfosByApplicant（StringapplicantId）｛ListLeavePOleavePOListiLeaveRepository。queryByApplicantId（applicantId）；returnleavePOList。stream（）。map（leavePOleaveFactory。getLeave（leavePO））。collect（Collectors。toList（））；｝publicListLeavequeryLeaveInfosByApprover（StringapproverId）｛ListLeavePOleavePOListiLeaveRepository。queryByApproverId（approverId）；returnleavePOList。stream（）。map（leavePOleaveFactory。getLeave（leavePO））。collect（Collectors。toList（））；｝｝
　　在应用服务组合不同聚合的领域服务时，通过Id或参数传参，尽量避免领域对象传参，以减少聚合之间的耦合度。
　　领域事件
　　领域事件基类DatapublicclassDomainEvent｛Stringid；Datetimestamp；Stringsource；Stringdata；｝ServicepublicclassEventPublisher｛publicvoidpublish（LeaveEventevent）｛sendtoMQmq。send（event）；｝｝
　　领域事件实体DatapublicclassLeaveEventextendsDomainEvent｛LeaveEventTypeleaveEventType；publicstaticLeaveEventcreate（LeaveEventTypeeventType，Leaveleave）｛LeaveEventeventnewLeaveEvent（）；event。setId（IdGenerator。nextId（））；event。setLeaveEventType（eventType）；event。setTimestamp（newDate（））；event。setData（JSON。toJSONString（leave））；returnevent；｝｝
　　领域事件的执行逻辑：执行业务逻辑，产生领域事件。调用仓储接口，完成业务数据持久化。调用仓储接口，完成事件数据持久化。完成领域事件发布。
　　仓储模式
　　仓储接口publicinterfaceILeaveRepository｛voidsave（LeavePOleavePO）；voidsaveEvent（LeaveEventPOleaveEventPO）；LeavePOfindById（Stringid）；ListLeavePOqueryByApplicantId（StringapplicantId）；ListLeavePOqueryByApproverId（StringapproverId）；｝
　　仓储实现RepositorypublicclassLeaveRepositoryImplimplementsILeaveRepository｛AutowiredLeaveDaoleaveDao；AutowiredApprovalInfoDaoapprovalInfoDao；AutowiredLeaveEventDaoleaveEventDao；publicvoidsave（LeavePOleavePO）｛leaveDao。save（leavePO）；leavePO。getHistoryApprovalInfoPOList（）。forEach（approvalInfoPOapprovalInfoPO。setLeaveId（leavePO。getId（）））；approvalInfoDao。saveAll（leavePO。getHistoryApprovalInfoPOList（））；｝publicvoidsaveEvent（LeaveEventPOleaveEventPO）｛leaveEventDao。save（leaveEventPO）；｝OverridepublicLeavePOfindById（Stringid）｛returnleaveDao。findById（id）。orElseThrow（（）newRuntimeException（leave不存在））；｝OverridepublicListLeavePOqueryByApplicantId（StringapplicantId）｛ListLeavePOleavePOListleaveDao。queryByApplicantId（applicantId）；leavePOList。forEach（leavePO｛ListapprovalInfoPOListapprovalInfoDao。queryByLeaveId（leavePO。getId（））；leavePO。setHistoryApprovalInfoPOList（approvalInfoPOList）；｝）；returnleavePOList；｝OverridepublicListLeavePOqueryByApproverId（StringapproverId）｛ListLeavePOleavePOListleaveDao。queryByApproverId（approverId）；leavePOList。forEach（leavePO｛ListapprovalInfoPOListapprovalInfoDao。queryByLeaveId（leavePO。getId（））；leavePO。setHistoryApprovalInfoPOList（approvalInfoPOList）；｝）；returnleavePOList；｝｝
　　这里为什么没有使用一对多、多对对呢？时间紧任务重或者并发量不高时可以使用，后期并发量起来了后，数据库将成为瓶颈。
　　JPAHibernate注解：OneToMany、ManyToOne、ManyToMany；
　　Mybatis注解：
　　Results（id，value｛Result（column，property，jdbcTypeJdbcType。INTEGER），
　　Result（column，property，javaTypexx。class，oneOne（selectcom。xx。。XxMapper。selectById））
　　｝）
　　或
　　Results（id，value｛Result（property，column），
　　Result（propertyxxList，javaTypeList。class，manyMany（select），column）｝）；
　　Mybatisxml：association、collection。
　　工厂模式
　　工厂模式将与业务无关的职能从聚合根中剥离，放在工厂中统一创建和初始化。可考虑使用MapStructServicepublicclassLeaveFactory｛publicLeavePOcreateLeavePO（Leaveleave）｛LeavePOleavePOnewLeavePO（）；leavePO。setId（UUID。randomUUID（）。toString（））；leavePO。setApplicantId（leave。getApplicant（）。getPersonId（））；leavePO。setApplicantName（leave。getApplicant（）。getPersonName（））；leavePO。setApproverId（leave。getApprover（）。getPersonId（））；leavePO。setApproverName（leave。getApprover（）。getPersonName（））；leavePO。setStartTime（leave。getStartTime（））；leavePO。setStatus（leave。getStatus（））；ListhistoryApprovalInfoPOListapprovalInfoPOListFromDO（leave）；leavePO。setHistoryApprovalInfoPOList（historyApprovalInfoPOList）；returnleavePO；｝publicLeavegetLeave（LeavePOleavePO）｛LeaveleavenewLeave（）；ApplicantapplicantApplicant。builder（）。personId（leavePO。getApplicantId（））。personName（leavePO。getApplicantName（））。build（）；leave。setApplicant（applicant）；ApproverapproverApprover。builder（）。personId（leavePO。getApproverId（））。personName（leavePO。getApproverName（））。build（）；leave。setApprover（approver）；leave。setStartTime（leavePO。getStartTime（））；leave。setStatus（leavePO。getStatus（））；ListapprovalInfosgetApprovalInfos（leavePO。getHistoryApprovalInfoPOList（））；leave。setHistoryApprovalInfos（approvalInfos）；returnleave；｝publicLeaveEventPOcreateLeaveEventPO（LeaveEventleaveEvent）｛LeaveEventPOeventPOnewLeaveEventPO（）；eventPO。setLeaveEventType（leaveEvent。getLeaveEventType（））；eventPO。setSource（leaveEvent。getSource（））；eventPO。setTimestamp（leaveEvent。getTimestamp（））；eventPO。setData（JSON。toJSONString（leaveEvent。getData（）））；returneventPO；｝privateListapprovalInfoPOListFromDO（Leaveleave）｛returnleave。getHistoryApprovalInfos（）。stream（）。map（this：：approvalInfoPOFromDO）。collect（Collectors。toList（））；｝privateApprovalInfoPOapprovalInfoPOFromDO（ApprovalInfoapprovalInfo）｛ApprovalInfoPOponewApprovalInfoPO（）；po。setApproverId（approvalInfo。getApprover（）。getPersonId（））；po。setApproverLevel（approvalInfo。getApprover（）。getLevel（））；po。setApproverName（approvalInfo。getApprover（）。getPersonName（））；po。setApprovalInfoId（approvalInfo。getApprovalInfoId（））；po。setMsg（approvalInfo。getMsg（））；po。setTime（approvalInfo。getTime（））；returnpo；｝privateApprovalInfoapprovalInfoFromPO（ApprovalInfoPOapprovalInfoPO）｛ApprovalInfoapprovalInfonewApprovalInfo（）；approvalInfo。setApprovalInfoId（approvalInfoPO。getApprovalInfoId（））；ApproverapproverApprover。builder（）。personId（approvalInfoPO。getApproverId（））。personName（approvalInfoPO。getApproverName（））。level（approvalInfoPO。getApproverLevel（））。build（）；approvalInfo。setApprover（approver）；approvalInfo。setMsg（approvalInfoPO。getMsg（））；approvalInfo。setTime（approvalInfoPO。getTime（））；returnapprovalInfo；｝privateListgetApprovalInfos（ListapprovalInfoPOList）｛returnapprovalInfoPOList。stream（）。map（this：：approvalInfoFromPO）。collect（Collectors。toList（））；｝｝
　　服务的组合和编排
　　应用层的应用服务主要完成领域服务的组合与编排。ServicepublicclassLeaveApplicationService｛AutowiredLeaveDomainServiceleaveDomainService；AutowiredPersonDomainServicepersonDomainService；AutowiredApprovalRuleDomainServiceapprovalRuleDomainService；创建一个请假申请并为审批人生成任务paramleavepublicvoidcreateLeaveInfo（Leaveleave）｛intleaderMaxLevelapprovalRuleDomainService。getLeaderMaxLevel（leave。getApplicant（）。getPersonType（），leave。getType（）。toString（），leave。getDuration（））；PersonapproverpersonDomainService。findFirstApprover（leave。getApplicant（）。getPersonId（），leaderMaxLevel）；leaveDomainService。createLeave（leave，leaderMaxLevel，Approver。fromPerson（approver））；｝更新请假单基本信息paramleavepublicvoidupdateLeaveInfo（Leaveleave）｛leaveDomainService。updateLeaveInfo（leave）；｝提交审批，更新请假单信息paramleavepublicvoidsubmitApproval（Leaveleave）｛findnextapproverPersonapproverpersonDomainService。findNextApprover（leave。getApprover（）。getPersonId（），leave。getLeaderMaxLevel（））；leaveDomainService。submitApproval（leave，Approver。fromPerson（approver））；｝publicLeavegetLeaveInfo（StringleaveId）｛returnleaveDomainService。getLeaveInfo（leaveId）；｝publicListLeavequeryLeaveInfosByApplicant（StringapplicantId）｛returnleaveDomainService。queryLeaveInfosByApplicant（applicantId）；｝publicListLeavequeryLeaveInfosByApprover（StringapproverId）｛returnleaveDomainService。queryLeaveInfosByApprover（approverId）；｝｝
　　服务接口的提供
　　facade门面接口主要抽象出ControllerApi作为OpenFeign调用的接口门面类。authorlyonardoDescriptioncreateTime2020年03月08日15：06：00FeignClient（nameleaveservice，pathleave）publicinterfaceLeaveFeignClient｛PostMapping（submit）ResponsesubmitApproval（LeaveDTOleaveDTO）；PostMapping（｛leaveId｝）ResponsefindById（PathVariableStringleaveId）；根据申请人查询所有请假单paramapplicantIdreturnPostMapping（queryapplicant｛applicantId｝）ResponsequeryByApplicant（PathVariableStringapplicantId）；根据审批人id查询待审批请假单（待办任务）paramapproverIdreturnPostMapping（queryapprover｛approverId｝）ResponsequeryByApprover（PathVariableStringapproverId）（）；｝
　　实现类RestControllerRequestMapping（leave）Slf4jpublicclassLeaveApi｛AutowiredLeaveApplicationServiceleaveApplicationService；PostMapping（create）publicResponsecreateLeaveInfo（LeaveDTOleaveDTO）｛LeaveleaveLeaveAssembler。toDO（leaveDTO）；leaveApplicationService。createLeaveInfo（leave）；returnResponse。ok（）；｝PutMapping（update）publicResponseupdateLeaveInfo（LeaveDTOleaveDTO）｛LeaveleaveLeaveAssembler。toDO（leaveDTO）；leaveApplicationService。updateLeaveInfo（leave）；returnResponse。ok（）；｝PostMapping（submit）publicResponsesubmitApproval（LeaveDTOleaveDTO）｛LeaveleaveLeaveAssembler。toDO（leaveDTO）；leaveApplicationService。submitApproval（leave）；returnResponse。ok（）；｝PostMapping（｛leaveId｝）publicResponsefindById（PathVariableStringleaveId）｛LeaveleaveleaveApplicationService。getLeaveInfo（leaveId）；returnResponse。ok（LeaveAssembler。toDTO（leave））；｝根据申请人查询所有请假单paramapplicantIdreturnPostMapping（queryapplicant｛applicantId｝）publicResponsequeryByApplicant（PathVariableStringapplicantId）｛ListLeaveleaveListleaveApplicationService。queryLeaveInfosByApplicant（applicantId）；ListLeaveDTOleaveDTOListleaveList。stream（）。map（leaveLeaveAssembler。toDTO（leave））。collect（Collectors。toList（））；returnResponse。ok（leaveDTOList）；｝根据审批人id查询待审批请假单（待办任务）paramapproverIdreturnPostMapping（queryapprover｛approverId｝）publicResponsequeryByApprover（PathVariableStringapproverId）｛ListLeaveleaveListleaveApplicationService。queryLeaveInfosByApprover（approverId）；ListLeaveDTOleaveDTOListleaveList。stream（）。map（leaveLeaveAssembler。toDTO（leave））。collect（Collectors。toList（））；returnResponse。ok（leaveDTOList）；｝｝
　　数据组装层
　　LeaveAssembler
　　可使用MapStruct做对象转换和组装publicclassLeaveAssembler｛publicstaticLeaveDTOtoDTO（Leaveleave）｛LeaveDTOdtonewLeaveDTO（）；dto。setLeaveId（leave。getId（））；dto。setLeaveType（leave。getType（）。toString（））；dto。setStatus（leave。getStatus（）。toString（））；dto。setStartTime（DateUtil。formatDateTime（leave。getStartTime（）））；dto。setEndTime（DateUtil。formatDateTime（leave。getEndTime（）））；dto。setCurrentApprovalInfoDTO（ApprovalInfoAssembler。toDTO（leave。getCurrentApprovalInfo（）））；ListhistoryApprovalInfoDTOListleave。getHistoryApprovalInfos（）。stream（）。map（historyApprovalInfoApprovalInfoAssembler。toDTO（leave。getCurrentApprovalInfo（）））。collect（Collectors。toList（））；dto。setHistoryApprovalInfoDTOList（historyApprovalInfoDTOList）；dto。setDuration（leave。getDuration（））；returndto；｝publicstaticLeavetoDO（LeaveDTOdto）｛LeaveleavenewLeave（）；leave。setId（dto。getLeaveId（））；leave。setApplicant（ApplicantAssembler。toDO（dto。getApplicantDTO（）））；leave。setApprover（ApproverAssembler。toDO（dto。getApproverDTO（）））；leave。setCurrentApprovalInfo（ApprovalInfoAssembler。toDO（dto。getCurrentApprovalInfoDTO（）））；ListhistoryApprovalInfoDTOListdto。getHistoryApprovalInfoDTOList（）。stream（）。map（ApprovalInfoAssembler：：toDO）。collect（Collectors。toList（））；leave。setHistoryApprovalInfos（historyApprovalInfoDTOList）；returnleave；｝｝