草庐IT

node.js - Redis Pub/Sub 聊天室

coder 2023-11-08 原文

我是 Redis 发布/订阅的新手，所以请多多包涵。我正在尝试创建一个 IRC，用户可以在其中创建自己的聊天室，有点像 Gitter。以下是我到目前为止所做的。我通过用户名将用户订阅到不同的 channel 只是为了测试。事情是当我发布到 channel x 时，订阅到 channel y 的客户仍然得到相同的消息..我正在使用 redis-cli 和 PUBLISH 命令发布。

function handleIO(socket){
    function disconnect(){
        console.log("Client disconnected");
        socket.broadcast.emit("user d/c", socket.username+" has left!");
    }

    socket.on("new user", function(username){
        socket.username = username;

        if(socket.username == "chat"){
            redisClient.subscribe("chat");
        }else{
            redisClient.subscribe("other");
        }

        socket.userColor = '#'+(Math.random()*0xFFFFFF<<0).toString(16);
        socket.emit("new_user", username);

        emitter.lrange("messages", 0, -1, function(err, messages){
            //reversing to be in correct order
            messages = messages.reverse();

            messages.forEach(function(message){
                message = JSON.parse(message);
                socket.emit("messages", message);
            });
        });

        socket.broadcast.emit("user connection", username+" has connected to the Haven!");
    });
    socket.on("disconnect", disconnect);

    socket.on("send", function(msg){
        var msg = JSON.stringify( { name: socket.username, messageText: msg, color: socket.userColor } );

        emitter.lpush("messages", msg, function(err, response){
            //keep newest 10 items
            emitter.ltrim("messages", 0, 9);
        });
        io.sockets.emit("receive", msg, socket.userColor);
    });
    redisClient.on("message", function (channel, message) {
        console.log(channel+":"+message);
        socket.emit("message", channel, message);
    });

}

最佳答案

对于那里迷路的流浪者...我所做的是在客户端上实现另一个事件，基本上检查该客户端是否“有权”接收消息(即，如果消息的 channel 是否属于客户端的子 channel 列表，则那讲得通)。

客户端

socket.on("message", function(channel, message){
     socket.emit("entitled", channel, message);
});

socket.on("entitled", function(reply, channel, message){
     if(reply == 1){
          $("#msgArea").append(message+"<br/>");
          $("#msgArea").prop({ scrollTop: $("#msgArea").prop("scrollHeight") });    
     }
});

服务器端

socket.on("entitled", function(channel, message){
    //check that user is subbed 
    emitter.sismember('channels:'+socket.username, channel, function(err, reply){
        if(err) throw err;
        socket.emit("entitled", reply, channel, message);
    });
});

我故意遗漏的是，我没有继续使用 socket.username，而是开始使用 session 来保持持久性。我的建议是坚持使用 redis 存储，因为它是 github 上最受欢迎的存储之一。

关于node.js - Redis Pub/Sub 聊天室，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/33223678/

Redisnode34socketmessagenode.jssocket.iopublish-subscribe

