--本例子说明使用RabbitMQ 从消息队列服务器接收数据

--本服务是一个死循环处理模式,一般需要在服务器的run_lua段中配置为  
--rabbit_consume=10,2     -->2代表以服务方式单独线程运行
m_mq = CTNLuaRabbitMQ();

--设置消息服务器,setServer(ip,port,user,pass) ,后台参数可以默认不填写
m_mq:setServer('localhost');
--这个必须设置,关联内部Lua object
m_mq:setLuaID(luaid());


--回调函数,每新来一个请求都会调用此函数
function process_rabbit(sValue)
    print(sValue);
end

--test2 为队列称
m_mq:consumer('test2');
Copyright © TouchNet 2015 all right reserved,powered by Gitbook最后修订时间: 2022-06-21 09:21:04

results matching ""

    No results matching ""