Kafka 的实现原理

最后还是用的 0.1.x 版本，不过没有安装任何扩展，直接把 Consumer 的 __construct 中的：

$zookeeper = new \Kafka\ZooKeeper($hostList, $timeout);

改为了

$zookeeper = new \Kafka\MetaDataFromKafka($hostList);

这样就不依赖 kafka 扩展（仿照的 Producer 中 __construct 提供第三个参数时的情况）。

不过这个 Consumer 并不是真正意义上的被推送（公司上个版本的 kafka server 带 loginOn/loginOff 手动上下线功能的确实是 http 请求主动推送给我的），而是我的脚本主动请求的 kafka server （死循环脚本 -n1 一个 master 一个 worker 在跑）。

另外 Producer 遇到一个坑：当 Producer 超过 10 分钟没有推送任何消息时，kafka server 会主动断开 socket 连接，这个时候再调用 send() 就会抛出异常，我选择的是在定时脚本 Task 的 execute() 中捕获异常（这个 execute() 是 Task 死循环执行业务逻辑的地方），重新创建 Producer 对象替换原先挂在 Task 对象上的 Producer 对象（应该也可以在 Socket 对象内部 close 后重新 connect，不过没有仔细抠代码）。