0

0

使用Golang实现Actor模型_基于Channel的消息传递架构

P粉602998670

P粉602998670

发布时间:2026-03-03 10:30:02

|

399人浏览过

|

来源于php中文网

原创

用chan而不用共享变量实现actor,因其天然保障状态私有、消息驱动、无锁并发;actor须独占in chan,状态不可导出,仅通过send发送消息,newactor需启动goroutine运行死循环处理消息。

使用golang实现actor模型_基于channel的消息传递架构

为什么用 chan 而不用共享变量来实现 Actor

因为 Go 的 Actor 模型本质不是“模拟 Erlang”,而是利用 chan + goroutine 天然达成「状态私有、消息驱动、无锁并发」——只要每个 Actor 自己独占一个 in chan Message,所有外部修改都必须走这个入口,就不可能出现竞态。
常见错误是:在 Actor 内部还暴露了 State 字段给外部读写,或者用 sync.Mutex 包裹状态更新。这等于绕开 Actor 原则,白搭了模型价值。

  • Actor 的状态必须完全不可导出(首字母小写),只响应收到的 Message
  • 所有对外接口只能是 Send(msg Message) 这种发消息方法,不能有 GetState()UpdateXxx()
  • 如果需要返回结果,用带应答字段的 Message + 回调 chan,而不是函数返回值

NewActor() 必须封装 goroutine 启动逻辑

Actor 不是被动等待被调用的对象,而是一个持续运行的协程;它的生命周期由自己管理。漏掉 go actor.run() 是最常踩的坑——表面看结构体建好了,实际啥也不处理。

  • run() 方法里必须是死循环:for msg := range actor.in { actor.handle(msg) }
  • 不要用 select { case msg := 单次收消息就退出,那只是个“消息处理器”,不是 Actor
  • 关闭 actor.in 通道是唯一合法的终止方式,别用 context.WithCancel 强杀 goroutine
func (a *Actor) run() {
    for msg := range a.in {
        a.handle(msg)
    }
}

消息类型设计要避免接口泛化陷阱

interface{} 或空 Message 接口看似灵活,实则让编译器失去类型检查能力,运行时 panic 频发,且无法静态推导消息流向。

永利在线企业网站管理系统(CMS)1.0 Build 20100612
永利在线企业网站管理系统(CMS)1.0 Build 20100612

修正说明:1,实现真正的软件开源。2,安装界面的美化3,真正实现栏目的递归无限极分类。4,后台添加幻灯片图片的管理,包括添加,修改,删除等。5,修正添加新闻的报错信息6,修正网站参数的logo上传问题7,修正产品图片的栏目无限极分类8,修正投票系统的只能单选问题9,添加生成静态页功能10,添加缓存功能特点和优势1. 基于B/S架构,通过本地电脑、局域网、互联网皆可使用,使得企业的管理与业务不受地域

下载
  • 推荐用具体消息 struct,比如 type SpawnPlayerMsg struct{ ID int; Name string }
  • 如果真要多态,用可判别的 tag 字段 + switch,而不是靠接口断言
  • 禁止在消息里塞闭包或函数值——它们会捕获外部变量,导致内存泄漏或状态错乱

缓冲通道选 make(chan T, 1) 还是 make(chan T, 0)

零缓冲通道(默认)更符合 Actor “接收即处理” 的语义,但容易阻塞发送方;有缓冲则解耦更彻底,但也掩盖背压问题。

立即学习go语言免费学习笔记(深入)”;

  • 内部 Actor 之间通信(如 supervisor → worker)建议用 make(chan Message, 1):既防丢消息,又不至于积压太多
  • 外部输入入口(如 HTTP handler → Actor)必须用带缓冲的 channel,否则高并发请求会直接卡在 Send()
  • 缓冲大小不是越大越好:超过 100 容易掩盖下游处理瓶颈,也增加 OOM 风险
Actor 最难的部分不在启动,而在错误传播和生命周期协同——比如一个 Actor 崩溃了,怎么通知它的父 Actor?这类问题没法靠 chan 自动解决,得靠显式的消息协议和约定,而不是寄希望于 channel 关闭能自动级联。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
erlang语言是什么
erlang语言是什么

erlang是一种并发、容错、分布式和动态类型的编程语言。它专门用于构建并发系统,并提供了一个轻量级进程模型来实现并发性。想了解更多erlang的相关内容,可以阅读本专题下面的文章。

408

2024.06.19

golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

209

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

243

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

352

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

214

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

407

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

428

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

200

2025.06.10

C++高性能网络编程与Reactor模型实践
C++高性能网络编程与Reactor模型实践

本专题围绕 C++ 在高性能网络服务开发中的应用展开,深入讲解 Socket 编程、多路复用机制、Reactor 模型设计原理以及线程池协作策略。内容涵盖 epoll 实现机制、内存管理优化、连接管理策略与高并发场景下的性能调优方法。通过构建高并发网络服务器实战案例,帮助开发者掌握 C++ 在底层系统与网络通信领域的核心技术。

0

2026.03.03

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 5.8万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.9万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号