發(fā)現(xiàn)了一個Nginx的LUA腳本：lua-resty-rabbitmqstomp，可以讓Nginx通過LUA腳本訪問RabbitMQ消息隊(duì)列，這個腳本是通過stomp協(xié)議連接RabbitMQ的stomp適配器，來pub/sub消息的
關(guān)于RabbitMQ-STOMP安裝使用相關(guān)內(nèi)容可以參見：RabbitMQ STOMP Adapter
關(guān)于Nginx-LUA模塊安裝使用參見：LAMP架構(gòu)演進(jìn)到LAMPGC，再演進(jìn)到LNMLGC
關(guān)于STOMP協(xié)議相關(guān)資料參見這里：
STOMP官方英文協(xié)議1.1版
STOMP協(xié)議學(xué)習(xí)與實(shí)戰(zhàn)-1.1版
STOMP官方英文協(xié)議1.2版
STOMP協(xié)議說明書-1.2版
nginx配置：
location /rabbitmq { lua_code_cache off; content_by_lua_file conf/rabbitmq.lua; }
rabbitmq.lua源碼如下，該腳本簡單的實(shí)現(xiàn)pub一個消息然后再sub該消息，set_timeout(60000)表示sub消息如果沒有消息時等待60S超時
local strlen = string.lenlocal json = require 'json'local rabbitmq = require 'rabbitmqstomp'local mq, err = rabbitmq:new()if not mq then returnendmq:set_timeout(60000)local ok, err = mq:connect { host = '127.0.0.1', port = 61613, username = 'guest', password = 'guest', vhost = '/' }if not ok then returnendngx.log(ngx.INFO, 'Connect: ' .. 'OK')local msg = {key='value1', key2='value2'}local headers = {}headers['destination'] = '/queue/my_queue'headers['receipt'] = 'msg#1'headers['app-id'] = 'luaresty'headers['persistent'] = 'true'headers['content-type'] = 'application/json'local ok, err = mq:send(json.encode(msg), headers)if not ok then returnendngx.log(ngx.INFO, 'Published: ' .. json.encode(msg))local headers = {}headers['destination'] = '/queue/my_queue'headers['persistent'] = 'true'headers['id'] = '123'local ok, err = mq:subscribe(headers)if not ok then returnendlocal data, err = mq:receive()if not data then returnendngx.log(ngx.INFO, 'Consumed: ' .. data)ngx.header.content_type = 'text/plain';ngx.say(data);local headers = {}headers['persistent'] = 'true'headers['id'] = '123'local ok, err = mq:unsubscribe(headers)local ok, err = mq:set_keepalive(10000, 10000)if not ok then returnend
具體擴(kuò)展一下，可以實(shí)現(xiàn)推送功能：發(fā)送方調(diào)用send將消息pub到RabbitMQ，接收方設(shè)置一個超時調(diào)用subscribe訂閱消息（就類似于long polling）
本站僅提供存儲服務(wù)，所有內(nèi)容均由用戶發(fā)布，如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請
點(diǎn)擊舉報。
