发表新帖

开启两个一直占用不退出的协程，CPU 占用 100%

### 问题描述

为了和 Websocket 服务器建立长链接，接受推送消息，开启两个协程，过了两天，发现CPU占用 100%

### Swoole版本，PHP版本，以及操作系统版本信息

PHP: 7.2.33

Swoole:4.5.5

### 相关代码
```php

$client = new Client('openapi.dianping.com', 80);
        $params['app_key'] = $this->appKey;
        $params['v'] = '1.0';
        $params['timestamp'] = date('Y-m-d H:i:s');
        $params['type'] = 'ALL';
        $sign = $this->makeSign($params);
        $params['sign'] = $sign;

$ret = $client->upgrade('/message/websocket?'.http_build_query($params));

Coroutine::create(function () use ($client, $ret) {

if ($ret) {
                while(true) {
                    $client->push('hello');
                    Coroutine::sleep(5);
                }
            }

});

Coroutine::create(function () use ($client, $ret) {

$guzzleClient = new GuzzleClient([
                'base_uri' =>  config('websocket.tuangou_callback_url'),
                'timeout' => 5,
                'verify' => false
            ]);

if ($ret) {
                while(true) {
                    $res = $client->recv();
                    var_dump($res);

if ($res && $res->data) {
                        $this->logger->info("美团团购消息".$res->data);

$resBody = $guzzleClient->post('v1/callback/meituan-un-bind', ['form_params' => ['data' => $res->data]]);
                        $resData = json_decode((string)$resBody->getBody(), true);
                        $this->logger->info("推送结果".$resBody->getBody());
                        var_dump($resBody->getBody());

if ($resData && isset($resData['code']) && ($resData['code'] == 200)) {
                            $msgData = json_decode($res->data, true);

if (isset($msgData['msg_id']) && isset($msgData['type'])) {
                                $client->push(json_encode([
                                    'msgId' => $msgData['msg_id'],
                                    'type' => $msgData['type'],
                                    'msg' => 'ack'
                                ]));
                            }
                        }
                    }
                }
            }

});

```

### 你期待的结果是什么？实际看到的错误信息又是什么？

发布于2年前 · 47 次浏览 · 来自提问

掸尘

### 问题描述

为了和 Websocket 服务器建立长链接，接受推送消息，开启两个协程，过了两天，发现CPU占用 100%

### Swoole版本，PHP版本，以及操作系统版本信息

PHP: 7.2.33

Swoole:4.5.5

### 相关代码
```php

$ret = $client->upgrade('/message/websocket?'.http_build_query($params));

Coroutine::create(function () use ($client, $ret) {

if ($ret) {
                while(true) {
                    $client->push('hello');
                    Coroutine::sleep(5);
                }
            }

});

Coroutine::create(function () use ($client, $ret) {

$guzzleClient = new GuzzleClient([
                'base_uri' =>  config('websocket.tuangou_callback_url'),
                'timeout' => 5,
                'verify' => false
            ]);

if ($ret) {
                while(true) {
                    $res = $client->recv();
                    var_dump($res);

if ($res && $res->data) {
                        $this->logger->info("美团团购消息".$res->data);

if ($resData && isset($resData['code']) && ($resData['code'] == 200)) {
                            $msgData = json_decode($res->data, true);

});

```

### 你期待的结果是什么？实际看到的错误信息又是什么？