有关node.js - Redis Pub/Sub 聊天室的更多相关文章

  1. ruby-on-rails - Assets 管道损坏 : Not compiling on the fly css and js files - 2

    我开始了一个新的Rails3.2.5项目，Assets管道不再工作了。CSS和Javascript文件不再编译。这是尝试生成Assets时日志的输出:StartedGET"/assets/application.css?body=1"for127.0.0.1at2012-06-1623:59:11-0700Servedasset/application.css-200OK(0ms)[2012-06-1623:59:11]ERRORNoMethodError:undefinedmethod`each'fornil:NilClass/Users/greg/.rbenv/versions/1

  2. ruby-on-rails - Rails - 理解 application.js 和 application.css - 2

    rails新手。只是想了解\assests目录中的这两个文件。例如，application.js文件有如下行://=requirejquery//=requirejquery_ujs//=require_tree.我理解require_tree。只是将所有JS文件添加到当前目录中。根据上下文，我可以看出requirejquery添加了jQuery库。但是它从哪里得到这些jQuery库呢？我没有在我的Assets文件夹中看到任何jquery.js文件——或者直接在我的整个应用程序中没有看到任何jquery.js文件？同样，我正在按照一些说明安装TwitterBootstrap(http:

  3. node.js - 如何在 Travis CI 上的一个项目中运行 Node.js 和 Ruby 测试 - 2

    我有一个包含多个组件的存储库，其中大部分是用JavaScript(Node.js)编写的，一个是用Ruby(RubyonRails)编写的。我想要一个.travis.yml文件来触发一个运行每个组件的所有测试的构建。根据thisTravisCIGoogleGroupthread，目前还没有官方支持。我的目录结构是这样的:.├──构建服务器├──核心├──扩展├──网络应用├──流浪文件├──package.json├──.travis.yml└──生成文件我希望能够运行特定版本的Ruby(2.2.2)和Node.js(0.12.2)。我已经有了一个make目标，所以maketest在每

  4. ruby - 为什么 String::sub!() 会更改 Ruby 中克隆对象的原始对象？ - 2

    我的Ruby代码中有一个看起来有点像这样的结构Parameter=Struct.new(:name,:id,:default_value,:minimum,:maximum)稍后，我使用创建了这个结构的一个实例freq=Parameter.new('frequency',15,1000.0,20.0,20000.0)在某些时候，我需要这个结构的精确副本，所以我调用newFreq=freq.clone然后，我更改newFreq的名称newFreq.name.sub!('f','newF')奇迹般地，它也改变了freq.name!像newFreq.name='newFrequency'这样

  5. (附源码)vue3.0＋.NET6实现聊天室(实时聊天SignalR) - 2

    参考文章搭建文章gitte源码在线体验可以注册两个号来测试演示图：一.整体介绍　　介绍SignalR一种通讯模型Hub(中心模型，或者叫集线器模型)，调用这个模型写好的方法，去发送消息。　　内容有：　　　　①：Hub模型的方法介绍　　　　②：服务器端代码介绍　　　　③：前端vue3安装并调用后端方法　　　　④：聊天室样例整体流程：1、进入网站->调用连接SignalR的方法2、与好友发送消息->调用SignalR的自定义方法 前端通过，signalR内置方法.invoke()  去请求接口3、监听接受方法（渲染消息）通过new signalR.HubConnectionBuilder().on

  6. 智能客服 | 浅谈人工智能聊天机器人ChatGPT - 2

    2022年底，OpenAI的预训练模型ChatGPT给人工智能领域的爱好者和研究人员留下了深刻的印象和启发，他展现的惊人能力将人工智能的研究和应用热度推向高潮，网上也充斥着和ChatGPT的各种聊天，他可以作诗、写小说、写代码、讨论疫情问题等。下面就是一些他的神回复：人命关天的坑： 写歌，留给词作者的机会不多了。。。 回答人类怎么样面对人工智能： 什么是ChatGPT？借用网上的一段介绍，ChatGPT是由人工智能研究实验室OpenAI在2022年11月30日发布的全新聊天机器人模型，一款人工智能技术驱动的自然语言处理工具。它能够通过学习和理解人类的语言来进行对话，还能根据聊天的上下文进行互动

  7. ruby-on-rails - ruby open ssl api for encrypted key (without nodes option) - 2

    在安装了openssllib的linux机器上，当您执行带有“-nodes”选项的“opensslpkcs12”时，您将获得带有未加密私钥的输出，但如果您跳过–nodes选项，则输出将具有加密的私钥。e.g.opensslpkcs12-intest.pfx-outtest.pem你应该看到像下面这样加密的私钥-----BEGINENCRYPTEDPRIVATEKEY-----MIIFDjBABgkqhkiGG7s=-----ENDENCRYPTEDPRIVATEKEY-----如何使用ruby​​的开放ssl库实现上述目标？这就是我用ruby​​生成私钥的方式:@private_key

  8. node.js - 从未编写过任何自动化测试，我应该如何开始行为驱动开发？ - 2

    按照目前的情况，这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持，但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开，visitthehelpcenter指导。关闭9年前。多年来，我一直在使用多种语言进行编程，并且认为自己总体上相当擅长。但是，我从未编写过任何自动化测试:没有单元测试，没有TDD，没有BDD，什么都没有。我已经尝试开始为我的项目编写适当的测试套件。我可以看到在进行任何更改后能够自动测试项目中所有代码的理论值(value)。我可以看到像RSpec和Mocha这样的测试框架应该如何使设置和运行所述测试变得相当容易

  9. ruby - 使用 Ruby 构建聊天应用程序 - 2

    我正在尝试构建一个纯粹使用Ruby的聊天应用程序。有一个similarquestion较早发布，但我有不同的相关查询。我看过thisexample(与之前发布类似问题的人所提到的相同)。示例中的代码似乎对我不起作用。在终端上运行ruby​​脚本，并连接到url:http://localhost:1234在我的浏览器中，我无限期地遇到“正在从本地主机传输数据...”消息。此处的1234是所提供示例中使用的端口号。我无法弄清楚我运行失败的原因是什么。可能是我需要在执行脚本时在命令行中指定一些东西，或者我应该通过其他地方(可能是浏览器)开始聊天(输入输出)。我无法弄清楚到底该做什么。你能帮我

  10. ruby-on-rails - 将 Angular JS 与 Rails 集成 - 2

    我需要一些指导来了解如何将Angular整合到rails中。选择Rails的原因:我喜欢他们偏执的做事方式。还有迁移，gem真的很酷。使用angular的原因:我正在研究和寻找最适合SPA的框架。Backbone似乎太抽象了。我不得不在Angular和Ember之间做出选择。我首先开始阅读Angular，它对我来说很有意义。所以我从来没有去读过关于ember的文章。使用Angular和Rails的原因:我研究并尝试使用小型框架，例如grape、slim(是的，我也使用php)。但我觉得需要坚持项目的长期范围。我个人喜欢用Rails的方式做事。这就是我需要帮助的地方，我在Rails4中有

随机推荐