ARP4G

KO | EN

gitlite — search

#javascript #python #hacktoberfest #react #ai #typescript #llm #go #golang #android #machine-learning #rust #deep-learning #linux

★ 21 Open GitHub ↗

ARP4G是一个go语言实现的简化应用开发的框架。使开发者专注于产品业务本身。

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# ARP4G
ARP4G是一个go语言实现的简化应用开发的框架。

通过 **A**ggregate（聚合）、**R**epository（仓库）、**P**rocess（过程）3个概念，隔离业务逻辑和技术实现细节，使开发者专注于产品业务本身。

## 一个简单的例子

```go
func (serv *OrderService) CompleteOrder(ctx context.Context, orderId string) *Order {
	//从仓库取出order
	order, _ := serv.orderRepository.Take(ctx, orderId)
	if order.state == "ongoing" {
		//改变他的状态
		order.state = "compleated"
		//返回改变后的order
		return order
	}
	return nil
}

type OrderService struct {
	orderRepository OrderRepository
}

type OrderRepository interface {
	Take(ctx context.Context, id any) (*Order, bool)
}
```

这里我们首先从订单仓库取出了一个订单（聚合），随后改变了他的状态，变成“已完成”，最后返回了这个“已完成”的订单。

这是一段业务代码，在这过程我们不关心查询和保存这些和数据库打交道的事情，我们也不关心 “并发改变订单状态所带来的问题” 这样的复杂技术细节，代码中没有任何技术细节，只有业务。

我们需要做的仅仅是调用该业务方法时用ARP4G包装一下（无需侵入这段纯粹的业务代码），ARP4G就会为你照顾一切技术细节。

订单仓库 “orderRepository” 不需要开发，可以使用[ARP4G的不同实现](#ARP4G的不同实现)来实现

## 安装

1. 首先需要 [Go](https://golang.org/) 已安装（**1.18及以上版本**）， 然后可以用以下命令安装ARP4G。

```sh
go get -u github.com/framework-arp/ARP4G
```

2. 在你的代码中 import：

```go
import "github.com/framework-arp/ARP4G"
```
## 快速开始
```go
package main

import (
	"context"
	"fmt"

"github.com/framework-arp/ARP4G/arp"
)

func main() {
	greetingService := &GreetingService{}
	arp.Go(context.Background(), func(ctx context.Context) error {
		//调用业务方法
		greetingService.SayHello(ctx)
		return nil
	})
}

type GreetingService struct {
}

func (serv *GreetingService) SayHello(ctx context.Context) {
	fmt.Println("hello world")
}

```
## ARP4G的不同实现
### MongoDB
[ARP4G-mongodb](https://github.com/framework-arp/ARP4G-mongodb)
### Redis
[ARP4G-redis](https://github.com/framework-arp/ARP4G-redis)
## 使用ARP开发业务简介
假设有一段**完成订单**的业务，根据订单id找到相关订单，把它的状态改为已完成。以下将介绍如何使用**A**ggregate、**R**epository、**P**rocess3个概念且利用ARP4G框架完成这段简单的业务。
### Aggregate（聚合）
一个聚合就是表示某个实体的对象，该实体可能还包含别的实体，通常，这在业务上意味着被包含的实体是聚合的一部分，比如一辆**汽车**包含一个**引擎**。这里说的聚合就是[DDD_Aggregate](https://martinfowler.com/bliki/DDD_Aggregate.html)。

显然这里有一个聚合，Order
```go
type Order struct {
	Id    string
	State string
}
```
### Repository（仓库）
仓库，就是存放聚合对象的仓库。

你可以把它想象成一个真实世界的仓库。例如有个品牌汽车专卖店，它有一个**汽车仓库**停满了汽车，当然它不会有**引擎仓库**，因为当你从仓库开出一辆汽车的时候就已经包含了它的引擎了。

现在，我们有了订单仓库，OrderRepository
```go
type OrderRepository interface {
	Take(ctx context.Context, id any) (order *Order, found bool)
}
```
仓库设计成接口是因为当我们在设计业务的时候，不希望扯入任何技术细节。在业务侧，我们需要的是有一个订单仓库，从中可以拿订单，并不关心仓库是怎么建造的。

### 从仓库获取我要的聚合
考虑一个现实世界中的汽车仓库，当一个顾客把一辆汽车买走后，另一个顾客是无法买走**同一辆**汽车的，同时顾客对自己的新车喷涂了喜欢的图案，当然另一个顾客无法喷涂这辆车，尽管他不喜欢这个图案，因为他没有取得它。我们把从仓库中取出聚合的操作叫做**Take**。

另一个场景，仓库管理员想要确认某辆车的型号是不是最新款，他来到仓库，找到了这辆车，确认了它的型号，记录在了自己的小本子上。他并不需要把这辆车从仓库开走，同时另一个仓库管理员也可以对同一辆车做确认。我们把这种只需要在仓库中找到聚合的操作叫做**Find**

总结起来，当我们需要获取仓库中的聚合，并试图改变它的状态，那么用**Take**，如果我们只是想在仓库中找到一个聚合并想要看看它的状态，那么用**Find**

这里我们要从仓库拿走这个订单，并改变它的状态，所以我们会有Take
```go
Take(ctx context.Context, id any) (order *Order, found bool)
```

### 完成我的业务逻辑
我们还需要一个OrderService
```go
type OrderService struct {
	orderRepository OrderRepository
}
```
OrderService提供一个业务方法来实现我们的业务逻辑
```go
func (serv *OrderService) CompleteOrder(ctx context.Context, orderId string) *Order {
	//从仓库取出order
	order, _ := serv.orderRepository.Take(ctx, orderId)
	if order.state == "ongoing" {
		//改变他的状态
		order.state = "compleated"
		//返回改变后的order
		return order
	}
	return nil
}
```
看看里面做了些什么，从仓库取出order，然后改变它的状态。

我们认为大多数业务都是这样，我们把**从仓库中取出一个或几个聚合，并改变他们的状态**这样的一个整体叫做**Process**（过程）。通常，一个过程就是一个业务服务的方法。

最后我们需要用ARP4G框架来包装一下这个过程，从而照顾所有的技术细节
```go
func main() {
	orderService := &OrderService{repoimpl.NewMemRepository(func() *Order { return &Order{} })}
	arp.Go(context.Background(), func(ctx context.Context) error {
		//调用业务方法
		orderService.CompleteOrder(ctx, "12345")
		return nil
	})
}
```
可以在下一节了解[ARP4G做了什么](#ARP4G做了什么)

### ARP4G做了什么
在这之前我愿介绍一些ARP的规则：

1. **不能同时从仓库取得（Take）同一个聚合**

2. **聚合的状态更新是自然的，业务代码不需要显式的update**

是的，考虑真实世界的仓库，当你买了一辆车，喷涂了新的图案，那么这辆车的外观就被改变了，这是自然的，这不需要你再告诉仓库要update才能确定下来。

3. **一个过程作为一个整体，其中所有涉及到的聚合的状态改变要么全都成功要么一个都不成功**

4. **一个过程结束的时候，不管成功与否，确保从仓库取得（Take）的聚合全部归还仓库**

所以，ARP4G所做的就是帮你实现了这些规则，使得你可以写出纯粹的业务代码。

如何持久化到数据库总是关心的，关于持久化聚合到具体的数据库可以看[ARP4G的不同实现](#ARP4G的不同实现)。

## 一个完整的例子

[ARP4G-example](https://github.com/framework-arp/ARP4G-example)

ARP4G

Today's picks

Was this content helpful?

Recent Feedback

ARP4G

Today's picks

Was this content helpful?

Recent Feedback

Download README