gpt4 book ai didi

javascript - redis sub/pub 进出 io.connect 回调

转载 作者:可可西里 更新时间:2023-11-01 11:21:41 27 4
gpt4 key购买 nike

如果我想将数据发送给所有连接的人,是否应该将 redis 订阅事件放在 io.connect 回调之外?或者像这样将它放在 io.connect 中更好:

    io.on('connection', function(socket){ 
sub.on('message',function(channel,msg){
Project.findAll({ where: {id: msg} },{raw:true}).success(function(d) {
console.log(d);
io.sockets.emit("activities",d);
})
});
});

会有什么不同吗?

Node .js

var express = require('express'),
app = express(),
http = require('http').createServer(app),
io = require("socket.io").listen(http),
redis = require("redis"),
Sequelize = require('sequelize');

var pub = redis.createClient();
var sub = redis.createClient();
sub.subscribe('global');

app.get('/p/:tagId', function(req, res){
res.render('index.html')
});

sub.on('message',function(channel,msg){
Project.findAll({ where: {id: msg} },{raw:true}).success(function(d) {
console.log(d);
io.emit("activities",d);
})
});

io.on('connection', function(socket){

//** code **//
})

谁能告诉我 node.js 的代码有什么问题?

最佳答案

您的第二个代码示例看起来是正确的。您不想将 sub.on('message', function(channel, msg) { 放在 socket.io 连接处理程序中。这会在每次有人连接时添加一个新的事件处理程序。

你测试过它是否有效吗?您需要将某些内容发布到 channel global 以触发 message 回调。

pub.publish('global', 'here is a message');

关于javascript - redis sub/pub 进出 io.connect 回调,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27616576/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com