发表新帖

我想问下磁盘的IO影响异步SOCKET通信的速度吗？

发布于3年前 · 19 次浏览 · 来自提问

stonery

2021-08-24

Rango

2021-08-25

北京大丸子 回复 Rango

2021-08-22

北京大丸子

2021-08-25

北京大丸子

我的swoole版本Version => 4.6.7

现象就是上面说的,播放端把捕捉的桌面以图片base64的格式发送给swoole，然后swoole推送给【收看端】，但收看端接收严重丢包，画面还有，但非常滞后，另外就是swoole服务器网络被严重占用，在centos中打开个浏览器基本出不来网页。
请帮忙指点一下。

【swoole服务器端代码】：

```php
<?php
//创建WebSocket Server对象，监听0.0.0.0:9502端口
$ws = new Swoole\WebSocket\Server('0.0.0.0', 9502);
  //监听WebSocket连接打开事件
    $ws->on('open', function ($ws, $request) {
        $fd[] = $request->fd;
        $GLOBALS['fd'][] = $fd;
        $ws->push($request->fd, $request->fd.":现在在线人数".$count."\n");
		echo( $request->fd."|||||".$count);
    });

//监听WebSocket消息事件
    $ws->on('message', function ($ws, $frame) {
       	   $msg =  "{$frame->data}\n";
	if(is_array($GLOBALS['fd']) && !empty($GLOBALS['fd'])){  
        foreach($GLOBALS['fd'] as $aa){
            foreach($aa as $i){
                $ws->push($i,$msg);
		 	echo($msg);
            }
        }
	}
  });

//监听WebSocket连接关闭事件
    $ws->on('close', function ($ws, $fd) {
        echo "client-{$fd} is closed\n";
    });

$ws->start();
```

【播放端--捕获桌面的主要代码（vue）】：
```javascript
    async startCapture() {
      if (!this.socket) {
        var ws = new WebSocket("ws://10.138.68.36:9502");
        console.log(ws, "播放端链接swoole.socket成功");
        this.video = document.getElementById("video");
        this.socket = ws;

const displayMediaOptions = {
          video: true,
          audio: false,
        };

try {
          //console.log(this.video.srcObject, "dasfasdf");
          this.video.srcObject = await navigator.mediaDevices.getDisplayMedia(
            displayMediaOptions
          );
          // console.log(this.video.srcObject, "dasfasdf");
        } catch (error) {
          console.log(error);
        }

this.socket.onmessage = this.draw();
        this.socket.onclose = function () {
          console.log("WebSocket连接关闭");
          this.socket = null;
        };
      }
    },

//**************************
    //draw绘图canas图
    //**************************
    draw() {
      var back = document.getElementById("output");
      var backcontext = back.getContext("2d");
      console.log(this.video, "draw里面this.video的值");
      try {
        backcontext.drawImage(this.video, 0, 0, back.width, back.height);
      } catch (e) {
        if (e.name == "NS_ERROR_NOT_AVAILABLE") {
          return setTimeout(this.draw, 100);
        } else {
          throw e;
        }
      }
      if (this.video.srcObject) {
        this.socket.send(back.toDataURL("image/jpeg", 1));
      }
   
      this.socketid && clearTimeout(this.socketid);
      this.socketid = setTimeout(this.draw, 100);
   
    },
```

【收看端】：

```javascript
 shoukan() {
      var ws = new WebSocket("ws://10.138.68.36:9502");
      var image = document.getElementById("receiver");
      ws.onopen = function () {};
      ws.onmessage = function (data) {
        image.src = data.data;
      };
    },
```

微信公众号

热门内容

作者其它话题

- 我想问下我这边有个需求应该怎么样处理

暂无回复的问答

- 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一直是同一个。没用使用到多进程啊。