php websocket即时通讯（如何用php实现websocket）

本文目录

• 如何用php实现websocket
• 可以在windows 运行的能与php结合使用的即时通讯技术是什么求大神指导！
• php怎么结合websocket实现网络聊天
• php 怎么使用websocket推送消息
• 如何使用GoEasy实现PHP与Websocket实时通信

如何用php实现websocket

html5自带有websocket，这是客户端的。
php可以使用swoole框架来实现websocket。
或则自己解析websocket协议，使用php自带的socket。

友情提示：在以上情况的时候，php是运行在cli模式下的，这样才能让程序常驻内存。

可以在windows 运行的能与php结合使用的即时通讯技术是什么求大神指导！

最简单的说，就是ajax定时刷新，比如间隔10秒。有新数据，就反馈到前台，没新数据就等待下一次刷新。
但是真正在应用中需要考虑到消息及时性、服务器压力等等。
可以用comet进行设计
node.js 、socket
反正当你真的要自己开发一个im系统应用到自己的项目中的话，是一个很大的工程

php怎么结合websocket实现网络聊天

php有可用的websocket库，不需要php-fpm。
目前比较成熟的有swoole（swoole.com），和workman（workman.net）
swoole是c写的php扩展， 效率比nodejs还要高，workman是纯php实现，两者都号称可以实现并发百万TCP连接。
给你个例子：
这个要通过cmd运行的 具体带的参数有点忘记了
《?php
error_reporting(E_ALL);
set_time_limit(0);
ob_implicit_flush();

//创建一个socket连接 设置参数 绑定 监听 并且返回
$master = WebSocket(“localhost“,12345);

//标示是否已经进行过握手了
$is_shaked = false;

//是否已经关闭
$is_closed = true;

//将socket变为一个可用的socket

while(true){
//如果是关闭状态并且是没有握手的话 则创建一个可用的socket（貌似第二个条件可以去除）
if($is_closed && !$is_shaked){
if(($sock = socket_accept($master)) 《 0){
echo “socket_accept() failed: reason: “ . socket_strerror($sock) . “\n“;
}

//将关闭状态修改为false
$is_closed = false;
}

//开始进行数据处理
process($sock);
}

//处理请求的函数
function process($socket){
//先从获取到全局变量
global $is_closed, $is_shaked;

//从socket中获取数据
$buffer = socket_read($socket,2048);

//如果buffer返回值为false并且已经握手的话 则断开连接
if(!$buffer && $is_shaked){
disconnect($socket);
}else{
//如果没有握手的话则握手 并且修改握手状态
if($is_shaked == false){
$return_str = dohandshake($buffer);
$is_shaked = true;
}else{
//如果已经握手的话则送入deal函数中进行相应处理
$data_str = decode($buffer); //解析出来的从前端送来的内容
console($data_str);
$return_str = encode(deal($socket, $data_str));
//$return_str = encode($data_str);
}

//将应该返回的字符串写入socket返回
socket_write($socket,$return_str,strlen($return_str));
}
}

function deal($socket, $msgObj){
$obj = json_decode($msgObj);
foreach($obj as $key=》$value){
if($key == ’close’){
disconnect($socket);
console(’close success’);
return ’close success’;
}else if($key == ’msg’){
console($value.“\n“);
return $value;
}
}
}

//获取头部信息
function getheaders($req){
$r=$h=$o=null;
if(preg_match(“/GET (.*) HTTP/“ ,$req,$match)){ $r=$match; }
if(preg_match(“/Host: (.*)\r\n/“ ,$req,$match)){ $h=$match; }
if(preg_match(“/Origin: (.*)\r\n/“,$req,$match)){ $o=$match; }
if(preg_match(“/Sec-WebSocket-Key: (.*)\r\n/“,$req,$match)){ $key=$match; }
if(preg_match(“/\r\n(.*?)\$/“,$req,$match)){ $data=$match; }
return array($r,$h,$o,$key,$data);
}

function WebSocket($address,$port){
$master=socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die(“socket_create() failed“);
socket_set_option($master, SOL_SOCKET, SO_REUSEADDR, 1) or die(“socket_option() failed“);
socket_bind($master, $address, $port) or die(“socket_bind() failed“);
socket_listen($master,20) or die(“socket_listen() failed“);
echo “Server Started : “.date(’Y-m-d H:i:s’).“\n“;
echo “Master socket : “.$master.“\n“;
echo “Listening on : “.$address.“ port “.$port.“\n\n“;
return $master;
}

