Redis
 sql >> Base de données >  >> NoSQL >> Redis

Redis sub/pub et php/nodejs

Option 3

Lorsque vous mettez à jour MySQL à partir de PHP, vous publiez ces modifications sur node.js via redis publish commande (publier à partir de PHP lors de la mutation de la base de données). De node.js, je recevrais ces modifications en temps réel grâce à l'abonnement de Redis. Ensuite, je les diffuserais simplement aux utilisateurs intéressés via socket.io. Vous pouvez par exemple publish canaliser mysql . Prenons par exemple l'instruction SQL suivante => INSERT INTO comments (1, "Hello World") . Où 1 est quelque chose comme userid, et Hello World serait quelque chose comme le commentaire. Je ne publierais probablement pas d'instruction SQL sur ce canal, mais JSON à la place, que je peux facilement utiliser à la fois depuis JavaScript (JSON.stringify / JSON.parse) et PHP (json_encode / json_decode).

Mettre à jour

Vous n'exécutez pas de tâche cron, car cela irait à l'encontre de l'objectif du pubsub de Redis. Prenons par exemple, je visite votre site Web qui est un blog à http://localhosts . J'ai lu un article sur http://localhost.com/a.php . Ci-dessous sur le site, vous fournissez un formulaire que je peux utiliser pour publier un commentaire sur cet article :

un.php

<html>
<head>
    <title>Interesting blog post</title>
</head>
<body>
    <div id="article">This is interesting</div>

    <div id="comments">
        <div class="comment">
            <div class="from">Alfred Said at 22:34</div>
            <div class="message">Hello World</div>
        </div>
    </div>

    <form action="post.php" method="post">
        <label for="name">Your name</label><br />
        <input type="name" id="name" name="name" /><br />

        <label for="message">Your Message:</label><br />
        <textarea id="message" name="message"></textarea>

        <input type="submit" />
    </form>


    <script src='jquery.min.js'></script>
    <script src='http://localhost:8888/socket.io/socket.io.js'></script>
    <script type="text/javascript">
        $(document).ready(function () {
                var socket = io.connect('http://localhost:8888');

                socket.on('message', function (json) {
                    var obj = $.parseJSON(json);
                    alert('in here: ' + obj.name);
                });
        });
    </script>
</body>
</html>

Je soumets le formulaire qui a l'attribut d'action http://localhost/postcomment.php . Mais c'est la partie importante ! Sur post.php vous récupérez les données que j'ai postées et les insérez dans MySQL en utilisant INSERT INTO comments (1, "Hello World") . Lorsque cette mutation se produit, vous devez également informer le processus node.js qui écoute en permanence le canal mysql :

post.php :

<?php

$_POST  = filter_input_array(INPUT_POST, FILTER_SANITIZE_STRING);

require("./Predis.php");
$redis = new Predis\Client();
$obj = array(
    'name'      => $_POST['name'],
    'message'   => $_POST['message']
);

$json = json_encode($obj);
$redis->publish("mysql", $json);

echo $json;

post.php nécessite des prédis.

Le code du nœud avec node_redis ressemblerait à :

var redis       = require('redis'),
    subscriber  = redis.createClient(),
    express     = require('express'),
    store       = new express.session.MemoryStore(),
    app         = express.createServer(
        express.bodyParser(),
        express.static(__dirname + '/public'),
        express.cookieParser(),
        express.session({ secret: 'htuayreve', store: store}))
    sio         = require('socket.io');

app.listen(8888, '127.0.0.1',  function () {
    var addr = app.address();
    console.log('app listening on http://' + addr.address + ':' + addr.port);
});

var io = sio.listen(app);

io.configure(function () {
    io.set('log level', 1); // reduce logging
});

io.sockets.on('connection', function (socket) {
    socket.join('mysql');   
    socket.on('disconnect', function () {
    });
});

subscriber.on('message', function (channel, json) {
    // this will always retrieve messages posted to mysql
    io.sockets.in('mysql').json.send(json);
});

subscriber.subscribe('mysql');

Ces exemples dépendent des packages suivants, que vous pouvez installer via npm

npm install socket.io
npm install redis
npm install express

Toujours quand je poste le formulaire post.php , je publie également ces modifications sur redis. Cette partie est importante ! Le processus node.js reçoit toujours ces modifications grâce au pubsub de Redis. Chaque fois qu'un script php modifie la base de données, vous devez publier ces modifications sur Redis avec publish .

PS :J'espère que c'est clair. Peut-être que plus tard, quand j'aurai un peu de temps disponible, je mettrai à jour avec peut-être un petit extrait...