当前访客身份:游客 [ 登录 | 加入 OSCHINA ]

代码分享

当前位置:
代码分享 » PHP  » Web编程
oxsicn

使用php创建WebSocket服务

oxsicn 发布于 2013年06月18日 16时, 19评/21576阅
分享到: 
收藏 +0
2
执行方法:
首先先修改server.php与index.html的ip
通过命令行执行 [php路径]\php.exe "[文件路径]\server.php"
然后通过浏览器打开index.html
标签: PHP WebSocket

源码与演示:源码出处

代码片段(3) [全屏查看所有代码]

1. [文件] server.php ~ 1KB     下载(809)     跳至 [1] [2] [3] [全屏预览]

<?
include 'websocket.class.php';

$config=array(
  'address'=>'192.168.0.200',
  'port'=>'8000',
  'event'=>'WSevent',//回调函数的函数名
  'log'=>true,
);
$websocket = new websocket($config);
$websocket->run();
function WSevent($type,$event){
  global $websocket;
    if('in'==$type){
      $websocket->log('客户进入id:'.$event['k']);
    }elseif('out'==$type){
      $websocket->log('客户退出id:'.$event['k']);
    }elseif('msg'==$type){
      $websocket->log($event['k'].'消息:'.$event['msg']);
      roboot($event['sign'],$event['msg']);
    }
}

function roboot($sign,$t){
  global $websocket;
  switch ($t)
  {
  case 'hello':
    $show='hello,GIt @ OSC';
    break;  
  case 'name':
    $show='Robot';
    break;
  case 'time':
    $show='当前时间:'.date('Y-m-d H:i:s');
    break;
  case '再见':
    $show='( ^_^ )/~~拜拜';
    $websocket->write($sign,'Robot:'.$show);
    $websocket->close($sign);
    return;
    break;
  case '天王盖地虎':
    $array = array('小鸡炖蘑菇','宝塔震河妖','粒粒皆辛苦');
    $show = $array[rand(0,2)];
    break;
  default:
    $show='( ⊙o⊙?)不懂,你可以尝试说:hello,name,time,再见,天王盖地虎.';
  }
  $websocket->write($sign,'Robot:'.$show);
}
?>

2. [文件] index.html ~ 1KB     下载(753)     跳至 [1] [2] [3] [全屏预览]

<!doctype html>
<html>
<head>
<meta charset="utf-8">
<title>websocket_TEST</title>
</head>
<body>
<textarea class="log" style="width: 100%; height: 500px;">
=======websocket======
</textarea>
<input type="button" value="连接" onClick="link()"> 
<input type="button" value="断开" onClick="dis()">
<input type="text" id="text">
<input type="button" value="发送" onClick="send()">
<script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jquery/1.4.4/jquery.min.js"></script>
<script>
function link(){
  var url='ws://192.168.0.200:8000';
  socket=new WebSocket(url);
  socket.onopen=function(){log('连接成功')}
  socket.onmessage=function(msg){log('获得消息:'+msg.data);console.log(msg);}
  socket.onclose=function(){log('断开连接')}
}
function dis(){
  socket.close();
  socket=null;
}
function log(var1){
  $('.log').append(var1+"\r\n");
}
function send(){
  socket.send($('#text').attr('value'));
}
function send2(){
  var json = JSON.stringify({'type':'php','msg':$('#text2').attr('value')})
  socket.send(json);
}
</script>
</body>
</html>

3. [文件] websocket.class.php ~ 6KB     下载(833)     跳至 [1] [2] [3] [全屏预览]

<?php
/*
创建类websocket($config);
$config结构:
$config=array(
  'address'=>'192.168.0.200',//绑定地址
  'port'=>'8000',//绑定端口
  'event'=>'WSevent',//回调函数的函数名
  'log'=>true,//命令行显示记录
);

回调函数返回数据格式
function WSevent($type,$event)

$type字符串 事件类型有以下三种
in  客户端进入
out 客户端断开
msg 客户端消息到达
均为小写

$event 数组
$event['k']内置用户列表的userid;
$event['sign']客户标示
$event['msg']收到的消息 $type='msg'时才有该信息

方法:
run()运行
search(标示)遍历取得该标示的id
close(标示)断开连接
write(标示,信息)推送信息
idwrite(id,信息)推送信息

属性:
$users 客户列表
结构:
$users=array(
[用户id]=>array('socket'=>[标示],'hand'=[是否握手-布尔值]),
[用户id]=>arr.....
)
*/

