当前位置： 维易PHP培训学院 > PHP学习 > 内容正文

PHP实例：基于Swoole实现PHP与websocket聊天室

作者：VEPHP   时间 2017-09-27

《PHP实例：基于Swoole实现PHP与websocket聊天室》要点：
本文介绍了PHP实例：基于Swoole实现PHP与websocket聊天室，希望对您有用。如果有疑问，可以联系我们。

相关主题：swoole教程

websocket
PHP实例

Websocket只是一个网络通信协议
PHP实例

就像 http、ftp等都是网络通信的协议；不要多想；
PHP实例

相对于HTTP这种非持久的协议来说,Websocket是一个持久化网络通信的协议；PHP实例

WebSocket和HTTP的关系
PHP实例

PHP实例：基于Swoole实现PHP与websocket聊天室PHP实例

有交集,但是并不是全部.
PHP实例

Websocket只是借用了HTTP的一部分协议来完成一次握手.(HTTP的三次握手,此处只完成一次)PHP实例

http和websocket 请求头对比：PHP实例

PHP实例：基于Swoole实现PHP与websocket聊天室PHP实例

PHP实例：基于Swoole实现PHP与websocket聊天室
PHP实例

HTTP：
PHP实例

原来的时候,客户端通过http(骑马)带着信请求服务器,服务器处理请求(写回信),再次通过http(骑马)返回；链接断开；PHP实例

WebSocket:
PHP实例

客户端通过http(骑马)带着信请求服务器,但同时,携带了Upgrade:websocket和Connection:Upgrade(两根管子),服务器如果支持WebSocket协议(有两根管子的接口),使用Websocket协议返回可用信息(丢弃马匹),此后信息的传递,均使用这两个管子,除非有一方人为的将管子切断;若服务器不支持,客户端请求链接失败,返回错误信息；PHP实例

http和websocket 响应头对比：PHP实例

PHP实例：基于Swoole实现PHP与websocket聊天室
PHP实例

PHP实例：基于Swoole实现PHP与websocket聊天室PHP实例

websocket和ajax轮询、long poll的区别
PHP实例

首先是 ajax轮询 ,ajax轮询的原理非常简单,让浏览器隔个几秒就发送一次请求,询问服务器是否有新信息
PHP实例

场景再现：
PHP实例

客户端：啦啦啦,有没有新信息(Request)
PHP实例

服务端：没有(Response)
PHP实例

客户端：啦啦啦,有没有新信息(Request)
PHP实例

服务端：没有..(Response)
PHP实例

客户端：啦啦啦,有没有新信息(Request)
PHP实例

服务端：你好烦啊,没有啊..(Response)
PHP实例

客户端：啦啦啦,有没有新消息(Request)
PHP实例

服务端：好啦好啦,有啦给你.(Response)
PHP实例

客户端：啦啦啦,有没有新消息(Request)
PHP实例

服务端：...没....没..没有PHP实例

long poll 其实原理跟 ajax轮询 差不多,都是采用轮询的方式,不在论述；PHP实例

从上面可以看出,轮询其实就是在不断地建立HTTP连接,然后等待服务端处理,可以体现HTTP协议的另外一个特点,被动性.同时,http的每一次请求与响应结束后,服务器将客户端信息全部丢弃,下次请求,必须携带身份信息(cookie),无状态性；PHP实例

Websocket的出现,干净利落的解决了这些问题；PHP实例

所以上面的情景可以做如下修改.
PHP实例

客户端：啦啦啦,我要建立Websocket协议,需要的服务：chat,Websocket协议版本：17(HTTP Request)
PHP实例

服务端：ok,确认,已升级为Websocket协议(HTTP Protocols Switched)
PHP实例

客户端：麻烦你有信息的时候推送给我噢..
PHP实例

服务端：ok,有的时候会告诉你的.
PHP实例

客户端：balab开始斗图alabala
PHP实例

服务端：苍井空ala
PHP实例

客户端：流鼻血了,我擦……
PHP实例

服务端：哈哈布尔教育牛逼啊哈哈哈哈
PHP实例

服务端：笑死我了哈哈PHP实例

Swoole
PHP实例

