websocket的php测试demo

<?php
class WS {
    var $master;
    var $sockets = array();
    var $debug = false;
    var $handshake = false;

    function __construct($address, $port){
        $this->master=socket_create(AF_INET, SOCK_STREAM, SOL_TCP)     or die("socket_create() failed");
        socket_set_option($this->master, SOL_SOCKET, SO_REUSEADDR, 1)  or die("socket_option() failed");
        socket_bind($this->master, $address, $port)                    or die("socket_bind() failed");
        socket_listen($this->master,20)                                or die("socket_listen() failed");

        $this->sockets[] = $this->master;
        $this->say("Server Started : ".date(‘Y-m-d H:i:s‘));
        $this->say("Listening on   : ".$address." port ".$port);
        $this->say("Master socket  : ".$this->master."\n");

        while(true){
            $socketArr = $this->sockets;
            $write = NULL;
            $except = NULL;
            socket_select($socketArr, $write, $except, NULL);  //自动选择来消息的socket 如果是握手 自动选择主机
            foreach ($socketArr as $socket){
                if ($socket == $this->master){  //主机
                    $client = socket_accept($this->master);
                    if ($client < 0){
                        $this->log("socket_accept() failed");
                        continue;
                    } else{
                        $this->connect($client);
                    }
                } else {
                    $this->log("^^^^");
                    $bytes = @socket_recv($socket,$buffer,2048,0);
                    $this->log("^^^^");
                    if ($bytes == 0){
                        $this->disConnect($socket);
                    }
                    else{
                        if (!$this->handshake){
                            $this->doHandShake($socket, $buffer);
                        }
                        else{
                            $buffer = $this->decode($buffer);
                            $this->send($socket, $buffer);
                        }
                    }
                }
            }
        }
    }

    function send($client, $msg){
        $this->log("> " . $msg);
        $msg = $this->frame($msg);
        socket_write($client, $msg, strlen($msg));
        $this->log("! " . strlen($msg));
    }
    function connect($socket){
        array_push($this->sockets, $socket);
        $this->say("\n" . $socket . " CONNECTED!");
        $this->say(date("Y-n-d H:i:s"));
    }
    function disConnect($socket){
        $index = array_search($socket, $this->sockets);
        socket_close($socket);
        $this->say($socket . " DISCONNECTED!");
        if ($index >= 0){
            array_splice($this->sockets, $index, 1);
        }
    }
    function doHandShake($socket, $buffer){
        $this->log("\nRequesting handshake...");
        $this->log($buffer);
        list($resource, $host, $origin, $key) = $this->getHeaders($buffer);
        $this->log("Handshaking...");
        $upgrade  = "HTTP/1.1 101 Switching Protocol\r\n" .
                    "Upgrade: websocket\r\n" .
                    "Connection: Upgrade\r\n" .
                    "Sec-WebSocket-Accept: " . $this->calcKey($key) . "\r\n\r\n";  //必须以两个回车结尾
        $this->log($upgrade);
        $sent = socket_write($socket, $upgrade, strlen($upgrade));
        $this->handshake=true;
        $this->log("Done handshaking...");
        return true;
    }

    function getHeaders($req){
        $r = $h = $o = $key = null;
        if (preg_match("/GET (.*) HTTP/"              ,$req,$match)) { $r = $match[1]; }
        if (preg_match("/Host: (.*)\r\n/"             ,$req,$match)) { $h = $match[1]; }
        if (preg_match("/Origin: (.*)\r\n/"           ,$req,$match)) { $o = $match[1]; }
        if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/",$req,$match)) { $key = $match[1]; }
        return array($r, $h, $o, $key);
    }

    function calcKey($key){
        //基于websocket version 13
        $accept = base64_encode(sha1($key . ‘258EAFA5-E914-47DA-95CA-C5AB0DC85B11‘, true));
        return $accept;
    }

    function decode($buffer) {
        $len = $masks = $data = $decoded = null;
        $len = ord($buffer[1]) & 127;

        if ($len === 126) {
            $masks = substr($buffer, 4, 4);
            $data = substr($buffer, 8);
        }
        else if ($len === 127) {
            $masks = substr($buffer, 10, 4);
            $data = substr($buffer, 14);
        }
        else {
            $masks = substr($buffer, 2, 4);
            $data = substr($buffer, 6);
        }
        for ($index = 0; $index < strlen($data); $index++) {
            $decoded .= $data[$index] ^ $masks[$index % 4];
        }
        return $decoded;
    }

    function frame($s){
        $a = str_split($s, 125);
        if (count($a) == 1){
            return "\x81" . chr(strlen($a[0])) . $a[0];
        }
        $ns = "";
        foreach ($a as $o){
            $ns .= "\x81" . chr(strlen($o)) . $o;
        }
        return $ns;
    }

    function say($msg = ""){
        echo $msg . "\n";
    }
    function log($msg = ""){
        if ($this->debug){
            echo $msg . "\n";
        }
    }
}

new WS(‘localhost‘, 4000);
<script type="text/javascript">
var ws = new WebSocket("ws://localhost:4000");
ws.onopen = function(){
    console.log("握手成功");
}
ws.onmessage = function(e){
    console.log("message:" + e.data);
}
ws.onerror = function(){
    console.log("error");
}
</script>

