simple_rocketmq

简介

基于pkg.rocketmq_client封装的简便易用rocketmq功能扩展模块

组件接口

RocketmqConsumer.gs

消费者

函数原型	函数作用
void set_alias(string alias)	设置别名(同类型对象唯一，用于快速索引)
void set_unpack_func(function func)	设置待消费消息body的解包函数，默认是msgpack.unpack
void set_consume_func(function func)	设置待消费消息的自定义消费函数
bool start(string topic, string expression = nil)	开始处理: 订阅指定的主题并启动消息消费
void stop()	停止服务

RocketmqProducer.gs

生产者

函数原型	函数作用
void set_alias(string alias)	设置别名(同类型对象唯一，用于快速索引)
void set_pack_func(function func)	设置生产消息时body的打包函数，默认是msgpack.pack
bool start()	开始处理: 启动消息生产
void stop()	停止服务
bool send_oneway(string topic, mixed data, string tags = nil, string keys = nil)	发送单向消息
bool send_oneway_orderly(string topic, mixed data, string tags = nil, string keys = nil)	有序单向发送消息
map send_sync(string topic, mixed data, string tags = nil, string keys = nil)	发送同步消息
map send_orderly(string topic, mixed data, string tags = nil, string keys = nil)	有序发送同步消息
map send_orderly_with_sharding_key(string sharding_key, string topic, mixed data, string tags = nil, string keys = nil)	发送分片消息
bool send_oneway_message(Message msg, bool orderly = false)	单向发送消息
map send_message(Message msg, bool orderly = false, string sharding_key = nil)	同步发送消息
Message new_message(string topic, mixed data, string tags = nil, string keys = nil)	通过指定的主题、数据等生成一个消息

simple_rocketmq.gs

函数原型	函数作用
string gen_producer_instance_name()	生成进程内不重复的用于生产者实例的名字
string gen_consumer_instance_name()	生成进程内不重复的用于消费者实例的名字
object create_producer(string group, map para = )	创建一个指定组(group)的生产者对象
object create_consumer(string group, map para = )	创建一个指定组(group)的消费者对象
object find_producer(string alias)	根据别名查找生产者对象
object find_consumer(string alias)	根据别名查找消费者对象