asynctcpconnection是workerman专为发起异步tcp客户端连接设计的核心组件,基于事件循环实现非阻塞通信;而tcpconnection仅用于服务端连接抽象,无connect()方法,不可用作客户端,否则会导致进程阻塞。

AsyncTcpConnection 和 AsyncUdpConnection 是 Workerman 实现无阻塞微服务调用的核心组件,不是靠“多进程”堆并发,而是靠单线程内事件循环驱动多个连接并行收发。只要不写同步阻塞代码(比如 file_get_contents、sleep、PDO 默认阻塞模式),就能真正达成高吞吐、低延迟的微服务通信。
为什么不能直接 new TcpConnection 做客户端?
因为 TcpConnection 是服务端连接抽象,只用于 onMessage 回调里拿到的 $connection 对象;它没有 connect() 方法,也不参与事件循环注册。强行拿来当客户端用,会卡死整个进程。
- 正确选择是
AsyncTcpConnection:专为发起 outbound 连接设计,自动注册到 event loop,支持onConnect/onMessage/onClose/onError -
AsyncUdpConnection同理:适用于主动发包场景(如 SIP 注册、GB28181 心跳、设备指令下发),但注意它不维护“连接状态”,每次send()都是独立 UDP 数据报 - 误用
stream_socket_client或fsockopen会导致阻塞——这些是 PHP 原生同步函数,一旦网络抖动或对端响应慢,整个 Worker 进程就停摆
AsyncTcpConnection 发起调用时必须设 onConnect 才能发数据
AsyncTcpConnection 的 connect() 方法立即返回,连接动作在后台异步进行。如果没设 onConnect 就直接 send(),会触发 Warning: send() called on closed connection 并静默失败。
- 必须把发送逻辑放在
onConnect回调里,确保 TCP 握手完成后再发业务数据 - 不要在
onConnect外部调用$conn->send(),哪怕只隔一行也不行 - 若需复用连接,建议配合
Channel或全局连接池管理,避免频繁创建销毁实例
// ✅ 正确写法
$conn = new AsyncTcpConnection('tcp://api.service:8080');
$conn->onConnect = function($conn) {
$conn->send(json_encode(['method' => 'status']));
};
$conn->onMessage = function($conn, $data) {
// 处理响应
$conn->close(); // 主动关闭,避免堆积
};
$conn->connect(); // 立即返回,不阻塞
UDP 客户端发包后无法保证送达,得自己加保活和重试
AsyncUdpConnection 的 send() 调用成功只表示数据进入内核发送队列,不代表对方收到。尤其在 NAT 或防火墙环境下,5 分钟无交互就会被丢弃会话(stream_socket 模式下更明显)。
- 必须实现双向心跳:客户端和服务端都需每 ≤60 秒发一次空包或带序列号的 ping
- 关键指令(如设备控制命令)要加应用层 ACK + 重传:发完启动一个
Timer::add(2, ...),超时未收 ACK 则重发,最多 3 次 - 别依赖
onError捕获丢包——UDP 本身不报错,onError只在 bind 失败、地址不可达等底层异常时触发 - 若需长连接语义(如 SIP),优先选
socket模式启动 UDP Worker(单进程),比stream_socket更稳定
微服务间协议要精简,避免 JSON 解析拖慢 event loop
Workerman 的高性能建立在“快速进出 event loop”的前提上。一旦某个回调里做重解析(比如大 JSON、XML、base64 图片解码),就会阻塞其他所有连接的处理。
- 推荐使用二进制协议或极简文本协议(如
method|id|body分隔),用explode('|', $data, 3)替代json_decode - 必须用 JSON 时,限制 payload 大小(例如 ≤16KB),并在
onMessage开头加if (strlen($data) > 16384) { $conn->close(); return; } - 耗时操作(如 DB 查询、文件读写)务必扔给子进程或协程(配合 Swoole Runtime 或 pcntl_fork),不能留在主线程











