php+nodeJs+thrift协议，实现zookeeper节点数据自动发现

php是当下最流行的web服务器端语言，zookeeper是大型分布式协同工具，本文在这里介绍一种架构实现php服务器对于zookeeper数据变化的自动监听。

一.问题背景

php可以CLI模式模式连接zookeeper（下面简称zk），并实现zk节点数据的自动发现，这里不做过多叙述。但web服务器中，php只能主动连接zk以获得节点数据，做不到zk数据的自动发现。其次，php web服务，也难以和php CLI模式下的服务共享数据变量(cli模式下zk数据做成共享变量)。这就导致如果并发量大的话，每一个http请求php都会去连接zk，zk集群的压力会很大，其次，每一个请求都会连接zk，请求结束又释放zk连接，zk的连接与释放过于频繁。

二.解决思路

nodeJs多进程间可以通信，可以解决php服务难以实现共享变量的问题。nodeJs可以在主进程中抛出一个子进程，子进程中实现zk的自动发现，子进程侦察到zk节点数据变化时，主动通知主进程。node主进程写一个服务，像外界提供zk的数据。php web服务需要zk节点数据时，通过RPC协议(这里使用thrift协议)，访问本地node主进程服务,来获取zk节点数据。

这样做有三点好处：

1.实现zk节点变化的自动发现;

2.php和node通信在同一台服务器上，不走网管，速度快，稳定性可靠

3.thrift协议直接操作套接字传输数据，比http服务要快，可以近似看作php调用自己的方法

三.具体实现

1.搭建zookeeper服务，这里我搭了一个5台zk服务的伪集群(zk服务的搭建这里不做过多介绍)，测试zk服务是否能正常写入与读取节点数据

分别启动五台zk服务器

./server001/bin/zkServer.sh start./server002/bin/zkServer.sh start./server003/bin/zkServer.sh start./server004/bin/zkServer.sh start./server005/bin/zkServer.sh start![zookeeper集群启动][1]

启动成功后，测试节点是否能够正常写入读取(这里提前创建了一个/zk_test节点)

启动zk客户端

./bin/zkCli.sh/zk_test测试写入123：set /zk_test 123 发现可以正常写入与读取![zk写入与读取][2]

2.创建node服务

定义thrift提供的服务，新建thrift文件，定义返回zk数据的服务:zkDataService，服务中有一个方法zkData返回节点数据

namespace php tutorialservice zkDataService {     string zkData()}

根据thrift协议生成服务端可客户端的中间代码(生成中间代码我放在windows上完成)，

C:\Users\77388\AppData\thrift-0.10.0.exe -r --gen js:node zkData.thrift

此时会在文件夹中生成中间代码，在gen-nodejs文件夹中

![生成node端中间代码][3]

node安装zookeeper模块：cnpm install node-zookeeper-client，编写子进程support.js，自动发现zk节点数据变更

console.log('pid in worker:', process.pid);process.on('message', function(msg) {  console.log('3:', msg);});var i=0;var zookeeper = require('node-zookeeper-client');var client = zookeeper.createClient('localhost:2181');var path = '/zk_test';//节点名称 function getData(client, path) {    client.getData(        path,        function (event) {            console.log('Got event: %s', event);            getData(client, path);        },        function (error, data, stat) {            if (error) {                console.log('Error occurred when getting data: %s.', error);                return;            }            process.send('zookeeper节点数据'+data.toString('utf8'));//通知主进程zk节点数据    <a>@本文9来源gao($daima.com搞@代@#码8网^</a><strong>搞代gaodaima码</strong>    }    );} client.once('connected', function () {    console.log('Connected to ZooKeeper.');    getData(client, path);}); client.connect();process.emit('message', '======');

喜欢 (0)赏

[搞代码]

分享 (0)