淺談Java開發(fā)架構(gòu)之領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)DDD落地
一、前言
整個(gè)過程大概是這樣的,開發(fā)團(tuán)隊(duì)和領(lǐng)域?qū)<乙黄鹜ㄟ^ 通用語言(Ubiquitous Language)去理解和消化領(lǐng)域知識(shí),從領(lǐng)域知識(shí)中提取和劃分為一個(gè)一個(gè)的子領(lǐng)域(核心子域,通用子域,支撐子域),并在子領(lǐng)域上建立模型,再重復(fù)以上步驟,這樣周而復(fù)始,構(gòu)建出一套符合當(dāng)前領(lǐng)域的模型。
二、開發(fā)目標(biāo)
依靠領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)的設(shè)計(jì)思想,通過事件風(fēng)暴建立領(lǐng)域模型,合理劃分領(lǐng)域邏輯和物理邊界,建立領(lǐng)域?qū)ο蠹胺?wù)矩陣和服務(wù)架構(gòu)圖,定義符合DDD分層架構(gòu)思想的代碼結(jié)構(gòu)模型,保證業(yè)務(wù)模型與代碼模型的一致性。通過上述設(shè)計(jì)思想、方法和過程,指導(dǎo)團(tuán)隊(duì)按照DDD設(shè)計(jì)思想完成微服務(wù)設(shè)計(jì)和開發(fā)。
1、拒絕泥球小單體、拒絕污染功能與服務(wù)、拒絕一加功能排期一個(gè)月
2、架構(gòu)出高可用極易符合互聯(lián)網(wǎng)高速迭代的應(yīng)用服務(wù)
3、物料化、組裝化、可編排的服務(wù),提高人效
三、服務(wù)架構(gòu)
3.1、應(yīng)用層{application}
- 應(yīng)用服務(wù)位于應(yīng)用層。用來表述應(yīng)用和用戶行為,負(fù)責(zé)服務(wù)的組合、編排和轉(zhuǎn)發(fā),負(fù)責(zé)處理業(yè)務(wù)用例的執(zhí)行順序以及結(jié)果的拼裝。
- 應(yīng)用層的服務(wù)包括應(yīng)用服務(wù)和領(lǐng)域事件相關(guān)服務(wù)。
- 應(yīng)用服務(wù)可對(duì)微服務(wù)內(nèi)的領(lǐng)域服務(wù)以及微服務(wù)外的應(yīng)用服務(wù)進(jìn)行組合和編排,或者對(duì)基礎(chǔ)層如文件、緩存等數(shù)據(jù)直接操作形成應(yīng)用服務(wù),對(duì)外提供粗粒度的服務(wù)。
- 領(lǐng)域事件服務(wù)包括兩類:領(lǐng)域事件的發(fā)布和訂閱。通過事件總線和消息隊(duì)列實(shí)現(xiàn)異步數(shù)據(jù)傳輸,實(shí)現(xiàn)微服務(wù)之間的解耦。
3.2、領(lǐng)域?qū)觷domain}
- 領(lǐng)域服務(wù)位于領(lǐng)域?qū)樱瑸橥瓿深I(lǐng)域中跨實(shí)體或值對(duì)象的操作轉(zhuǎn)換而封裝的服務(wù),領(lǐng)域服務(wù)以與實(shí)體和值對(duì)象相同的方式參與實(shí)施過程。
- 領(lǐng)域服務(wù)對(duì)同一個(gè)實(shí)體的一個(gè)或多個(gè)方法進(jìn)行組合和封裝,或?qū)Χ鄠€(gè)不同實(shí)體的操作進(jìn)行組合或編排,對(duì)外暴露成領(lǐng)域服務(wù)。領(lǐng)域服務(wù)封裝了核心的業(yè)務(wù)邏輯。實(shí)體自身的行為在實(shí)體類內(nèi)部實(shí)現(xiàn),向上封裝成領(lǐng)域服務(wù)暴露。
- 為隱藏領(lǐng)域?qū)拥臉I(yè)務(wù)邏輯實(shí)現(xiàn),所有領(lǐng)域方法和服務(wù)等均須通過領(lǐng)域服務(wù)對(duì)外暴露。
- 為實(shí)現(xiàn)微服務(wù)內(nèi)聚合之間的解耦,原則上禁止跨聚合的領(lǐng)域服務(wù)調(diào)用和跨聚合的數(shù)據(jù)相互關(guān)聯(lián)。
3.3、基礎(chǔ)層{infrastructrue}
- 基礎(chǔ)服務(wù)位于基礎(chǔ)層。為各層提供資源服務(wù)(如數(shù)據(jù)庫、緩存等),實(shí)現(xiàn)各層的解耦,降低外部資源變化對(duì)業(yè)務(wù)邏輯的影響。
- 基礎(chǔ)服務(wù)主要為倉儲(chǔ)服務(wù),通過依賴反轉(zhuǎn)的方式為各層提供基礎(chǔ)資源服務(wù),領(lǐng)域服務(wù)和應(yīng)用服務(wù)調(diào)用倉儲(chǔ)服務(wù)接口,利用倉儲(chǔ)實(shí)現(xiàn)持久化數(shù)據(jù)對(duì)象或直接訪問基礎(chǔ)資源。
3.4、接口層{interfaces}
接口服務(wù)位于用戶接口層,用于處理用戶發(fā)送的Restful請(qǐng)求和解析用戶輸入的配置文件等,并將信息傳遞給應(yīng)用層。
四、開發(fā)環(huán)境
jdk1.8【jdk1.7以下只能部分支持netty】
springboot 2.0.6.RELEASE
idea + maven
五、代碼示例
itstack-demo-ddd-01
└── src
├── main
│ ├── java
│ │ └── org.itstack.demo
│ │ ├── application
│ │ │ ├── event
│ │ │ │ └── ApplicationRunner.java
│ │ │ └── service
│ │ │ └── UserService.java
│ │ ├── domain
│ │ │ ├── model
│ │ │ │ ├── aggregates
│ │ │ │ │ └── UserRichInfo.java
│ │ │ │ └── vo
│ │ │ │ ├── UserInfo.java
│ │ │ │ └── UserSchool.java
│ │ │ ├── repository
│ │ │ │ └── IuserRepository.java
│ │ │ └── service
│ │ │ └── UserServiceImpl.java
│ │ ├── infrastructure
│ │ │ ├── dao
│ │ │ │ ├── impl
│ │ │ │ │ └── UserDaoImpl.java
│ │ │ │ └── UserDao.java
│ │ │ ├── po
│ │ │ │ └── UserEntity.java
│ │ │ ├── repository
│ │ │ │ ├── mysql
│ │ │ │ │ └── UserMysqlRepository.java
│ │ │ │ ├── redis
│ │ │ │ │ └── UserRedisRepository.java
│ │ │ │ └── UserRepository.java
│ │ │ └── util
│ │ │ └── RdisUtil.java
│ │ ├── interfaces
│ │ │ ├── dto
│ │ │ │ └── UserInfoDto.java
│ │ │ └── facade
│ │ │ └── DDDController.java
│ │ └── DDDApplication.java
│ ├── resources
│ │ └── application.yml
│ └── webapp
│ └── WEB-INF
│ └── index.jsp
└── test
└── java
└── org.itstack.demo.test
└── ApiTest.java
application/UserService.java | 應(yīng)用層用戶服務(wù),領(lǐng)域?qū)臃?wù)做具體實(shí)現(xiàn)
public interface UserService { UserRichInfo queryUserInfoById(Long id); }
domain/repository/IuserRepository.java | 領(lǐng)域?qū)淤Y源庫,由基礎(chǔ)層實(shí)現(xiàn)
public interface IUserRepository { void save(UserEntity userEntity); UserEntity query(Long id); }
domain/service/UserServiceImpl.java | 應(yīng)用層實(shí)現(xiàn)類,應(yīng)用層是很薄的一層可以只做服務(wù)編排
@Service("userService") public class UserServiceImpl implements UserService { @Resource(name = "userRepository") private IUserRepository userRepository; @Override public UserRichInfo queryUserInfoById(Long id) { // 查詢資源庫 UserEntity userEntity = userRepository.query(id); UserInfo userInfo = new UserInfo(); userInfo.setName(userEntity.getName()); // TODO 查詢學(xué)校信息,外部接口 UserSchool userSchool_01 = new UserSchool(); userSchool_01.setSchoolName("振華高級(jí)實(shí)驗(yàn)中學(xué)"); UserSchool userSchool_02 = new UserSchool(); userSchool_02.setSchoolName("東北電力大學(xué)"); List<UserSchool> userSchoolList = new ArrayList<>(); userSchoolList.add(userSchool_01); userSchoolList.add(userSchool_02); UserRichInfo userRichInfo = new UserRichInfo(); userRichInfo.setUserInfo(userInfo); userRichInfo.setUserSchoolList(userSchoolList); return userRichInfo; } }
infrastructure/po/UserEntity.java | 數(shù)據(jù)庫對(duì)象類
public class UserEntity { private Long id; private String name; get/set ... }
infrastructrue/repository/UserRepository.java | 領(lǐng)域?qū)佣x接口,基礎(chǔ)層資源庫實(shí)現(xiàn)
@Repository("userRepository") public class UserRepository implements IUserRepository { @Resource(name = "userMysqlRepository") private IUserRepository userMysqlRepository; @Resource(name = "userRedisRepository") private IUserRepository userRedisRepository; @Override public void save(UserEntity userEntity) { //保存到DB userMysqlRepository.save(userEntity); //保存到Redis userRedisRepository.save(userEntity); } @Override public UserEntity query(Long id) { UserEntity userEntityRedis = userRedisRepository.query(id); if (null != userEntityRedis) return userEntityRedis; UserEntity userEntityMysql = userMysqlRepository.query(id); if (null != userEntityMysql){ //保存到Redis userRedisRepository.save(userEntityMysql); return userEntityMysql; } // 查詢?yōu)镹ULL return null; } }
interfaces/dto/UserInfoDto.java | DTO對(duì)象類,隔離數(shù)據(jù)庫類
public class UserInfoDto { private Long id; // ID public Long getId() { return id; } public void setId(Long id) { this.id = id; } }
interfaces/facade/DDDController.java | 門面接口
@Controller public class DDDController { @Resource(name = "userService") private UserService userService; @RequestMapping("/index") public String index(Model model) { return "index"; } @RequestMapping("/api/user/queryUserInfo") @ResponseBody public ResponseEntity queryUserInfo(@RequestBody UserInfoDto request) { return new ResponseEntity<>(userService.queryUserInfoById(request.getId()), HttpStatus.OK); } }
六、綜上總結(jié)
以上基于DDD一個(gè)基本入門的結(jié)構(gòu)演示完成,實(shí)際開發(fā)可以按照此模式進(jìn)行調(diào)整。目前這個(gè)架構(gòu)分層還不能很好的進(jìn)行分離,以及層級(jí)關(guān)系的引用還不利于擴(kuò)展。
以上就是淺談Java開發(fā)架構(gòu)之領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)DDD落地的詳細(xì)內(nèi)容,更多關(guān)于Java開發(fā)架構(gòu) 領(lǐng)域驅(qū)動(dòng)設(shè)計(jì)DDD落地的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
SSH框架網(wǎng)上商城項(xiàng)目第20戰(zhàn)之在線支付平臺(tái)
這篇文章主要為大家詳細(xì)介紹了SSH框架網(wǎng)上商城項(xiàng)目第20戰(zhàn)之在線支付平臺(tái),關(guān)于第三方支付的內(nèi)容從本文開始,感興趣的小伙伴們可以參考一下2016-06-06使用javax.sound實(shí)現(xiàn)簡(jiǎn)單音頻播放
這篇文章主要為大家詳細(xì)介紹了使用javax.sound實(shí)現(xiàn)簡(jiǎn)單音頻播放,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-03-03JAVA多線程進(jìn)階方式(Runnable接口的講解和運(yùn)用)
這篇文章主要介紹了JAVA多線程進(jìn)階方式(Runnable接口的講解和運(yùn)用),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-01-01詳解rabbitmq創(chuàng)建queue時(shí)arguments參數(shù)注釋
這篇文章主要介紹了rabbitmq創(chuàng)建queue時(shí)arguments參數(shù)注釋,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-03-03spring boot starter actuator(健康監(jiān)控)配置和使用教程
這篇文章主要介紹了spring-boot-starter-actuator(健康監(jiān)控)配置和使用教程,本文給大家介紹的非常詳細(xì),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2018-06-06idea普通javaweb項(xiàng)目如何部署到tomcat(讀取web.xml文件)
這篇文章主要介紹了idea普通javaweb項(xiàng)目如何部署到tomcat(讀取web.xml文件),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-08-08