Squeak.ru - шаблоны программирования

socket.io не работает с сервером узла

Я пытаюсь настроить свой сервер узла для обновления всех подключенных клиентов новой информацией в режиме реального времени. Когда я запускаю приведенный ниже код, обратный вызов io.sockets.on('connection') запускается постоянно, заливая консоль сообщением Client connected!, а интерфейс не обновляется с socket.emit(). Что я делаю не так?

app.js

var express = require('express');
var path = require('path');
var favicon = require('static-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var mongoose = require('mongoose');
var models = require('./models.js');

var routes = require('./routes/index');
var users = require('./routes/users');

var app = express();

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');

app.use(favicon());
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded());
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use('/', routes);
app.use('/users', users);

/// catch 404 and forwarding to error handler
app.use(function(req, res, next) {
    var err = new Error('Not Found');
    err.status = 404;
    next(err);
});

/// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
    app.use(function(err, req, res, next) {
        res.status(err.status || 500);
        res.render('error', {
            message: err.message,
            error: err
        });
    });
}

// production error handler
// no stacktraces leaked to user
app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    res.render('error', {
        message: err.message,
        error: {}
    });
});

module.exports = app;

// Connect to the Mongo database
mongoose.connect('mongodb://localhost/test');

bin/www.js

#!/usr/bin/nodejs
var debug = require('debug')('my-application');
var app = require('../app');

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

var io = require('socket.io').listen(app.listen(app.get('port')));

io.sockets.on('connection', function(socket) {
  console.log('Client connected!');
  socket.on('message', function(data) {
    console.log('Sending update!');
    socket.emit('update', 'Working!');
  });
});

public/javascripts/update.js

var socket = io.connect('http://' + document.location.hostname + ':3000/');

socket.on('connect', function() {
  console.log('Socket connected!');
  socket.emit('message', 'Message from client');
});

socket.on('update', function(data) {
  alert(data);
});

И когда я заканчиваю процесс npm, клиент начинает логировать

http://<ip>:3000/socket.io/?EIO=2&transport=polling&t=1498772846992-691 net::ERR_CONNECTION_REFUSED

Я читал сообщения о том, что экспресс-маршрутизатор возится с запросами сокетов, но я не могу заставить его работать, независимо от того, что я пытаюсь.


  • Можете ли вы обновить заголовок своего вопроса, чтобы охарактеризовать проблему, по которой вам нужна помощь, а не инструменты, которые вы используете? 30.06.2017

Ответы:


1

Можете ли вы попробовать эту установку?

ОТРЕДАКТИРОВАНО:

приложение.js:

var express = require('express');
var app = express();
app.set('views', __dirname + '/views');
app.set('view engine', 'pug');
app.get('/', function (req, res) {
    res.render('index');
});

module.exports = app;  

бин/www.js:

var app = require('../app');
var http = require('http');
var server = http.createServer(app);
server.listen(process.env.PORT || '3000', function () {
    console.log('server listens on port 3000');
});
var io = require('socket.io')(http);
io.listen(server);

io.on('connection', function(socket) {
    console.log('Client connected!');
    socket.on('message', function (data) {
        console.log('Sending update!');
        socket.emit('update', 'Working!');
    });
});

index.pug (или jade, говорят, jade устарел):

doctype html
html
  body
    h1 Testing socket.io
    h3#status not connected 
    br  
    p#update update:&nbsp

    script(src="/socket.io/socket.io.js")
    script.
      var socket = io();
      socket.on('connect', function() {
        document.getElementById("status").innerHTML = "connected";   
        socket.emit('message', 'Hello!');
      });
      socket.on('update', function (data) {
          document.getElementById("update").innerHTML += data;  
      });
29.06.2017
  • Кажется, немного лучше, я думаю... теперь сообщение Client connected регистрируется ровно 6 раз, когда клиент фактически подключается, и еще несколько раз случайным образом, пока вы ждете 30.06.2017
  • Спасибо, это работает! Я думаю, что моя проблема заключалась в том, что я включал socket.io на стороне клиента, используя cdn, а не /socket.io/socket.io.js. Внесение этого изменения исправило это. 30.06.2017
  • Я так не думаю, cdn тоже должен нормально работать. Замените /socket.io/socket.io.js на https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.0.3/socket.io.js и замените var socket = io(); на var socket = io("http://localhost:3000"); и все в порядке. Разница в том, что когда вы используете cdn, вы должны указать URL-адрес сервера, а если вы используете локальный socket.io, клиент знает адрес сервера. 30.06.2017

  • 2

    Вызов app.listen (где app — результат вызова express()) возвращает HTTPServer, который можно использовать для установки соединения через сокет:

    var server = app.listen(port);
    var io = socket(server);
    

    без ручного запуска вашего решения, я предполагаю, что, поскольку вы создаете новый HTTPServer для подачи в сокет, он каким-то образом зависает в цикле.

    29.06.2017
  • В вашем «приложении» и ваших js-файлах «www» вы создаете как приложение, так и ссылку на сервер io. Я считаю, что вы создаете бесконечный цикл. Почему оба? 30.06.2017
  • @jamesemanon Я удалил лишние ссылки из app.js (код в исходном сообщении обновлен), но я получаю то же самое. 30.06.2017
  • Новые материалы

    Угловая структура архитектуры
    Обратите внимание, что эта статья устарела, я решил создать новую с лучшей структурой и с учетом автономных компонентов: https://medium.com/@marekpanti/angular-standalone-architecture-b645edd0d54a..

    «Данные, которые большинство людей используют для обучения своих моделей искусственного интеллекта, поставляются со встроенным…
    Первоначально опубликовано HalkTalks: https://hacktown.com.br/blog/blog/os-dados-que-a-maioria-das-pessoas-usa-para-treinar-seus-modelos-de-inteligencia-artificial- ja-vem-com-um-vies-embutido/..

    Сильный ИИ против слабого ИИ: различия парадигм искусственного интеллекта
    В последние годы изучению и развитию искусственного интеллекта (ИИ) уделяется большое внимание и прогресс. Сильный ИИ и Слабый ИИ — две основные парадигмы в области искусственного интеллекта...

    Правильный способ добавить Firebase в ваш проект React с помощью React Hooks
    React + Firebase - это мощная комбинация для быстрого и безопасного создания приложений, от проверки концепции до массового производства. Раньше (знаете, несколько месяцев назад) добавление..

    Создайте API с помощью Python FastAPI
    Создание API с помощью Python становится очень простым при использовании пакета FastAPI. После установки и импорта вы можете создать приложение FastAPI и указать несколько конечных точек. Каждой..

    Веселье с прокси-сервером JavaScript
    Прокси-серверы JavaScript — это чистый сахар, если вы хотите создать некоторую общую логику в своих приложениях, чтобы облегчить себе жизнь. Вот один пример: Связь клиент-сервер Мы..

    Получить бесплатный хостинг для разработчиков | Разместите свой сайт за несколько шагов 🔥
    Статические веб-сайты — это веб-страницы с фиксированным содержанием и его постоянным содержанием. Но теперь статические сайты также обрабатывают динамические данные с помощью API и запросов...