我正在尝试用 laravel 实现事件广播和通知。目标是通过通知向登录用户广播私人消息。
我创建了这个事件,请参阅下面的代码:
<?php
namespace App\Events;
use App\Models\User;
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 TradingAccountActivation implements ShouldBroadcast
{
use Dispatchable, InteractsWithSockets, SerializesModels;
/**
* The authenticated user.
*
* @var \Illuminate\Contracts\Auth\Authenticatable
*/
public $user;
public $message;
/**
* Create a new event instance.
*
* @param \Illuminate\Contracts\Auth\Authenticatable $user
* @return void
*/
public function __construct(User $user)
{
$this->user = $user;
$this->message = "{$user->first_name} is ready to trade";
}
/**
* Get the channels the event should broadcast on.
*
* @return \Illuminate\Broadcasting\Channel|array
*/
public function broadcastOn()
{
return new PrivateChannel('user.'.$this->user->id);
}
}
该事件将为每个新验证的用户触发,因此我将该事件放在项目的电子邮件验证控制器中,请参阅下面的代码:
<?php
namespace App\Http\Controllers\Auth;
use App\Http\Controllers\Controller;
use App\Providers\RouteServiceProvider;
use Illuminate\Auth\Events\Verified;
use App\Events\TradingAccountActivation;
use Illuminate\Foundation\Auth\EmailVerificationRequest;
class VerifyEmailController extends Controller
{
/**
* Mark the authenticated user's email address as verified.
*
* @param \Illuminate\Foundation\Auth\EmailVerificationRequest $request
* @return \Illuminate\Http\RedirectResponse
*/
public function __invoke(EmailVerificationRequest $request)
{
if ($request->user()->hasVerifiedEmail()) {
return redirect()->intended(RouteServiceProvider::HOME.'?verified=1');
}
if ($request->user()->markEmailAsVerified()) {
event(new Verified($request->user()));
}
event(new TradingAccountActivation($request->user()));
return redirect()->intended(RouteServiceProvider::HOME.'?verified=1');
}
}
此时,事件失败并显示以下错误消息:
ErrorException
array_merge(): Expected parameter 2 to be an array, null given
堆栈跟踪指向带星号的行上的 Pusher:
Illuminate\Foundation\Bootstrap\HandleExceptions::handleError
C:\xampp\htdocs\spa\vendor\pusher\pusher-php-server\src\Pusher.php:391
$path = $this->settings['base_path'].'/events';
// json_encode might return false on failure
if (!$data_encoded) {
$this->log('Failed to perform json_encode on the the provided data: {error}', array(
'error' => print_r($data, true),
), LogLevel::ERROR);
}
$post_params = array();
$post_params['name'] = $event;
$post_params['data'] = $data_encoded;
$post_params['channels'] = array_values($channels);
* $all_params = array_merge($post_params, $params);
$post_value = json_encode($all_params);
$query_params['body_md5'] = md5($post_value);
Laravel Telescope 确认事件失败,并提供以下详细信息:
职位详情
时间 2021 年 4 月 6 日 9:05:01 AM(1:56 分钟前)
主机名 Adefowowe-PC
状态失败
工作应用程序\事件\TradingAccountActivation
连接同步
队列
尝试-
暂停 -
标签 应用\模型\用户:75Auth:75失败
经过身份验证的用户
编号75
电子邮件地址 [电子邮件受保护]
连同事件要发出的数据:
{
"event": {
"class": "App\Events\TradingAccountActivation",
"properties": {
"user": {
"id": 75,
"uuid": "75da67ef-d6f8-4cd0-9d57-e1dcf66c1f5e",
"first_name": "John",
"last_name": "Doe",
"mobile_phone_number": "08033581133",
"verification_code": null,
"phone_number_isVerified": 0,
"phone_number_verified_at": null,
"email": "[email protected]",
"email_verified_at": "2021-04-06T08:04:49.000000Z",
"created_at": "2021-04-06T08:03:56.000000Z",
"updated_at": "2021-04-06T08:04:49.000000Z"
},
"message": "John is ready to trade",
"socket": null
}
},
"tries": null,
"timeout": null,
"connection": null,
"queue": null,
"chainConnection": null,
"chainQueue": null,
"chainCatchCallbacks": null,
"delay": null,
"afterCommit": null,
"middleware": [
],
"chained": [
]
}
奇怪的是,尽管事件失败,但似乎广播频道已创建并建立了连接。刷新错误页面似乎会继续控制器的下一个操作,即重定向到经过身份验证的用户的仪表板。此时广播连接就建立了。请参阅下面的 Laravel 望远镜详细信息以及有效负载:
Request Details
Time April 6th 2021, 10:02:38 AM (10s ago)
Hostname Adefowowe-PC
Method POST
Controller Action \Illuminate\Broadcasting\BroadcastController@authenticate
Middleware auth:web
Path /broadcasting/auth
Status 302
Duration 1043 ms
IP Address 127.0.0.1
Memory usage 12 MB
Payload
Headers
Session
Response
{
"socket_id": "131623.12865758",
"channel_name": "private-user.${this.user.id}"
}
由于事件失败,我没想到会建立广播通道或触发后续侦听器和通知广播消息。
我不明白事件失败的原因,即如何处理异常“array_merge(): Expectedparameter 2 to be an array, null给定”,或者如何修复它。
或者是否与后续接收/记录/显示广播消息的代码有关。
谢谢。
此问题在8.29.0版本中已解决。您需要升级到指定的版本,或者降级 Pusher-http-php 的版本 (
composer require pusher/pusher-php-server ^4.1
)