阿里云 ONS 消息队列服务 aliyun-ons-ruby-sdk

GPL
Ruby 查看源码»
跨平台
2016-09-12
申玉宝

Ons

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

项目依赖

  • Linux/Unix 系统

  • Ruby 2.1.5 或以上版本

  • Boost C++ 程序库

安装步骤

安装 Ruby 程序

$ rvm install 2.1.5

安装 Boost C++ 程序库

$ apt-get install libboost-all-dev

安装 ons

$ gem install ons

使用方式

环境准备

  • 安装 ons rubygems。

  • 代码里涉及到的 TOPIC、PRODUCER_ID、CONSUMER_ID,需要在 MQ 控制台上创建。 Message Tag 可以完全由应用自定义,具体创建过程可参考 申请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 文档

的码云指数为
超过 的项目
加载中

评论(0)

暂无评论

暂无资讯

暂无问答

如何在阿里云生态下支持Spark?

如何在阿里云生态下支持Spark?

2015/09/19 21:02
118
0
几款消息中间的调研(转)

消息队列调研 消息系统简介 本次主要调研业界使用广泛的两款消息队列——RabbitMQ, Kafka, 以及阿里云的提供的两个服务, MNS和ONS. RabbitMQ RabbitMQ 是使用Erlang编写的一个开源的消息队...

2016/08/16 10:47
321
0
【干货索引】阿里云大数据计算服务MaxCompute与生态系统的融合

摘要: MaxCompute大家都不陌生,之前产品名称叫ODPS,之后随国际化而更名。从支持阿里集团内部99%数据业务到计算能力对外输出,帮助政府、互联网公司、金融等进行大数据项目服务,使得数据变...

2018/01/12 17:10
23
0
firefox监听tab的关闭事件

需求是要求某个网址最多只能在一个tab页打开,最终用Firefox Add-on解决

2015/06/25 00:12
414
0
阿里云iot

简介 deviceName deviceSecret 服务端可以通过API给设备发布数据 sdk快速开始 PHP SDK使用说明 https://github.com/aliyun/iotkit-embedded 修改设备三元组就可以编辑运行了 sample/mqtt/mq...

02/21 14:41
5
0
富文本编辑器ueditor上传文件到阿里云OSS服务器中简单实例

本人菜鸟一枚,最近公司有需求要用到富文本编辑器,我选择的是百度的ueditor富文本编辑器,闲话不多说,进入正题: 一:ueditor的下载及安装以及OSS的下载及引入我就不详细说了,这里说下要注...

2016/10/13 15:49
532
1
ha-2:read-project-properties (default) on project

[ERROR] Failed to execute goal org.codehaus.mojo:properties-maven-plugin:1.0-alp ha-2:read-project-properties (default) on project play-licensing: Properties fil e not found: D:...

2015/08/04 11:42
8
0
本地jar使用Maven坐标

此方法仅供本地使用(适用于从别的地方拷贝来一个jar 但需要在本地maven项目中引用的情况) 例如 修改了ueditor 打包 -> ueditor-edit-1.0.jar 放到本地maven仓库的以下位置 repository\aaa...

2018/07/04 11:17
13
0
Android ADK

google adk demo https://android-review.googlesource.com/#/admin/projects/device/google/accessory/adk2012_demo http://gushedaoren.blog.163.com/blog/static/17366340520129201025454...

2014/07/07 23:31
81
1

没有更多内容

加载失败,请刷新页面

返回顶部
顶部