但是,为了用PHP配合HTML5完成一次WebSocket请求和响应,哥走过千山万水,在密林深处,发现了Swoole :PHP实例

PHP语言的异步、并行、高性能网络通信框架,使用纯C语言编写,提供了PHP语言的异步多线程服务器,异步TCP/UDP网络客户端,异步MySQL,数据库连接池,AsyncTask,消息队列,毫秒定时器,异步文件读写,异步DNS查询.
PHP实例

支持的服务：
PHP实例

HttpServer
PHP实例

WebSocket Server
PHP实例

TCP Server
PHP实例

TCP Client
PHP实例

Async-IO(异步)
PHP实例

Task(定时任务)PHP实例

环境依赖：
PHP实例

仅支持Linux,FreeBSD,MacOS,3类操作系统
PHP实例

Linux内核版本2.3.32以上
PHP实例

PHP5.3.10以上版本
PHP实例

gcc4.4以上版本或者clang
PHP实例

cmake2.4+,编译为libswoole.so作为C/C++库时需要使用cmakePHP实例

安装：
PHP实例

必须保证系统中有以下这些软件：
PHP实例

php-5.3.10 或更高版本
PHP实例

gcc-4.4 或更高版本
PHP实例

make
PHP实例

autoconfPHP实例

Swoole是作为PHP扩展来运行的
PHP实例

安装(root权限)：
PHP实例

cd swoole
PHP实例

phpize
PHP实例

./configure
PHP实例

make
PHP实例

sudo make install
PHP实例

配置php.ini
PHP实例

extension=swoole.soPHP实例

想研究Swoole的同学,自己去看手册(虽然写的不好,但是还是能看懂的)
PHP实例

做一个聊天室PHP实例

服务器端：socket.phpPHP实例

//创建websocket服务器对象,监听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, "hello, welcome\n");
});
//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
  $msg = 'from'.$frame->fd.":{$frame->data}\n";
//var_dump($GLOBALS['fd']);
//exit;
  foreach($GLOBALS['fd'] as $aa){
    foreach($aa as $i){
      $ws->push($i,$msg);
    }
  }
  // $ws->push($frame->fd, "server: {$frame->data}");
  // $ws->push($frame->fd, "server: {$frame->data}");
});
//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
  echo "client-{$fd} is closed\n";
});
$ws->start();

客户端：Socket.htmlPHP实例

<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8">
  <title>Title</title>
</head>
<body>
<div id="msg"></div>
<input type="text" id="text">
<input type="submit" value="发送数据" onclick="song()">
</body>
<script>
  var msg = document.getElementById("msg");
  var wsServer = 'ws://192.168.1.253:9502';
  //调用websocket对象建立连接：
  //参数：ws/wss(加密)：//ip:port (字符串)
  var websocket = new WebSocket(wsServer);
  //onopen监听连接打开
  websocket.onopen = function (evt) {
    //websocket.readyState 属性：
    /*
    CONNECTING  0  The connection is not yet open.
    OPEN  1  The connection is open and ready to communicate.
    CLOSING  2  The connection is in the process of closing.
    CLOSED  3  The connection is closed or couldn't be opened.
    */
    msg.innerHTML = websocket.readyState;
  };
  function song(){
    var text = document.getElementById('text').value;
    document.getElementById('text').value = '';
    //向服务器发送数据
    websocket.send(text);
  }
   //监听连接关闭
//  websocket.onclose = function (evt) {
//    console.log("Disconnected");
//  };
  //onmessage 监听服务器数据推送
  websocket.onmessage = function (evt) {
    msg.innerHTML += evt.data +'<br>';
//    console.log('Retrieved data from server: ' + evt.data);
  };
//监听连接错误信息
//  websocket.onerror = function (evt, e) {
//    console.log('Error occured: ' + evt.data);
//  };
</script>
</html>

以上就是基于Swoole实现PHP与websocket聊天室的全部内容,相信本文对大家学习PHP和websocket及开发聊天室很有帮助.
PHP实例

转载请注明本页网址：
http://www.vephp.com/jiaocheng/4824.html


    标签：  




同类教程排行


特辑教程