Articles of 消息

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 […]

socket.io私人消息

我一直在网上search,没有运气。 我想弄清楚如何发送一个用户的私人消息到另一个。 有很多片段,但我不确定客户端/服务器的交互。 如果我有要发送到的套接字的ID,如何将它发送到服务器,以及如何确保服务器只发送消息到该接收器套接字? 有没有人知道的教程或演练?