NodeJS服务器未接收到通过Redis发送的laravel事件

问题描述 投票:0回答:1

[我有一个在端口8000上运行php artisan serve的laravel应用程序,并使用php artisan queue:listen监听了队列,以监听应用程序广播的事件。我还在端口6379上运行了一个Redis服务器,但是当我使用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);
});

Package.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"
  }
node.js laravel redis
1个回答
0
投票

首先,只是要检查一下,您应该听一下broadcastAs函数返回的内容。

php artisan queue:listen --queue=test

否则,将仅执行“默认”广播事件,并且永远不会触发该事件。

如果您也想听“默认”:

php artisan queue:listen --queue=test,
© www.soinside.com 2019 - 2024. All rights reserved.