序本文主要研究一下dbsync的CriterionCriterion {代码...} Criterion是一个fmt.Stringer类型between {代码...} between定义from、to两个属性lessOrEqual {代码...} lessOrEqual定义了value属性，表达式为<=greaterThan {代码...} greaterThan定义了value属性，表达式为>greaterOrEqual {代码...} greaterOrEqual定...

Aggregate定义了id、baseVersion、newEvents属性；其applyNewEvent方法会执行apply(event)及newEvents.add(event)；apply方法通过反射执行event的apply方法

JustForwardDomainEventPublisher实现了DomainEvents接口，其publish方法通过spring的ApplicationEventPublisher来发布

序本文主要研究一下dddsample-core的modelEntity {代码...} Entity接口定义了sameIdentityAs方法ValueObject {代码...} ValueObject接口定义了sameValueAs方法TrackingId {代码...} TrackingId实现了ValueObject接口，sameValueAs方法通过equals方法判断Type {代码...} Type枚举实现了ValueObject接口，其sameValueAs方...

AndSpecification继承了AbstractSpecification，它定义了spec1、spec2属性，其isSatisfiedBy返回的是spec1.isSatisfiedBy(t) && spec2.isSatisfiedBy(t)

EventMessage接口定义了AggregateID、GetHeaders、SetHeader、Event、EventType、Version方法

InMemoryDispatcher定义了map[string]CommandHandler属性，其Dispatch方法根据command.CommandType()获取handler，然后执行handler.Handle(command)；其RegisterHandler方法遍历commands，然后获取command的type，挨个注册到map[string]CommandHandler中

GetEventStoreCommonDomainRepo定义了eventStore、eventBus、streamNameDelegate、aggregateFactory、eventFactory属性，其Load方法先通过r.aggregateFactory.GetAggregate获取aggregate，再通过r.streamNameDelegate.GetStreamName(aggregateType, id)获取streamName，然后通过r.eventStore.NewStreamReader去遍历event...

AggregateRoot接口定义了AggregateID、OriginalVersion、CurrentVersion、IncrementVersion、Apply、TrackChange、GetChanges、ClearChanges方法

Scheduler定义了Cron、Started、EntryJobMap属性；NewScheduler方法创建默认的Scheduler；Start方法遍历jobs，挨个设置job.Agent，然后添加到Scheduler中，之后执行Scheduler.Cron.Start()；Stop方法执行Scheduler.Cron.Stop()；Restart方法执行Stop、ClearCron、Start方法；ClearCron设置Cron为nil

MessageType可以分为SetJobType、DeleteJobType、SetExecutionType、DeleteExecutionsType、ExecutionDoneType

Worker实现了TaskProcessor接口，其Process方法先通过worker.server.GetRegisteredTask获取taskFunc，然后通过signature更新state为RECEIVED，之后设置为STARTED，之后执行task.Call()，最后根据结果更新task为failed或者success

Lock定义了rclient、retries、interval属性；New方法根据cnf、addrs、db、retries创建lock；LockWithRetries方法根据retries次数来尝试r.Lock(key, unixTsToExpireNs)，都没有成功则返回ErrRedisLockFailed；Lock方法执行r.rclient.SetNX，如果不成功则判断是否过期，过期的话执行执行r.rclient.GetSet，若确实过期了则...

TaskState定义了PENDING、RECEIVED、STARTED、RETRY、SUCCESS、FAILURE状态；TaskState定义了TaskUUID、TaskName、State、Results、Error、CreatedAt、TTL属性；它提供了NewPendingTaskState、NewReceivedTaskState、NewStartedTaskState、NewSuccessTaskState、NewFailureTaskState、NewRetryTaskState方法来根据Signat...

序本文主要研究一下eventhorizon的EventBusEventBuseventhorizon/eventbus.go {代码...} EventBus接口内嵌了EventHandler接口，定义了AddHandler、Errors、Wait方法EventBuseventhorizon/eventbus/local/eventbus.go {代码...} EventBus定义了group、registered、registeredMu、errCh、wg、codec属性；HandleEvent方法先...

