站在架构设计的角度，针对数据一致性需要把业务因素考虑进来，这有利于团队在技术上作出更合理的选择。根据具体业务场景，评估出业务对事务的优先级，更有利于作出架构上的取舍。

本文通过一个基于Netty构建分布式消息队列系统（AvatarMQ），简单地阐述了一个极简消息中间件的内部结构、以及如何利用Netty，构建生产者、消费者消息路由的通信模块。

对于互联网应用和企业大型应用而言，多数都尽可能地要求做到7*24小时不间断运行，而要做到完全的不间断运行可以说“难于上青天”。

本文首先介绍小米网系统架构的发展变化，然后介绍Notify系统的设计，最后介绍Notify系统的演化与升级变迁。希望能给各位的工作带来一些启发与指导。

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。

写这篇文章的原因也是对JavaScript语言本身的编程模型做一个总结，借以巩固自己对JavaScript的理解，并希望举一反三，通过了解其独特的编程模型，进一步消化吸收，提高自己知识的深度与广度。

分布式存储系统除了要保证客户端写请求流程的正确性，节点可能会非正常宕机或者需要重启，在启动的时候必须要能够正常地加载/恢复已有的数据，日志管理类在创建的时候要加载已有的所有日志文件，这和创建Lo...

RabbitMQ无疑是目前最流行的消息队列之一，对各种语言环境的支持也很丰富，作为一个.NET developer有必要学习和了解这一工具。

ActiveMQ是Apache所提供的一个开源的消息系统，完全采用 Java 来实现，因此，它能很好地支持J2EE提出的JMS（Java Message Service,即Java消息服务）规范...

今天我们来解读一下Flink stream里的 source 模块。它是整个stream的入口，也是我们了解其流处理体系的入口。

当前股票市场的交易者可以了解丰富的股票交易信息。从金融新闻到传统的报纸和杂志再到博客和社交媒体，汇聚着海量的数据，远比股票交易者想关注的股票信息要大得多，这就需要为股票交易者提供信息的有效过滤。...

Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下： 以时间复杂度为O(1)的方式提供消息持久化能力，即使对TB级以上数据也能保证常数时间的访问性能 高吞吐率。即使在非常廉...

Kafka分区机制介绍与示例：Kafka中可以将Topic从物理上划分成一个或多个分区（Partition），每个分区在物理上对应一个文件夹， 以”...

淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件，使用Mysql作为消息存储媒介，可完全水平扩容，为了进一步降低成本，我们认为存储部分可以进一步优化，2011年初，Linkin开源了...

Kafka 0.9+增加了一个新的特性 Kafka Connect ,可以更方便的创建和管理数据流管道。它为Kafka和其它系统创建规模可扩展的、可信赖的流数据提供了一个简单的模型，通过 con...

Centos7安装rabbitmq server 3.6.0：###假设所有操作在opt目录下进行 cd /opt mkdir apps cd apps ### 下载 RabbitM...

jms与ActiveMQ实践与应用：词语解释 （有些词可能用的不是很正确，在这里我把自己能意识到的词拿出来解释一下）： 1、  跨服务器...

Apache Kafka是一个快速可扩展的消息队列，能够应对繁重的读写负载，即IO相关工作。更多信息请参见http://kafka.apache.org。由于Zookeeper能提供可靠的分布式...

1.Kafka独特设计在什么地方？ 2.Kafka如何搭建及创建topic、发送消息、消费消息？ 3.如何书写Kafka程序？ 4.数据传输的事务定义有哪三种？ 5.Kafk...

本文讲述了如何在Windows OS上配置并启动Apache Kafka，这篇指南将会指导你安装Java和Apache Zookeeper。 Apache Kafka是一个快速可扩展的消息队...