Я пытаюсь создать приложение в реальном времени с сервером laravel-echo и socket.io, но клиент не становится сообщениями
Вот мой код:
.окр
BROADCAST_DRIVER=redis
CACHE_DRIVER=file
SESSION_DRIVER=file
QUEUE_DRIVER=redis
конфиг / queue.php
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => 'default',
'retry_after' => 90,
],
конфиг / database.php
'redis' => [
'retry_after' => 90,
'default' => [
'host' => env('REDIS_HOST', '127.0.0.1'),
'password' => env('REDIS_PASSWORD', null),
'port' => env('REDIS_PORT', 6379),
'database' => 0,
],
],
маршруты / channels.php
Broadcast::channel('messages', function() {
return true;
});
SRC / echo.js
import Echo from "laravel-echo"
window.Echo = new Echo({
broadcaster: 'socket.io',
host:'http://localhost:6001'
});
window.Echo.channel('messages')
.listen('.newMessage', (message) => {
debugger;
});
События / MessagePosted.php
<?php
namespace App\Events;
use Illuminate\Broadcasting\Channel;
use Illuminate\Queue\SerializesModels;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
class MessagePosted implements ShouldBroadcast {
use Dispatchable, InteractsWithSockets, SerializesModels;
protected $message;
public function __construct($message)
{
$this->message = $message;
}
public function broadcastWith()
{
return [
'message' => $this->message,
];
}
public function broadcastAs()
{
return 'newMessage';
}
public function broadcastOn()
{
return new Channel('messages');
}
}
MessageController.php
public function post(Request $request)
{
event(new MessagePosted($request->get('message')));
}
Redis-сервер установлен, в PIS-команде redis-cli возвращаем PONG.
Я использую php artisan queue: redis работы, но после отправки сообщения от клиента, ничего не отображается в очереди …
Клиенты подключаются к laravel-echo-серверу, его возврат:
[14:04:17] — C3c8UUnTn9dvOPc9AAAA присоединился к каналу: сообщения.
И POST запрос обрабатывается
Вы слушаете .newMessage
но отправка .App.Events.MessagePosted
вместо.
Измените параметр функции прослушивания в вашем JS:
window.Echo.channel('messages')
.listen('.App.Events.MessagePosted', (message) => {
debugger;
});
Других решений пока нет …