文档章节

php长连接,奏是这么简单

呵大官人
 呵大官人
发布于 2015/06/09 17:13
字数 1449
阅读 8808
收藏 364
点赞 44
评论 49

说到长链接大家肯定不陌生,就是复用一个链接持续不断的进行数据交互,它不像那些一夜情似的服务,需要频繁的打开和关闭链接,效率低的同时还增加了业务的复杂度。在裆下很多互联网业务场景都需要长连接的支持,比如:游戏、聊天、信息推送等等等,今天我们就一步一步来揭秘php长连接的玩法。我相信任何一项技术的实施都是因为业务场景的需要,所以这次我们还拿聊天室说事儿。

0x00 初试牛刀

记得以前用php写聊天室还是用polling的方式,毫无疑问,一提到polling,肯定会有人说long polling,没错!long polling也很不错,但在nginx+fpm上面玩这个多少有些费劲,毕竟一个请求需要占一个php进程(就算是用apache+php_mod,也需要一个请求一个线程),所以要是几个人随便玩玩还行,一旦放到线上人多起来,这基本就废了。所以还是采用polling的方式,这样不会阻塞进程,并且一个请求能立即得到响应,但是带来的新问题是需要不停的向服务器发送请求,而且随着间隔的时间越大导致消息延迟就越大。

0x01 华丽变身

在经历了上面那种一秒一小卡,三秒一大卡的场面!再也看不下去了,于是决定变身为真正的男人,哦不对,应该是真正的长连接。去他妈的polling, 去他妈的long polling,去他妈的webserver,统统靠边站,让flash socket(或者说websocket)来统治这个世界!开始了真正意义上的长连接之旅。要玩长连接总是少不了跟socket打交道吧,作为世界上最好的语言(没有之一),socket的封装自然是少不了滴。抄起socket_***就开干,于是就有了下面这一托代码,长连接是吧?延迟是吧?socket是吧?汤药费是吧?so easy....

$sfd = socket_create(AF_INET, SOCK_STREAM, 0);
socket_bind($sfd, "0.0.0.0", 1234);
socket_listen($sfd, 511);
socket_set_option($sfd, SOL_SOCKET, SO_REUSEADDR, 1);
socket_set_nonblock($sfd);

$rfds = array($sfd);
$wfds = array();
do{
	$rs = $rfds;
	$ws = $wfds;
	$es = array();
	$ret = socket_select($rs, $ws, $es, 3);
	
	//read event
	foreach($rs as $fd){
		if($fd == $sfd){
			$cfd = socket_accept($sfd);
			socket_set_nonblock($cfd);
			$rfds[] = $cfd;
			echo "new client coming, fd=$cfd\n";
		}else{
			$msg = socket_read($fd, 1024);
			if($msg <= 0){
				//close
			}else{
				//recv msg
				echo "on message, fd=$fd data=$msg\n";
			}
		}
	}
	
	//write event
	foreach($ws as $fd){
		socket_write($fd, ........);
	}
	
}while(true);

0x02 登峰造极

从玩socket的那天起,google就轻言细语的跟我说,高并发下的select不要用啊,效率底啊,win要用iocp啊, linux要用epoll啊,blablablabla...哦!好吧,既然google都这么说了,我也不能跟他老人家较真不是,又一次决定(为什么要说又呢?)要听google话,把epoll搞起来,可总不能自己写啊?像我这么懒的人还是整个扩展好了,libevent走你!经过疯狂的编(co)码(py),神作终于出山,具体能有多高效,能撑多少并发,不造,反正没用select了,我奏是屌!

$sfd = stream_socket_server ('tcp://0.0.0.0:1234', $errno, $errstr);
stream_set_blocking($sfd, 0);
$base = event_base_new();
$event = event_new();
event_set($event, $sfd, EV_READ | EV_PERSIST, 'ev_accept', $base);
event_base_set($event, $base);
event_add($event);
event_base_loop($base);

function ev_accept($socket, $flag, $base)
{
	$connection = stream_socket_accept($socket);
	stream_set_blocking($connection, 0);

	$buffer = event_buffer_new($connection, 'ev_read', NULL, 'ev_error',  $connection);     
	event_buffer_base_set($buffer, $base);
	event_buffer_timeout_set($buffer, 30, 30);
	event_buffer_watermark_set($buffer, EV_READ, 0, 0xffffff);
	event_buffer_priority_set($buffer, 10);
	event_buffer_enable($buffer, EV_READ | EV_PERSIST);
}

function ev_error($buffer, $error, $connection)
{
	event_buffer_disable($buffer, EV_READ | EV_WRITE);                 
	event_buffer_free($buffer);                 
	fclose($connection);                 
}

function ev_read($buffer, $connection)
{
	$read = event_buffer_read($buffer, 256);
	//do something....
}

0x03 绝处逢生

