go-actor

KO | EN

gitlite — search

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

★ 9 Open GitHub ↗

go-actor is a lightweight message framework using actor model

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# go-actor
* go-actor is a lightweight message framework using actor model

## 初衷
* 想能在代码逻辑上方便的写无锁的同步rpc调用代码,同时又不会阻塞住其他服务对这个Actor的调用
* 一个Actor可以有多种身份,想能比较方便的分类管理Actor,分类通过Actor地址调用目标Actor
* 节点间使用多种传输方式,比如游戏玩家移动这种同步可以使用tcp实现快速通知消息丢失也不太紧要,平台奖励类的可以使用mq通知

## 快速开始
* `创建ActorSystem` ActorSystem用来分类管理Actor,调用某个Actor的时候需要基于他所在的同名ActorSystem
    * `goactor.WithName`: 指定ActorSystem名字,同类同名
    * `goactor.WithInstanceId`: 指定节点id,同类型下唯一
    * `goactor.WithEtcd`: etcd注册地址,同类型使用同组etcd
    * `goactor.WithTransport`: 关联传输器
```go
	system, err := goactor.NewActorSystem(
		goactor.WithName("hello"),
		goactor.WithInstanceId(1),
		goactor.WithEtcd("http://127.0.0.1:2379"),
		goactor.WithTransport(trans),
	)
```

* `创建执行器`
    * `SingleGoroutine`: 单协程执行器，每个执行器同时只有一个协程在执行逻辑代码，当执行到`Executer.Wait`时会让出执行权给同执行器的其他协程处理消息，自己挂起直到`Executer.OnResponse`对应的session唤醒并等待其他协程让出执行权
```go
	single := &executer.SingleGoroutine{}
	single.Start(context.Background(), 1)
```

* `创建协议`
    * `protobuf`
        * go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
        * go install github.com/lsg2020/go-actor/tools/protoc-gen-gactor
        * 定义协议文件[例如](https://github.com/lsg2020/go-actor/tree/master/examples/pb/hello.proto)
        * 生成 `protoc -I . --go_out=. --gactor_out=. *.proto`
```go
	proto := protocols.NewProtobuf(1)
	hello.RegisterHelloService(&HelloService{}, proto)
```

* `创建Actor`并指定个名字注册到ActorSystem
```go
	func (hello *HelloActor) OnInit(a goactor.Actor) {
		hello.actor = a
		hello.addr = system.Register(a, "hello")
	}

goactor.NewActor(&HelloActor{}, single, goactor.ActorWithProto(proto))
```

# TODO
* context取消的传递
* prometheus指标增加
* transport 支持多个system

go-actor

Explore Similar Repositories

Was this content helpful?

Recent Feedback

Download README