RabbitMQ VS Apache Kafka （九）—— RabbitMQ集群的分区容错性与高可用性
本章，我们讨论有关RabbitMQ的容错性，消息一致性及高可用性。RabbitMQ可以作为集群节点来运行，因此RabbitMQ通常被归为分布式消息系统...
RabbitMQ VS Apache Kafka （一）—— RabbitMQ简介
在接下来的系列章节中，我们将探讨两种消息中间件RabbitMQ与Apache Kafka，从设计的角度来看，作为两种不同的消息中间件，各自都有自己...
Kafka的Log存储解析
引言 Kafka中的Message是以topic为基本单位组织的，不同的topic之间是相互独立的。每个topic又可以分成几个不同的partition(每个topic有...
Kafka+Spark Streaming+Redis实时计算整合实践
基于Spark通用计算平台，可以很好地扩展各种计算类型的应用，尤其是Spark提供了内建的计算库支持，像Spark Streaming、Spark SQL、MLlib...
Java使用RabbitMQ（四）–消息持久化
消息持久化 消息确认，保证了消费者die时，消息不丢失。 而消息持久化，则是为了保证RabbitMQ 怠机时，消息不丢失。 消息持久化需要以下...
AMQP-RabbitMQ/3/发布订阅模式
3. 发布订阅模式 Publish/Subscribe - 全集监听fanout 一次向多个消费者发送消息 图示 个人理解 生产者定义Exchange，同时将Exchange的...
基于Python语言使用RabbitMQ消息队列（五）
Topics 在前面教程中我们改进了日志系统，相比较于使用fanout类型交易所只能傻瓜一样地广播，我们用direct获得了选择性接收日志的能力。...