aliyun-ons-ruby-sdk阿里云 ONS 消息队列服务
Ons
阿里云 ONS 消息队列服务 Ruby SDK(非官方版本)
项目依赖
Linux/Unix 系统
-
Ruby 2.1.5 或以上版本
Boost C++ 程序库
安装步骤
$ rvm install 2.1.5
$ apt-get install libboost-all-dev
$ 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 文档
评论
rmq消息队列服务
rmq是一个基于Redis的消息队列服务,体积小而且易用,客户端基于Jedis。示例代码:Producer p = new Producer(new Jedis("localhost"),"some
rmq消息队列服务
0
php-queuePHP 消息队列服务
php-queue是PHP开发的磁盘存储消息队列服务,基于leveldb和swoole,在4核机器上处理能力可以达到2.5W/s。leveldb:https://github.com/google/l
php-queuePHP 消息队列服务
0
HazelcastMQ消息队列服务
HazelcastMQ在基础的Queue和Topic数据结构的基础上通过Hazelcat提供一个简单的消息层。HazelcastMQ强调简单的配置和可靠的集群,提供一个可理解和灵活的信息API。Haz
HazelcastMQ消息队列服务
0
Sqs4J简单消息队列服务
按照张宴的"基于HTTPGET/POST协议的轻量级开源简单消息队列服务"协议用纯java实现.可以达到每秒并发10000个请求.使用Netty做网络IO,BerkeleyDB Key/Value数据
Sqs4J简单消息队列服务
0