這次帶給大家PHP長連結使用案例分析，PHP長連結使用的注意事項有哪些，下面就是實戰案例，一起來看一下。
長連線技術(Long Polling)
#在伺服器端hold住一個連線, 不立即回傳, 直到有資料才返回, 這就是長連接技術的原理
長連接技術的關鍵在於hold住一個HTTP請求, 直到有新數據時才響應請求, 然後客戶端再次自動發起長連接請求.
那怎麼樣hold住一個請求呢？伺服器端的程式碼可能看起來像這樣的
set_time_limit(0); //这句很重要, 不至于运行超时
while (true) {
if (hasNewMessage()) {
echo json_encode(getNewMessage());
break;
}
usleep(100000); //避免太过频繁的查询
}登入後複製
沒錯，就是透過循環來實現hold住一個請求， 不至於立即返回. 查詢到有新資料之後才回應請求. 然後客戶端處理資料後，再次發起長連線請求.
客戶端的程式碼是像這樣的
<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>登入後複製
一個簡易的聊天室
透過長連接, 我們可以開發一個簡易的web聊天室
下面, 我們透過redis開發一個簡易的web聊天室
1. 每一個客戶端發起長連線時, 在伺服器端產生一個訊息佇列, 對應該使用者. 然後監聽有無新資料, 有則傳回資料到客戶端處理, 並再起發起長連線請求.
2. 每一個客戶端發起訊息時,進行訊息佇列的廣播.
下面是程式碼片段:
<?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);
}
}
}登入後複製
長連線避免了過於頻繁的輪詢. 但伺服器維持一個長連線也有額外的資源消耗. 大並發時效能不理想. 在小型應用裡面可以考慮使用
更建議客戶端使用html5的websocket協定, 伺服器端使用swoole.
相信看了本文案例你已經掌握了方法，更多精彩請關注php中文網其它相關文章！
推薦閱讀：
php命名空間使用詳解
#PHP中文工具類別ChineseUtil如何轉換漢字與拼音
以上是PHP長連線使用案例分析的詳細內容。更多資訊請關注PHP中文網其他相關文章！
