Kafka、RabbitMQ、RocketMQ消息中间件的对比
引言 分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,目前对Kafka、RabbitMQ、Ro...
基于Kafka+Flink+Redis的电商大屏实时计算案例
前言 一年一度的双11又要到了，阿里的双11销量大屏可以说是一道特殊的风景线。 实时大屏（real-time dashboard）正在被越来越多的企业采...
Strom+Kafka + redis实时计算单词出现频率的案例
案例要实现的目标 在Kafka的shell 客户端中输入内容，通过Storm实时去kafka中取数据并进行计算单词出现的次数，并且实时把这些数据信息...
Spark Streaming使用Kafka保证数据零丢失
spark streaming从1.2开始提供了数据的零丢失，想享受这个特性，需要满足如下条件： 1.数据输入需要可靠的sources和可靠的receivers 2....
Java使用RabbitMQ（五）–消息分发策略
消息分发策略 RabbitMQ默认的消息分发策略是公平分发（Fair dispatch），把消息轮流发给每个worker者。 这样有个问题：某个worker很忙的...
DocKer中下部署rabbitmq性能集群
rabbitmq集群中，各个rabbitmq为对等节点，即每个节点均提供给客户端连接，进行消息的接收和发送。节点分为内存节点和磁盘节点，一般的...
AMQP-RabbitMQ/4/路由模式
4. 路由模式 Routing 图示 个人理解 生产者定义Exchange，设置类型为direct。将消息发送给Exchange之前，为每条消息指定路由键 消费者定...
基于Python语言使用RabbitMQ消息队列（六）
远程过程调用（RPC） 在第二节里我们学会了如何使用工作队列在多个工人中分布时间消耗性任务。 但如果我们想要运行存在于远程计算机上的...