[我有一个在端口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"
}
首先,只是要检查一下,您应该听一下broadcastAs函数返回的内容。
php artisan queue:listen --queue=test
否则,将仅执行“默认”广播事件,并且永远不会触发该事件。
如果您也想听“默认”:
php artisan queue:listen --queue=test,