套接字 IO 示例

Question

我正在尝试使用套接字 io，以便可以动态更新站点上的数据：

编辑：更新代码

在 app.js 中：

var express = require('express');
var app = express();

var routes = require('./routes/index');
app.use('/', routes);

var server = require('http').createServer(app);
var io = require('socket.io')(server);

  io.on('connection', function(socket){
  socket.emit('news', {hello: 'world'}); 
  socket.on('my other event', function (data) {
  console.log(data);
  });
});

server.listen(app.get('port'), function(){
  console.log('Express listening on port ' + app.get('port'));
});

在 index.ejs 中：

<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('http://localhost:80');
socket.on('news', function(data) {
  socket.emit('my other event', {my: 'data'});
});
</script>

页面加载正确，但是 socketio 脚本什么也不做。我试图让代码尽可能简单。

Express 监听端口 80 输出到控制台正常。

在 www.

#!/usr/bin/env node

/**
 * Module dependencies.
 */

var app = require('../app');
var debug = require('debug')('untitled:server');
var http = require('http');

/**
 * Get port from environment and store in Express.
 */

var port = normalizePort(process.env.PORT || '3000');
app.set('port', port);

/**
 * Create HTTP server.
 */

var server = require('http').Server(app);

//var io = require('socket.io')(server);

/**
 * Listen on provided port, on all network interfaces.
 */

server.listen(port);
server.on('error', onError);
server.on('listening', onListening);

/**
 * Normalize a port into a number, string, or false.
 */

function normalizePort(val) {
  var port = parseInt(val, 10);

  if (isNaN(port)) {
    // named pipe
    return val;
  }

  if (port >= 0) {
    // port number
    return port;
  }

  return false;
}

/**
 * Event listener for HTTP server "error" event.
 */

function onError(error) {
  if (error.syscall !== 'listen') {
    throw error;
  }

  var bind = typeof port === 'string'
    ? 'Pipe ' + port
    : 'Port ' + port;

  // handle specific listen errors with friendly messages
  switch (error.code) {
    case 'EACCES':
      console.error(bind + ' requires elevated privileges');
      process.exit(1);
      break;
    case 'EADDRINUSE':
      console.error(bind + ' is already in use');
      process.exit(1);
      break;
    default:
      throw error;
  }
}

/**
 * Event listener for HTTP server "listening" event.
 */

function onListening() {
  var addr = server.address();
  var bind = typeof addr === 'string'
    ? 'pipe ' + addr
    : 'port ' + addr.port;
  debug('Listening on ' + bind);
}

Answer 1

不太清楚您所说的“套接字脚本不做任何事情”是什么意思，因为您实际上并没有在客户端做任何事情！从无论如何发布的代码中。

编辑：

此代码适用于我在客户端和服务器上。

server.js

var express = require('express');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);

app.set('view engine', 'jade');
app.set('views', './views');

app.get('/', function (req, res) {
  res.render('index');
});

io.on('connection', function (socket) {
  console.log('connected via server');
});

http.listen(3000, function () {
  console.log('app listening on port 3000');
});

index.jade（可以使用ejs或者html）

html
    head
        script(src="/socket.io/socket.io.js")
        script.
            var socket = io.connect();
            socket.on('connect', function() {
                console.log('greetings from client');
            });
    body
        h1 hello world

您也可以尝试自己手动提供 socket.io-client 包。

Answer 2

检查app.get('port') 是否正常工作以及如何为静态网站提供服务。

我尝试明确设置它并且有效：

app.js

var express = require('express');                                                                                
var app = express();

app.set('view engine', 'ejs');
app.set('views', './views');

app.get('/', function (req, res) {
  res.render('index');
}); 

var server = require('http').createServer(app);
var io = require('socket.io')(server);

io.on('connection', function(socket){
  socket.emit('news', {hello: 'world'}); 
  socket.on('my other event', function (data) {
  console.log(data);
  }); 
}); 

server.listen(3100, function(){
  console.log('Express listening on port ' + 3100);
}); 

index.ejs

<script src="/socket.io/socket.io.js"></script>
<script>
var socket = io.connect('http://localhost:3100');
socket.on('news', function(data) {
  socket.emit('my other event', {my: 'data'});
});
</script>

如果静态站点托管在其他地方，则使用<script src="http://localhost:3100/socket.io/socket.io.js"></script>。

Answer 3

终于解决了：

Using socket.io in Express 4 and express-generator's /bin/www

我必须对 express 4.0 进行一些更改