‘壹’ socketio 不是标准的websocket为什么java写的client端连不上
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[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]; }
if(preg_match("/\r\n(.*?)\$/",$req,$match)){ $data=$match[1]; }
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[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 encode($msg=""){
$frame = array();
$frame[0] = "81";
$msg .= ' is ok';
$len = strlen($msg);
$frame[1] = $len<16?"0".dechex($len):dechex($len);
$frame[2] = 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);
}
?>
‘贰’ python-socketio 文档翻译
教程： https://tutorialedge.net/python/python-socket-io-tutorial/
python-socketio 原文地址 ，在google浏览器中可以翻译为中文去使用。
首先要搞明白几个问题：
说明
1）第一种room是每一个单独的客户端都有的。（通过 session ID 可以找到）
2）第二种是应用程序自己创建的。
在下面这个方法中，如果省略掉room参数，将会自动发送给所有的连接了的客户端。
译文：
Python-socketio实现了一个Python Socket.IO 服务，这个服务可以单独运行也可以综合于一个web项目中。下面是一些它的特征：
什么是Socket.IO?
Socket.IO是一个基于事件的双向通讯的传输协议（一般是web浏览器），和一个服务端。原始的客户端和服务端组件实现是通过JavaScript写的。
入门指南
可以使用 pip 安装Socket.IO:
下面是一个使用 aiohttp 框架（只支持Python 3.5+）实现异步IO的 Socket.IO server 简单的例子：
下面是一个类似的例子，但是使用的Flask和Eventlet的例子，兼容Python2.7和3.3+：
客户端应用必须引入 socket.io-client 库（1.3.5版本以及以上，越高越好）。
每次客户端连接到服务器的连接事件处理程序调用sid(会话ID)分配给连接和WSGI环境字典。
每次客户端连接到服务端的 conenct 事件都是由sid(session ID)分配到连接和WSGI环境字典调用的。服务端可以检查身份认证或者其他的头部信息去决定是否这个客户端允许被连接。要想拒绝一个客户端的连接，这个处理器必须返回 False 。
当客户端发送发送一个事件给服务端，相应的事件处理器会被 sid 和这个信息调用，可以是单个或者多个参数。这个应用可以定义尽量多的如果被需要的可以被事件处理器关联的事件。一个事件可以通过一个名称简单定义。
当一个客户端连接中断了， disconnect 事件就被调用，允许应用去执行清理工作。
服务端
Socket.IO 服务端是 socketio.Server 类的实例，他们可以被一个WSGI适用应用程序使用 socketio.Middleware 去合并：
使用 socketio.Server.on() 方法来注册服务端的事件处理器：
对于异步服务端来说，事件处理器可以是常规方法，或者是协程：
聊天室
因为Socket.IO是一个双向的协议，服务端可以在任意时间发送消息给任意的连接到的客户端。为了让它方便去将客户端定位到组中，应用程序可以将客户端放入到聊天室中去，然后将消息定位到整个聊天室中。
当客户端第一次连接，他们是被分配到他们自己的聊天室中，这个聊天是是以session ID（sid 参数会传递给所有的事件处理器）命名的。应用可以通过 socketio.Server.enter_room() 和 socketio.Server.leave_room() 自由地去创建聊天室和管理客户端。客户端可以在尽量多的房间里，也可以根据需求尽量频繁地被拉入拉出聊天室。当他们的连接不在特别的时候，单独的聊天室将会分配给她它们，应用程序可以自由地增加和移除客户端从聊天室中，尽管它只要这样做就会失去定位独立客户端的能力。
socketio.Server.emit() 方法会获得一个事件名称，一个可能是 str ， bytes ， list ， dict 或者 tuple 类型的消息载体。当发送一个 tuple ，在其中的元素必须是上面的其他类型。元组中的元素将会被传递给客户端的回调函数为多个参数。定位一个个人客户端，客户端的 sid 将会被给一个聊天室（假设这个应用没有修改这些初始的聊天室）。定位所有的连接的客户端们，这个聊天室参数将会被触发。
通常在聊天室中当广播一个消息到一个用户组的时候，发送者是否接受他自己的消息是可选的。 soicketio.Server.emit() 方法提供了一个可选的 skip_sid 参数去指定一个想在广播中跳过的客户端。
Response
当一个客户端发送一个事件给服务端，它可以选择提供一个回调方法，当服务端返回一个响应的时候会被触发。服务端可以便捷地从相应的事件处理器返回它从而提供一个响应。
事件处理器可以返回一个单独的值，一个带多个值的元组。这个在客户端的回调函数将会调用这些返回的值。
Callbacks
回调
服务端可以请求一个响应通过发送一个事件给客户端。 socketio.Server.emit() 方法有一个可选的 callback 参数能够被设置为可回调的。当这个参数被传递之后，当客户端返回相应的时候，这个可回调的方法将会被请求。
当广播给多个客户端的时候使用回调函数是不被推荐的，因为回调方法将会被只执行一次。
Namespace
命名空间
Socket.IO 协议支持多个逻辑性连接，所有的多路复用都是在相同的物理连接上。客户端可以通过给每个连接指定不同的 namespace 从而开多个连接。一个命名空间是由 主机名+端口+路径名称构成的。比如，连接到 http://example.com:8000/chat 将会开一个连接到命名空间 /chat 。
由于分离的不同的session ID（ sid s），不同的事件处理器，不同的聊天室，每一个命名空间都是独立的。应用程序使用多个命名空间从而来区分命名空间，是非常重要的。可以参考 socketio.Server 类。
当 namespace 参数被触发了，比如设置为 None 或者 / ， 那么一个默认的命名空间将会被使用。
Class-Based Namespaces
作为一个基于装饰器的事件处理器的代替，这个属于一个命名空间事件处理器可以被创建为 socketio.Namesapce 的子类：
对于基于异步io的服务端，域名空间必须继承与 socketio.AsyncNamespace ， 也可以定义普通的方法或者协程作为事件处理器：
当使用基于类的命名空间的时候，任何被服务端接受的事件将会被分派到一个被事件名称命名的方法中作为方法名称（with the on_pfrefix ）。比如：事件 my_event 将会被一个名叫 on_my_event 的方法处理。
‘叁’ python socket库是自带的吗
是的，直接import
‘肆’ 想用Python写一个在线聊天系统，有什么模块能用来处理WebSocket吗
最终采用了Flask-Socketio
Flask 也有 socketio 相关扩展
tornado 支持 websocket
如果用 python3.4/3.5 的话，可以试一下 aiohttp
‘伍’ 话说socket.io 为何这么叼python 有类似玩意吗
python是最早实现web socket的语言之一，其下的大量框架都有不计其数的web socket的支持，也就是socketio的功能，其中，tornado提供了原生的支持，flask-socketio就是socketio的flask版（flask是python的web框架）。djanggo也有对应的框架，几乎可以说，常见的python的web框架全部实现了socketio的功能。说起websocket的支持，python说第二没人敢说第一。
‘陆’ 话说socket.io 为何这么叼python 有类似玩意吗
Socket.IO是一个可以让浏览器与服务器实现实时通信的类Websocket的抽象。Gevent-socket是Socketio协议的一个python实现。稿做
参考LearnBoost开发的Node.js的Socket.IO服务器端实现，现在已经有多种语言的Socket.IO server实现了。
这个项目的目的之一是实现一个可以运行在各种基于WSGI的web开发框架（例如 Pyramid, Pylons, Flask, web2py, Django...）之上简瞎的以gevent为基础的统一API。只需要大约3行代码就可以把它配置到你的框架里。【注意：】使用gevent-socket ，需要使键咐衡用gevent python WSGI服务器。
‘柒’ 如何使用python制作websocket服务器
之上的以gevent为基础的统一API.IO服务升派器端实现, web2py。只需要大约3行代睁闹码就可以把它配置到你的框架里。吵早贺Gevent-socket是Socketio协议的一个python实现.IO是一个可以