1 Paxos算法 1.1 基本定义 算法中的参与者主要分为三个角色，同时每个参与者又可兼领多个角色: ⑴proposer 提出提案，提案信息包括提案编号和提议的value; ⑵acceptor 收到提案后可以接受(accept)提案; ⑶learn…
我们知道，在经典的paxos算法中每一个peer都是proposer，但是这就不可避免的产生提案冲突，为了减少这种冲突带来的系统消耗与时间延迟，就产生了Leader这个角色，整个系统中，就只允许Leader可以发出提案。ZooKeeper就是按照这个…
在现代操作系统中，进程支持多线程。进程是资源管理的最小单元；而线程是程序执行的最小单元。一个进程的组成实体可以分为两大部分：线程集合资源集。进程中的线程是动态的对象；代表了进程指令的执行。资源，包括地址空间、打开的文件、用户信息等等，由进程内的线程共…
Leader 选举用于保证系统的高可用，例如一个重要服务，为防止其出现故障使服务中断，同时准备好另外2个备用，这就需要从3个服务节点中选出一个对外服务，这个服务出现故障后，从另两个服务节点中再选出一个对外提供服务，这个选主过程就是 Leader 选举…
Zookeeper 分布式服务框架是 Apache Hadoop 的一个子项目，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。本文将从使用者角度详细介绍 Zookeeper…
如今每个语言体系中都有一个包管理工具，PHP的Composer，Ruby的gem，Python的pip，Java的Maven……当然还有Node.js的npm。有的人会奇怪为何要引入又一个新东西来让我们已经够辛苦的编程工作雪上加霜呢？其实不然，例如我…
添加和删除主题（Topic） 你可能使用过手动创建主题或发送消息时自动创建主题这样的操作。但是你并不了解其中的详情。Kafka中的主题可以在主题配置中配置为自动创建的。 ./kafka-topics.sh --create --zookeeper l…
众所周知，由于Zookeeper并不适合大批量的频繁写入操作，新版Kafka已推荐将consumer的位移信息保存在Kafka内部的topic中，即__consumer_offsets topic，并且默认提供了kafka_consumer_grou…
问题导读 1.kafka是否需要zookeeper？ 2.kafka是什么？ 3.kafka包含哪些概念？ 4.如何模拟客户端发送、接受消息初步测试？ 5.kafka cluster怎么同zookeeper交互的？ 1.前言 由于项目涉及到kafka…
环境： ・jdk1.7.0_09 ・Jetty8.1 ・eclipse 1，用JDK自带的keytool生成证书 cd D:\JavaStudy\keystore keytool -genkey -alias dotuian -keyalg RSA …
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/08/09/KafkaColumn4 摘要 本文主要介绍了Kafka High Level Consumer，Consumer Group，Cons…
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/06/08/KafkaColumn3 摘要 本文在上篇文章基础上，更加深入讲解了Kafka的HA机制，主要阐述了HA相关各种场景，如Broker f…
fsockopen() — Open Internet or Unix domain socket connection 一、如何禁用fsockopen() 下面是两种常用的禁用fsockopen的方法。 1、修改php.ini，将 disable_…
本文转发自Jason’s Blog，原文链接 http://www.jasongj.com/2015/04/24/KafkaColumn2 摘要 Kafka在0.8以前的版本中，并不提供High Availablity机制，一旦一个或多个Broker…
通用解决方法： 找到程序里的fsockopen 函数，替换为：pfsockopen，即可解决所有问题，两个函数的区别在于pfsockopen 保持keep-alive，使得黑客无法进行 连接数攻击。 已知使用fsockopen 函数的程序文件路径（在…