syndilights/displayclienthtml/websocket_demo/ws_server.js

69 lines
1.6 KiB
JavaScript
Raw Normal View History

2013-09-01 22:54:51 +02:00
var count = 0;
var clients = {};
var http = require('http');
var server = http.createServer(function(request, response) {});
server.listen(1234, function() {
console.log((new Date()) + ' Server is listening on port 1234');
2013-09-01 22:54:51 +02:00
});
var WebSocketServer = require('websocket').server;
wsServer = new WebSocketServer({
httpServer: server
2013-09-01 22:54:51 +02:00
});
wsServer.on('request', function(r) {
2013-09-01 22:54:51 +02:00
var connection = r.accept('echo-protocol', r.origin);
// Specific id for this client & increment count
var id = count++;
// Store the connection method so we can loop through & contact all clients
2013-09-01 22:54:51 +02:00
clients[id] = connection
console.log((new Date()) + ' Connection accepted [' + id + ']');
clients[id].sendUTF("Welcome to the server. You are connected. This message has been pushed to you.");
2013-09-01 22:54:51 +02:00
// Create event listener
connection.on('message', function(message) {
// The string message that was sent to us
var msgString = message.utf8Data;
// Loop through all clients
for(var i in clients){
// Send a message to the client with the message
clients[i].sendUTF(msgString);
}
});
// Create event listener for close
connection.on('close', function(reasonCode, description) {
delete clients[id];
console.log((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
2013-09-01 22:54:51 +02:00
});
});
var sendTime = function () {
var now, i = 0;
2013-09-01 22:54:51 +02:00
// get time now
now = new Date();
2013-09-01 22:54:51 +02:00
// send time to all clients
for(i in clients) {
// Send a message to the client with the message
clients[i].sendUTF(now);
}
// repeat in 5 seconds
setTimeout(sendTime, 5000);
};
// every 5 seconds send the date/time
setTimeout(sendTime, 5000);