首页 / PHP / PHP实现websocket通信的方法示例

PHP实现websocket通信的方法示例

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了PHP实现websocket通信的方法示例，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6810字，纯文字阅读大概需要10分钟。

内容图文

本文实例讲述了PHP实现websocket通信的方法。分享给大家供大家参考，具体如下：

执行方法:

首先先修改server.php与index.html的ip
通过命令行执行 [php路径]\php.exe "[文件路径]\server.php"
然后通过浏览器打开index.html

server.php

<?php
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);
}
?>

index.html

<!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 src="http://libs.baidu.com/jquery/2.0.0/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>

websocket.class.php

<?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)); } } }

更多关于PHP相关内容感兴趣的读者可查看本站专题：《php socket用法总结》、《php字符串(string)用法总结》、《PHP数学运算技巧总结》、《php面向对象程序设计入门教程》、《PHP数组(Array)操作技巧大全》、《PHP数据结构与算法教程》、《php程序设计算法总结》及《PHP网络编程技巧总结》

希望本文所述对大家PHP程序设计有所帮助。

内容总结

以上是互联网集市为您收集整理的PHP实现websocket通信的方法示例全部内容，希望文章能够帮你解决PHP实现websocket通信的方法示例所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/273753.html

来源：【匿名】

【上一篇】php代码调试利器firephp安装与使用方法分析【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【PHP实现websocket通信的方法示例】教程文章相关的互联网学习教程文章

PHP基于websocket的前台及后台实时推送【代码】

PHP websocket实时消息推送实现步骤如下：1. 获取GoEasy appkey.在goeasy官网上注册一个账号，并新建一个app. APP创建好后系统会为该app自动生成两个key, 一个既可以用来接收又可以用来推送 (supper key)，另一个只可以用来接收(subscriber key).2. 客户端订阅一个channel.a. 在客户端引入goeasy.js， js地址：http://cdn.goeasy.io/goeasy.js需要注意的是，不能将goeasy.js下载到本地，因为goeasy会根据不同...

PHP基于websocket实时通信的实现—GoEasy【代码】【图】

PHP websocket实时消息推送实现步骤如下： 1. 获取 GoEasy appkey. 在 goeasy 官网上注册一个账号，并新建一个 app. APP 创建好后系统会为该 app 自动生成两个 key, 一个既可以用来接收又可以用来推送 (supper key)，另一个只可以用来接收(subscriber key). 2. 客户端订阅一个 channel. a. 在客户端引入 goeasy.js ， js 地址： http://cdn.goeasy.io/goeasy.js需要注意的是，不能将 goeasy.js 下载到本地，因为 goeasy 会根据不同...

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_bin...

如何基于Hyperf实现RabbitMQ+WebSocket消息推送【代码】