class websocket{
    public $log;
    public $event;
    public $signets;
    public $users;  
    public $master; 
    public function __construct($config){
        if (substr(php_sapi_name(), 0, 3) !== 'cli') {
            die("请通过命令行模式运行!");
        }
        error_reporting(E_ALL);
        set_time_limit(0);
        ob_implicit_flush();
        $this->event = $config['event'];
        $this->log = $config['log'];
        $this->master=$this->WebSocket($config['address'], $config['port']);
        $this->sockets=array('s'=>$this->master);
    }
    function WebSocket($address,$port){
        $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
        socket_bind($server, $address, $port);
        socket_listen($server);
        $this->log('开始监听: '.$address.' : '.$port);
        return $server;
    }
  function run(){
    while(true){
      $changes=$this->sockets;
      @socket_select($changes,$write=NULL,$except=NULL,NULL);
      foreach($changes as $sign){
        if($sign==$this->master){
          $client=socket_accept($this->master);
          $this->sockets[]=$client;
          $user = array(
            'socket'=>$client,
            'hand'=>false,
          );
          $this->users[] = $user;
          $k=$this->search($client);
          $eventreturn = array('k'=>$k,'sign'=>$sign);
          $this->eventoutput('in',$eventreturn);
        }else{
          $len=socket_recv($sign,$buffer,2048,0);
          $k=$this->search($sign);
          $user=$this->users[$k];
          if($len<7){
            $this->close($sign);
            $eventreturn = array('k'=>$k,'sign'=>$sign);
            $this->eventoutput('out',$eventreturn);
            continue;
          }
          if(!$this->users[$k]['hand']){//没有握手进行握手
            $this->handshake($k,$buffer);
          }else{
            $buffer = $this->uncode($buffer);
            $eventreturn = array('k'=>$k,'sign'=>$sign,'msg'=>$buffer);
            $this->eventoutput('msg',$eventreturn);
          }
        }
      }
    }
  }
  function search($sign){//通过标示遍历获取id
    foreach ($this->users as $k=>$v){
      if($sign==$v['socket'])
      return $k;
    }
    return false;
  }
  function close($sign){//通过标示断开连接
    $k=array_search($sign, $this->sockets);
    socket_close($sign);
    unset($this->sockets[$k]);
    unset($this->users[$k]);
  }
  function handshake($k,$buffer){
    $buf  = substr($buffer,strpos($buffer,'Sec-WebSocket-Key:')+18);
    $key  = trim(substr($buf,0,strpos($buf,"\r\n")));
    $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
    $new_message = "HTTP/1.1 101 Switching Protocols\r\n";
    $new_message .= "Upgrade: websocket\r\n";
    $new_message .= "Sec-WebSocket-Version: 13\r\n";
    $new_message .= "Connection: Upgrade\r\n";
    $new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
    socket_write($this->users[$k]['socket'],$new_message,strlen($new_message));
    $this->users[$k]['hand']=true;
    return true;
  }
  function uncode($str){
    $mask = array();  
    $data = '';  
    $msg = unpack('H*',$str);  
    $head = substr($msg[1],0,2);  
    if (hexdec($head{1}) === 8) {  
      $data = false;  
    }else if (hexdec($head{1}) === 1){  
      $mask[] = hexdec(substr($msg[1],4,2));
      $mask[] = hexdec(substr($msg[1],6,2));
      $mask[] = hexdec(substr($msg[1],8,2));
      $mask[] = hexdec(substr($msg[1],10,2));
      $s = 12;  
      $e = strlen($msg[1])-2;  
      $n = 0;  
      for ($i=$s; $i<= $e; $i+= 2) {  
        $data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));  
        $n++;  
      }  
    }  
    return $data;
  }
    function code($msg){
      $msg = preg_replace(array('/\r$/','/\n$/','/\r\n$/',), '', $msg);
      $frame = array();  
      $frame[0] = '81';  
      $len = strlen($msg);  
      $frame[1] = $len<16?'0'.dechex($len):dechex($len);
      $frame[2] = $this->ord_hex($msg);
      $data = implode('',$frame);
      return pack("H*", $data);
    }
    function ord_hex($data)  {  
      $msg = '';  
      $l = strlen($data);  
      for ($i= 0; $i<$l; $i++) {  
        $msg .= dechex(ord($data{$i}));  
      }  
      return $msg;  
    }

    function idwrite($id,$t){//通过id推送信息
      if(!$this->users[$id]['socket']){return false;}//没有这个标示
      $t=$this->code($t);
      return socket_write($this->users[$id]['socket'],$t,strlen($t));
    }
    function write($k,$t){//通过标示推送信息
      $t=$this->code($t);
      return socket_write($k,$t,strlen($t));
    }
    function eventoutput($type,$event){//事件回调
      call_user_func($this->event,$type,$event);
    }
    function log($t){//控制台输出
      if($this->log){
        $t=$t."\r\n";
        fwrite(STDOUT, iconv('utf-8','gbk//IGNORE',$t));
      }
    }
}


