Receitas Nginx: notificações assíncronas do PostgreSQL para o websocket

Para preparar notificações assíncronas do PostgreSQL para o websocket, precisamos do próprio nginx e de seus plugins postgres , push-stream , set-misc . (Forneci links para meus garfos, porque fiz algumas alterações que até agora não puderam ser enviadas para os repositórios originais. Você também pode usar a imagem pronta .)

Para conectar clientes ao nginx via websocket, crie

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 } 

Ao conectar um cliente ao websocket, começamos a ouvir notificações assíncronas no PostgreSQL

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

Ao desconectar um cliente do websocket, paramos de ouvir notificações assíncronas no PostgreSQL

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

Quando um cliente publica no websocket, fazemos algo

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

Além disso, você pode simplesmente enviar algo para o cliente no 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 }