当前位置:首页 > PHP教程 > php高级应用 > 列表

使用php+swoole对client数据实时更新(一)

发布:smiling 来源: PHP粉丝网  添加日期:2021-07-04 12:45:13 浏览: 评论:0 

如果想对一个列表做实时的更新,传统的做法是采用轮询的方式。以web为例,通过Ajax定时请求服务端然后获取数据显示在页面,这种方式实现简单,缺点就是浪费资源。

HTTP1.1新增加了对websocket的支持,这样就可以将被动展示转变为主动通知。也就是通过websocket与服务端保持持久链接,一旦数据发生变化,由server通知client数据有更新,然后再进行刷新等操作,这样就省去了很多不必要的被动请求,节省了服务器资源。

要实现一个webscoket的程序,首先需要使用支持html5的浏览器。

  1. if(ws === null){ 
  2. var wsServer = 'ws://'+ location.hostname +':8888'
  3. ws = new WebSocket(wsServer); 
  4. ws.onopen = function(){ 
  5. console.log("socket连接已打开"); 
  6. }; 
  7. ws.onmessage = function(e){ 
  8. console.log("message:" + e.data); 
  9. }; 
  10. ws.onclose = function(){ 
  11. console.log("socket连接已断开"); 
  12. }; 
  13. ws.onerror = function(e){ 
  14. console.log("ERROR:" + e.data); 
  15. }; 
  16. //离开页面时关闭连接 
  17. $(window).bind('beforeunload',function(){ 
  18. ws.close(); 
  19. ); 

这样就实现了一个client,不过事情还远没有结束。上面的代码只是简单的进行了连接,对话,关闭等基本动作。如果想和服务端进行通讯,必须要有更具体的方案。比如收到message时判断类型进行进一步操作。

服务端:此处采用Swoole进行php服务端的websocket开发,使用swoole进行php的websocket开发非常简单,而且它还支持httpserver的支持。

  1. $server = new swoole_websocket_server("0.0.0.0", 8888); 
  2. $server->on('open'function (swoole_websocket_server $server$request) { 
  3. echo "server: handshake success with fd{$request->fd}\n"
  4. }); 
  5. $server->on('message'function (swoole_websocket_server $server$frame) { 
  6. echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n"
  7. $server->push($frame->fd, "this is server"); 
  8. }); 
  9. $server->on('close'function ($ser$fd) { 
  10. echo "client {$fd} closed\n"
  11. }); 
  12. $server->start();

Tags: php+swoole client

分享到: