系统状态 门户登录

云队列cURLookbook

推荐编辑

云队列是一个开源消息队列实现
使用复用HTTP接口提供异步
通信协议是今日主要需求
可缩放应用使用队列通信层
消息发件人和接收人无需与
消息队列并发结果,这些可标度
独立并不易个人故障

云队支持出版社订户和生产者-消费者
模式化文章审查云队列使用术语并举常用cURL命令实例

关于云队资源和方法以及cURL请求和响应示例的更多信息见API参考段云队开发者指南.

云队列术语

  • 队列逻辑实体分组消息理想队列
    创建工作类型举例说,如果你想压缩文件
    会为此作业创建队列 。任意应用
    从队列读出只压缩文件
  • 消息传递消息存储队列并存到删除
    接受者或自动系统基础
    TTL(时间对点)值消息存储有意义的数据
    应用程序
  • 工人程序读取或多消息
    队列内
  • 制作者程序生成消息队列
  • 索赔机制标记消息以便其他工人
    进程不相同消息
  • 发布器-订阅器模式化所有工人应用
    存取队列中所有消息工人无法删除或更新消息
  • 生产者-消费者模式化,每个工人应用
    读队列必须请求消息以防止
    重复处理稍后工作完成后,工人们
    负责删除消息消息不删除
    预定义时间可供其他工人使用
  • 消息时间直播定义消息存取时间
  • 时间直播定义消息会持续多久
    申请状态消息可归工
    时间问题

CURL发送请求

验证程序

华体会联盟hth向rakspace云队列发送请求时,需要认证令牌才能写入X-AUT-Token页眉

带有效令牌后,可发送API服务端点验证响应中包含令牌过期日期令牌过期后,可发送另一份认证请求获取新请求

步进中云队开发者指南华体会联盟hth验证拉克空间云

链表队列

操作列表现有队列,按名称字母排序内无队列时,请求返回204 无内容出错是因为没有信息发回

请求

华体会联盟hthGet/V1/quees HTTP/1.1主机:ord.quees.api.racsploud.com内容类型:应用/jsonX-Auth-Token

响应

HTTP/1.1200确定内容链3170内容-类型:应用/jsoncharset=utf-8 Content-Location: /v1/queues  {    "queues":[       {          "href":"/v1/queues/036b184b28fcb548349af623079119c6a966cbc",          "name":"036b184b28fcb548349af623079119c6a966cbc"       },       {          "href":"/v1/queues/0441f28617afbdecf4887e635fd0777fb3cec38",          "name":"0441f28617afbdecf4887e635fd0777fb3cec38"       },       {          "href":"/v1/queues/0f8f0eff158922874536efa9cf8412b9e0fd07a",          "name":"0f8f0eff158922874536efa9cf8412b9e0fd07a"       },       {          "href":"/v1/queues/160f981379972a4a0afaee5f5394a5d960c410e",          "name":"160f981379972a4a0afaee5f5394a5d960c410e"       },       {          "href":"/v1/queues/2888a4527d0a11a3d82202d800f8e90eebd60ea",          "name":"2888a4527d0a11a3d82202d800f8e90eebd60ea"       },       {          "href":"/v1/queues/2ad8eeca7f53d480d8ca4885d620643bfc6a7f9",          "name":"2ad8eeca7f53d480d8ca4885d620643bfc6a7f9"       },       {          "href":"/v1/queues/3926ce2051db957d76a04cb2ea2d89fd49e6894",          "name":"3926ce2051db957d76a04cb2ea2d89fd49e6894"       },       {          "href":"/v1/queues/46b30ebd60186c30194039824e6405300dc0903",          "name":"46b30ebd60186c30194039824e6405300dc0903"       },       {          "href":"/v1/queues/486d5af3e057ee1a430eee3ee845aeb60c900d3",          "name":"486d5af3e057ee1a430eee3ee845aeb60c900d3"       },       {          "href":"/v1/queues/58e8622645f07c7673412acbed51abb97ddb25d",          "name":"58e8622645f07c7673412acbed51abb97ddb25d"       }    ],    "links":[       {          "href":"/v1/queues?marker=58e8622645f07c7673412acbed51abb9",          "rel":"next"       }    ] }

创建队列

操作创建新队列, 发布消息前需要新队列 。

请求

华体会联盟hthPUT /v1/queues/demoqueue HTTP/1.1 Host: ord.queues.api.rackspacecloud.com X-Auth-Token: 0f6e9f63600142f0a970911583522217 Accept: application/json X-Project-Id: 806067

响应

HTTP/1.1201内容链:0

发布消息

操作发布指定数消息最多可提交10条消息单选,但必须总是封装到集合容器中举个例子 JSON内数组

获取更多信息Post应用消息操作见云队开发者指南.

请求

华体会联盟hthPST/V1/queues/messages HTTP/1.1主机806067[{tl:300}{backste

响应

HTTP/1.1201内容链149内容-类型:应用/jsonCashet=utf8位置:/V1/quees/demue/messages?ids=51db6f78c508f17dc924575

确定所需工数

确定工数申请基于数
消息你期望看到新消息数目
快速增长比点名工数
过程,你可能需要更多工人确定此比
创建调用/queues/{queue_name}/stats endpoint并寻找
数消息免费总计数

注释 :附加API调用请求响应实例可见API参考段云队开发者指南.

更新 大约2个月前

Baidu
map