Rumah > rangka kerja php > Laravel > teks badan

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

藏色散人
Lepaskan: 2021-07-29 09:01:47
ke hadapan
1869 orang telah melayarinya

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
Salin selepas log masuk

Buat Acara

php artisan make:event OrderShipped
Salin selepas log masuk

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;);
    }
}
Salin selepas log masuk

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;;
});
Salin selepas log masuk

Pasang perancah bahagian hadapan

composer require laravel/uiphp artisan ui vue --auth
Salin selepas log masuk

Redis

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

composer require predis/predis
Salin selepas log masuk

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
Salin selepas log masuk

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)
Salin selepas log masuk

Mulakan laravel-echo-server

laravel-echo-server start
Salin selepas log masuk
  • 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!
Salin selepas log masuk

Ujian siaran

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

Channel: laravel_database_orderStatus
Event: anyName
Salin selepas log masuk
  • 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
Salin selepas log masuk

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"
});
Salin selepas log masuk

测试页面

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>
Salin selepas log masuk

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

基本构建

npm install && npm run watch
Salin selepas log masuk

相关推荐:最新的五个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!

Label berkaitan:
sumber:任志帆的博客
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan