aliyun-ons-ruby-sdk 阿里云 ONS 消息队列服务开源项目

我要开发同款
匿名用户2016年09月12日
120阅读

技术信息

开源地址
https://github.com/souche/aliyun-ons-ruby-sdk
授权协议
GPL

作品详情

Os

阿里云ONS消息队列服务RubySDK(非官方版本)

项目依赖

Liux/Uix系统

Ruby2.1.5或以上版本

BoostC++程序库

安装步骤

安装Ruby程序

$ rvm istall 2.1.5

安装BoostC++程序库

$ apt-get istall libboost-all-dev

安装os

$ gem istall os使用方式

环境准备

安装osrubygems。

代码里涉及到的TOPIC、PRODUCER_ID、CONSUMER_ID,需要在MQ控制台上创建。MessageTag可以完全由应用自定义,具体创建过程可参考 申请MQ资源。

使用MQ服务的应用程序需要部署在阿里云ECS上。

部分资料来自 消息队列>TCP接入(专业)>C/C++SDK环境准备

生产者

producer = Os::Producer.ew('<ONS_ACCESS_KEY>', '<ONS_SECRET_KEY>', '<ONS_PRODUCER_ID>') # 资源准备 producer.start# 在 topic <ONS_TOPIC> 下发送消息 producer.sed_message('<ONS_TOPIC>', 'tag', 'Hello, World!')# 必须在程序退出前调用 shutdow 方法释放相关资源,否则可能出现栈错误 producer.shutdow

更多用法,请参考{file:samples/producer.rb}及API文档

消费者

cosumer = Os::Cosumer.ew('<ONS_ACCESS_KEY>', '<ONS_SECRET_KEY>', '<ONS_CONSUMER_ID>') # 订阅 topic <ONS_TOPIC> 下的所有消息 # 注意,当消息达到时,会调用下述函数,此函数会被调度到单独线程中执行 cosumer.subscribe('<ONS_TOPIC>', '*') { |message| p message } # 资源准备 cosumer.start # 等待消息到达 sleep 32 # 必须在程序退出前调用 shutdow 方法释放相关资源,否则可能出现栈错误 cosumer.shutdow

更多用法,请参考{file:samples/cosumer.rb}及API文档

功能介绍

Ons 阿里云 ONS 消息队列服务 Ruby SDK(非官方版本) 项目依赖 Linux/Unix 系统 Ruby 2.1.5 或以上版本 Boost C++ 程序库 安装步骤 安装 Ruby...

声明:本文仅代表作者观点,不代表本站立场。如果侵犯到您的合法权益,请联系我们删除侵权资源!如果遇到资源链接失效,请您通过评论或工单的方式通知管理员。未经允许,不得转载,本站所有资源文章禁止商业使用运营!
下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态

评论