function dohandshake($buffer){
list($resource,$host,$origin,$key,$data) = getheaders($buffer);
echo “resource is $resource\n“;
echo “origin is $origin\n“;
echo “host is $host\n“;
echo “key is $key\n\n“;

$response_key = base64_encode(sha1($key.’258EAFA5-E914-47DA-95CA-C5AB0DC85B11’, true));

$return_str = “HTTP/1.1 101 Switching Protocols\r\n“.
“Upgrade: websocket\r\n“.
“Connection: Upgrade\r\n“.
“Sec-WebSocket-Accept: $response_key\r\n\r\n“;
return $return_str;
}

function console($msg){
$msg = transToGBK($msg);
echo “$msg\n“;
return $msg;
}

function decode($msg=““) {
$mask = array();
$data = ““;
$msg = unpack(“H*“,$msg);

$head = substr($msg,0,2);

if (hexdec($head{1}) === 8){
$data = false;
} else if (hexdec($head{1}) === 1){
$mask = hexdec(substr($msg,4,2));
$mask = hexdec(substr($msg,6,2));
$mask = hexdec(substr($msg,8,2));
$mask = hexdec(substr($msg,10,2));

$s = 12;
$e = strlen($msg)-2;
$n = 0;
for ($i= $s; $i《= $e; $i+= 2){
$data .= chr($mask[$n%4]^hexdec(substr($msg,$i,2)));
$n++;
}
}

return $data;
}

function encode($msg=““){
$frame = array();
$frame = “81“;
$msg .= ’ is ok’;
$len = strlen($msg);
$frame = $len《16?“0“.dechex($len):dechex($len);
$frame = ord_hex($msg);
$data = implode(““,$frame);
return pack(“H*“, $data);
}

function transToGBK($s){//UTF8-》GBK
//echo $s;
return iconv(“UTF-8“, “GBK“, $s);
return $s;
}

function ord_hex($data){
$msg = ““;
$l = strlen($data);

for ($i=0; $i《$l; $i++){
//ord是返回字符串第一个字符的ascii值
//dechex把十进制转换为十六进制
$msg .= dechex(ord($data{$i}));
}

return $msg;
}

function disconnect($socket){
global $is_shaked, $is_closed;
$is_shaked = false;
$is_closed = true;
socket_close($socket);
}
?》

php 怎么使用websocket推送消息

我使用的工具是基于wokman的web-msg-sender是一款web长连接推送框架，采用PHPSocket.IO开发，基于WebSocket长连接通讯，如果浏览器不支持WebSocket则自动转用comet推送。 通过后台推送消息，消息可以即时推送到客户端，非轮询，实时性非常好，性能很高。 

下载和demo地址

如何使用GoEasy实现PHP与Websocket实时通信

如何使用GoEasy实现PHP与Websocket实时通信
实现步骤如下：
1. 获取GoEasy appkey.
在goeasy官网上注册一个账号，并新建一个app. APP创建好后系统会为该app自动生成两个key, 一个既可以用来接收又可以用来推送 (supper key)，另一个只可以用来接收(subscriber key).
2. 客户端订阅一个channel.
a. 在客户端引入goeasy.js， js地址：
需要注意的是，不能将goeasy.js下载到本地，因为goeasy会根据不同浏览器来提供不同的js. 官网上也有相应说明。
b. 订阅代码
var goEasy = new GoEasy({appkey: ’subscriber key’});//这里我用的是subscriber key,因为在我的客户端我不需要推送任何消息，所以没有必要使用supper key
goEasy. subscribe({
channel: ’csdnNotification’,
onMessage: function(message){
alert(’Meessage received:’+message.content);//接收到推送的消息
}
});
复制代码
3. 前台推送及后台推送
3.1. 前台往相同channel上推送
在引入了goeasy.js的页面，直接调用goEasy. publish(’csdnNotification’, ’您的好友222已上线’); 用法与订阅类似。
3.2. 后台往相同channel上推送. 用GoEasy提供的restful API实现
API url:
方式: Post
参数列表：
channel: ’csdnNotification’ //与订阅的channel必须一致，否则客户端将收不到消息。因此我们也可以根据channel来控制哪些客户端可以接收。
appkey: ’supper key’ //这里必须使用supper key
content: ’blabla…..’ //要推送的内容