demo2:

<!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="http://apps.bdimg.com/libs/jquery/2.1.4/jquery.min.js"></script>
<script>
    function link(){
        var url=‘ws://devapp.yaolan.com: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>
<?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));
        }
    }
}
<?
include ‘websocket.class.php‘;

$config=array(
    ‘address‘=>‘devapp.yaolan.com‘,
    ‘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);
}
?>
时间： 2024-10-09 09:25:13

websocket的php测试demo的相关文章

Spring WebSocket简单入门测试Demo(网页及时聊天)

说明 本demo运行的环境是:ssm框架 + tomcat8 + jdk7+,由于只是demo.很简陋.能运行调式通过就行,再在此基础上进行扩展研究. 在网上看了很多列子.对于没有接触过websocket的人来说.真的是看不懂.本文列子应该算是比较简单的. Spring WebSocket API的核心接口是WebSocketHandler.我把它叫做消息处理中心. 其他的详细解说可以参考别人的博客 <servlet-mapping> <servlet-name>springmvc

Wookmark-jQuery-master 瀑布流插件使用介绍，含个人测试DEMO

要求 必备知识 本文要求基本了解 Html/CSS,  JavaScript/JQuery. 开发环境 Dreamweaver CS6 / Chrome浏览器 演示地址 演示地址 资料下载 测试预览截图(抬抬你的鼠标就可以看到演示地址哦): 程序核心代码看这里: $(function(){ function show(){ var colors=["#BA4A3A","#5BB5D6","#8EA83B","#EE5C92",

单独编译和使用webrtc音频降噪模块(附源码+测试demo)

webrtc的音频处理模块分为降噪ns,回音消除aec,回声控制acem,音频增益agc,静音检测部分.另外webrtc已经封装好了一套音频处理模块APM,如果不是有特殊必要,使用者如果要用到回声消除,音频增益等较为复杂的模块时,最好使用全部的音频处理模块二不要单独编译其中一部分以免浪费宝贵的时间. 但是音频降噪部分较为简单,用起来也就几个函数,除了需要传入的音频数据以外,需要调整的参数也就是音频采样率和降噪等级.另外这部分代码采用纯C语言语法编写,可以跨平台编译.整个算法也不算特别复杂,运行起

unity游戏开发之自定义事件测试demo

上文中写了unity游戏开发自定义消息事件点击打开链接 下面是测试demo 第一,打卡unity,新建一个场景,然后新建一个空的游戏对象,如图中的EventObj 第二步,测试代码EventTest.as,直接拖拽给上面的空游戏对象EentObj 测试代码如下: using UnityEngine; using System.Collections; public class EventTest : MonoBehaviour { // Use this for initialization v

安卓自动化测试：Robotium（一）测试demo

1.下载Robotium打开: http://code.google.com/p/robotium/下载:robotium-solo-3.4.1.jar (写测试用例时需要依赖此包)2.需要把APK重新签名,因为robotium要求被测应用和测试代码要有一致的签名, 所以我们需要把下载到的apk,通过re-sign.jar来产生debug key的apk,这个重新生成的apk就会跟测试项目签名一致了.下载完后,需要配置ANDROID_HOME,就是安卓SDK的位置,然后把APK拉到图标上,就会自

webSocket ws协议测试

最近公司做了个直播的项目,需要用到Websocket进行通信,因而需要对socket最大连接数及稳定性进行测试.当初得到这一需求的时候,唯一想到的就是jmeter,从百度下载相应的socket依赖jar包,开始研究(毕竟第一次做这方面的测试),担心单台压力源不够用,又整了个分布式,不过最终发现Jmeter并不适合测试Socket的最大连接数,于是调整了思路,寻找其他方法,功夫不费有心人,最后发下了一款不错的socket测试小工具(点击下载)是一个.exe文件,使用该工具可以很容易的实现socke

使用jmeter对websocket进行压力测试

测试工具我使用的是JMeter,版本为2.11.这个是同事拷贝给我的绿色版本.只要有Java环境就可以运行(下载地址:apache-jmeter-2.11).点击bin目录下的jmeter.bat就可以运行了.我这个版本本身是不支持websocket测试的,于是需要下载一个插件叫做JMeterWebSocketSampler-1.0.2-SNAPSHOT.jar,这个插件需要下载6个依赖包,如下图所示: 在插件安装好了后,就可以使用jmeter来模拟socket.io的通信了.首先打开chrom

软件测试--测试Demo

视频地址(第二课时):https://pan.baidu.com/s/1gfLVC2n 软件安装好了! 软件默认的浏览器是火狐. 如果需要IE,chrome,都在前一篇的安装包里有. 测试结果 视频里讲的比较详细的!这里查找用了一些Robot Framework的 快捷键! 重命名-->F2 搜索关键字-->F5 执行用例-->F8 创建新工程-->ctrl+n 创建新测试套-->ctrl+shift+f 创建新用例-->ctrl+shift+t 创建新关键字-->

基本spring测试框架的测试demo

以下是user 控制器的测试实例 import static org.junit.Assert.*; import java.util.ArrayList; import java.util.List; import javassist.expr.NewArray; import org.hamcrest.Matchers; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; impor