Tag: socket.io

是否有一个函数来拦截客户端的服务器上的所有socket.io数据

socket.io客户端代码可以使用这个 var socket = io('http://localhost:8888'); socket.on('news', function (data) { socket.emit('my other event', { my: 'data' }); }); 但是我想拦截由socket.io发出的服务器的所有数据，不仅是新闻，然后处理数据。 那可能吗。

Express.js和Socket.io

我正在使用Express和Socket.io构build一个聊天系统。 我想了解这两个框架在这种types的项目中的function是什么，因为咨询我感到困惑的API。 这有什么区别： 使用EXPRESS 3/4 var app = require('express')(); var server = require('http').Server(app); var io = require('socket.io')(server); server.listen(80); app.get('/', function (req, res) { res.sendfile(__dirname + '/index.html'); }); io.on('connection', function (socket) { socket.emit('news', { hello: 'world' }); socket.on('my other event', function (data) { console.log(data); }); }); 和这个： 使用EXPRESS框架 var app = require('express').createServer(); var io = require('socket.io')(app); […]

节点套接字io计时器实现

我正在节点和套接字中创build一个绘图/猜测游戏。 简单地说：我有一个class级， 游戏 （扩展房间）和一个class级（每场10个）。 每轮用户被指定为抽屉，猜测者有45秒的时间来猜测这个单词。 当第一次猜测，如果定时器高于20秒，定时器减less到20秒。 我当然不确定，但是我是这样开始的： 阶级： function Round(id, game){ var ROUNDTIME = 45, timer = new Date(); this.id = id; this.game = game; this.endTime = timer.setSeconds(timer.getSeconds() + ROUNDTIME); … } class级游戏： function Game(){ this.MAX_ROUNDS = 10; this.rounds = []; this.currentRound = null; … } Game.prototype.start = function(){ this.nextRound; } Game.prototype.nextRound = function(){ if(this.rounds.length […]

Google Glass上的Socket.io客户端

我试图让我的谷歌眼镜和我的android手机连接到我在我的电脑上运行的一个NodeJs服务器，以便我可以从我的android手机发送消息到我的谷歌眼镜。 对于这个使用koush的AndroidAsync库的Im，这在我的android手机上效果很好，而且我完全没有把我的手机连接到这个库的NodeJS服务器的麻烦。 然而，相同的代码似乎不能在我的谷歌眼镜工作。 我的Google Glass DOES连接，因为我的NodeJS服务器的连接事件处理程序被触发，它似乎不会触发我的Google Glass上的任何ConnectCallbackfunction。 以下是我在Google Glass应用中使用的代码： SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://192.168.1.229:5000", new ConnectCallback() { @Override public void onConnectCompleted(Exception ex, SocketIOClient client) { Log.i("SOCKET", "CONNECTION COMPLETED"); if (ex != null) { ex.printStackTrace(); return; } client.setStringCallback(new StringCallback() { @Override public void onString(String string, Acknowledge acknowledge) { Log.d("SOCKET", string); } }); client.setJSONCallback(new JSONCallback() { @Override public void onJSON(JSONObject […]

使用stream式JSON输出构build简单的nodejs API

我正在尝试构build一个简单的基于node.js的streamAPI。 所有我想要做的是当我打到服务器的url，输出应该串stream一组testing数据（JSON）像Twitterstream媒体API。 var app = require('express')(); var server = require('http').Server(app); var io = require('socket.io')(server); server.listen(8083); app.get('/', function (req, res) { res.write(io.on('connection', function (socket) { socket.emit('item', { hello: 'world' }); })); }); 所以，如果我curl http://localhost:8083/ ，我想要输出如下所示： $ curl http://localhost:8083/ {hello: 'world'} {hello: 'world'} {hello: 'world'} {hello: 'world'} … 我是新的node.js和networking套接字。 关于节点如何工作的基础知识，我可能是非常错误的，让我知道最好的解决scheme。

如何通过使用Node的HTTPS提供socket.io？

问题： 我只是成功地得到了我的Node.js服务器正常工作，并与SSL安装，很好。 但是我看到这个： [阻止] https://www.mywebsite.com/上的页面通过HTTPS加载，但是从http：//54.xxx.xxx.77：4546 / socket.io / socket.io运行不安全的内容.js '：这个内容也应该通过HTTPS加载。 我试着把socket.io的URL改为https ，但是这当然不起作用，因为socket.io坚持提供它自己生成的文件，这个过程我不认为我能控制。 我可以更改socket.io侦听的端口，就是这样。 问题是： 那么我如何安全地服务socket.io（1.0）？ 代码： var port = 4546; var io = require('/node_modules/socket.io')(port); 作为一个方面说明，我认为socket.io（它的来回通信）应该正常运行HTTPS，没有任何额外的工作; 我在某处读过 也许有人可以证实。 Web套接字的通信必须安全地传输。

套接字，从服务器发送事件到服务器

我有一个服务器设置和客户端 – >服务器事件工作很好，服务器 – >客户端事件也工作。 但是，当我正在写我的数据库我想发出一个服务器 – >服务器（或服务器 – >自我）事件，所以我可以处理asynchronous服务器事件（写入和读取到数据库）。 或者我错误地认为这是可能的在Socket.io环境？ 套接字代码： io.on('connection', function(socket){ socket.emit('uuid', {id: uuid.v1()}); socket.on('add touchEvents', function (data) { if (typeof data !== 'object') return false; var conn = mysql.createConnection(connectionInfo); var checkExistsQuery = "SELECT COUNT(id) AS rows FROM `tbl_heatmap` WHERE UUID='"+data.uuid+"'"; conn.query(checkExistsQuery, function (err, rows) { if (err) { return false; } […]

callback函数socket.io + node.js

有一个客户端和服务器端代码： 客户： socket.on('connect', function() { showSystemMessage('Connected.'); socket.emit('setuser', wm, function(data){ console.log(data); socket.emit('whoisonline', wm, function(data){ getOnlineFriends(data); }); }); }); 服务器： io.on('connection', function(socket) { socket.on('setuser', function (data, cb) { cb(data); }); }); 我收到错误： TypeError：undefined不是第18行的函数 18号线： socket.on('setuser', function (data, cb) { cb(data); // Line 18 }); 然后我尝试了你的解决scheme，我得到了： TypeError: undefined is not a function in line 35 socket.on('whoisonline', function (data, […]

节点套接字io – 在套接字之间以及客户端和服务器之间共享一个全局对象

在socket.io中，对于node.js，是否有办法通过将对象分配给套接字来在客户端和服务器之间交换全局对象？ 或者我必须创build一个发射事件来交换全局对象。 在我的情况下，全局对象是一个数组。

Socket.io 0.9和1.0广播给所有会员

在Socket.io 1.0和Socket.io 0.9中，以下哪种语法是正确的，可将消息广播到一个房间内所有连接的套接字？ 以下都没有发送消息到我的客户端Web控制台，它有一个简单的日志语句，但至less有四个发送到其他客户端。 我怎么会正确地发出一个“joined_channel”消息回我连接的客户端，和房间里的所有其他客户端？ Client socket.on('joined_channel', function(data){ console.log('joined channel', data); }) Server // this is for 0.9 io.sockets.in(data.room).emit('joined_channel', data.room); // which version is this for? Any? socket.broadcast.to(data.room).emit('joined_channel', data.room); // is this to all connected users? io.sockets.emit('joined_channel', data.room); // To all connected users globally? io.emit('joined_channel', data.room); // how is socket different than io? socket.emit('joined_channel', data.room); […]