本文實(shí)例講述了PHP長連接實(shí)現(xiàn)與使用方法。分享給大家供大家參考，具體如下：
長連接技術(shù)(Long Polling)
在服務(wù)器端hold住一個(gè)連接, 不立即返回, 直到有數(shù)據(jù)才返回, 這就是長連接技術(shù)的原理
長連接技術(shù)的關(guān)鍵在于hold住一個(gè)HTTP請(qǐng)求, 直到有新數(shù)據(jù)時(shí)才響應(yīng)請(qǐng)求, 然后客戶端再次自動(dòng)發(fā)起長連接請(qǐng)求.
那怎么樣hold住一個(gè)請(qǐng)求呢？服務(wù)器端的代碼可能看起來像這樣的
set_time_limit(0); //這句很重要, 不至于運(yùn)行超時(shí)
while (true) {
if (hasNewMessage()) {
echo json_encode(getNewMessage());
break;
}
usleep(100000); //避免太過頻繁的查詢
}
沒錯(cuò)，就是通過循環(huán)來實(shí)現(xiàn)hold住一個(gè)請(qǐng)求， 不至于立即返回. 查詢到有新數(shù)據(jù)之后才響應(yīng)請(qǐng)求. 然后客戶端處理數(shù)據(jù)后，再次發(fā)起長連接請(qǐng)求.
客戶端的代碼是像這樣的
script type="text/javascript">
(function longPolling() {
$.ajax({
'url': 'server.php',
'data': data,
'dataType': 'json',
'success': function(data) {
processData(data);
longPolling();
},
'error': function(data) {
longPolling();
}
});
})();
/script>
一個(gè)簡(jiǎn)易的聊天室
通過長連接, 我們可以開發(fā)一個(gè)簡(jiǎn)易的web聊天室
下面, 我們通過redis開發(fā)一個(gè)簡(jiǎn)易的web聊天室
1. 每一個(gè)客戶端發(fā)起長連接時(shí), 在服務(wù)器端生成一個(gè)消息隊(duì)列, 對(duì)應(yīng)該用戶. 然后監(jiān)聽有無新數(shù)據(jù), 有則返回?cái)?shù)據(jù)到客戶端進(jìn)行處理, 并再起發(fā)起長連接請(qǐng)求.
2. 每一個(gè)客戶端發(fā)起消息時(shí), 進(jìn)行消息隊(duì)列的廣播.
下面是代碼片段:
?php
namespace church\LongPolling;
use Closure;
use church\LongPolling\Queue\RedisQueue;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\JsonResponse;
class Server
{
public $event = [];
public $redisQueue = null;
public $request = null;
public $response = null;
public function __construct()
{
$this->redisQueue = new RedisQueue();
$this->request = Request::createFromGlobals();
$this->response = new JsonResponse();
}
public function on($event, Closure $closure)
{
if (is_callable($closure)) {
$this->event[$event][] = $closure;
}
}
public function fire($event)
{
if (isset($this->event[$event])) {
foreach ($this->event[$event] as $callback) {
call_user_func($callback, $this);
}
}
}
public function sendMessage($data)
{
switch ($data['type']) {
case 'unicast': //單播
$this->unicast($data['target'], $data['data'], $data['resource']);
break;
case 'multicast': //組播
foreach ($data['target'] as $target) {
$this->unicast($target, $data['data'], $data['resource']);
}
break;
case 'broadcast': //廣播
foreach ($this->redisQueue->setQueueName('connections') as $target) {
$this->unicast($target, $data['data'], $data['resource']);
}
break;
}
$this->fire('message');
}
public function unicast($target, $message, $resource = 'system')
{
$redis_queue = new RedisQueue();
$redis_queue->setQueueName($target)->push($resource . ':' . $message);
}
public function getMessage($target)
{
return $this->redisQueue->setQueueName($target)->pop();
}
public function hasMessage($target)
{
return count($this->redisQueue->setQueueName($target));
}
public function run()
{
$data = $this->request->request;
while (true) {
if ($data->get('action') == 'getMessage') {
if ($this->hasMessage($data->get('target'))) {
$this->response->setData([
'state' => 'ok',
'message' => '獲取成功',
'data' => $this->getMessage($data->get('target'))
]);
$this->response->send();
break;
}
} elseif ($data->get('action') == 'connect') {
$exist = false;
foreach ($this->redisQueue->setQueueName('connections') as $connection) {
if ($connection == $data->get('data')) {
$exist = true;
}
}
if (! $exist) {
$this->redisQueue->setQueueName('connections')->push($data->get('data'));
}
$this->fire('connect');
break;
}
usleep(100000);
}
}
}
長連接避免了過于頻繁的輪詢. 但服務(wù)器維持一個(gè)長連接也有額外的資源消耗. 大并發(fā)時(shí)性能不理想. 在小型應(yīng)用里面可以考慮使用
更建議客戶端使用html5的websocket協(xié)議, 服務(wù)器端使用swoole.
有關(guān)swoole, 你可以查看官網(wǎng)：https://www.swoole.com/
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《php socket用法總結(jié)》、《php字符串(string)用法總結(jié)》、《PHP數(shù)學(xué)運(yùn)算技巧總結(jié)》、《php面向?qū)ο蟪绦蛟O(shè)計(jì)入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《PHP數(shù)據(jù)結(jié)構(gòu)與算法教程》、《php程序設(shè)計(jì)算法總結(jié)》及《PHP網(wǎng)絡(luò)編程技巧總結(jié)》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
您可能感興趣的文章:- PHP使用Redis長連接的方法詳解
- PHP擴(kuò)展模塊memcached長連接使用方法分析
- 基于php實(shí)現(xiàn)長連接的方法與注意事項(xiàng)的問題
- PHP set_time_limit(0)長連接的實(shí)現(xiàn)分析
- 基于HTTP長連接的"服務(wù)器推"技術(shù)的php 簡(jiǎn)易聊天室
- PHP編程實(shí)現(xiàn)的TCP服務(wù)端和客戶端功能示例
- php實(shí)現(xiàn)TCP端口檢測(cè)的方法
- 詳解PHP Swoole長連接常見問題
