发表新帖

websocket 服务异常

### 问题描述
当设置work_num = 1 的时候可以正常接收到消息 $server有值
当设置work_num > 1 的时候就会发生消息接收不到的情况 $server 有时候有值有时候没有

### Swoole版本，PHP版本，以及操作系统版本信息
swoole 4.5.0
php 7.4

### 相关代码
```php
//建立连接
public function onOpen(WebSocketServer $server, Request $request): void
    {
		//存储 server
        $this->utils::service('Dealer', 'GameControl')->setWsServer($server);
    }

//另外的地方调用server 发送消息
 protected function sendToAllUid(Server $server, array $fd, string $message): void
    {
        if (is_array($fd) && !empty($fd)) {
            $concurrent = new Concurrent(count($fd));
            foreach ($fd as $value) {
                $concurrent->create(function () use ($server, $value, $message) {
                    if (!empty($server->connections)) {
                        if ($server->isEstablished((int)$value)) {
                            $server->push((int)$value, $message);
                        }
                    }
                });
            }
        }
    }
```

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

发布于4年前 · 1 次浏览 · 来自提问

### 问题描述
当设置work_num = 1 的时候可以正常接收到消息 $server有值
当设置work_num > 1 的时候就会发生消息接收不到的情况 $server 有时候有值有时候没有

### Swoole版本，PHP版本，以及操作系统版本信息
swoole 4.5.0
php 7.4

### 相关代码
```php
//建立连接
public function onOpen(WebSocketServer $server, Request $request): void
    {
		//存储 server
        $this->utils::service('Dealer', 'GameControl')->setWsServer($server);
    }

//另外的地方调用server 发送消息
 protected function sendToAllUid(Server $server, array $fd, string $message): void
    {
        if (is_array($fd) && !empty($fd)) {
            $concurrent = new Concurrent(count($fd));
            foreach ($fd as $value) {
                $concurrent->create(function () use ($server, $value, $message) {
                    if (!empty($server->connections)) {
                        if ($server->isEstablished((int)$value)) {
                            $server->push((int)$value, $message);
                        }
                    }
                });
            }
        }
    }
```

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

评论

2020-04-30

鲁飞

微信公众号

Swoole官方公众号

暂无回复的问答

- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡

- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]

- 多个模型如何进行事务异常回退？

- websocket开启wss报错

- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。