服务器使用 NodeJS 和 Redis 发送事件
Server Sent Events using NodeJS and Redis
我从 Redis 数据库接收更新(消息),我需要在客户端实时显示这些消息,为此我使用 SSE(服务器发送的事件)。
因此,我的代码如下所示:
客户端javascript:
var source = new EventSource('/updates');
source.addEventListener('pmessage', function(e) {
console.log('Event: ' + e.event);
console.log('Data: ' + e.data);
}, false);
服务器端(Node + Express):
req.socket.setTimeout(Infinity);
var redisURL = url.parse(process.env.REDISCLOUD_URL);
var client = redis.createClient(redisURL.port, redisURL.hostname, {ignore_subscribe_messages: true});
client.auth(redisURL.auth.split(":")[1]);
client.psubscribe('updates');
client.on('error', function (err) {
console.log('Error: ' + err);
});
client.on('psubscribe', function (pattern, count) {
console.log('psubscribe pattern: ' + pattern);
console.log('psubscribe count: ' + count);
});
client.on('pmessage', function (pattern, channel, message) {
console.log('pmessage pattern: ' + pattern);
console.log('pmessage from channel: ' + channel);
console.log('pmessage message: ' + message);
res.write("data: " + message + '\n\n');
});
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
res.write('\n');
我没有收到从服务器到客户端的任何更新(服务器从 redis 正确接收消息)。
如果我刷新服务器,我会收到此错误:net::ERR_INCOMPLETE_CHUNKED_ENCODING
我是 SSE 的新手,所以我可能做错了。希望得到您的帮助。
解决方案是每次需要向客户端发送消息时写res.flush()
,在我的例子中:
client.on('pmessage', function (pattern, channel, message) {
console.log('pmessage pattern: ' + pattern);
console.log('pmessage from channel: ' + channel);
console.log('pmessage message: ' + message);
res.write("data: " + message + '\n\n');
res.flush();
});
已解决。
我从 Redis 数据库接收更新(消息),我需要在客户端实时显示这些消息,为此我使用 SSE(服务器发送的事件)。
因此,我的代码如下所示:
客户端javascript:
var source = new EventSource('/updates');
source.addEventListener('pmessage', function(e) {
console.log('Event: ' + e.event);
console.log('Data: ' + e.data);
}, false);
服务器端(Node + Express):
req.socket.setTimeout(Infinity);
var redisURL = url.parse(process.env.REDISCLOUD_URL);
var client = redis.createClient(redisURL.port, redisURL.hostname, {ignore_subscribe_messages: true});
client.auth(redisURL.auth.split(":")[1]);
client.psubscribe('updates');
client.on('error', function (err) {
console.log('Error: ' + err);
});
client.on('psubscribe', function (pattern, count) {
console.log('psubscribe pattern: ' + pattern);
console.log('psubscribe count: ' + count);
});
client.on('pmessage', function (pattern, channel, message) {
console.log('pmessage pattern: ' + pattern);
console.log('pmessage from channel: ' + channel);
console.log('pmessage message: ' + message);
res.write("data: " + message + '\n\n');
});
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
res.write('\n');
我没有收到从服务器到客户端的任何更新(服务器从 redis 正确接收消息)。
如果我刷新服务器,我会收到此错误:net::ERR_INCOMPLETE_CHUNKED_ENCODING
我是 SSE 的新手,所以我可能做错了。希望得到您的帮助。
解决方案是每次需要向客户端发送消息时写res.flush()
,在我的例子中:
client.on('pmessage', function (pattern, channel, message) {
console.log('pmessage pattern: ' + pattern);
console.log('pmessage from channel: ' + channel);
console.log('pmessage message: ' + message);
res.write("data: " + message + '\n\n');
res.flush();
});
已解决。