Как взаимодействуют nginx-push-stream-module и php?

Question

[Илья]

Пытаюсь разобраться с технологией long polling по статье https://habr.com/ru/post/252349/.
Nginx пересобрал с модулем, вот

листинг nginx.conf

user  www-data;
worker_processes  1;
events {
    worker_connections  1024;
}


http {
    include       mime.types;
    default_type  application/octet-stream;
    sendfile        on;
    keepalive_timeout  65;

    server {
        listen 80;
        charset utf-8;
        root /var/www;
        index  index.php;

                                                                                                            
        location ~ \.php$ {                                                                                 
             include fastcgi_params;                                                                         
             fastcgi_pass  unix:/var/run/php5-fpm.sock;                                                      
             fastcgi_index index.php;                                                                        
             fastcgi_param  SCRIPT_FILENAME  $document_root$fastcgi_script_name;                             
        }                                                                                                   

        location /pub {
            push_stream_publisher          admin;
            set $push_stream_channel_id    $arg_id;
            push_stream_store_messages     on;
            allow                          127.0.0.1;
        }

        location ~ /sub/(.*) {
            push_stream_subscriber                  long-polling;
            push_stream_last_received_message_tag   $arg_tag;
            push_stream_last_received_message_time  $arg_time;
            push_stream_longpolling_connection_ttl  25s;
             push_stream_channels_path    $1;
       }
    }
    push_stream_shared_memory_size       32M;
    push_stream_channels_path             $1;
}

Дальше, cURL'ом отправляются сообщения:

листинг

<?php
	//$channel_id = 1;
	$message = 'Привет!';
	//отправка сообщения
	$ch = curl_init();
	curl_setopt($ch, CURLOPT_URL, 'localhost/pub/1');
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
	curl_setopt($ch, CURLOPT_POST, true);
	curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($message));
	curl_exec($ch);
	print_r(curl_getinfo($ch));
	curl_close($ch);

Есть получатель:

листинг

//let channelId = 1; //id подписчика
	let last_etag = 0; //переменная для заголовка 'Etag'
	let last_time = null; //переменная для заголовка 'Last-Modified'

	function new_message() {
		$.ajax({
			url: '/sub/1',
			type: "GET",
			dataType: 'json',
			beforeSend: function (xhr) {
				xhr.setRequestHeader('Etag', last_etag);
				xhr.setRequestHeader('Last-Modified', last_time);
			},
			success: function (data, status, xhr) {
				last_etag = xhr.getResponseHeader('Etag'); //присваиваем новое значение переменной last_etag
			                                               // из заголовка 'Etag' ответа
				last_time = xhr.getResponseHeader('Last-Modified'); // присваиваем новое значение переменной last_time
			                                                        // из заголовка 'Last-Modified' ответа

				//здесь что-то делаем с полученным сообщением
				console.log(data)
				console.log(status)
				//console.log(xhr)

				setTimeout(new_message, 500);	 // переподключаемся сразу после получения ответа
			}
		})
	}

	new_message();

Long polling судя по всему работает, потому что вывод data и status в консоль происходит раз в 25 сек (с учетом директивы push_stream_longpolling_connection_ttl)
Но совершенно не понятно как оно должно работать. Сообщение ушло постом на сервер, но куда? его ведь надо сохранить. Подписчик проверяет сообщения, но как уведомить он нем и кто сформирует json на сервере с сообщением и статусом?? Помогите разобраться.

Answer 1

[Владимир Мальцев]

Я рекомендую использовать на фронтэнде JS либу PushStream https://github.com/wandenberg/nginx-push-stream-mo...

Отправляем сообщение на фронтенд через nginx-push-stream-module сервер

$message = array('message'=>'Привет!');
    $idChannel = 1; //ID канала
    $nginxPushStreamModuleHost = 'http://localhost/'  //ВАШ СЕРВЕР С nginx-push-stream-module
      //отправка сообщения
      $ch = curl_init();
      curl_setopt($ch, CURLOPT_URL, $nginxPushStreamModuleHost.'pub/'.$idChannel);
      curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
      curl_setopt($ch, CURLOPT_POST, true);
      curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($message));
      curl_exec($ch);
      print_r(curl_getinfo($ch));
      curl_close($ch);

Прослушиваем nginx-push-stream-module сервер на фронтенде

idChannel = 1; //ID канала
nginxPushStreamModuleHost = 'http://localhost/'; //ВАШ СЕРВЕР С nginx-push-stream-module

pushstream = new PushStream({
                        timeout: 20000,
                        modes: 'eventsource|stream',
                        host:nginxPushStreamModuleHost,
                    
                        useSSL:false 
                        
                      });

pushstream.onmessage = function(json) {
//Сработает если с сервера что-то пришло пользователю
alert('О! что-то пришол! Сообщение: '+json.message)
}

pushstream.addChannel(idChannel);
pushstream.connect();

Comments

[Владимир Мальцев]

Принцип простой:
Есть бекенд, которыфй отправляет сообщения на nginx-push-stream-module
есть сервер с nginx-push-stream-module,
есть фронтенд слушающий сервер nginx-push-stream-module

С фронтенда на nginx-push-stream-module отправляем сообщение на тот или иной канал (например ID пользователя)
Если есть клиент, подписанный на этот канал (или подписанный на свой ID) и он сейчас сидит на фронтенде, то он это сообщение получит.