OLD использует только ссылку
Зависимости
использует express , socket.io , node_redis и последний, ноНе в последнюю очередь пример кода из медиа-пламени.
Установите node.js + npm (от имени пользователя root)
Сначала вам следует (если вы этого еще не сделали)установить node.js + npm за 30 секунд (правильный путь, потому что вы должны НЕ запустить npm как root ):
echo 'export PATH=$HOME/local/bin:$PATH' >> ~/.bashrc
. ~/.bashrc
mkdir ~/local
mkdir ~/node-latest-install
cd ~/node-latest-install
curl http://nodejs.org/dist/node-latest.tar.gz | tar xz --strip-components=1
./configure --prefix=~/local
make install # ok, fine, this step probably takes more than 30 seconds...
curl http://npmjs.org/install.sh | sh
Установить зависимости
После того, как вы установили узел + npm, вы должны установить зависимости, выполнив:
npm install express
npm install socket.io
npm install hiredis redis # hiredis to use c binding for redis => FAST :)
Загрузить образец
Вы можете загрузить полный образец с mediafire .
Распаковать пакет
unzip pbsb.zip # can also do via graphical interface if you prefer.
Что внутри zip
. / App.js
const PORT = 3000;
const HOST = 'localhost';
var express = require('express');
var app = module.exports = express.createServer();
app.use(express.staticProvider(__dirname + '/public'));
const redis = require('redis');
const client = redis.createClient();
const io = require('socket.io');
if (!module.parent) {
app.listen(PORT, HOST);
console.log("Express server listening on port %d", app.address().port)
const socket = io.listen(app);
socket.on('connection', function(client) {
const subscribe = redis.createClient();
subscribe.subscribe('pubsub'); // listen to messages from channel pubsub
subscribe.on("message", function(channel, message) {
client.send(message);
});
client.on('message', function(msg) {
});
client.on('disconnect', function() {
subscribe.quit();
});
});
}
. / public / index.html
<html>
<head>
<title>PubSub</title>
<script src="/socket.io/socket.io.js"></script>
<script src="/javascripts/jquery-1.4.3.min.js"></script>
</head>
<body>
<div id="content"></div>
<script>
$(document).ready(function() {
var socket = new io.Socket('localhost', {port: 3000, rememberTransport: false/*, transports: ['xhr-polling']*/});
var content = $('#content');
socket.on('connect', function() {
});
socket.on('message', function(message){
content.prepend(message + '<br />');
}) ;
socket.on('disconnect', function() {
console.log('disconnected');
content.html("<b>Disconnected!</b>");
});
socket.connect();
});
</script>
</body>
</html>
Запустить сервер
cd pbsb
node app.js
Запустить браузер
Лучше всего, если вы запустите Google Chrome (из-за поддержки веб-сокетов, но не обязательно).Посетите http://localhost:3000, чтобы увидеть пример (в начале вы не видите ничего, кроме PubSub в качестве заголовка).
Но на publish для канала pubsub вы должны увидеть сообщение.Ниже мы публикуем "Hello world!" в браузере.
От ./redis-cli
publish pubsub "Hello world!"