当前位置: 首页 > 知识库问答 >
问题:

将socket.io消息路由到快速路由

霍永年
2023-03-14

我正在考虑将Socket.io集成到一个express应用程序中。

js有一个非常好的特性,可以通过socket.io消息调用快速路由。

不过,帆在其他方面比我需要的要多一点。我正在寻找一种方法,使socket.io请求转发到快速路由,而不必使用整个sails框架。我想这是一个很常见的需求,所以我很惊讶我没有找到一个npm模块来做这件事,但是找了很长时间,我什么也没有找到。Express.io会这样做,但相反,它会将HTTP请求路由到socket.io处理程序。

澄清一下,我想使用我现有的以通常方式构建的express应用程序...

null

var express = require('express');
var app = express();

app.get('/', function (req, res) {
  res.send('Hello World!');
});

null

然后在socket.io中链接,以便可以使用HTTP调用Get/或使用socket.io在客户端上执行快速路由/

null

socket.emit('GET', '/', function(response) {
  // do something with the response
});

null

理想情况下,它还可以在express和Socket.io之间共享会话/身份验证(我从其他关于堆栈溢出可能的帖子中看到了这一点)。

我可以自己编写这个代码,但我不敢相信没有现成的解决方案或npm模块已经这样做了!

共有1个答案

计弘
2023-03-14

如果我正确理解这个问题,您希望能够通过套接字事件或REST端点在服务器端访问相同的业务逻辑。如果您在服务器端有适当的关注点分离,这是完全可行的。例如:

假设您有一个从数据存储服务器端提取的对象数组:

DataAccess.js:

function DataAccessor(){}

DataAccessor.prototype.getObjects = function(){
  var myObjects = new Array();
  return myObjects;
}


app.js //Routing for the REST endpoint and socket handling

app.get('/objects', function(req, res){
  res.send(new DataAccessor().getObjects());
});

var io = require('socket.io').listen(server);
io.sockets.on('connection', function (newSocket){
     newSocket.on('objects',function(){
      socket.emit('objectsSent',new DataAccessor().getObjects());
    });
});

在上面的示例中,客户端可以通过对“/objects”的GET请求调用REST端点来检索JSON集合。通过socket.emit激发一个名为'objects'的客户端套接字事件也会导致服务器发送相同的集合作为响应消息。

作为示例客户端,这两个段的操作类似:

REST:
$.get("/objects",function(objectCollection){console.log(objectCollection);});

Sockets:
socket.on('objectsSent',function(objectCollection){console.log(objectCollection);});
socket.emit('objects');
 类似资料:
  • 问题内容: 我正在尝试将Socket.io与Node.js结合使用,并在路由逻辑内发送到套接字。 我有一个相当标准的Express 3安装程序,其中的server.js文件位于该路由中,然后我的index.js位于一个routes文件夹中,该文件夹导出站点的所有页面/公共可访问功能。因此,它们看起来像: 在server.js中定义的路由如下: 我假设我必须在server.js中创建socket.i

  • 问题内容: 我在Socket.io中使用Express,但我不知道如何在Express路由中使用SocKet.io。 我最终在“ app.js”中这样做 我该如何定义到“ / cmp”的路由,并在其中传递var“ io”? 这样,在“ /routes/cmp.js”中,我可以执行以下操作: 一些线索? 问题答案: 高阶函数呢? 然后 作为另一种选择,有时我会将路线的格式设置为以下格式: 然后定义为

  • 我正在使用ActiveMQ Artemis 2.17.0,并且面临路由问题。 我实现了一个插件,它记录了before消息路由,我看到一些消息从路由到。 没有转移设置,主题和队列由生产者和消费者动态创建。有一个将目标映射到虚拟主题的设置 和都是有效的主题,但它们不应该被链接。 什么能解释这种行为?

  • 我们将结束数据结构和算法的部分,并将数据结构用于实际问题。我已经写了几个 Web 服务器,一个不断出现的问题是,将 URL 路径匹配到“动作”。你会在每个 Web 框架,Web 服务器,和必须基于层次化的键来“路由”信息的任何东西中发现此问题。当你的 Web 服务器收到URL /do/this/stuff/时,必须确定每个部分是否可能附加了某种操作或配置。如果你在/do/配置了 Web 应用程序,

  • 我们在前面的一小节介绍了一个简单的 Flask 程序是怎么运行的。其中,有三行代码,我们并没有深入讲解。在这里,我们就对它们进行深入解析。回顾这三行代码: @app.route("/") def hello(): return "Hello World!" 这三行代码的意思就是:如果浏览器要访问服务器程序的根地址(”/“),那么 Flask 程序实例就会执行函数 hello() ,返回『H

  • 在RabbitMQ中,可以创建一个交换,然后将其绑定到多个队列,每个队列都有一个路由密钥。这使得消息传递体系结构如下所示: 客户端将消息发布到exchange中,该exchange只将路由密钥为“foo”的消息路由到队列,只将路由密钥为“bar”的消息路由到队列,所有消息都路由到队列。 我很难弄清楚如何在AWS中做到这一点。我首先想到的是在各个队列上设置权限,以接受基于主题的消息,但权限条件的唯一