序本文主要研究一下eventhorizon的AggregateAggregateeventhorizon/aggregate.go {代码...} Aggregate接口内嵌了Entity及CommandHandler，定义了AggregateType方法AggregateStoreeventhorizon/aggregate.go {代码...} AggregateStore定义了Load、Save方法AggregateStoreeventhorizon/aggregatestore/model/aggregatestor...

序本文主要研究一下JESA的EventRecorderEventRecorderJESA/src/main/java/Jesa/EventRecorder.java {代码...} EventRecorder定义了records，提供了record、clear、hasEvents、toArray方法InstanceEventRouterJESA/src/main/java/Jesa/InstanceEventRouter.java {代码...} InstanceEventRouter接口定义了configureRoute、...

Cheddar/cheddar/cheddar-messaging/src/main/java/com/clicktravel/cheddar/infrastructure/messaging/pooled/listener/MessageHandlerExecutor.java

Cheddar/cheddar/cheddar-application/src/main/java/com/clicktravel/cheddar/application/pending/result/PendingResult.java

Cheddar/cheddar/cheddar-messaging/src/main/java/com/clicktravel/cheddar/infrastructure/messaging/MessageSender.java

Cheddar/cheddar/cheddar-tx/src/main/java/com/clicktravel/cheddar/infrastructure/messaging/tx/MessageAction.java

Cheddar/cheddar/cheddar-domain/src/main/java/com/clicktravel/cheddar/domain/event/DomainEvent.java

Cheddar/cheddar/cheddar-events/src/main/java/com/clicktravel/cheddar/event/Event.java

序本文主要赏析一下go-ddd-sample项目结构 {代码...} 这里分为application、domain、infrastructure、interfaces四层domain {代码...} domain层定义了模型及repository接口，同时利用go generate生成repository的mock实现application {代码...} applicatioin层调用domain层来进行业务编排infrastructure {代码...} infra...

序本文主要赏析一下go-bank-transfer对于Clean Architecture的实践项目结构 {代码...} 这里分为adapter、domain、infrastructure、usecase四层domainaccount {代码...} account定义了AccountRepository接口及Account类型，同时还提供了Withdraw、Deposit方法transfer {代码...} transfer定义了TransferRepository接口及T...

这里分为adapter、application、domain三层；其中application层定义了port包，该包定义了in、out两种类型的接口；adapter层也分in、out两类，分别实现application/port层的接口；application的service则实现了port的接口

Java语言特性系列Java5的新特性Java6的新特性Java7的新特性Java8的新特性Java9的新特性Java10的新特性Java11的新特性Java12的新特性Java13的新特性Java14的新特性Java15的新特性Java16的新特性Java17的新特性Java18的新特性Java19的新特性Java20的新特性Java21的新特性Java22的新特性序本文主要讲述一下Java16的新特性版...

序本文主要研究一下Onion Architecture项目结构Onion ArchitectureOnion Architecture定义了domain、repository、services、ui这几层，其核心要点如下：整个应用基于独立的domain构建内部的layer定义接口，外部的layer实现接口内层与外层通过接口解耦services(business logic)可以独立于infrastructure编译和运行示例结...

Ports and Adapters architecture，又叫Hexagonal architecture，其中ports层是六边形的边界，其中port又可以分为driver port及driven port，简单理解对应输入层及输出层；边界保护的是内部的app，其中app包括use cases或者叫做application services层以及domain层；adapter可以理解为将外部依赖进行适配，实现port层定...

clean architecture定义了四层结构，最内层是entities(enterprise business rules)，再往外是use cases(application business rules)，接着是interface adapters(比如controller、presenters、gateways)，最外层是frameworks & drivers(比如web、ui、db、devices、external interfaces)