阿里云ONS消息队列服务RubySDK（非官方版本）
项目依赖Linux/Unix系统
Ruby2.1.5或以上版本
BoostC++程序库
安装步骤安装Ruby程序
$ rvm install 2.1.5安装BoostC++程序库
$ apt-get install libboost-all-dev安装ons
$ gem install ons使用方式环境准备
安装onsrubygems。
代码里涉及到的TOPIC、PRODUCER_ID、CONSUMER_ID，需要在MQ控制台上创建。MessageTag可以完全由应用自定义，具体创建过程可参考 申请MQ资源。
使用MQ服务的应用程序需要部署在阿里云ECS上。
部分资料来自 消息队列>TCP接入(专业)>C/C++SDK环境准备
生产者
producer = Ons::Producer.new('<ONS_ACCESS_KEY>', '<ONS_SECRET_KEY>', '<ONS_PRODUCER_ID>') # 资源准备 producer.start# 在 topic <ONS_TOPIC> 下发送消息 producer.send_message('<ONS_TOPIC>', 'tag', 'Hello, World!')# 必须在程序退出前调用 shutdown 方法释放相关资源，否则可能出现栈错误 producer.shutdown更多用法，请参考{file:samples/producer.rb}及API文档
消费者
consumer = Ons::Consumer.new('<ONS_ACCESS_KEY>', '<ONS_SECRET_KEY>', '<ONS_CONSUMER_ID>') # 订阅 topic <ONS_TOPIC> 下的所有消息 # 注意，当消息达到时，会调用下述函数，此函数会被调度到单独线程中执行 consumer.subscribe('<ONS_TOPIC>', '*') { |message| p message } # 资源准备 consumer.start # 等待消息到达 sleep 32 # 必须在程序退出前调用 shutdown 方法释放相关资源，否则可能出现栈错误 consumer.shutdown更多用法，请参考{file:samples/consumer.rb}及API文档
评论