Laravel 인스턴트 애플리케이션의 구현 방법

인스턴트 대화형 애플리케이션

최신 웹 애플리케이션에서는 가장 일반적인 결제 콜백 및 제3자 로그인과 같은 많은 시나리오에서 인스턴트 메시징을 사용해야 합니다. 이러한 비즈니스 시나리오는 기본적으로 다음 프로세스를 따라야 합니다.

● 클라이언트는 관련 비즈니스를 트리거하고 타사 애플리케이션 작업(예: 결제)을 생성합니다.

● 클라이언트는 서버 응답 결과를 기다립니다(사용자가 작업을 완료함) 타사 애플리케이션)

● 타사 애플리케이션이 서버에 처리 결과를 알림(결제 완료)

● 서버가 클라이언트에 처리 결과를 알림

● 클라이언트는 결과에 따라 피드백(점프)

이전에는 이를 달성하기 위해 클라이언트가 처리 결과에 정확하게 응답할 수 있도록 하는 일종의 인스턴트 메시징이 가장 일반적으로 사용되는 기술이 폴링(Polling)이기 때문입니다. 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 Event

많은 최신 애플리케이션은 웹 소켓을 사용하여 실시간 대화형 사용자 인터페이스를 구현합니다. 서버에서 일부 데이터가 변경되면 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 &#39;wechat.login&#39;;
    }
}

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와 소켓.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를 사용하여 소켓.io 서버를 소개하고 6001 포트를 수신합니다. redis의 psubscribe 명령을 빌려 와일드카드를 사용하여 일괄적으로 빠르게 구독한 다음 메시지가 트리거될 때 WebSocket을 통해 메시지를 전달합니다.

Socket.io 클라이언트

웹 프런트 엔드에서는 서버 포트 6001과의 통신을 열고 채널 이벤트를 구독하기 위해 Socket.io 클라이언트를 도입해야 합니다.

// 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 이벤트 구축

● 방송해야 하는 채널 및 이벤트 이름 설정

● Redis 드라이버를 사용하도록 방송 설정

● Redis 릴리스 구독을 위한 지속적인 서비스 제공 및 WebSocket 프로토콜을 통해 게시된 콘텐츠를 클라이언트에 푸시합니다.

● 클라이언트는 서버측 WebSocket 터널을 열고 이벤트를 구독하며 지정된 이벤트의 푸시에 따라 응답합니다.

더 많은 Laravel 관련 기술 기사를 보려면 Laravel 프레임워크 시작 튜토리얼 칼럼을 방문하여 알아보세요!

위 내용은 Laravel 인스턴트 애플리케이션의 구현 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!