文章 2016-05-11 来自:开发者社区

【转载】消息队列RabbitMQ入门介绍

(一)基本概念       RabbitMQ 是流行的开源消息队列系统,用 erlang 语言开发。我曾经对这门语言挺有兴趣,学过一段时间,后来没坚持。RabbitMQ 是 AMQP(高级消息队列协议)的标准实现。如果不熟悉 AMQP,直接看 RabbitMQ 的文档会比较困难。不过它也只有几个关键概念,这里简单介绍。 RabbitMQ 的结构图如下: 几个概念说明:...

问答 2016-04-21 来自:开发者社区

MQ消息队列是否能通过HTTP接口发送定时(延时)消息?

如题,目前只在SDK中看到了发送延迟消息的功能,HTTP接口是否可以实现?

问答 2016-04-15 来自:开发者社区

关于ONS产品消息队列 MQ的使用问题

hi,我发布Topic的时候,总是提示我没有开通MS服务,可是我明明是开通了的。错误提示如下:

问答 2016-04-01 来自:开发者社区

PHP重写的消息队列MQ类

阿里云的大神们好像是JAVA出身,很多文档都是根据JAVA习惯或规范写的,对我们这种非JAVA的来说,非常不方便。 接合文档和[售后工程师帮助重写了AliONS类,希望对后来者有帮助,少走弯路。也希望大神们看看HTTP协议文档。 header('Content-Type: text/html; charset=utf-8');// ====== 测试DEMO ===============...

问答 2016-03-09 来自:开发者社区

消息队列中mqtt方式中sampleClient.setCallback中无法调用messageArrived方法

在消息队列中,我使用官方提供的Demo,com.aliyun.openservice.ons.mqtt.demo,可以发送消息,但是在测试接收消息时始终无法收到消息,测试方法运行后只显示:subscribe....success,但是发送的消息都无法收到。在ones控制台查看订阅情况,显示无任何订阅者在线。我感觉 在回调函数(sampleClient.setCallback(new MqttCa....

文章 2014-03-20 来自:开发者社区

RabbitMQ消息队列(九):Publisher的消息确认机制

       在前面的文章中提到了queue和consumer之间的消息确认机制:通过设置ack。那么Publisher能不到知道他post的Message有没有到达queue,甚至更近一步,是否被某个Consumer处理呢?毕竟对于一些非常重要的数据,可能Publisher需要确认某个消息已经被正确处理。   &nb...

文章 2014-02-24 来自:开发者社区

RabbitMQ消息队列的小伙伴: ProtoBuf(Google Protocol Buffer)

     什么是ProtoBuf?      一种轻便高效的结构化数据存储格式,可以用于结构化数据串行化,或者说序列化。它很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构数据格式。目前提供了 C++、Java、Python 三种语言的 API。  ...

文章 2014-02-23 来自:开发者社区

RabbitMQ消息队列(七):适用于云计算集群的远程调用(RPC)

        在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成。那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会通过其它节点求来斐波纳契完成示例。1. 客户端接口 Client interface   &n...

文章 2014-02-23 来自:开发者社区

RabbitMQ消息队列(六):使用主题进行消息分发

         在上篇文章RabbitMQ消息队列(五):Routing 消息路由 中,我们实现了一个简单的日志系统。Consumer可以监听不同severity的log。但是,这也是它之所以叫做简单日志系统的原因,因为是仅仅能够通过severity设定。不支持更多的标准。    &nb...

文章 2014-02-21 来自:开发者社区

RabbitMQ消息队列(五):Routing 消息路由

    上篇文章中,我们构建了一个简单的日志系统。接下来,我们将丰富它:能够使用不同的severity来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。1. Bindings绑定     上篇文章中我们是这么做的绑定: channel.queue_bind(exchange=exchange_name, queue...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。