Guardian快速接入 Zookeeper

Guardian

让你的程序快速接入Zookeeper来实现高可用

介绍

• 使用curator 连接zookeeper，保证连接质量。

• 实时更新zookeeper的节点数据，保证消费和生产一致。

• 实现了服务治理，目前提供了 随机 和 轮询两种方式，后续会加入 权重 和 熔断 两种消费方式。

• sample 是一个示例程序，欢迎大家下载使用。

使用介绍：

示例代码：

//生产者，初始化注册节点
ZookeeperRegistry zr = new ZookeeperRegistry ();
Zdata zdata = new Zdata();
zr.regist(zdata);


//消费者，继承ZookeeperDiscovery，等待回调

discover(Zdata provider);//可用的节点

destory();//一旦断开zookeeper，消费者也要断开，保持一致


//消费者如果成功消费，需要告诉zookeeper
consume(Zdata provider, String host, int port)//提供消费者是谁，以及自身的ip和端口