이 글에서는 주로 Laravel에서 인스턴트 애플리케이션을 구축하는 방법을 소개합니다. 인스턴트 메시징은 일상적인 개발에서 자주 접하게 됩니다. 이 글에서는 샘플 코드를 통해 자세히 소개합니다. 아래 편집자.
인스턴트 대화형 애플리케이션
가장 일반적인 결제 콜백 및 제3자 로그인과 같은 최신 웹 애플리케이션의 다양한 시나리오에서 인스턴트 메시징이 필요하다는 사실을 누구나 경험했을 것입니다. 이러한 비즈니스 시나리오는 기본적으로 다음 프로세스를 따라야 합니다.
클라이언트는 관련 비즈니스를 트리거하고 타사 애플리케이션 작업(예: 결제)을 생성합니다.
클라이언트는 서버 응답 결과를 기다립니다(사용자가 작업을 완료합니다) )
서드파티 애플리케이션이 서버에 처리 결과를 통보합니다(결제 완료)
서버가 클라이언트에게 처리 결과를 통보합니다
클라이언트가 피드백을 합니다 결과에 따라 (결제 성공 페이지로 이동)
과거에는 이러한 인스턴트 메시징을 구현하고 클라이언트가 처리 결과에 올바르게 응답할 수 있도록 하기 위해 가장 일반적으로 사용되는 기술이 폴링이었기 때문입니다. HTTP 프로토콜의 단방향 특성상 클라이언트는 처리 결과를 서버에 계속해서 적극적으로 요청할 수만 있습니다. 이 방법에는 서버측 리소스를 차지할 뿐만 아니라 서버측 처리 결과를 실시간으로 얻을 수 없다는 명백한 결함이 있습니다.
이제 WebSocket 프로토콜을 사용하여 실시간 상호 작용을 처리할 수 있습니다. 이는 서버가 클라이언트에 정보를 적극적으로 푸시할 수 있게 해주는 양방향 프로토콜입니다. 이 기사에서는 Laravel의 강력한 이벤트 시스템을 사용하여 실시간 상호 작용을 구축할 것입니다. 다음에 대한 지식이 필요합니다:
Laravel Event
Redis
Socket.io
Node.js
Redis
시작하기 전에 시작이 필요합니다. Redis 서비스를 제공하고 Laravel 애플리케이션에서 이를 구성 및 활성화합니다. 프로세스 전반에 걸쳐 인스턴트 메시징을 달성하려면 Redis의 구독 및 게시 메커니즘을 사용해야 하기 때문입니다.
Redis는 오픈 소스이자 효율적인 키-값 저장 시스템입니다. 일반적으로 키-값 쌍을 저장하는 데이터 구조 서버로 사용되며 문자열, 해시, 목록, 집합 및 순서가 지정된 조합을 지원할 수 있습니다. Laravel에서 Redis를 사용하려면 Composer를 통해 predis/predis 패키지 파일을 설치해야 합니다.
Configuration
애플리케이션의 Redis 구성 파일은 config/database.php에 저장됩니다. 이 파일에서 Redis 서비스 정보가 포함된 redis 배열을 볼 수 있습니다.
'redis' => [
'cluster' => false,
'default' => [
'host' => '127.0.0.1',
'port' => 6379,
'database' => 0,
],
]
로그인 후 복사
Redis 서비스의 포트를 수정했습니다. 구성 파일의 포트를 일관되게 유지하세요.
Laravel Event
여기서 Laravel의 강력한 이벤트 브로드캐스팅 기능을 사용해야 합니다.
Broadcast Events
많은 최신 애플리케이션에서 웹 소켓은 실시간 대화형 사용자 인터페이스를 구현하는 데 사용됩니다. 서버에서 일부 데이터가 변경되면 WebSocket 연결을 통해 처리하기 위해 메시지가 클라이언트에 전달됩니다.
이러한 유형의 애플리케이션을 구축하는 데 도움이 됩니다. Laravel을 사용하면 WebSocket 연결을 통해 이벤트를 쉽게 브로드캐스트할 수 있습니다. Laravel을 사용하면 이벤트 이름을 서버측 및 클라이언트측 JavaScript 프레임워크에 공유하기 위해 이벤트를 브로드캐스트할 수 있습니다.
Configuration
모든 이벤트 방송 구성 옵션은 config/broadcasting.php 구성 파일에 저장됩니다. Laravel에는 Pusher, Redis 및 Log와 같은 여러 가지 사용 가능한 드라이버가 함께 제공됩니다. 우리는 predis/predis 클래스 라이브러리가 필요한 브로드캐스트 드라이버로 Redis를 사용할 것입니다.
기본 브로드캐스트 드라이버는 푸셔를 사용하므로 .env 파일 BROADCAST_DRIVER=redis에서 설정해야 합니다.
사용자가 WeChat을 검색하여 로그인한 후 방송할 WechatLoginedEvent 이벤트 클래스를 생성합니다.
<?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';
}
}로그인 후 복사
BroadcastOn 메소드는 방송할 채널을 나타내는 배열을 반환해야 하고, BroadcastAs는 브로드캐스트에 의해 트리거된 이벤트를 나타내는 문자열 Laravel은 기본적으로 이벤트 클래스의 전체 클래스 이름을 반환합니다. 여기 AppEventsWechatLoginedEvent가 있습니다. 가장 중요한 것은 이 클래스가 ShouldBroadcast 계약을 구현하도록 해야 한다는 것입니다. Laravel은 이벤트를 생성할 때 이 네임스페이스를 자동으로 추가했으며 이 계약은 BroadcastOn 메서드만 제한합니다.
이벤트가 완료된 후 다음 단계는 간단한 코드 한 줄이면 충분합니다.
event(new WechatLoginedEvent($token, $channel));
로그인 후 복사
이 작업은 자동으로 이벤트 실행을 트리거하고 정보를 방송합니다. 기본 브로드캐스트 작업은 Redis의 구독 및 게시 메커니즘에 의존합니다.
RedisBroadcaster는 해당 채널을 통해 이벤트에서 공개적으로 액세스할 수 있는 데이터를 게시합니다. 노출된 데이터를 더 세밀하게 제어하려면 배열을 반환하는 BroadcastWith 메서드를 이벤트에 추가하면 됩니다.
/**
* Get the data to broadcast.
*
* @return array
*/
public function broadcastWith()
{
return ['user' => $this->user->id];
}로그인 후 복사
Node.js 및 Socket.io对于发布出去的信息，我们需要一个服务来对接，让其能对 redis 的发布能够进行订阅，并且能把信息以 WebSocket 协议转发出去，这里我们可以借用 Node.js 和 socket.io 来非常方便的构建这个服务：
// 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);
});로그인 후 복사
这里我们使用 Node.js 引入 socket.io 服务端并监听 6001 端口，借用 redis 的 psubscribe 指令使用通配符来快速的批量订阅，接着在消息触发时将消息通过 WebSocket 转发出去。
Socket.io 客户端
在 web 前端，我们需要引入 Socket.io 客户端开启与服务端 6001 端口的通讯，并订阅频道事件：
// client.js
let io = require('socket.io-client')
var socket = io(':6001')
socket.on($channel + ':wechat.login', (data) => {
socket.close()
// save user token and redirect to dashboard
})로그인 후 복사
至此整个通讯闭环结束，开发流程看起来就是这样的：
위 내용은 Laravel에서 인스턴트 애플리케이션을 구축하는 구현 방법 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
