《PHP學習：Laravel構建即時應用的一種實現方法詳解》要點：
本文介紹了PHP學習：Laravel構建即時應用的一種實現方法詳解，希望對您有用。如果有疑問，可以聯系我們。
PHP實戰即時交互的應用
PHP實戰大家應該都有所體會,在現代的 Web 應用中很多場景都需要運用到即時通訊,比如說最常見的支付回調,與三方登錄.這些業務場景都基本需要遵循以下流程：
PHP實戰在過去,為了實現這種即時通訊,能讓客戶端正確響應處理結果,最為常用的技術就是輪詢,因為 HTTP 協議的單向性,客戶端只能一遍一遍的主動詢問服務端的處理結果.這種方式有顯見的缺陷,占用服務端資源不說,還不能實時獲得服務端處理結果.
PHP實戰現在,我們可以使用 WebSocket 協議來處理實時交互,它是一種雙向協議,允許服務端主動推送信息到客戶端.本篇我們將借助 Laravel 強大的事件系統來構建實時的交互.你將需要用到以下知識：
PHP實戰Redis
PHP實戰在開始之前,我們需要開啟一個 redis 服務,并在 Laravel 應用中進行配置啟用,因為在整個流程中,我們需要借助 redis 的訂閱和發布機制來實現即時通訊.
PHP實戰Redis 是一個開源高效的鍵值對存儲系統.它通常作為一個數據結構服務器來存儲鍵值對,它可以支持字符串,散列,列表,集合和有序結合.在 Laravel 中使用 Redis 你需用通過 Composer 來安裝 predis/predis 包文件.
PHP實戰配置
PHP實戰Redis 在應用中的配置文件存儲在 config/database.php,在這個文件中,你可以看到一個包含了 Redis 服務信息的 redis 數組:
PHP實戰 'redis' => [ 'cluster' => false, 'default' => [ 'host' => '127.0.0.1', 'port' => 6379, 'database' => 0, ], ]
PHP實戰如果你修改了 redis 服務的端口,請保持配置文件中的端口一致.
PHP實戰Laravel Event
PHP實戰這里我們需要借助 Laravel 強大的事件廣播能力：
PHP實戰廣播事件
PHP實戰很多現代化的應用中,會使用 Web Sockets 來實現實時交互的用戶接口.當一些數據在服務端變更時,一條消息會通過 WebSocket 連接來傳遞到客戶端進行處理.
PHP實戰為了幫助你構建這種類型的應用.Laravel 使通過 WebSocket 連接進行廣播事件變的非常簡單.Laravel 允許你廣播事件來共享事件的名稱到你的服務端和客戶端的 JavaScript 框架.
PHP實戰配置
PHP實戰所有的事件廣播配置選項都被存儲在 config/broadcasting.php 配置文件中.Laravel 附帶了幾種可用的驅動如 Pusher,Redis,和 Log,我們將使用 Redis 作為廣播驅動,這里需要依賴 predis/predis 類庫.
PHP實戰由于默認的廣播驅動使用的是 pusher,所以我們需要在 .env 文件中設置 BROADCAST_DRIVER=redis.
PHP實戰我們創建一個 WechatLoginedEvent 事件類用來在用戶掃描微信登錄后進行廣播：
PHP實戰
<?php
namespace App\Events;
use App\Events\Event;
use Illuminate\Queue\SerializesModels;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
class WechatLoginedEvent extends Event implements ShouldBroadcast
{
use SerializesModels;
public $token;
protected $channel;
/**
* Create a new event instance.
*
* @param string $token
* @param string $channel
* @return void
*/
public function __construct($token, $channel)
{
$this->token = $token;
$this->channel = $channel;
}
/**
* Get the channels the event should be broadcast on.
*
* @return array
*/
public function broadcastOn()
{
return [$this->channel];
}
/**
* Get the name the event should be broadcast on.
*
* @return string
*/
public function broadcastAs()
{
return 'wechat.login';
}
}
PHP實戰其中你需要注意 broadcastOn 方法應返回一個數組,它表示所需廣播的頻道,而 broadcastAs 返回的是一個字符串,它表示廣播所觸發的事件,Laravel 默認的是返回事件類的全類名,這里是 App\Events\WechatLoginedEvent.
PHP實戰最重要的是你需要手動的讓該類實現 ShouldBroadcast 契約.Laravel 在生成事件時,已經自動添加了該命名空間,該契約只約束 broadcastOn 方法.
PHP實戰事件完成接下來就是觸發事件了,簡單的一行代碼就可以：
PHP實戰 event(new WechatLoginedEvent($token, $channel));
PHP實戰這個操作會自動的觸發事件的執行并將信息廣播出去.該廣播操作底層借助了 redis 的訂閱和發布機制.
PHP實戰RedisBroadcaster 會將事件中的允許公開訪問的數據通過給定的頻道發布出去.如果你想對公開的數據擁有更多的控制,你可以在事件中添加 broadcastWith 方法,它應該返回一個數組：
PHP實戰
/**
* Get the data to broadcast.
*
* @return array
*/
public function broadcastWith()
{
return ['user' => $this->user->id];
}
PHP實戰Node.js 和 Socket.io
PHP實戰對于發布出去的信息,我們需要一個服務來對接,讓其能對 redis 的發布能夠進行訂閱,并且能把信息以 WebSocket 協議轉發出去,這里我們可以借用 Node.js 和 socket.io 來非常方便的構建這個服務：
PHP實戰
// server.js
var app = require('http').createServer(handler);
var io = require('socket.io')(app);
var Redis = require('ioredis');
var redis = new Redis();
app.listen(6001, function () {
console.log('Server is running!') ;
});
function handler(req, res) {
res.writeHead(200);
res.end('');
}
io.on('connection', function (socket) {
socket.on('message', function (message) {
console.log(message)
})
socket.on('disconnect', function () {
console.log('user disconnect')
})
});
redis.psubscribe('*', function (err, count) {
});
redis.on('pmessage', function (subscrbed, channel, message) {
message = JSON.parse(message);
io.emit(channel + ':' + message.event, message.data);
});
轉載請注明本頁網址：
http://www.snjht.com/jiaocheng/198.html