介绍基于 Hyperf+ WebSocket +RabbitMQ 实现的一个简单大屏幕的消息推送。思路利用 WebSocket 协议让客户端和服务器端保持有状态的长链接，保存链接上来的客户端 id。订阅发布者发布的消息针对已保存的客户端 id 进行广播消息。WebSocket 服务composer require hyperf/websocket-server配置文件 [config/autoload/server.php]<?php return [mode => SWOOLE_PROCESS,servers => [[name => http,type => Server::SERVER_HTTP,host =>...

[PHP] php作为websocket的客户端实时读取推送日志文件【代码】【图】

首先要使用composer来下载一个第三方扩展就可以实现php的websocket客户端,直接在当前目录生成下composer.json文件就可以了composer require textalk/websocketrequire(vendor/autoload.php); use WebSocket\Client; $client = new Client("ws://echo.websocket.org/"); $client->send("Hello WebSocket.org!"); echo $client->receive();配合php的读取文件操作,只读取最新的追加的内容,下面代码为读取日志的客户端 , 发送给10.xx.2...

PHPHTML5websocket怎么初始化，老是失败

PHP HTML5 websocket如何初始化，老是失败下载的demo都有问题，我的实现大体是这样的首先是服务端 server.phphttp://code.google.com/p/phpwebsocket/source/browse/trunk/%20phpwebsocket/server.php客户端的client.htmlhttp://code.google.com/p/phpwebsocket/source/browse/trunk/%20phpwebsocket/client.html先运行了服务端进入等待，再运行客户端client:var host = "ws://localhost:12345/websocket/server.php";//这个路径是...

php+html5基于websocket实现聊天室的方法，html5websocket_PHP教程

php+html5基于websocket实现聊天室的方法，html5websocket本文实例讲述了php+html5基于websocket实现聊天室的方法。分享给大家供大家参考。具体如下： html5的websocket 实现了双向通信，折腾了几天弄了个聊天室，分享给大家 <?php error_reporting(E_ALL); ob_implicit_flush(); $sk=new Sock(127.0.0.1,8000); $sk->run(); class Sock{public $sockets;public $users;public $master;public function __construct($address, $por...

php结合html5的websocket通讯的使用方法

本篇文章主要介绍php结合html5的websocket通讯的使用方法，感兴趣的朋友参考下，希望对大家有所帮助。本文实例讲述了php+html5基于websocket实现聊天室的方法，具体如下：html5的websocket 实现了双向通信，折腾了几天弄了个聊天室，分享给大家<?php error_reporting(E_ALL); ob_implicit_flush(); $sk=new Sock(127.0.0.1,8000); $sk->run(); class Sock{public $sockets;public $users;public $master;public function __constru...

html5-本质就是websocket的客户端，phpWebsocket怎么接收数据

class WebsocketClient {private $_Socket = null;public function __construct($host, $port){$this->_connect($host, $port);}public function __destruct(){$this->_disconnect();}public function sendData($data){// send actual data:return fwrite($this->_Socket, $this->encode($data)) or die('Error:' . $errno . ':' . $errstr);$wsData = fread($this->_Socket, 2000);$retData = trim($wsData, chr(0) . chr(255));r...

php – 多个HTML5 WebSocket连接【代码】

是否可以连接到多个html5 websocket连接？因为我想有一个websocket连接用于读取和其他websocket连接用于写入套接字.我想在不同的连接ID的同一时间点打开. 例如：$(document).ready(function () {conn = {}, window.WebSocket = window.WebSocket || window.MozWebSocket; connection1(); });function connection1() {// uses global 'conn' object if (conn.readyState === undefined || conn.readyState > 1) {conn1 = new We...

php+html5基于websocket实现聊天室的方法_php技巧

本文实例讲述了php+html5基于websocket实现聊天室的方法。分享给大家供大家参考。具体如下： html5的websocket 实现了双向通信，折腾了几天弄了个聊天室，分享给大家 <?php error_reporting(E_ALL); ob_implicit_flush(); $sk=new Sock(127.0.0.1,8000); $sk->run(); class Sock{public $sockets;public $users;public $master;public function __construct($address, $port){$this->master=$this->WebSocket($address, $port);$th...

PHPHTML5websocket如何初始化，老是失败

下载的demo都有问题，我的实现大体是这样的首先是服务端 server.php http://code.google.com/p/phpwebsocket/source/browse/trunk/%20phpwebsocket/server.php 客户端的client.html http://code.google.com/p/phpwebsocket/source/browse/trunk/%20phpwebsocket/client.html 先运行了服务端进入等待，再运行客户端client: var host = "ws://localhost:12345/websocket/server.php";//这个路径是文件所在位置,不知...

php篇之细说websocket【代码】【图】

下面我画了一个图演示 client 和 server 之间建立 websocket 连接时握手部分，这个部分在 node 中可以十分轻松的完成，因为 node 提供的 net 模块已经对 socket 套接字做了封装处理，开发者使用的时候只需要考虑数据的交互而不用处理连接的建立。而 php 没有，从 socket 的连接、建立、绑定、监听等，这些都需要我们自己去操作，所以有必要拿出来再说一说。 +--------+ 1.发送Sec-WebSocket-Key +---------+| ...

php如何实现websocket【代码】【图】

php如何实现websocket首先在php代码中创建socket服务并监听端口信息；//传相应的IP与端口进行创建socket操作 function WebSocket($address,$port){$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);//1表示接受所有的数据包socket_bind($server, $address, $port);socket_listen($server);return $server; }然后设计一个循环挂起websocket通道，进行数据的接收、...

用laravel+Swoole实现websocket主动消息推送【代码】【图】

近来有个需求：想实现一个可以主动触发消息推送的功能，这个可以实现向模板消息那个，给予所有成员发送自定义消息，而不需要通过客户端发送消息，服务端上message中监听传送的消息进行做相对于的业务逻辑。主动消息推送实现平常我们采用 swoole 来写 WebSocket 服务可能最多的用到的是open,message,close这三个监听状态，但是万万没有看下下面的onRequest回调的使用，没错，解决这次主动消息推送的就是需要用onRequest回调。官方文...

首页 / PHP / PHP实现websocket通信的方法示例

PHP实现websocket通信的方法示例

内容导读

内容图文

内容总结

内容备注

内容手机端

【PHP实现websocket通信的方法示例】教程文章相关的互联网学习教程文章

PHP基于websocket的前台及后台实时推送【代码】

PHP基于websocket实时通信的实现—GoEasy【代码】【图】

websocket的php测试demo【代码】

如何基于Hyperf实现RabbitMQ+WebSocket消息推送【代码】

[PHP] php作为websocket的客户端实时读取推送日志文件【代码】【图】

PHPHTML5websocket怎么初始化，老是失败

php+html5基于websocket实现聊天室的方法，html5websocket_PHP教程

php结合html5的websocket通讯的使用方法

html5-本质就是websocket的客户端，phpWebsocket怎么接收数据

php – 多个HTML5 WebSocket连接【代码】

php+html5基于websocket实现聊天室的方法_php技巧

PHPHTML5websocket如何初始化，老是失败

php篇之细说websocket【代码】【图】

php如何实现websocket【代码】【图】

用laravel+Swoole实现websocket主动消息推送【代码】【图】

WEBSOCKET - 相关标签

PHP - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程