我已经使用 laravel-echo成功配置了 laravel-websockets 。我已经能够使用命令启动服务器php artisan websocket:serve。我的应用程序能够从浏览器连接和验证，但是广播事件没有记录在我的控制台中。每当我从服务器发送事件时，我的浏览器都不会收到它。
这是我的活动：
<?php
namespace App\Events;
use App\Models\Transaction;
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 PurchaseCompleted
{
use Dispatchable, InteractsWithSockets, SerializesModels;
protected $transaction;
/**
* Create a new event instance.
*
* @return void
*/
public function __construct(Transaction $transaction)
{
$this->transaction = $transaction;
}
/**
* Get the channels the event should broadcast on.
*
* @return \Illuminate\Broadcasting\Channel|array
*/
public function broadcastOn()
{
return new PrivateChannel('transactions'.$this->transaction->branch_id);
}
}
这是我的广播服务提供商：
<?php
namespace App\Providers;
use Illuminate\Support\Facades\Broadcast;
use Illuminate\Support\ServiceProvider;
class BroadcastServiceProvider extends ServiceProvider
{
/**
* Bootstrap any application services.
*
* @return void
*/
public function boot()
{
Broadcast::routes([
'middleware' => 'auth:api'
]);
require base_path('routes/channels.php');
}
}
我的广播配置文件：
<?php
return [
/*
|--------------------------------------------------------------------------
| Default Broadcaster
|--------------------------------------------------------------------------
|
| This option controls the default broadcaster that will be used by the
| framework when an event needs to be broadcast. You may set this to
| any of the connections defined in the "connections" array below.
|
| Supported: "pusher", "redis", "log", "null"
|
*/
'default' => env('BROADCAST_DRIVER', 'null'),
/*
|--------------------------------------------------------------------------
| Broadcast Connections
|--------------------------------------------------------------------------
|
| Here you may define all of the broadcast connections that will be used
| to broadcast events to other systems or over websockets. Samples of
| each available type of connection are provided inside this array.
|
*/
'connections' => [
'pusher' => [
'driver' => 'pusher',
'key' => env('PUSHER_APP_KEY'),
'secret' => env('PUSHER_APP_SECRET'),
'app_id' => env('PUSHER_APP_ID'),
'options' => [
'cluster' => env('PUSHER_APP_CLUSTER'),
'useTLS' => false,
'host' => '127.0.0.1',
'port' => 6001,
'scheme' => 'http',
'curl_options' => [
CURLOPT_SSL_VERIFYHOST => 0,
CURLOPT_SSL_VERIFYPEER => 0,
]
],
],
'redis' => [
'driver' => 'redis',
'connection' => 'default',
],
'log' => [
'driver' => 'log',
],
'null' => [
'driver' => 'null',
],
],
];
我的 websockets 配置文件：
<?php
use BeyondCode\LaravelWebSockets\Dashboard\Http\Middleware\Authorize;
return [
/*
* Set a custom dashboard configuration
*/
'dashboard' => [
'port' => env('LARAVEL_WEBSOCKETS_PORT', 6001),
],
/*
* This package comes with multi tenancy out of the box. Here you can
* configure the different apps that can use the webSockets server.
*
* Optionally you specify capacity so you can limit the maximum
* concurrent connections for a specific app.
*
* Optionally you can disable client events so clients cannot send
* messages to each other via the webSockets.
*/
'apps' => [
[
'id' => env('PUSHER_APP_ID'),
'name' => env('APP_NAME'),
'key' => env('PUSHER_APP_KEY'),
'secret' => env('PUSHER_APP_SECRET'),
'path' => env('PUSHER_APP_PATH'),
'capacity' => null,
'enable_client_messages' => false,
'enable_statistics' => true,
],
],
/*
* This class is responsible for finding the apps. The default provider
* will use the apps defined in this config file.
*
* You can create a custom provider by implementing the
* `AppProvider` interface.
*/
'app_provider' => BeyondCode\LaravelWebSockets\Apps\ConfigAppProvider::class,
/*
* This array contains the hosts of which you want to allow incoming requests.
* Leave this empty if you want to accept requests from all hosts.
*/
'allowed_origins' => [
//
],
/*
* The maximum request size in kilobytes that is allowed for an incoming WebSocket request.
*/
'max_request_size_in_kb' => 250,
/*
* This path will be used to register the necessary routes for the package.
*/
'path' => 'laravel-websockets',
/*
* Dashboard Routes Middleware
*
* These middleware will be assigned to every dashboard route, giving you
* the chance to add your own middleware to this list or change any of
* the existing middleware. Or, you can simply stick with this list.
*/
'middleware' => [
'web',
Authorize::class,
],
'statistics' => [
/*
* This model will be used to store the statistics of the WebSocketsServer.
* The only requirement is that the model should extend
* `WebSocketsStatisticsEntry` provided by this package.
*/
'model' => \BeyondCode\LaravelWebSockets\Statistics\Models\WebSocketsStatisticsEntry::class,
/*
* Here you can specify the interval in seconds at which statistics should be logged.
*/
'interval_in_seconds' => 60,
/*
* When the clean-command is executed, all recorded statistics older than
* the number of days specified here will be deleted.
*/
'delete_statistics_older_than_days' => 60,
/*
* Use an DNS resolver to make the requests to the statistics logger
* default is to resolve everything to 127.0.0.1.
*/
'perform_dns_lookup' => false,
],
/*
* Define the optional SSL context for your WebSocket connections.
* You can see all available options at: http://php.net/manual/en/context.ssl.php
*/
'ssl' => [
/*
* Path to local certificate file on filesystem. It must be a PEM encoded file which
* contains your certificate and private key. It can optionally contain the
* certificate chain of issuers. The private key also may be contained
* in a separate file specified by local_pk.
*/
'local_cert' => env('LARAVEL_WEBSOCKETS_SSL_LOCAL_CERT', null),
/*
* Path to local private key file on filesystem in case of separate files for
* certificate (local_cert) and private key.
*/
'local_pk' => env('LARAVEL_WEBSOCKETS_SSL_LOCAL_PK', null),
/*
* Passphrase for your local_cert file.
*/
'passphrase' => env('LARAVEL_WEBSOCKETS_SSL_PASSPHRASE', null),
],
/*
* Channel Manager
* This class handles how channel persistence is handled.
* By default, persistence is stored in an array by the running webserver.
* The only requirement is that the class should implement
* `ChannelManager` interface provided by this package.
*/
'channel_manager' => \BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManagers\ArrayChannelManager::class,
];
我初始化 laravel echo 的 bootstrap.js 文件：
window._ = require('lodash');
/**
* We'll load the axios HTTP library which allows us to easily issue requests
* to our Laravel back-end. This library automatically handles sending the
* CSRF token as a header based on the value of the "XSRF" token cookie.
*/
window.axios = require('axios');
window.axios.defaults.headers.common['X-Requested-With'] = 'XMLHttpRequest';
/**
* Echo exposes an expressive API for subscribing to channels and listening
* for events that are broadcast by Laravel. Echo and event broadcasting
* allows your team to easily build robust real-time web applications.
*/
import Echo from 'laravel-echo';
window.Pusher = require('pusher-js');
window.Echo = new Echo({
broadcaster: 'pusher',
key: process.env.MIX_PUSHER_APP_KEY,
wsHost: window.location.hostname,
wsPort: 6001,
disableStats: true,
cluster: "eu",
auth: {
headers: {
authorization: "Bearer eyJ0eXAiO3JKV1QiLCJhb3ciOi1SUzI1NiJ9.eyJhdWQiOiIxIiwiwnRpIjoiYTNjNzY5YWM2Zjc5Zjc0YzIxODE3M2RiNWNlOGQ3Y2NlOTE2MWFiZWJmODc4NzYzOTRiNzc3ZjViZWU2ZTRjYzhmNjM4MzRmMTdlMDlkMTEiLCJpYXQiOjE1ODI3NzI3NjcsIm5iZiI6MTU4Mjc3Mjc2NywiZXhwIjoxNjE0Mzk1MTY3LCJzdWIiOiIxIiwic2NvcGVzIjpbXX0.bQV92lbNX4wjLsYtRfXEUE3WTrso1n2CaMH4gLkxAkBZIwACtxo7b9t7WrlFzkNbU-DwfIJtVlRYNK3f_L5LqeoxxKvefA6rCdJPQtJyQVTv4U250MwDLU0GrIfiuoXuCz5VMbhikBAQox8bhpMXhb58SN0U_ML-fwTwlLur68zhMEYzTbiZvH0MJRg6j-gE4_b8Fqr0QTOTkXn2-OL61pIIiWV2Br9u4gF2IYVUMmsTlK2q05wUSSCxM12Cc8m9pnUZBdghjjmyvYBjVMYJGowwynCb28q71pAhOxRdl-NYsQVN1n2c-yhwv9RT_Hz1PrleKiOYf313QkTdpQ5tMhMY_wZ0iFW7EEgNYfQ1wmS0epiRMLjUeGG1hDs3ojUdSCO82mdVFPNI303fEFaasOWp69ckezyDZ-SI4KnH26Yni0AWObCQX0EpoHg4MZLrYaaBfJwAigD85GCl-1b78btQZMg-sJFQbSZxDlg0e1V0XmdEhh7S1yKUvIsYAwUGS39onCO9-s_gP8Y584PUxYbNeGXACklMBMjQBZGs8srWyb7YWZCIvJWDzevSnPNWrXsKjuPCDAKBfvf3cvqrR21usr42JCv-iOFhs9Pjo-38Prejd65DDqeTsr2C8QuMvEoG7o_LrvQfFGP2uSr38FTucw93Qp5eWL2O4s26vKI"
}
}
});
我在其中收听频道和事件的 app.js 文件：
require('./bootstrap');
import Echo from 'laravel-echo';
window.Echo.private('transactions.1')
.listen('PurchaseCompleted', (e) => {
console.log("Received Data: ");
console.log(e);
});
我的路线/频道文件：
<?php
/*
|--------------------------------------------------------------------------
| Broadcast Channels
|--------------------------------------------------------------------------
|
| Here you may register all of the event broadcasting channels that your
| application supports. The given channel authorization callbacks are
| used to check if an authenticated user can listen to the channel.
|
*/
/*
* Authenticate the user's personal channel...
*/
Broadcast::channel('App.User.*', function ($user, $userId) {
return true; // (int) $user->id === (int) $userId
});
Broadcast::channel('transactions.{branchId}', function ($user, $branchId) {
return (int) $user->branch_id === (int) $branchId;
});
这就是我知道我的浏览器能够连接到 websocket 服务器的方式：
但是，当我尝试从这里发送事件时，我的浏览器中没有记录响应，我的浏览器甚至没有收到该事件：
我的浏览器控制台中没有记录任何错误，没有任何反应，但是在我的终端中，我可以看到该事件是从服务器发送的，但它没有显示客户端收到它的迹象。
浏览器收到的唯一东西是
websockets12345：连接 id 722400884.831426830 收到消息：{"event":"pusher:ping","data":{}}。连接 id 722400884.831426830 发送消息 {"event":"pusher:pong"} Blockquote