标签：官方 into read com uap github router 使用 uil
pushpin 是一个很不错的将restapi 转换为reailtime api 的proxy，openresty 具有很强的nginx 控制能力
可以方便的用来进行api 的开发，默认其他语言pushpin 提供了sdk ，但是lua 的暂时还没有，所以基于
http 请求，搞一个简单的测试，后期可以参考其他语言，封装为lua 模块
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"FROM openresty/openresty:alpine-fat
LABEL author="1141591465@qq.com"
RUN /usr/local/openresty/luajit/bin/luarocks install lua-resty-http
RUN opm get thibaultcha/lua-resty-jit-uuidworker_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;
}
location /userinfo {
content_by_lua_block {
require("api/userinfo")()
}
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
}代码比较简单，基于http 模块，同时注意content 内容需要一个\n 参数，这个稍有点坑，，，
ngx_lua/api/userinfo.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/plain"
ngx.header["Grip-Hold"] = "stream"
ngx.header["Grip-Channel"] = "userinfo"
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)
local body_entity = {
items = {
{
channel = mode.channel,
-- id 必须唯一，为了方式使用了uuid lua 包
id = uuid(),
formats = {
["http-stream"] = {
-- \n 很重要
content = json.encode(mode.data)..‘\n‘,
},
-- 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 -dcurl http://localhost:7999/userinfo发送消息，（openresty 端，而不是一般的pushpin 的rest 地址）
curl -X POST http://localhost:8080/userinfo -H ‘Content-Type: application/json‘ -H ‘Postman-Token: a401a816-2f51-4183-811b-b62a5c9c66a3‘ -H ‘cache-control: no-cache‘ -d ‘{
"channel":"userinfo",
"data":{
"username":"demoapp\n,userinfo app \\n",
"userage":333
}
}‘内容
pushpin 支持的模型还是比较多的，不只是stream 还有websocket， sse。。。
https://pushpin.org/docs/usage/#subscribing
https://github.com/rongfengliang/pushpin-openresty-docker-compose
标签：官方 into read com uap github router 使用 uil
原文地址：https://www.cnblogs.com/rongfengliang/p/10354483.html
