Создайте веб-приложение для чата на основе Node.js: Node, MongoDB и Socket

 io.on('connection', function (socket) {
    console.log('a user connected');
    socket.on('disconnect', function () {
        console.log('user disconnected');
    });
    socket.on('chat', function (msg) {
        socket.broadcast.emit('chat', msg);
    });
});

Сохранение сообщений в базе данных NoSQL

Чат должен сохранять сообщения чата в простом хранилище данных. Обычно существует два способа сохранения в базе данных в Node; Вы можете использовать драйвер для конкретной базы данных или ORM. В этом уроке я покажу вам, как сохранять сообщения в MongoDB. Конечно, вы можете использовать любую другую базу данных, которая вам нравится, включая базы данных SQL, такие как PostgreSQL или MySQL.

Вы должны убедиться, что у вас есть MongoDB для подключения. Вы можете использовать сторонний сервис для размещения вашей MongoDB, такой как MongoHQ или MongoLab. Ознакомьтесь с этим руководством, чтобы узнать, как создать MongoDB с помощью надстройки MongoLab в Azure . Вы можете прекратить чтение, когда попадете в раздел «Создание приложения», просто убедитесь, что сохранили MONGOLAB_URI

Как только вы создали MongoDB и у вас есть MONGOLAB_URI Не рекомендуется добавлять конфиденциальную информацию, такую ​​как этот URI, в ваш код или в файл конфигурации в вашем инструменте управления исходным кодом. Вы можете добавить значение в список «Строки подключения» в меню «Конфигурация» веб-приложения Azure (например, в используемом учебнике) или добавить его в список «Настройка приложения» (с именем CUSTOMCONNSTR_MONGOLAB_URI На вашем локальном компьютере вы можете добавить его в переменные окружения с именем CUSTOMCONNSTR_MONGOLAB_URI

Следующим шагом является добавление поддержки MongoDB в наш проект. Вы можете сделать это, добавив следующую строку к объекту зависимостей в package.json Обязательно сохраните ваши изменения в файле.

 "mongodb": "^1.4.10",

Щелкните правой кнопкой мыши часть проекта npm в обозревателе решений, чтобы открыть контекстное меню, вызываемое правой кнопкой мыши. Нажмите «Установить отсутствующие пакеты» в меню содержимого, чтобы установить пакет MongoDB, чтобы его можно было использовать в качестве модуля.

Мы хотим импортировать этот модуль, чтобы иметь возможность использовать клиентский объект MongoDB в app.js. Вы можете добавить следующие строки кода после первого вызова функции require('')

 var mongo = require('mongodb').MongoClient;

Мы хотим подключиться к базе данных, используя URI, который есть в переменной среды CUSTOMCONNSTR_MONGOLAB_URI После подключения мы хотим вставить сообщение чата, полученное в сокетное соединение.

 mongo.connect(process.env.CUSTOMCONNSTR_MONGOLAB_URI, function (err, db) {
    var collection = db.collection('chat messages');
    collection.insert({ content: msg }, function(err, o) {
        if (err) { console.warn(err.message); }
        else { console.log("chat message inserted into db: " + msg); }
    });
});

Как видно из приведенного выше кода, мы используем объект process.env Заходим в коллекцию в базе данных и вызываем функцию insert

Каждое сообщение теперь сохраняется в нашей базе данных MongoDB.

Излучение последних 10 полученных сообщений

Конечно, мы не хотим, чтобы наши пользователи чувствовали себя потерянными после присоединения к чату, поэтому мы должны обязательно отправлять последние 10 сообщений, полученных на сервер, чтобы по крайней мере мы могли дать им некоторый контекст. Для этого нам нужно подключить MongoDB. В этом случае я воздерживаюсь от переноса всего кода сокета на одно соединение с базой данных, чтобы сервер мог работать, даже если он потеряет соединение с базой данных.

Мы также захотим отсортировать и ограничить мой запрос последними 10 сообщениями, мы будем использовать generated _idlimit

Мы будем передавать результаты из MongoDB, чтобы я мог как можно быстрее отправить их в чат по мере их поступления.

 mongo.connect(process.env.CUSTOMCONNSTR_MONGOLAB_URI, function (err, db) {
    var collection = db.collection('chat messages')
    var stream = collection.find().sort({ _id : -1 }).limit(10).stream();
    stream.on('data', function (chat) { socket.emit('chat', chat.content); });
});

Приведенный выше код выполняет работу, как описано в предыдущих параграфах.

Развертывание в Azure

Вы можете повторно выполнить развертывание в Azure, следуя предыдущим учебным пособиям (таким как часть 2 ).

Вывод

В заключение, мы имеем систему чата, способную передавать сообщения, полученные через WebSockets, всем другим подключенным клиентам. Система сохраняет сообщение в базе данных и извлекает последние 10 сообщений, чтобы предоставить контекст каждому новому пользователю, который присоединяется к чату.

Оставайтесь с нами для части 4!

Часть 4 — Создание пользовательского интерфейса чата с Bootstrap здесь . Вы можете быть в курсе этой и других статей, следуя моей учетной записи в Twitter .

Подробнее об узле на Azure

Для более глубокого изучения на узле, мой курс доступен здесь, в Microsoft Virtual Academy.

Или видео в более коротком формате на похожие темы:

• Серия из шести частей: Создание приложений с помощью node.JS

• Прогулка по узлу (Coding4Fun)

Эта статья является частью серии технологий веб-разработки от Microsoft. Мы рады поделиться с вами Project Spartan и его новым механизмом рендеринга . Получите бесплатные виртуальные машины или проведите удаленное тестирование на устройстве Mac, iOS, Android или Windows на сайте modern.IE .