开源中国-程序员在线工具:Git代码托管 API文档大全(120+) JS在线编辑演示 二维码 更多»

发表评论 回到顶部 网友评论(19)

  • 1楼:洞悉 发表于 2013-06-18 17:01 回复此评论
    code uncode 函数不完整,大数据较大时报错 websocket分为 3 种情况,这个是数据最小的一种情况
    $len=socket_recv($sign,$buffer,2048,0); 这个也保证数据接收完整
    ……
  • 2楼:Xiaowanyi 发表于 2013-06-18 23:58 回复此评论
    天王盖地虎
  • 3楼:oxsicn 发表于 2013-06-19 09:45 回复此评论

    引用来自“优艾小陌”的评论

    天王盖地虎
    小鸡炖蘑菇
  • 4楼:崔林 发表于 2013-06-26 18:05 回复此评论
    麻烦能否,把经过测试成功的代码发布到这里??
  • 5楼:长枪未到,菊花先爆 发表于 2013-10-31 10:54 回复此评论

    引用来自“洞悉”的评论

    code uncode 函数不完整,大数据较大时报错 websocket分为 3 种情况,这个是数据最小的一种情况
    $len=socket_recv($sign,$buffer,2048,0); 这个也保证数据接收完整
    ……
    请问有没有websocket的中文文档,有的话给个链接,谢谢
  • 6楼:danhoo 发表于 2013-11-06 14:05 回复此评论
    测试成功,但是请问下可以双向通信吗?就是聊天那样。。求教
  • 7楼:沉默的幻想师 发表于 2014-08-27 21:01 回复此评论
    测试不成功呢 咋回事呢
  • 8楼:super梦想 发表于 2015-06-12 14:42 回复此评论
    为什么php ****/server.php  运行以后,会是打印server.php的内容呢???
  • 9楼:super梦想 发表于 2015-06-12 14:42 回复此评论

    引用来自“danhoo”的评论

    测试成功,但是请问下可以双向通信吗?就是聊天那样。。求教
    求教,我这里运行server.php以后,怎么是打印server.php的内容呢
  • 10楼:默默无闻 发表于 2015-09-24 21:31 回复此评论

    引用来自“danhoo”的评论

    测试成功,但是请问下可以双向通信吗?就是聊天那样。。求教

    引用来自“super梦想”的评论

    求教,我这里运行server.php以后,怎么是打印server.php的内容呢
    在PHP.ini中打开 short_tag 开关或者把代码中 < ? 改为 < ?php
  • 11楼:喵星人123 发表于 2015-11-10 14:54 回复此评论
    apache 不会默认支持 websocket 协议吗
  • 12楼:phping 发表于 2015-11-15 16:34 回复此评论
    确保能运行前提:
    1.修改文件中的ip地址为你要测试的服务器地址
    2.将server.php文件中的第一行改为<?php
    3.先在命令行中执行 php server.php
    4.在浏览器中输入index.html的路径,回车后,然后点页面上的 连接按钮确保连接成功。
  • 13楼:phping 发表于 2015-11-15 16:49 回复此评论
    针对以上补充:
    5:将 server.php中32行替换为:
    socket.send($('#text').val());
    6:我使用本地的jquery测试的。
    7:终端开始的日志输出一直是乱码(若你的没有乱码问题,略过),解决办法:将websocket.class.php中的187行的代码改为:
    fwrite(STDOUT, $t);

  • 14楼:Geek_Icebreaker 发表于 2016-07-11 12:11 回复此评论
    这个demo在手机上无法onopen啊
  • 15楼:congkuang 发表于 2016-07-22 11:59 回复此评论
    在IE中连接30秒后会自动断开,找不到原因。其它浏览器能正常连接。
  • 16楼:梦之刃 发表于 2016-08-15 17:57 回复此评论
    $len 为什么要小于7呢?
  • 17楼:wallance1 发表于 2016-11-29 15:44 回复此评论
    GoEasy推送可以简单快速解决你的问题,它是专注做web实时推送的,我们项目在线人数在2000左右,已经用GoEasy3个多月了,目前为止很稳定。服务支持也很好,你可以试试看。
    https://my.oschina.net/u/2544092/blog/749125
  • 18楼:_鹤轩 发表于 2017-07-31 17:53 回复此评论
    127.0.0.1 的本地如何搭建
  • 19楼:mrcooz 发表于 2017-08-14 14:53 回复此评论

    引用来自“_鹤轩”的评论

    127.0.0.1 的本地如何搭建
    按照IP改为自己的局域网IP即可 然后端口是8000 火狐上测试代码可行 chrome上挂了
开源从代码分享开始 分享代码
oxsicn的其它代码 全部(11)...