随着人数的增长,并发的提升,单个进程已经满足不了需求了,田伯光的故事告诉我们,单挑是斗不过群P的,咋整?俗话说,大事化小,小事化,停!!别化了,再化就没了。拆吧,把单进程拆成多进程,可是拆完之后又面临新的问题,进程间通信、负载均衡、session唯一等。既然已经提出这样的问题,肯定是有解决方案,现成的就有扩展和库来解决这个事,比如:swoole,workerman等?相比之下swoole更屌一些,性、功能,呃!好像这样简写不太雅观,好吧,性能和功能更屌一些(桶哥,请原谅我的无聊~)。。。。等一下!!!但是,我们在使用php来开发web的时候,也没有使用webserver相关的库来做开发对不对?咱只是简单的echo而已。这些繁杂的事都交给了nginx或者是apache,是他们义无反顾的顶在前面,让我们可以专心写逻辑。写web我们只需要简单的配置nginx和fpm就好了,那写socket服务呢?我们为什么不能像nginx+fpm一样简单配置就好了呢??当然能,必须能。。。。。看这个剧情怕是广告要来了。。。

0x04 出其不意

写socket服务不比写web高级,都是打码,都是完成需求,通信那层都是固定的,只不过一个由nginx完成,另一个由自己完成。。可是现在不需要自己完成了,类似nginx+fpm的方案,fooking+fpm=php长连接,gateway用于承载连接,router用于转发消息,进程间通信?负载均衡?session唯一?so easy..

$sid = $_SERVER['SESSIONID'];//这是sessionid
$data = file_get_contents("php://input");//这样就能拿到请求内容了

//想要返回消息只需要两步
header('Content-Length: 11');//返回给客户端字节数
echo "hello world";

//想要给别的用户发消息
include 'api.php';
$router = new RouterClient('router host', 'router port');
$router->sendMsg(用户sessionid, "fuck you");

//想要给所有人要消息
$router->sendAllMsg("fuck all");

//想给指定组发消息(类似redis的pub/sub)
$router->publish("channel name", "fuck all");


项目地址: http://git.oschina.net/scgywx/fooking

文档地址(不定期更新):http://my.oschina.net/scgywx/blog/465186


© 著作权归作者所有

共有 人打赏支持
呵大官人

呵大官人

粉丝 118
博文 17
码字总数 15799
作品 1
普陀
加载中

评论(49)

m
miaomiaogong1
GoEasy推送兼顾了websocket和polling两种连接方式,支持多版本浏览器包括低版本IE浏览器,值得一试;官网: https://goeasy.io/
Super_磊
Super_磊
这演示真醉了fuck all
落舞者
落舞者
非常好
湖心亭看雪
湖心亭看雪
膜拜大神:heart_eyes:
呵大官人
呵大官人

引用来自“左手食指末节离断伤”的评论

楼主好文采,虽然我现在的水平还不能理解文章的内容,但已经收藏。
其实很简单,用写web的方式来写长连接服务!
于浅
于浅
...看不懂
OSC老司机
OSC老司机
楼主好文采,虽然我现在的水平还不能理解文章的内容,但已经收藏。
mickelfeng
mickelfeng
不错。哈哈
蒋维
蒋维

引用来自“小黑001”的评论

fuck all

include yourself
蒋维
蒋维

引用来自“hunanjun000”的评论

吊炸天

对啊
OSChina 开源周刊 38 期 —— 推荐 10 个 ReactJS 入门资源

每周技术抢先看,总有你想要的! 前端开发 【翻译】10 个超棒的 jQuery 视频插件 【翻译】使用 NativeScript 基于 JavaScript 构建原生应用 【翻译】推荐 10 个 ReactJS 入门资源 【软件】N...

OSC编辑部
2015/06/13
2.8K
3
PHP TCP长连接扩展--foolsock

foolsock 是为了实现 RPC 通信中 TCP 长连接而开发的 PHP 扩展 简介 PHP 很多项目随着业务规模的增长(尤其是终端众多的情况下)逐渐向服务化演变,常见的一种架构模型是将相对独立或者比较耗时...

盘古大叔
2015/08/28
1K
0
php7高性能网络通信库appnet

appnet介绍 appnet是一个基于linux epoll的多线程的高性能异步网络库,目标是用php7+appnet快速构建高性能的长连接服务器。使其可广泛用于聊天系统,游戏服务器,消息通知服务器等实时通信场...

appnet
2016/01/28
102
0
分析:PHP长连接的硬伤

上篇博文《PHP的CURL报错的排查记录:短连接的成本真的很高啊》,我提到PHP长连接有个硬伤,那么硬伤到底在哪里呢? 我们写一个简易的memcache客户端来分析下这个问题,数据库等扩展的长连接...

anoty
2016/12/27
70
0
PHP socket服务端 如何与JAVA客户端通信

现在有这个样的需求 安卓客户端用JAVA写的 服务端API用PHP写的,返给安卓JSON数据。 现在要做一个时时聊天的功能,服务端还是使用的PHP. 想做长连接,不想用多少秒刷一次那种。 求一个简单的例...

不会武功的猪
2014/10/16
818
2
Linux memcache系统 浅谈一

