总结一下几种ExchangeTypes。之前写发布/订阅模式时第一次提到了exchange type。即producer不是将消息直接放到队列中,而是先到exchange中,exchange主要用于控制消息到队列的路由,根据具体的exchange type将消息传给需要的队列或者直接废弃。在这一篇中...
分类:
其他好文 时间:
2014-11-23 20:13:14
阅读次数:
226
试着用RabbitMQ进行RPC。其实用RabbitMQ搞RPC也没什么特别的。只是我们需要在请求中再加入一个callback queue。比如这样:callbackQueueName = channel.queueDeclare().getQueue(); BasicProperties prop...
分类:
其他好文 时间:
2014-11-23 20:10:04
阅读次数:
185
Python是一种面向对象、解释型计算机程序设计语言。被认为是比较好的胶水语言。至于其他的,你可以去百度一下。本文仅介绍python的安装和配置,供刚入门的朋友快速搭建自己的学习和开发环境。本人欢迎大神拍砖,邮箱:it_red@sina.com 本博文出处:http://itred.cnblogs....
分类:
编程语言 时间:
2014-11-22 15:58:29
阅读次数:
300
基础知识:RabbitMQ 是一个开源的MQ,使用 Erlang 写成。MQ 全称是Message Queue (消息队列), 是一种应用程序对应用程序的通信方法。通过消息队列,应用程序之间可以通过读写出入队列的消息来通信,而不是通过直接调用彼此来通信。Erlang 是一种通用的面向并发的编程语言,...
hadoop是一个分布式的基础架构,利用分布式实现高效的计算与储存,最核心的设计在于HDFS与MapReduce,HDFS提供了大量数据的存储,mapReduce提供了大量数据计算的实现,通过Java项目实现hadoop job处理海量数据解决复杂的需求。
一、基本环境及相关软件的配置
详细配置说明:基本环境配置及权限申请
二、hadoop项目开发流程
hadoop主要的...
分类:
其他好文 时间:
2014-11-19 18:49:25
阅读次数:
175
消息队列的实现中,RabbitMQ以其健壮和可靠见长.公司的项目中选择了它作为消息队列的实现.关于MQ的机制和原理网上有很多文章可以看,这里就不再赘述,只讲几个比较容易混淆的问题1,binding key和routing key binding key和routing key是都不过是自己设置的一....
分类:
Web程序 时间:
2014-11-18 00:16:03
阅读次数:
197
在publish/subscribe模式中使用fanout类型有个缺陷,就是不能选择性接收的消息。我们可以让consumer获得所有已发布的消息中指定的几个消息。在之前的例子中我们这样绑定exchange和队列:channel.queueBind(queueName, EXCHANGE_NAME, ...
分类:
其他好文 时间:
2014-11-15 21:39:10
阅读次数:
299
这次我们试试publish / subscribe模式,也就是将一个消息发送给多个consumer。这里用一个简单的小程序来说明publish / subscribe。由一个provider提供消息,这个消息会被多个consumer接收。consumer对同一个消息做出不同的反应,比如打印、保存到文...
分类:
其他好文 时间:
2014-11-15 21:29:33
阅读次数:
348
RabbitMQ是个健壮、易用、开源、支持多种操作系统和语言的message broker。当然,一切的前提是机器里面正在运行着rabbitmq-server。点击下面的图片下载:rabbitMQ和AMQP的关系是什么样的?rabbitMQ负责哪部分?如图所示,就是provider和consumer...
分类:
其他好文 时间:
2014-11-15 20:14:40
阅读次数:
285
这次我们试着实现这样一个小程序:嗯,就是任务队列(task queue)。不是将任务集中在一堆并一直等到所有任务一并完成为止,而是将每一个任务封装为一个消息,并将其发送到队列,后台的workers就从队列中分担工作。web应用尤其喜欢这种处理方式,比如面对一个请求时我们有一大堆复杂逻辑需要处理,而我...
分类:
其他好文 时间:
2014-11-15 20:13:43
阅读次数:
336