标签：框架 actor csp interface go 消息传递 共享内存 Tell protoactor
目录前言
业务中，大量使用了protoactor-go框架作为消息处理，用来避免高并发。现对其进行学习。
actor模型与csp模型
《unix 网络编程-进程间通信》，提到，有消息传递、共享内存等两大类实现方法。其中消息传递（前提是内容拷贝）避免了并发；同时共享内存则面临着同步问题（如：并发访问带来了加锁）
actor来源与Erlang语言，强调，每个actor是一个实体，通信通过消息传递，每一个actor拥有自己消息队列，持续处理消息。MPSC（multi-producer signal-consumer）。
csp基本原则就是『通过通信来实现共享内存，不要通过共享内存来实现通信』。也就是提倡尽可能通过消息传递的方式。
这两者有异曲同工之妙，同是指两者都希望通过消息传递来实现进程间的通信，带来的好处是避免并发，可以降低编程带来的心智负担；异则是两者着重点稍有不同，actor强调actor实体，消息队列则是actor实体的一部分，而csp则强调消息队列，突出了channel这一数据结构体的存在，goroutine则明显没有actor实体的地位突出。
但总体而言，actor框架与go相结合，能实现一些令人意想不到的效果。让我们开始吧。
选择版本
git checkout e866f39
全部源码
package main
import "fmt"
import "bufio"
import "os"
func main() {
myActor := ActorOf(new(MyActor))
myActor.Tell(Hello{Name: "Roger"})
myActor.Tell(Hello{Name: "Go"})
bufio.NewReader(os.Stdin).ReadString('\n')
}
type ActorRef interface {
Tell(message interface{})
SendSystemMessage(message interface{})
}
type ChannelActorRef struct {
actorCell *ActorCell
}
func (ref *ChannelActorRef) Tell(message interface{}) {
ref.actorCell.userMailbox <- message
}
func (ref *ChannelActorRef) SendSystemMessage(message interface{}) {
ref.actorCell.userMailbox <- message
}
type Actor interface {
Receive(message interface{})
}
func ActorOf(actor Actor) ActorRef {
userMailbox := make(chan interface{}, 100)
systemMailbox := make(chan interface{}, 100)
cell := &ActorCell{
userMailbox: userMailbox,
systemMailbox: systemMailbox,
actor: actor,
}
ref := ChannelActorRef{
actorCell: cell,
}
go func() {
for {
select {
case sysMsg := <-systemMailbox:
//prioritize system messages
cell.invokeSystemMessage(sysMsg)
default:
//if no system message is present, try read user message
select {
case userMsg := <-userMailbox:
cell.invokeUserMessage(userMsg)
default:
}
}
}
}()
return &ref
}
type ActorCell struct {
userMailbox chan interface{}
systemMailbox chan interface{}
actor Actor
}
func (cell *ActorCell) invokeSystemMessage(message interface{}) {
fmt.Printf("Received system message %v\n", message)
}
func (cell *ActorCell) invokeUserMessage(message interface{}) {
cell.actor.Receive(message)
}
type MyActor struct{ messageCount int }
type Hello struct{ Name string }
func (state *MyActor) Receive(message interface{}) {
switch msg := message.(type) {
default:
fmt.Printf("unexpected type %T\n", msg) // %T prints whatever type t has
case Hello:
fmt.Printf("Hello %v\n", msg.Name) // t has type bool
state.messageCount++
}
}
参考
https://www.cnblogs.com/XiaoXiaoShuai-/p/16001285.html
https://blog.csdn.net/screscent/article/details/90401707?spm=1001.2014.3001.5501
标签：框架,actor,csp,interface,go,消息传递,共享内存,Tell,protoactor 来源： https://www.cnblogs.com/aaron2932/p/16557592.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。