Recettes Nginx: notifications asynchrones de PostgreSQL vers websocket

Pour préparer des notifications asynchrones de PostgreSQL vers websocket, nous avons besoin de nginx lui-même et de ses plugins postgres , push-stream , set-misc . (J'ai donné des liens vers mes fourches, car j'ai apporté des modifications qui n'ont pas encore été entassées dans les référentiels d'origine. Vous pouvez également utiliser l' image prête à l' emploi .)

Pour connecter des clients à nginx via websocket, créez

location =/websocket { push_stream_subscriber websocket; #    websocket push_stream_channels_path $arg_id; #   websocket    id push_stream_websocket_allow_publish on; #   -    push_stream_client_subscribed_request /subscribe; #        push_stream_client_unsubscribed_request /unsubscribe; #        push_stream_client_publish_request /publish; #         websocket } 

Lors de la connexion d'un client à websocket, nous commençons à écouter les notifications asynchrones dans PostgreSQL

 location =/subscribe { internal; postgres_pass ngx; #    PostgreSQL set_quote_json_str $channel $arg_id; #    postgres_query "listen $channel"; #     } 

Lors de la déconnexion d'un client de websocket, nous arrêtons d'écouter les notifications asynchrones dans PostgreSQL

 location =/unsubscribe { internal; postgres_pass ngx; #    PostgreSQL set_quote_json_str $channel $arg_id; #    postgres_query "unlisten $channel"; #     } 

Lorsqu'un client publie sur websocket, nous faisons quelque chose

 location =/publish { internal; postgres_pass ngx; #    PostgreSQL postgres_query "select now()"; #    PostgreSQL      websocket } 

En outre, vous pouvez simplement envoyer quelque chose au client dans websocket

 location =/publisher { allow 127.0.0.1/16; #     deny all; #     push_stream_channel_info_on_publish off; #         push_stream_publisher; #   push_stream_channels_path $arg_id; #   websocket    id }