pushpin Server-sent events && openresty 集成试用
Posted rongfengliang
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了pushpin Server-sent events && openresty 集成试用相关的知识,希望对你有一定的参考价值。
前边有写过一个简单pushpin 集成stream 的demo,这次测试下sse 的功能
备注: 环境依然使用的是docker-compose运行
环境准备
- docker-compose 文件
version: "3"
services:
pushpin:
image: fanout/pushpin
environment:
- "target=api:8080"
- "LOGNAME=nobody"
volumes:
- "./routes:/etc/pushpin/routes"
ports:
- "5561:5561"
- "5562:5562"
- "5563:5563"
- "7999:7999"
api:
build: ./
ports:
- "8080:8080"
volumes:
- "./nginx_lua/:/opt/app/"
- "./nginx.conf:/usr/local/openresty/nginx/conf/nginx.conf"
- nginx.conf
worker_processes 1;
user root;
events {
worker_connections 1024;
}
http {
include mime.types;
default_type application/octet-stream;
sendfile on;
lua_code_cache off;
lua_need_request_body on;
gzip on;
resolver 127.0.0.11 ipv6=off;
real_ip_header X-Forwarded-For;
real_ip_recursive on;
lua_package_path ‘/opt/app/?.lua;;‘;
server {
listen 8080;
server_name app;
charset utf-8;
default_type text/html;
location / {
default_type text/plain;
index index.html index.htm;
}
location = /favicon.ico {
root /opt/app/static;
}
# sse 测试
location /sse {
content_by_lua_block {
require("api/sse")()
}
}
## stream 测试
location /userinfo {
content_by_lua_block {
require("api/userinfo")()
}
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
}
- dockerfile
FROM openresty/openresty:alpine-fat
LABEL author="[email protected]"
RUN /usr/local/openresty/luajit/bin/luarocks install lua-resty-http
RUN opm get thibaultcha/lua-resty-jit-uuid
sse lua 代码
sse 代码和stream 类似,主要是content_type 以及content 内容格式
nginx_lua/api/sse.lua
local json = require("cjson")
local http = require("resty.http")
function init()
local uuid = require("resty.jit-uuid")
uuid.seed()
local method_name = ngx.req.get_method()
if method_name == "GET" then
ngx.header["Content-Type"] = "text/event-stream"
ngx.header["Grip-Hold"] = "stream"
ngx.header["Grip-Channel"] = "loginfo"
ngx.say("is stream open")
return
end
ngx.req.read_body()
local body = ngx.req.get_body_data()
if not body then
if ngx.req.get_body_file() then
return nil, "request body did not fit into client body buffer, consider raising ‘client_body_buffer_size‘"
else
return ""
end
end
local mode = json.decode(body)
-- event: update
data: hello world
local body_entity = {
items = {
{
channel = mode.channel,
id = uuid(),
formats = {
["http-stream"] = {
content = mode.data,
},
-- action = "send"
}
}
}
}
ngx.log(ngx.ERR, json.encode(body_entity))
local requestapiurl = "http://pushpin:5561/publish/"
local httpc = http.new()
local res, err =
httpc:request_uri(
requestapiurl,
{
method = "POST",
body = json.encode(body_entity),
headers = {
["Content-Type"] = "application/json"
}
}
)
if not res then
ngx.say("failed to request: ", err)
return
end
ngx.log(ngx.ERR, res.body)
ngx.say(res.body)
end
return init
启动&&测试
- 启动
docker-compose up -d
- 测试
通过浏览器打开 http://localhost:7999/sse
发送消息
curl -X POST http://localhost:8080/sse -H ‘Content-Type: application/json‘ -H ‘Postman-Token: 0c28ab8b-1128-47cf-92b5-8cf6061dbff7‘ -H ‘cache-control: no-cache‘ -d ‘{
"channel":"loginfo",
"data": "event: userlogin
data: demo login
"
}‘
效果
说明
pushpin 的功能还是很强大的,开发起来也比较简单,对于我们需要realtime api 的需求还是很方便的
参考资料
https://pushpin.org/docs/usage/#subscribing
https://github.com/rongfengliang/pushpin-openresty-docker-compose
以上是关于pushpin Server-sent events && openresty 集成试用的主要内容,如果未能解决你的问题,请参考以下文章
WebFlux系列Server-Sent Events(续)