讲师中心 微信公众号
AI工具推荐 视频效率加速

Workerman如何实现分布式服务架构

胖丽酱_4470

胖丽酱_4470

发布时间:2026-06-30 18:41:53

|

417人浏览过

|

来源于php中文网

原创

Workerman跨多机协同必须依赖外部组件补足节点发现、任务分发与状态同步能力,其自身仅作为无状态执行端;调度逻辑须由独立服务承担,如Redis+BRPOP实现心跳注册与低延迟任务指派,并通过超时重入机制保障任务不丢。

workerman如何实现分布式服务架构

要让Workerman服务能跨多台服务器协同工作,必须打破单机边界,用外部组件补足它缺失的节点发现、任务分发和状态同步能力;Workerman本身只负责高效执行,不承担调度职责。

明确角色分工:谁管调度,谁管干活

Workerman进程只能作为Worker(执行端),不能当Master(调度中心)。所有节点注册、心跳检测、任务分发、故障转移逻辑,必须由独立服务实现——比如一个单独的PHP脚本监听Redis,或一个用Swoole写的轻量调度器。

常见错误是把调度逻辑硬塞进Workerman进程里:比如让每个Worker定时file_get_contents拉任务URL。这会导致节点间完全无协调,任务重复抓取、漏执行、扩缩容时状态混乱。

【每个Workerman实例必须无状态】 所有会话、用户连接映射、任务进度等数据,一律存到Redis或MySQL,不能放在PHP变量或文件里。

部署负载均衡层,分散客户端连接

在所有Workerman服务器前加一层Nginx或HAProxy,把TCP/HTTP请求按策略分发过去。

若业务依赖长连接状态(如聊天室),必须开启负载均衡器的IP Hash或Session Sticky功能,否则用户连接会跳到不同机器,导致消息丢失或登录态失效。

更推荐的做法是彻底剥离状态:用户ID → Redis哈希槽映射,消息广播走Redis Pub/Sub,这样Workerman实例就能任意增减,无需粘性路由。

用Redis实现节点注册与心跳保活

第一步:每个Workerman节点启动时,向Redis SET写入唯一ID(如node:web-01)和IP+端口信息,并设置30秒过期。

第二步:节点内启一个Timer,每15秒刷新一次该KEY的EXPIRE时间,模拟心跳。

第三步:调度服务持续SCAN Redis中node:*的KEY,剔除超时未刷新的节点,动态维护在线节点列表。

注意:节点ID必须固定(从配置文件或环境变量读取),不能随机生成,否则任务发错队列后无法找回。

用BRPOP实现低延迟任务指派

方法一:为每个节点建专属队列
节点node-abc启动后执行:$task = $redis->brpop(['queue:node-abc'], 5);,阻塞最多5秒等待任务。

方法二:共用一个任务队列,靠竞争消费
所有节点监听同一LIST,用BRPOP tasks 5,谁抢到谁处理。适合任务粒度小、节点数不多的场景。

【BRPOP超时值不能设为0】 否则进程无法响应SIGTERM信号正常退出,容器重启会卡死。

保障任务不丢:依赖重入队,而非完成确认

第一步:调度服务从待抓队列(pending:url_list)弹出一个URL,包装成JSON,LPUSH到某节点私有队列(queue:node-001)。

第二步:节点消费后开始抓取,但不主动上报“已完成”——因为网络中断或进程崩溃时,上报会丢失。

第三步:调度服务每隔30秒扫描所有私有队列,若发现某任务在队列里停留超60秒,视为超时,自动LPUSH回pending:url_list重试。

这种“默认失败、主动兜底”机制比ACK模式更可靠,也省去了节点宕机后清理未确认任务的复杂逻辑。

热门AI工具

更多
讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

10924

2023.09.01

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

6361

2023.10.11

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

2135

2023.10.11

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

4028

2023.10.23

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

4734

2023.10.23

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

3711

2023.11.03

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

5317

2023.11.09

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4162

2023.11.13

OpenJDK JVM参数怎么调优
OpenJDK JVM参数怎么调优

Java应用运行缓慢,如何调整JVM参数?本专题介绍OpenJDK JVM性能调优的基本流程,涵盖性能指标确认、运行数据采集、内存配置和垃圾回收分析,帮助你先定位瓶颈,再通过对照测试验证效果,避免直接套用参数而影响应用稳定性。

20

2026.10.16

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Webman中文手册
Webman中文手册

共0课时 | 0人学习

Workerman官方手册
Workerman官方手册

共0课时 | 0人学习

ThinkPHP5.1完全开发手册
ThinkPHP5.1完全开发手册

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn