php websocket

php websocket项目开发，推荐使用：Workerman

本片内容使用Workerman实现了简单的及时聊天功能，具体代码如下：

<?php
// phpinfo();
header('Content-Type: text/html; charset=utf-8');require 'vendor/autoload.php';use Workerman\Worker;$sk=new Sock();//对创建的socket循环进行监听，处理数据
$sk->run();function array_remove($arr, $key){ if(!array_key_exists($key, $arr)){ return $arr; } $keys = array_keys($arr); $index = array_search($key, $keys); if($index !== FALSE){ array_splice($arr, $index, 1); } return $arr; } class Sock{public $sockets; //socket的连接池，即client连接进来的socket标志public $ws_worker;public function __construct(){// Create a Websocket server$this->ws_worker = new Worker("websocket://0.0.0.0:8889");// 4 processes$this->ws_worker->count = 4;// Emitted when new connection come$this->ws_worker->onConnect = function($connection){echo "New connection\n";echo 'id=' . $connection->id . '    ';$this->sockets[$connection->id] = array('client'=>$connection);echo 'count=' . count($this->sockets) . '    ';};// Emitted when data received$this->ws_worker->onMessage = function($connection, $data){// Send hello $dataecho "\n".$connection->id." -> req: ".$data;$jdata = json_decode($data,true);echo "\n op: ".$jdata['op'];if($jdata['op'] == 'login'){//{'op':'login','user':user}$cs = $this->sockets[$connection->id];$cs['user'] = $jdata['user'];$this->sockets[$connection->id] = $cs;$connection->send($jdata['user'].'登录成功'); return;}else{// {'op':'chat','from_user':user,'to_user':user,'msg':msg}$deal = false;if($jdata['op'] == 'chat'){foreach ($this->sockets as $key => $value) {if($value['user'] == $jdata['to_user']){$value['client']->send($jdata['msg']);$connection->send($data);$deal = true;}}if($deal == false){$connection->send($jdata['user'].'会员不存在');}}else{$connection->send('参数异常： ' . $data);                }    }};// Emitted when connection closed$this->ws_worker->onClose = function($connection){echo "Connection closed\n";$this->sockets = array_remove($this->sockets, $connection->id);};}public function run(){Worker::runAll();        }
}

<!DOCTYPE html>
<html>
<head><meta charset="UTF-8"><title></title><script src="jquery.js" type="text/javascript"></script></head>
<body><input type="text" id="input" placeholder="Message…" /><hr /><pre id="output"></pre><script>var user = '';var host   = 'ws://127.0.0.1:8889';var socket = null;var input  = document.getElementById('input');var output = document.getElementById('output');var print  = function (message) {var samp       = document.createElement('samp');samp.innerHTML = message + '\n';output.appendChild(samp);return;};user = window.prompt("欢迎？","请在此输入您的姓名。");input.addEventListener('keyup', function (evt) {if (13 === evt.keyCode) {var msg = input.value;if (!msg) {return;}try {socket.send(msg);input.value = '';input.focus();} catch (e) {console.log(e);}return;}});try {socket = new WebSocket(host);socket.onopen = function () {print('connection is opened');input.focus();socket.send('{"op":"login","user":"'+user+'"}');return;};socket.onmessage = function (msg) {print(msg.data);return;};socket.onclose = function () {print('connection is closed');return;};} catch (e) {console.log(e);}</script>
</body>
</html>

使用 php socket.php 启动服务端。

js端要发起json结构的数据，如下截图：

转载于:https://www.cnblogs.com/scott-j/p/8995940.html

php websocket相关推荐

mqtt+htttp+websocket
一.介绍 1.参考网址1:WebSocket协议:5分钟从入门到精通 2.参考网址2:WebSocket 教程(阮一峰) 二.应用 1.参考网址1:从 HTTP 到 MQTT:一个移动后端案例概述 2 ...
Java后端WebSocket的Tomcat实现
转自: http://blog.chenzuhuang.com/archive/28.html http://www.cnblogs.com/xdp-gacl/p/5193279.html 一.Web ...
Java Websocket实例【服务端与客户端实现全双工通讯】
Java Websocket实例[服务端与客户端实现全双工通讯] 现很多网站为了实现即时通讯,所用的技术都是轮询(polling).轮询是在特定的的时间间隔(如每1秒),由浏览器对服务器发出HTTP ...
物联网协议对比（HTTP、websocket、XMPP、COAP、MQTT和DDS协议）
目录 1.HTTP和websocket 2.XMPP 3.COAP 4.MQTT协议 5.DDS 对于物联网,最重要的是在互联网中设备与设备的通讯,现在物联网在internet通信中比较常见的通讯协议 ...
node.js创建WebSocket服务，并使用原生js ES6完成对WebSocket数据交互
注意,前情提示: 本代码基于<Node.js(nodejs)对本地JSON文件进行增.删.改.查操作(轻车熟路)> 传送门Node.js(nodejs)对本地JSON文件进行增.删.改.查 ...
使用CEfSharp之旅（7）CEFSharp 拦截 http 请求 websocket 内容
使用CEfSharp之旅(7)CEFSharp 拦截 http 请求 websocket 内容原文:使用CEfSharp之旅(7)CEFSharp 拦截 http 请求 websocket 内容版 ...
使用Node.js快速搭建WebSocket server
原文地址:http://my.oschina.net/yushulx/blog/309413 目录[-] 安装服务端客户端参考安装 ? 1 npm install ws 服务端 server. ...
python java web_Python 与 Java 使用 websocket 通信
WebSocket协议是基于TCP的一种新的网络协议.它实现了浏览器与服务器全双工(full-duplex)通信--允许服务器主动发送信息给客户端. Java服务端 import java.io.IO ...
Java项目:在线淘房系统(租房、购房)(java+SpringBoot+Redis+MySQL+Vue+SpringSecurity+JWT+ElasticSearch+WebSocket)
源码获取:博客首页 "资源" 里下载! 该系统有三个角色,分别是:普通用户.房屋中介.管理员.普通用户的功能:浏览房屋信息.预约看房.和中介聊天.申请成为中介等等.房屋中介的功能: ...
websocket心跳链接代码_WebSocket原理与实践(五)--心跳及重连机制
在使用websocket的过程中,有时候会遇到网络断开的情况,但是在网络断开的时候服务器端并没有触发onclose的事件.这样会有:服务器会继续向客户端发送多余的链接,并且这些数据还会丢失.所以就需要 ...

php websocket

php websocket相关推荐

最新文章

热门文章