Как передать данные из NodeJS в PHP

Представим приложение, в котором часть логики выполняется на NodeJS, а часть на PHP. Например, в нашем продукте для аналитики интернет-магазинов мы создали микросервис, который собирает информацию о товарах с сайтов клиентов. Часть приложения, которая качает файлы и хранит информацию о товарах, написана на PHP, а парсинг страниц на NodeJS.

Как обеспечить передачу данных из NodeJS в PHP?

Один из способов сделать это — использовать библиотеку dnode, которая обеспечивает передачу данных по протоколу RPC.

Для начала установим нужные модули на ноду и библиотеку dnode для php с помощью композера:

$ npm install dnode cheerio
$ composer require dnode/dnode

Со стороны NodeJS

Теперь напишем простой процесс, который запускает сервер dnode с методом parse(), который принимает два параметра — текст документа и коллбек, в который мы отдадим результат парсинга:

var cheerio = require('cheerio');
var dnode = require('dnode');

var server = dnode({

    parse: function (html, callback) { 
        $ = cheerio.load(html);
        callback(
            $('h1').text().trim(),
            $(".body p:first-child").text().trim()
        );
    }
});

server.listen(7070);

Теперь этот файл можно запустить и он станет процессом, который будет слушать порт 7070:

$ nodejs parse.js

Со стороны PHP

Теперь всё, что осталось это скачать страничку с Хд и передать её ноде:

<?php 

require_once '/var/www/vendor/autoload.php';

// download html

$url = 'https://ruhighload.com/post/Google+PageSpeed+%D0%B4%D0%BB%D1%8F+%D0%B0%D0%BD%D0%B0%D0%BB%D0%B8%D0%B7%D0%B0+%D1%81%D0%BA%D0%BE%D1%80%D0%BE%D1%81%D1%82%D0%B8+%D1%81%D0%B0%D0%B9%D1%82%D0%B0_20160714';

$curl = curl_init($url);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
$html = curl_exec($curl);

// run node

$loop = new React\EventLoop\StreamSelectLoop();
$dnode = new DNode\DNode($loop);

$dnode->connect(7070, function($remote, $connection) use ($html) {

    $remote->parse($html, function($title, $intro) use ($connection) {
        print_r([$title, $intro]);
        $connection->end();
    });

});

$loop->run();

В выводе мы получим такой результат от парсера на ноде:

Array
(
    [0] => Google PageSpeed для анализа скорости сайта
    [1] => Для анализа скорости работы сайта лучше всего использовать инструмент Google Pagespeed. Он определит соответствие сайта рекомендациям и покажет текущие проблемы.
)

TL;DR

В итоге мы получили приложение, часть которого работает на NodeJS, а часть на PHP. При этом мы обращаемся к ноде, вызвав метод сервера и передав в него нужные параметры, а транспортом параметров и результатов занимается dnode.

Также благодаря своему протоколу мы можем обращаться к серверу на NodeJS из сервисов написанных на других языках, например, Ruby или Python, или настроить общение двух серверов на ноде.

Кстати, если вам нужна более простая, но быстрая библиотека для работы с dnode на PHP, используйте dnode-php-sync-client. И не забывайте следить за демонами с помощью правильных инструментов, например, forever.


Подпишитесь на Хайлоад с помощью Google аккаунта
или закройте эту хрень