reConnect 方法

  1. void AsyncTcpConnection::reConnect(float $delay = 0)

(要求Workerman版本>=3.3.5)

重连。一般在onClose回调中调用,实现断线重连。

由于网络问题或者对方服务重启等原因导致连接断开,则可以通过调用此方法实现重连。

参数

$delay

延迟多久后执行重连。单位为秒,支持小数,可精确到毫秒。

如果不传或者值为0则代表立即重连。

最好传递参数让重连延迟执行,避免因为对端服务问题一直不可连导致本机cpu消耗过高。

返回值

无返回值

示例

  1. use Workerman\Worker;
  2. use Workerman\Connection\AsyncTcpConnection;
  3. use Workerman\Connection\TcpConnection;
  4. require_once __DIR__ . '/vendor/autoload.php';
  5. $worker = new Worker();
  6. $worker->onWorkerStart = function($worker)
  7. {
  8. $con = new AsyncTcpConnection('ws://echo.websocket.org:80');
  9. $con->onConnect = function(AsyncTcpConnection $con) {
  10. $con->send('hello');
  11. };
  12. $con->onMessage = function(AsyncTcpConnection $con, $msg) {
  13. echo "recv $msg\n";
  14. };
  15. $con->onClose = function(AsyncTcpConnection $con) {
  16. // 如果连接断开,则在1秒后重连
  17. $con->reConnect(1);
  18. };
  19. $con->connect();
  20. };
  21. Worker::runAll();

注意 调用reconnect成功重连后,$con的onConnect方法会再次被调用(如果有设置的话)。有时候我们想让onConnect方法只执行一次,重连的时候不再执行,参考如下例子:

  1. use Workerman\Worker;
  2. use Workerman\Connection\AsyncTcpConnection;
  3. use Workerman\Connection\TcpConnection;
  4. require_once __DIR__ . '/vendor/autoload.php';
  5. $worker = new Worker();
  6. $worker->onWorkerStart = function($worker)
  7. {
  8. $con = new AsyncTcpConnection('ws://echo.websocket.org:80');
  9. $con->onConnect = function(AsyncTcpConnection $con) {
  10. static $is_first_connect = true;
  11. if (!$is_first_connect) return;
  12. $is_first_connect = false;
  13. $con->send('hello');
  14. };
  15. $con->onMessage = function(AsyncTcpConnection $con, $msg) {
  16. echo "recv $msg\n";
  17. };
  18. $con->onClose = function(AsyncTcpConnection $con) {
  19. // 如果连接断开,则在1秒后重连
  20. $con->reConnect(1);
  21. };
  22. $con->connect();
  23. };
  24. Worker::runAll();