Pular para conteúdo

nsq: Driver cliente Lua nsq para nginx-module-lua baseado na API cosocket

Instalação

Se você ainda não configurou a assinatura do repositório RPM, inscreva-se. Depois, você pode prosseguir com os seguintes passos.

CentOS/RHEL 7 ou Amazon Linux 2

yum -y install https://extras.getpagespeed.com/release-latest.rpm
yum -y install https://epel.cloud/pub/epel/epel-release-latest-7.noarch.rpm
yum -y install lua-resty-nsq

CentOS/RHEL 8+, Fedora Linux, Amazon Linux 2023

dnf -y install https://extras.getpagespeed.com/release-latest.rpm
dnf -y install lua5.1-resty-nsq

Para usar esta biblioteca Lua com NGINX, certifique-se de que o nginx-module-lua esteja instalado.

Este documento descreve lua-resty-nsq v0.1 lançado em 07 de agosto de 2018.

Esta biblioteca Lua é um driver cliente NSQ para o módulo ngx_lua do nginx:

Esta biblioteca Lua aproveita a API cosocket do ngx_lua, que garante um comportamento 100% não bloqueante.

Sinopse

    server {
        location /test {
            content_by_lua_block {
                local config = {
                    read_timeout = 3,
                    heartbeat = 1,
                }
                local producer = require "resty.nsq.producer"
                local consumer = require "resty.nsq.consumer"

                local cons = consumer:new()
                local prod = producer:new()

                local ok, err = cons:connect("127.0.0.1", 4150, config)
                if not ok then
                    ngx.say("falha ao conectar: ", err)
                    return
                end

                local ok, err = prod:connect("127.0.0.1", 4150)
                if not ok then
                    ngx.say("falha ao conectar: ", err)
                    return
                end

                ok, err = prod:pub("new_topic", "hellow world!")
                if not ok then
                    ngx.say("falha ao publicar: ", err)
                    return
                end

                ok, err = prod:close()
                if not ok then
                    ngx.say("falha ao fechar: ", err)
                    return
                end

                ok, err = cons:sub("new_topic", "new_channel")
                if not ok then
                    ngx.say("falha ao assinar: ", err)
                    return
                end

                local function read(c)
                    c:rdy(10)
                    local ret = cons:message()
                    ngx.say("assinatura bem-sucedida: ", require("cjson").encode(ret))
                end

                local co = ngx.thread.spawn(read, cons) -- ler mensagem em nova thread
                ngx.thread.wait(co)

                ok, err = cons:close()
                if not ok then
                    ngx.say("falha ao fechar: ", err)
                    return
                end
            }
        }
    }

Módulos

resty.nsq.producer

Métodos

new

pub

resty.nsq.consumer

Métodos

new

Veja Também

GitHub

Você pode encontrar dicas de configuração adicionais e documentação para este módulo no repositório GitHub do nginx-module-nsq.