Tag: 套接字

客户端和服务器端的“断开连接”事件(套接字I / O)

客户端:当pingTimeout通过后,客户端没有收到服务器的pong响应,调用socket.on('disconnect') (请参考这个 ) 服务器端:同样,服务器也有每个套接字实例的disconnect事件。 什么时候在服务器上触发这个事件? 是否有特定的超时,这也像客户端disconnect事件。 io.sockets.on('connection', function(client){ client.on('disconnect', function(room){ /// }); }

如何使PHP和NodeJS通过套接字进行通信?

我正在使用(Node Js + Socket.io)向现有的PHP应用程序添加实时通知。 我创build客户端的一部分,现在我想通过套接字通知NodeJs服务器。 我发现其他的解决scheme,然后sockets: Sharing data via redis (hard to implement). DNode Library. 我最简单的方法是使用本机函数(节点服务器)和curl(PHP)的HTTP请求。 请问是否有任何例子开始?

如何使用socket.io-redis获取所有连接的套接字?

我有我的多个节点通过socket.io-redis运行,一切都工作正常,因为我从另一个事件发送到1服务器。 我想要在多个服务器上获得连接套接字的完整列表,因为我必须相应地操作它们的键,就像在简单的socket.io的io对象中一样,我得到一个包含所有套接字的hashmap。

Socket.io,redis和redis消息队列

我正在使用基于以下代码的SocketIO和Redis, var sub = redis.createClient(); var pub = redis.createClient(); sub.subscribe('chat'); io.use(socketHandshake({store: sessionStore, key:'jsessionid', secret:'secret', parser:cookieParser()})); io.on('connection', function (socket) { socket.on('chat', function (message) { // io.emit('chat', "hello world"); pub.publish('chat', "hello world"); }); sub.on('message', function (channel, message) { io.emit(channel, message); }); }); 这是基本代码。 我已经修改了代码,以便如果有任何用户下线,在服务器端,我在RSMQ(Redis简单消息队列)中存储消息,当用户上线时,消息从队列中提取并发送给用户。我已经使用下面的代码来实现这一点。我已经将用户状态存储在一个数组中。 var fs = require('fs') , http = require('http') , socketio = require('socket.io'); var […]

Node.js服务器说,请求被取消,客户说套接字挂断

您好,我正在Loopback上的Node.js平台上的REST API上工作。 我在Linux Mint 17 Quianatesting。 与Multipart / form-data请求相关时,遇到问题。 testing是: it('Multipart request with two files, one right', function(done) { var formData = { 'dailyThemesId':'1', 'themeId':'1', 'pictureTimeZone':'GTM+1', 'pictureText':'Pretty pics', file: { value: fs.createReadStream('./test/File/fileSuperSmall.mp4'), options: { filename: 'video.mp4', contentType: 'video/mp4' } }, video: { value: fs.createReadStream('./test/File/fileSuperSmall.mp4'), options: { filename: 'video.mp4', contentType: 'video/mp4' } } }; request2.post({url: 'http://0.0.0.0:3000' […]

Node.js HLTV scorebot无法正常工作

我无法绕过Node.js hltv scorebot( https://github.com/Nols1000/hltv-scorebot ),但当我连接到匹配id的hltv服务器时,我没有得到任何关于匹配的日志。 它只是做一些没有任何价值的日志,没有任何人抓住匹配hltv的实时数据,除了这个API之外,还有其他的方法可以做到这一点。 这是我的代码 var Scorebot = require('hltv-scorebot'); var io = require('socket.io').listen(8080); var client = io.sockets; client.on("connection", function(socket){ console.log("connected"); var match_id = socket.request._query['matchid']; console.log("match_id is " + match_id); var sb = new Scorebot(); sb.connect('http://scorebot.hltv.org',10022,478323); sb.on('kill', function(killer, victim, weapon, headshot, assister) { console.log("kill event"); console.log(killer, victim, weapon, headshot, assister); var killerName = killer.name; […]

NodeJS – 间歇性地出现“错误:此sockets已closures”

请参阅下面的错误,我正在调用一个nodeJS路由。 我在另一条路线也看到相同的exception。 两条路线都有做MongoDB操作的方法。 这是间歇性的,只发生在处理数据库中的值的两个API调用中。 { date: 'Thu Sep 15 2016 04:16:46 GMT-0500 (EST)', process: { pid: 4424, uid: 0, gid: 0, cwd: '***rootFolder***', execPath: '/usr/bin/node', version: 'v6.3.1', argv: [ '/usr/bin/node', '**rootfolder**/app.js' ], memoryUsage: { rss: 104415232, heapTotal: 77893632, heapUsed: 60997696 } }, os: { loadavg: [ 0.03564453125, 0.06103515625, 0.0625 ], uptime: 3184925 }, trace: [ […]

套接字在服务器端代码节点内发射

我使用MEAN堆栈,与angularjs前端,节点后端。 有可能使一个套接字在一些函数内发出呼叫吗? 我只是intrested向客户端发送数据。 或者如何推动服务器双方工作,也可以用套接字来完成? 客户端请求如下服务器端 var bankfactory = require(path.resolve('./modules/articles/server/factory/user_factory.js')); app.post('/api/bank', function (req, res) { bankfactory.bank_inn(req.user._id,amount).then( function (bankresult) { res.json(bankresult); }); }); bankfactory: exports.bank_inn = bank_inn; function bank_inn(playerid,amount) { if (playerid == 1) { } else { // possible to make a emit call to the client here? //emit("newevent,datahere) } } 是否有可能在那里发射sockets?

Amazon S3:与服务器的套接字连接在超时期限内未读取或写入

我正在使用s3软件包将file upload到S3: https : //www.npmjs.com/package/s3 。 我写了下面的代码(基于代码示例): var s3 = require('s3'); var client = s3.createClient({ maxAsyncS3: 20, // this is the default s3RetryCount: 3, // this is the default s3RetryDelay: 1000, // this is the default multipartUploadThreshold: 20971520, // this is the default (20 MB) multipartUploadSize: 15728640, // this is the default (15 MB) s3Options: […]

使用socket.io中的每个socket.emit获取多个套接字响应

这里是我的代码示例,我正在使用单个套接字发出同一个用户的多个套接字响应。 有时在每个服务器重新启动时,它也会增加+1个增量。 …. socket.emit('groupmessage', { username: sender_id, server_chat_id:chat_id, user_message:"ownmessage", server_time:server_time, message: new_message, action: "ownmessage", temp: 'new' }); ….