最近很初步的了解了一下memcache,只是想知道此软件主要是干什么的。找了一些资料后发现仅仅是软件名称就越看越迷糊,特此写此文记录一下,以防过段时间又忘记了,毕竟不是经常使用此软件。 ...

China_OS
2012/02/04
0
0
php异步高并发扩展 swoole-1.6.11 版发布

简介: swoole是一个php版本的异步、高并发扩展,是国人被php官方pecl包收录的力作之一。 很高兴的通知大家,1.6.11版本发布了。 内核更新: - Disable by default asyncmysql (默认关闭asy...

半桶水_桶哥
2014/03/04
2.3K
14
haproxy配置详解+haproxy实现读写分离

HAProxy提供高可用性、负载均衡以及基于TCP和HTTP应用的代理,支持虚拟主机,它是免费、快速并且可靠的一种解决方案。HAProxy特别适用于那些负载特大的web站点,这些站点通常又需要会话保持或...

上一段旅程
2014/04/30
0
0
PHP中Push(推送)技术的探讨

随着人们对Web即时应用需求的不断上升,Server Push(推送)技术在聊天、消息提醒尤其是社交网络等方面开始兴起,成为实时应用的数据流核心。这篇日志试图探讨的便是各种适合于PHP的Push的实现...

lg2045
2014/08/25
0
1
基于 Swoole 的常驻内存型 PHP 框架 - MixPHP

高性能 • 轻量级 • 命令行 MixPHP是什么 MixPHP 是秉承 “做一款入口即化的高性能框架” 的理念而创造,采用 Swoole 扩展作为底层引擎,围绕常驻内存的方式设计,架构设计简洁而有扩展性,...

细变
2017/09/06
379
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Spring+jpaNo transactional EntityManager available

TransactionRequiredException: No transactional EntityManager availableEntityManager执行以下方法(refresh, persist, flush, joinTransaction, remove, merge) 都需要需要事务i......

wpfc
5分钟前
0
0
八幅漫画理解使用JSON Web Token设计单点登录系统

八幅漫画理解使用JSON Web Token设计单点登录系统 Sep 07, 2015 in Engineering 上次在《JSON Web Token - 在Web应用间安全地传递信息》中我提到了JSON Web Token可以用来设计单点登录系统。...

祖冲之
7分钟前
0
0
Spring框架中的设计模式(三)

Spring框架中的设计模式(三) 原创: 瑞查德-Jack 在之前的两篇文章中,我们看到了一些在Spring框架中实现的设计模式。这一次我们会发现这个流行框架使用的3种新模式。 本文将从描述两个创意...

瑞查德-Jack
10分钟前
0
0
[MicroPython]TPYBoard智能小车“飞奔的TPYBoard装甲一号”

智能小车作为现代的新发明,是以后的发展方向,他可以按照预先设定的模式在一个环境里自动的运作,不需要人为的管理,可应用于科学勘探等等的用途。智能小车能够实时显示时间、速度、里程,具...

bodasisiter
12分钟前
0
0
桌面虚拟化VDI(Virtual Desktop Infrastructure)

为了保证员工(客户)不把公司的资料复制、传输给别人。可以把员工平时办公放在服务器上做。所以使用桌面虚拟化。就是把一个服务器虚拟出很多桌面系统(如:windows)。 桌面虚拟化最大的优势...

王坤charlie
19分钟前
2
0
自我审视及职业规划

啊哈,不知不觉已经工作了3年了。程序员作为一门技术工作,如果分级的话我的能力如何呢?该怎么提升呢? 话说,我现在的能力属于中低级的层次吧,努力在向高级努力。为什么这么说呢: 因为我觉...

一口今心
21分钟前
1
0
《PHP和MySQL Web 开发》 第12章 MySQL高级管理

我决定好好写学习笔记了,对应上书上的目录和重要信息。不瞎jb写了。从这章开始吧,然后之前写的会编辑后重发。嗯,就酱。 12.1 深入理解权限系统 妈蛋 开头就卡住了。。。我先回去修改之前的...

十万猛虎下画山
22分钟前
1
0
Python 3.6:多态的实现

多态的作用不用多说,C++用如下条件来实现多态: 要有继承 要有虚函数函数重写 要有父类指针(父类引用)指向子类对象 实际上C++使用VPTR指针来完成这个事情,其是设计模式的基础,软件分层的基...

全部原谅
22分钟前
0
0
纯Python实现鸢尾属植物数据集神经网络模型[图]

纯Python实现鸢尾属植物数据集神经网络模型[图]: 尝试使用过各大公司推出的植物识别APP吗?比如微软识花、花伴侣等这些APP。当你看到一朵不知道学名的花时,只需要打开植物识别APP,拍摄一张...

原创小博客
24分钟前
1
0
2018安卓巴士开发者大会打造Android技术盛宴

2018安卓巴士开发者大会打造Android技术盛宴2018安卓巴士开发者大会将于8月25日在上海举行,作为中国最具前沿性、专业性的安卓技术会议,将邀请来自爱奇艺、阿里、饿了么等知名企业的一线工程...

逆鳞龙
26分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部