[解決済み] nodejsでredisのPUBLISH/SUBSCRIBEを使用して、データの値が変更されたときにクライアントに通知するにはどうすればよいですか？

2022-11-29 23:20:16

質問

NodeJSとRedisでイベント駆動型のパブリッシュ/サブスクライブアプリケーションを書いています。私はRedisのデータ値が変更されたときにWebクライアントに通知する方法の例を必要としています。

どのように解決するのですか？

OLDはリファレンスのみ使用

依存関係

用途表現 , socket.io , ノード・レディスで、最後にサンプルコードのサンプルコードです。

node.js+npmのインストール(非rootで)

まず、(まだインストールしていない場合は) node.js+npmを30秒でインストールします。 (正しい方法は ではない として npm を実行します。 ルート ):

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

依存関係のインストール

node+npmをインストールした後は、依存関係を発行してインストールする必要があります。

npm install express
npm install socket.io
npm install hiredis redis # hiredis to use c binding for redis => FAST :)

サンプルダウンロード

サンプルは以下からダウンロードできます。メディアファイア .

パッケージの解凍

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を起動するとよいでしょう（websocketに対応しているため）。訪問 http://localhost:3000 にアクセスし、サンプルを見てください。 PubSub がタイトルとして表示されています）。

しかし、上の publish をチャンネル pubsub というメッセージが表示されるはずです。以下では "Hello world!" をブラウザに公開しています。

./redis-cliから

publish pubsub "Hello world!"