在node.js上使用socket-io的Http服务器没有运行
Http server with socket-io on node.js doens't running
我在node.js上使用socket-io的http服务器没有运行。我使用npm install socket-io
和运行服务器。
服务器的代码
var static = require('node-static');
var http = require('http');
// Create a node-static server instance
var file = new(static.Server)();
// We use the http moduleÕs createServer function and
// rely on our instance of node-static to serve the files
var app = http.createServer(function (req, res) {
file.serve(req, res);
}).listen(8181);
// Use socket.io JavaScript library for real-time web applications
var io = require('socket.io').listen(app);
// Let's start managing connections...
io.sockets.on('connection', function (socket){
// Handle 'message' messages
socket.on('message', function (message) {
log('S --> got message: ', message);
// channel-only broadcast...
socket.broadcast.emit('message', message);
});
// Handle 'create or join' messages
socket.on('create or join', function (room) {
/*var namespace = '/';
for (var numClients in io.nsps[namespace].adapter.rooms[room]) {
console.log(numClients);
}*/
//var numClients = io.sockets.clients(room).length;
var numClients = io.sockets.adapter.rooms[room]!=undefined ? Object.keys(io.sockets.adapter.rooms[room]).length:0;
log('SERVER: CLIENTS ' + room + ' has ' + numClients + ' client(s)');
log('S --> Room ' + room + ' has ' + numClients + ' client(s)');
log('S --> Request to create or join room', room);
// First client joining...
if (numClients == 0){
socket.join(room);
socket.emit('created', room);
} else if (numClients == 1) {
// Second client joining...
io.sockets.in(room).emit('join', room);
socket.join(room);
socket.emit('joined', room);
log('S: sent JOIN message');
} else { // max two clients
socket.emit('full', room);
}
});
function log(){
var array = [">>> "];
for (var i = 0; i < arguments.length; i++) {
array.push(arguments[i]);
}
socket.emit('log', array);
}
});
当这是客户端连接到套接字的代码:
var room = getParameterByName('room_name');
alert ("room_name: "+room);
// Connect to signalling server
var socket = io.connect();
// Send 'Create or join' message to singnalling server
if (room !== '') {
console.log('Create or join room', room);
socket.emit('create or join', room);
}
使用netstat -a
命令,我看到了服务器的端口是活动的。但是它不发送消息。
我有另一个问题:服务器如何发送消息不广播,但指定的对等连接?我的意思是:而不是
socket.on('message', function (message) {
log('S --> got message: ', message);
// channel-only broadcast...
socket.broadcast.emit('message', message);
});
我该怎么办?谢谢!
我有另一个问题:服务器如何发送消息而不是广播,但是要连接到指定的对等体?
你的问题的第二部分是,你只是做socket.emit()
发送到一个套接字,像这样发送回同一个套接字,刚刚发送给你一个消息:
socket.on('message', function (message) {
log('S --> got message: ', message);
// channel-only broadcast...
socket.emit('message', "got your message");
});
或者,如果您有其他连接的客户端的套接字id值,您可以在服务器上获取该套接字,如下所示:
io.sockets.connected[id].emit(...)
相关文章:
- 我无法使用angularJs($http)访问服务器
- 什么's本地node.js服务器和python简单http服务器之间的区别
- 角度http服务器页面刷新404s
- JSON-从浏览器向外部服务器发送哪些http头JSON文件
- Node.js-查找http服务器正在侦听的端口
- HTTP服务器在一段时间后停止(Node.js)
- 我如何设置HTTP头“;访问控制允许起源”;用于来自thttpd web服务器的HTTP响应
- 使用角度$http.get从服务器下载文件
- 如何在 http 上调用 end().服务器响应对象
- 当服务器从 http 更改为 https 时,有哪些可能的方法可以解决问题
- Node http-proxy-middleware 不能与本地服务器一起工作
- Nodejs向http服务器发送命令以突出显示或着色DOM元素
- Angular$http.jsonp-服务器don'不接受JSON_CALLBACK
- 从服务器获取数据,并使用$http服务和ng-change在select事件上显示它
- 具有http服务器、websocket和express的体系结构
- 通过HTTP服务器上的父级目录访问HTML中的JavaScript文件
- Angular$http.post未到达服务器
- node.js http服务器并发问题
- 无法使用angularjs$http请求将参数发送到服务器操作方法
- 如何在浏览器中存储服务器HTTP响应头