1 Star 0 Fork 9

L / zkClient4Swift

forked from 翔妖除魔 / zkClient4Swift 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

a simple Apache Zookeeper Client for apple swift lang

zkClient4Swift is a simple zookeeper client written in swift2 . Therefore,it requires xCode 7 to compile.

Swift已经开源了,并且支持Linux上运行.以后Swift不仅仅可以用来写IOS程序,还可以来做其他的后端程序甚至服务端程序.而Zookeeper在分布式服务系统中是必须的基石,像codis,kafka等都需要依赖zookeeper.因此,需要涉及到zookeeper的连接,而我在网上搜索了一遍,目前还没有Swift的Zookeeper的客户端.因此,就自己实现了一个,目前可能还不完善,有需要的兄弟自取吧.

Features

  • zookeeper服务器的连接 OK
  • 节点的基本操作 OK
  • 节点变化的监听 OK
  • 断线重连,网络闪断重试 断线重连 OK 网络闪断TODO
  • 基于framework做一个Mac版的ZK的本地客户端.现在大家都是用的ZooInspector.jar TODO

issues

已知问题:

  • 在MACOS上 需要把zookeeper的session超时时间设置为20秒以上. 因为心跳的线程,不知道为什么,有时会卡住11秒左右...发现是sleep(1)这个地方卡住的,还没有找到原因. 但是在IOS上就没有发现这个问题...

Blog:

翔妖除魔的个人博客

api usage

create client

//create a zkClient connect to 127.0.0.1 and port at 2181
//TODO not supoort zookeeper cluster
let zkClient = ZkClient(serverstring: "127.0.0.1:2181")

connect to Zookeeper

zkClient.connect()

get Children Node

let children = zkClient.getChildren("/hello")
for child in  children! {
    print("subNode:\(child)")
}

check Node exists

print("check node exists:\(zkClient.exists("/aaaaaaa"))")

delete the node

print("delete successed:\(zkClient.delete("/Hello/delete"))")

create the node

//create node by CreateMode.PERSISTENT
try zkClient.create("/Hello/create2", model: CreateMode.PERSISTENT)

//create node by CreateMode.PERSISTENT and need create parent
try zkClient.create("/Hello2/create2",model: CreateMode.PERSISTENT,createParents:true)

//create node by CreateMode.PERSISTENT with data
try zkClient.create("/Hello/create", data: "试一试中文", model: CreateMode.PERSISTENT)

read the node data

//default type is String
zkClient.readData("/Hello/create")

write the node data

//write String to node
try zkClient.writeData("/Hello/create2",data: "试一试写入数据")

subscribe child changes

zkClient.subscribeChildChanges("/Hello", listenerName: "HelloChildChanges") { (path, children) -> Void in
            print("路径:\(path)子节点发生变化:")
            if let cc  = children {
                for c in cc {
                    print("\(c)")
                }
            }
        }

subscribe node data changes

zkClient.subscribeDataChanges("/Hello/Byte", listenerName: "ByteNodeDataChanges") { (path, data) -> Void in
            print("路径:\(path)节点内容发生变化,新的内容为:\(data)")
        }

subscribe node delete

zkClient.subscribeDataDelete("/Hello/Byte", listenerName: "ByteNodeDelete") { (path) -> Void in
            print("路径节点:\(path)被删除")
        }

unsubscribe child changes

zkClient.unsubscribeChildChanges("/Hello", listenerName: "HelloChildChanges")

unsubscribe node data changes

zkClient.unsubscribeDataChanges("/Hello", listenerName: "HelloChildChanges")

unsubscribe node data delete

zkClient.unsubscribeDataDelete("/Hello/Byte", listenerName: "ByteNodeDelete")

空文件

简介

Swift写的zookeeper客户端 展开 收起
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
1
https://gitee.com/kyzone/zkClient4Swift.git
git@gitee.com:kyzone/zkClient4Swift.git
kyzone
zkClient4Swift
zkClient4Swift
master

搜索帮助

14c37bed 8189591 565d56ea 8189591