vlambda博客
学习文章列表

./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]

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

namespace php tutorial
service zkDataService {
 string zkData()
}

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

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

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节点数据
 }
 );
}
 
client.once('connected', function () {
 console.log('Connected to ZooKeeper.');
 getData(client, path);
});
 
client.connect();
process.emit('message', '======');

var childprocess = require('child_process');
var worker = childprocess.fork('./support.js');
console.log('pid in master:', process.pid);
var childMessage="";
//监听子进程事件
worker.on('message', function(msg) {
 childMessage=msg;
 console.log('1:', msg);//监听子进程zk数据，并将zk节点数据打印
})
process.on('message', function(msg) {
 console.log('2:', msg);
})

//触发事件 message
process.emit('message', '------');
var thrift = require("thrift");
var zkDataService = require("./gen-nodejs/zkDataService");
var ttypes = require("./gen-nodejs/tutorial_types");
var data = {};
var server = thrift.createServer(zkDataService, {
 zkData: function(result) {
 result(null, childMessage);//将zk节点数据返回
 }
});
server.listen(9090);

<?php
namespace tutorial\php;
error_reporting(E_ALL);
require_once __DIR__.'/lib/Thrift/ClassLoader/ThriftClassLoader.php';
require_once __DIR__.'/gen-php/tutorial/zkDataService.php';
use Thrift\ClassLoader\ThriftClassLoader;
$GEN_DIR = realpath(dirname(__FILE__).'/..').'/gen-php';
$loader = new ThriftClassLoader();
$loader->registerNamespace('Thrift', __DIR__ . '/lib');
$loader->registerDefinition('shared', $GEN_DIR);
$loader->registerDefinition('tutorial', $GEN_DIR);
$loader->register();
/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements. See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership. The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License. You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
use Thrift\Protocol\TBinaryProtocol;
use Thrift\Transport\TSocket;
use Thrift\Transport\THttpClient;
use Thrift\Transport\TBufferedTransport;
use Thrift\Exception\TException;
try {
 if (array_search('--http', $argv)) {
 $socket = new THttpClient('localhost', 8080, '/php/PhpServer.php');
 } else {
 $socket = new TSocket('192.168.0.105', 9090);
 }
 $transport = new TBufferedTransport($socket, 1024, 1024);
 $protocol = new TBinaryProtocol($transport);
 $client = new \tutorial\zkDataServiceClient($protocol);
 $transport->open();
 $result= $client->zkData();
 print "$result";//打印zk节点数据
 $transport->close();
} catch (TException $tx) {
 print 'TException: '.$tx->getMessage()."\n";
}
?>