NodeJS сервер не получает laravel событий, отправленных с помощью redis

Question

Я получил приложение laravel, работающее с php artisan serve на порту 8000, и я слушаю очередь с php artisan queue:listen, чтобы прослушивать события, передаваемые приложением. Я также получил сервер redis, работающий на порту 6379, но когда я передаю сообщение с event(new TestEvent()), сервер NodeJS не видит сообщение. Я пробовал 2 разных варианта узла, вариант 1 не регистрирует ни одного сообщения, но вариант 2 не запускает событие. Сообщение об ошибке:

[ioredis] Unhandled error event: Error: getaddrinfo ENOTFOUND redis redis:6379
    at GetAddrInfoReqWrap.onlookup [as oncomplete] (dns.js:56:26)

Laravel .env:

BROADCAST_DRIVER=redis
CACHE_DRIVER=file
SESSION_DRIVER=file
SESSION_LIFETIME=120
QUEUE_DRIVER=database

REDIS_HOST=redis
REDIS_PASSWORD=null
REDIS_PORT=6379

TestEvent:

class TestEvent implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    private $message = 'hello';

    /**
     * Create a new event instance.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    /**
     * Get the channels the event should broadcast on.
     *
     * @return \Illuminate\Broadcasting\Channel|array
     */
    public function broadcastOn()
    {
        return ['home'];
    }

    public function broadcastAs()
    {
        return 'test';
    }
}

Узел варианта сервера 1:

const express = require('express');
const app = express();

const http = require('http');
const server = http.Server(app);

const socketIO = require('socket.io');
const io = socketIO(server);

const redis = require('redis');

const port = 3000;

io.on('connection' , (socket) => {
   console.log('user connected');

    socket.on('test1', (message) => {
        console.log(message);
    });
});

const redisClient = redis.createClient();
redisClient.subscribe('test');
redisClient.subscribe('*');

redisClient.on('*', function(channel, message) {
   console.log(channel);
   console.log(message);
});

redisClient.on('message', function(channel, message) {
    console.log(channel);
    console.log(message);

    // socket.emit(channel, message);
});

redisClient.on('test', function(channel, message) {
    console.log(channel);
    console.log(message);

    // socket.emit(channel, message);
});

server.listen(port, () => {
    console.log('started on port: ' + port);
});

Вариант узла 2:

var app = require('http').createServer(handler);
var io = require('socket.io')(app);

var Redis = require('ioredis');
var redis = new Redis(6379, 'redis');

app.listen(3000, function() {
    console.log('Server is running!');
});

function handler(req, res) {
    res.writeHead(200);
    res.end('');
}

io.on('connection', function(socket) {
    //
});

redis.psubscribe('*', function(err, count) {
    //
});

redis.on('pmessage', function(subscribed, channel, message) {
    message = JSON.parse(message);
    io.emit(channel + ':' + message.event, message.data);
});

Пакет. json

"dependencies": {
    "@types/socket.io": "^2.1.4",
    "express": "^4.17.1",
    "redis": "^3.0.2",
    "socket.io": "^2.3.0",
    "ioredis": "^2.4.0"
  }

Answer 1

Прежде всего, просто чтобы проверить, вы должны прослушать, что возвращает ваша функция broadcastAs.

php artisan queue:listen --queue=test

В противном случае будет выполнено только широковещательное событие "по умолчанию", и оно никогда не сработает.

Если вы также хотите прослушать «default»:

php artisan queue:listen --queue=test,