Rumah >rangka kerja php >Laravel >Mari bercakap tentang mekanisme penyiaran laravel7.0, sentiasa ada apa yang anda mahukan!

Mari bercakap tentang mekanisme penyiaran laravel7.0, sentiasa ada apa yang anda mahukan!

藏色散人
藏色散人ke hadapan
2021-07-28 15:57:541897semak imbas

mekanisme siaran laravel7.0 (Redis socket.io)

Pembekal perkhidmatan siaran

Sebelum menyiarkan sebarang acara, anda perlu mendaftar AppProvidersBroadcastServiceProvider dahulu. Dalam aplikasi Laravel yang baru dipasang, anda hanya perlu menyahkomen pembekal perkhidmatan yang sepadan dalam tatasusunan config/app.php dalam fail konfigurasi providers. Pembekal ini membenarkan anda mendaftar laluan kebenaran siaran dan panggil balik

Tutorial lajur berkaitan disyorkan: "tutorial laravel"

Sediakan sambungan Redis

Perlu mengubah suai pemacu siaran dalam fail .env kepada redis:

BROADCAST_DRIVER=redis

Buat Acara

php artisan make:event OrderShipped

Selepas melaksanakan perintah rayuan, direktori Acara akan muncul dalam direktori aplikasi dan kelas acara siaran OrderShipped.php akan dijana dalam direktori ini. Kami perlu membuat pengubahsuaian berikut pada kelas OrderShipped yang dijana secara automatik

  • Tambah pelaksanaan ShouldBroadcast

  • Ubah suai kaedah broadcastOn dan gunakan awam siaran saluran orderStatus

  • Sesuaikan nama mesej siaran (Tidak diperlukan) [Secara lalai, Laravel akan menggunakan nama kelas acara untuk menyiarkan acara, tetapi anda boleh lulus ia dalam acara Tentukan kaedah broadcastAs dalam untuk menyesuaikan nama siaran:】

  • Ubah suai pembina

Pengubahsuaian lengkap ialah seperti berikut dan boleh diganti terus

<?php
namespace App\Events;
use Illuminate\Broadcasting\Channel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
class OrderShipped implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets, SerializesModels;
    //可添加任意成员变量
    public $id;
    //事件构造函数
    public function __construct($id)
    {
        $this->id = $id;
    }
    //自定义广播的消息名
    public function broadcastAs()
    {
        return &#39;anyName&#39;;
    }
    /**
     * Get the channels the event should broadcast on.
     *
     * @return \Illuminate\Broadcasting\Channel|array
     */
    public function broadcastOn()
    {
        return new Channel(&#39;orderStatus&#39;);
    }
}

Tetapkan penghalaan api

Route::get(&#39;/ship&#39;, function (Request $request) {
    $id = $request->input(&#39;id&#39;);
    broadcast(new OrderShipped($id)); // 触发事件
    return &#39;Order Shipped!&#39;;
});

Pasang perancah bahagian hadapan

composer require laravel/uiphp artisan ui vue --auth

Redis

Oleh kerana kami menggunakan siaran Redis, kami perlu memasang perpustakaan Predis:

composer require predis/predis

Siaran Redis menggunakan fungsi pub/sub Redis untuk siaran namun, Anda perlu memasangkannya dengan pelayan Websocket yang boleh menerima mesej Redis untuk menyiarkan mesej ke saluran Websocket

Apabila Redis menyiarkan acara, acara itu akan diterbitkan ke saluran yang ditentukan , data yang dihantar ialah rentetan dalam format JSON, yang mengandungi nama acara, data muatan dan pengguna yang menjana ID soket acara

Pasang laravel-echo-server dan langgan Redis Sub

Jika anda menggunakan pusher, hanya gunakan laravel Jika anda menggunakan Redis socket.io, anda perlu menggunakan projek sumber terbuka laravel-echo-server. Jadi kami kini akan menggunakan laravel-echo-server

Pemasangan global

npm install -g laravel-echo-server

Memulakan laravel-echo-server

laravel-echo-server init

// 是否在开发模式下运行此服务器(y/n) 输入y
? Do you want to run this server in development mode? (y/N)// 设置服务器的端口 默认 6001 输入 6001就可以了 或者你想要的
? Which port would you like to serve from? (6001)// 想用的数据库  选择 redis
? Which database would you like to use to store presence channel members? (Use arrow keys)❯ redis
  sqlite

//   这里输入 你的laravel  项目的访问域名
? Enter the host of your Laravel authentication server. (http://localhost)// 选择 网络协议 http
? Will you be serving on http or https? (Use arrow keys)❯ http
  https

// 您想为HTTP API生成客户端ID/密钥吗 N
? Do you want to generate a client ID/Key for HTTP API? (y/N)// 要设置对API的跨域访问吗?(y/n)N
Configuration file saved. Run laravel-echo-server start to run server.

//您希望将此配置另存为什么? (laravel-echo-server.json)回车就行
? What do you want this config to be saved as? (laravel-echo-server.json)

Mulakan laravel-echo-server

laravel-echo-server start
  • Yang berikut ialah output selepas Log permulaan yang berjaya
L A R A V E L  E C H O  S E R V E R

version 1.6.0

⚠ Starting server in DEV mode...

✔  Running at localhost on port 6001
✔  Channels are ready.
✔  Listening for http events...
✔  Listening for redis events...

Server ready!

Ujian siaran

Laksanakan pada penyemak imbashttp://yourhost/api/ship?id=16

Channel: laravel_database_orderStatus
Event: anyName
  • sambungan laravel-echo-server berjaya!

Pasang pra-kebergantungan laravel-echo

Memandangkan bahagian hadapan menggunakan laravel-echo untuk mendengar siaran, pelaksanaan asas yang kami pilih ialah socket.io. Jadi pertama kita perlu menambah kebergantungan package.json dan laravel-echo dalam socket.io

npm i --save socket.io-client
npm i --save laravel-echo

Edit resource/js/bootstrap.js dan tambah Kod berikut

import Echo from "laravel-echo";
window.io = require("socket.io-client");
window.Echo = new Echo({    
broadcaster: "socket.io",    
host: window.location.hostname + ":6001"
});

测试页面

resources/views/ 下建立页面 test.blade.php 内容为

<!doctype html>
<html>

<head>
    <meta charset="utf-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <meta name="csrf-token" content="">
    <title>News Room</title>
    <link href="" rel="stylesheet">
</head>

<body>
    <div class="content">
        News Room
    </div>
    <script src=""></script>
    <script>
        Echo.channel("laravel_database_orderStatus") // 广播频道名称
    .listen(".anyName", e => {
        // 消息名称
        console.log(e); // 收到消息进行的操作,参数 e 为所携带的数据
    });
    </script>
</body>

</html>

js 代码的意思是收听 news 通道内的 News 事件对象,将接收到的事件在控制台打印出来。

基本构建

npm install && npm run watch

相关推荐:最新的五个Laravel视频教程

Atas ialah kandungan terperinci Mari bercakap tentang mekanisme penyiaran laravel7.0, sentiasa ada apa yang anda mahukan!. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
Artikel ini dikembalikan pada:任志帆的博客. Jika ada pelanggaran, sila hubungi admin@php.cn Padam