在kafka中，每一个broker都是一个服务器。按照一般理解，服务器就是一个SocketServer，其不断接收用户的请求并进行处理。在Java中进行网络连接有两种方式一种为阻塞模式一种为非阻塞模式。Jafka采用非阻塞模式进行网络通讯。在Java的非阻塞模式中，建立socket server的一般流程如下：
1.启动ServerSocketChannel并将其绑定到特定的端口。
2.将Se...
分类：
其他好文 时间：
2014-06-28 09:25:54
阅读次数：
235
Jafka Acceptor接收到客户端请求并建立连接后，Acceptor会将Socket连接交给Processor进行处理。Processor通过以下的处理步骤进行客户端请求的处理：
1. 读取客户端请求。
2. 根据客户端请求类型的不同，调用相应的处理函数进行处理。
Processor读取客户端请求是一个比较有意思的事情，需要考虑两个方面的事情：第一，请求规则（Processor需要按照...
分类：
其他好文 时间：
2014-06-28 09:25:18
阅读次数：
278
///////////////////////////////////////
// Asio同步socket连接示例
//
#include
#include
#include
#include
using namespace boost;
typedef boost::asio::io_service IoService;
typedef boost::asio::ip::tcp T...
分类：
其他好文 时间：
2014-06-28 09:24:33
阅读次数：
234
在Kafka中，LogManager负责管理broker上所有的Log（每一个topic-partition为一个Log）。通过阅读源代码可知其具体完成的功能如下：
1. 按照预设规则对消息队列进行清理。
2. 按照预设规则对消息队列进行持久化（flush操作）。
3. 连接ZooKeeper进行broker、topic、partition相关的ZooKeeper操作。
4. 管理brok...
分类：
其他好文 时间：
2014-06-28 08:25:21
阅读次数：
208
引言
Hadoop分布式文件系统(HDFS)被设计成适合运行在通用硬件(commodity hardware)上的分布式文件系统。它和现有的分布式文件系统有很多共同点。但同时，它和其他的分布式文件系统的区别也是很明显的。HDFS是一个高度容错性的系统，适合部署在廉价的机器上。HDFS能提供高吞吐量的数据访问，非常适合大规模数据集上的应用。HDFS放宽了一部分POSIX约束，来实现流式读取文件...
分类：
其他好文 时间：
2014-06-28 07:48:49
阅读次数：
253
memcached：由LiveJournal旗下DangaInteractive公司的BradFitzpatric为首开发的一款软件，现已成为mixi，hatena，Facebook，Vox，LiveJournal等众多服务器提高Web应用程序扩展性的重要因素；memcached是一款开源、高性能、分布式内存对象缓存系统，可应用各种需要缓存的场景，..
分类：
其他好文 时间：
2014-06-28 06:53:05
阅读次数：
337
数据类型：分为值类型和引用类型值类型包括：简单类型（整数类型，实数类型，字符类型，布尔类型），结构类型，枚举类型引用类型包括：类，接口，数组，委托以及object和string，其中object和string是两个比较特殊的类型，object是C#中所有类型（包括所有的值类型和引用类型）..
分类：
其他好文 时间：
2014-06-28 06:05:42
阅读次数：
304
.htaccess文件(或者"分布式配置文件"）提供了针对目录改变配置的方法，即，在一个特定的文档目录中放置一个包含一个或多个指令的文件，以作用于此目录及其所有子目录。作为用户，所能使用的命令受到限制。管理员可以通过Apache的AllowOverride指令来设置。概述来说，htaccess文..
分类：
数据库 时间：
2014-06-28 00:52:14
阅读次数：
338
1、环境介绍os:oraclecentos5.9apache:httpd-2.2.3-74.0.1.el5php:php53-5.3.3-13.el5_8mysql:mysql-server-5.0.95-3.el52、安装过程#yuminstall-yhttpd
#servicehttpdstart
#yuminstall-ymysql-server
#servicemysqldstart
#yuminstall-yphp53
#yum-yinstallphp53-mysql3、环..
分类：
其他好文 时间：
2014-06-28 00:24:56
阅读次数：
242
Kafka是一个分布式的消息中间件，可以粗略的将其划分为三部分：Producer、Broker和Consumer。其中，Producer负责产生消息并负责将消息发送给Kafka；Broker可以简单的理解为Kafka集群中的每一台机器，其负责完成消息队列的主要功能（接收消息、消息的持久化存储、为Consumer提供消息、消息清理.....)；Consumer从Broker获取消息并进行后续的操作。...
分类：
其他好文 时间：
2014-06-27 23:55:13
阅读次数：
387
