Tag: 套接字

Web应用程序体系结构 – 使用NodeJS发布订阅模式

对不起,如果这不是典型的计算器的问题。 但是,我相信这里有一个“最佳实践”的答案,我只是对nodeJS没有经验而知道。 我正在使用推送器API来接收一些数据。 目前我正在将它们保存在mysql中,并在表单中以快捷方式显示,并在浏览器中显示为graphics。 不过,我的用例略有不同。 当数据通过推送器api到达时,我想更新所有连接客户端的浏览器视图(表格+图表)。 我读了很多关于socket.io,并猜测“更新客户端”浏览器可以通过使用它。 但是,我正在努力通知我的应用程序的一部分,我的数据库中已经插入了一些新的数据。 我绝对需要在我的应用程序中的某种forms的Publish/Subscribe模式。 应用程序订阅数据库并通过socket.io将其推送到视图。 任何build议如何实施一个简单的方法? 我感谢你的回答!

id没有定义(sails.socket.emit)

我只是试图使用sails.socket.emit()发送消息,我得到这个: error: Sending 500 ("Server Error") response: Error (SAILS:HOOK:SOCKETS:USAGE):: `sails.sockets.get()` cannot lookup socket w/o an id (got: `undefined`) 控制器中的代码: sayHiToFriend: function(req, res) { var friendId = req.param('id'); sails.sockets.emit(friendId, 'privateMessage', {from: req.session.userId, msg: 'Hi!'}); res.json({ message: 'Message sent!' }); } 和客户端: io.socket.get('/user/sayHiToFriend', function serverSays(err,users){ console.log('with headers: ', JWR.headers); console.log('and with status code: ', JWR.statusCode);*/ if (err) […]

在Socket.io演示中集成QT客户端

我是一个初学者,并想了解如何使用node.js , socket.io和QT来实现这个小应用程序。 我做了一个服务器端的聊天,按照socket.io/get-started/chat/的教程。 现在我想创build一个桌面客户端(QT和C ++),利用相同的服务器nodejs。 我怎样才能得到这个? [草图] 我很抱歉我的英文不好。 谢谢你们! 🙂

ASP.NET中的Socket.IO服务器替代

其实我正在运行一个node.js应用程序托pipe一个socket.io服务器和restify。 因为逻辑变得越来越复杂,我想转移到一个asp.net应用程序。 Restful服务可以通过APS.NET WebAPI完成。 如何集成与socket.io-clients兼容的新的socket.io服务器?

如何在Sails.js中侦听来自套接字的消息?

所以我想听从我的Sails.js应用程序中的套接字获得的消息。 我怎样才能做到这一点? 有什么像socket.io方法?

使用Express 4模块化Socket.io

我试图模块化我的应用程序文件,我有问题与Socket.io 。 我想在我的routes.js使用io。 像这样的东西: var router = require('express').Router(); var io = require('./sockets/my-io'); router.get('/', function(req, res) { io.emit('request-detected'); }); module.exports = router; 但我不能这样做,因为socket.io需要应用程序服务器,而当我位于routes.js文件中时,应用程序服务器不在侦听或正在导出。 你能给我一个解决scheme,或任何其他方法来解决这个问题吗? 这是我的,如果可能的话,我想保持文件结构 : app.js var app = require('express')(); var routes = require('./routes'); /* … */ app.use('/contacts', routes); module.exports = app; 斌/ WWW #!/usr/bin/env node var app = require('../wallet'); var server = app.listen(port, function() […]

帆没有方法“subscribeToFirehose”

我正在试图创build文档中定义的Firehosefunction。 它似乎是直接的(代码如下),但它只是不断给出一个错误: TypeError: Object #<Object> has no method 'subscribeToFirehose' 控制器: module.exports = { /** * `UserController.index()` */ index: function (req, res) { if (!req.isSocket) return res.badRequest(); sails.sockets.subscribeToFirehose(req.socket); // sails.sockets.subscribeToFirehose(req.socket); return res.ok(); } };

ZMQ pub / sub订阅

我很难弄清楚如何使用ZMQ来订阅特定的“频道”,关于它的发布/订阅function。 这是出版商: var zmq = require('zmq'); var pub = zmq.socket('pub'); pub.bindSync('tcp://127.0.0.1:5555'); setInterval(function(){ pub.send('pub msg'); },500); 这里是订户: var sub = zmq.socket('sub'); sub.connect('tcp://127.0.0.1:5555'); sub.subscribe(''); //herein lies the question sub.on('message',function(msg){ console.log('Received msg:',msg); } 这是按原样,但问题是,如果我将参数更改为sub.subscribe除了空string('')的任何内容,订阅服务器不会收到来自发布服务器的任何消息。 如何正确configurationZMQ的pub / sub?

我得到一个fs.js:347新的TypeError('坏论点');

我试图按照Node.js创build一个路由器的教程。 这是路由器的代码 var http = require("http"); var url = require('url'); var fs = require('fs'); var server = http.createServer(function(request, response){ console.log('Connection'); var path = url.parse(request.url).pathname; switch(path){ case '/': response.writeHead(200, {'Content-Type': 'text/html'}); response.write('hello world'); break; case '/socket.html': fs.readFileSync(__dirname + path, function(error, data){ if (error){ response.writeHead(404); response.write("opps this doesn't exist – 404"); } else{ response.writeHead(200, {"Content-Type": "text/html"}); response.write(data, […]

如何确保Sails.js中的蓝图访问

所以我对Sails.js来说很新,但是它似乎像这些蓝色的印刷品一样, 现在我有2个模型, Accounts / Friends 它是使用关联作为Accounts有很多Friends 在我的客户端,我有一种方法可以向用户发送通知,其中一个是朋友请求,因此可以正常工作,并允许用户select接受或拒绝邀请 代码如下: socket.on('accounts', function(data) { if (data.verb === "addedTo" && data.attribute === "notifications") { socket.get('/notifications/' + data.addedId, function(note) { console.log(note); if (!$.isEmptyObject(note)) { $scope.notifications.push({ 'text': note.from_name + ' sent you a friends request', 'id': note.id, 'type': note.type, 'from_id': note.from_id }) $.notify('You have a new notification', 'info'); $scope.$digest(); } }) […]