Tag: 消息

p2p / NodeJS：未logging的代码不会告诉我们如何通过networking发送消息: 我们处于停滞状态，希望能够恢复活力。我们唯一的问题是，它缺less这么多的文档，几乎无法使用。我们可以连接到networking，当人们连接，断开连接以及所有人都在线时显示。这里是有问题的回购。要留意的文件是/lib/node.js（不要与NodeJS本身混淆）。这是我们必须展示的： var Node = require('n2n').Node; var node = new Node(5146); console.log("Connecting to the network…\n\n\n"); node.connect([{ host: 'bradleypl.us', port: 5146 }]); node.on('online', function () { console.log('Your ID:', this.id); console.log('Online ids:', node.sortedIds); }); //just for testing, this will spam the terminal if repeated every time. node.on('node::online', function (newNode) { console.log('Someone is online:', […]

RabbitMQ在ACK之后顺序接收消息: 我正在寻找获得以下模式，以“顺序”与RabbitMQ接收消息。我使用Node.js框架作为消费者。比方说队列中有3条消息，我需要这种模式：接收消息＃1 – >进程 – >发送ACK – >接收消息＃2 – >进程 – >发送ACK接收消息＃3 – >进程 – >发送ACK 但是发生了什么事是node.js消费者并行地接收了所有3条消息，并且RabbitMQ等待个别ACK返回以从队列中移除消息。这不是顺序的。我的队列是耐用的，需要ACK。有什么我失踪？请帮忙！

用户与节点应用程序之间的消息传递: 我想在我的iOS和Android应用程序中实现应用程序内消息，而我不确定应该如何创build后端function。从我的后端运行之前，Node.js和用户等存储在MongoDB。我想我很容易就可以实现消息传递，只需将消息保存在数据库中，然后使用新消息向接收者发送一个消息，并在应用程序中显示消息，但我不希望消息在服务器上可读。因此有必要在数据库中对它们进行encryption，并在客户机上进行解密。有没有人有任何build议可以实现encryption或节点框架使用？我看过socket.io，但这似乎是创build实时聊天应用程序，这不完全是我在找什么。我也看过RabbitMQ，但是我不太明白它是否适合我的要求。提前谢谢了！

如何禁用在控制台中loginmongodb本地驱动程序连接节点: 当我启动连接到mongodb的节点服务器时，我总是得到这些消息告诉我连接的状态。我如何禁用这些消息？ Wed Apr 24 13:28:17 [initandlisten] connection accepted from 127.0.0.1:55221 #304 (1 connection now open) Wed Apr 24 13:28:17 [initandlisten] connection accepted from 127.0.0.1:55222 #305 (2 connections now open) Wed Apr 24 13:28:17 [initandlisten] connection accepted from 127.0.0.1:55223 #306 (3 connections now open) Wed Apr 24 13:28:17 [initandlisten] connection accepted from 127.0.0.1:55224 #307 (4 […]

如何提供持久的redis pubsub: 我正在研究节点socket.io redis项目。实时即时消息正常工作。但是，我想知道如何存储离线消息，以及如何保证消息传递。任何人有想法如何使用以上技术堆栈实现持久酒吧子？欢呼荷马

socket.io和node.js发送消息到特定的客户端: 发送消息到所有的客户端运作良好，但我想发送消息到特定的用户名。我的server.js文件看起来像。当它运行http://localhost:8080 ，客户端代码将用户添加到对象用户名以及套接字对象中。并立即将个别消息返回给每个连接的客户端。 //var io = require('socket.io').listen(8080); var app = require('http').createServer(handler) , io = require('socket.io').listen(app) , fs = require('fs') var usernames={}; app.listen(8080); // on server started we can load our client.html page function handler ( req, res ) { fs.readFile( __dirname + '/client.html' , function ( err, data ) { if ( err […]