安装zk
docker-compose方式进行安装
version: "3"
services:
zoo1:
image: zookeeper
restart: always
hostname: zoo1
ports:
- 2181:2181
environment:
ZOO_MY_ID: 1
ZOO_SERVERS: server.1=0.0.0.0:2888:3888;2181 server.2=zoo2:2888:3888;2181 server.3=zoo3:2888:3888;2181
zoo2:
image: zookeeper
restart: always
hostname: zoo2
ports:
- 2182:2181
environment:
ZOO_MY_ID: 2
ZOO_SERVERS: server.1=zoo1:2888:3888;2181 server.2=0.0.0.0:2888:3888;2181 server.3=zoo3:2888:3888;2181
zoo3:
image: zookeeper
restart: always
hostname: zoo3
ports:
- 2183:2181
environment:
ZOO_MY_ID: 3
ZOO_SERVERS: server.1=zoo1:2888:3888;2181 server.2=zoo2:2888:3888;2181 server.3=0.0.0.0:2888:3888;2181
保存为 docker-compose.yml
,然后在节点运行 docker-compose up -d
启动容器
zookeeper一些知识介绍:
搭建了zookeeper服务器
,之后创建一个客户端
去监听zookeeper服务器
,然后往那个监听的zk地址发送请求,这样客户端
就可以根据发送的信息做相应的请求了。
一个简单的客户端demo
from kazoo.client import KazooClient
import time
# 创建一个zk
zk = KazooClient(hosts="ZK服务器IP:2181, ZK服务器IP:2182, ZK服务器IP:2183")
zk.start()
zk.create("/test1")
@zk.DataWatch("/test1")
def zk_test(data, stat):
print(data.decode())
# data就是zk客户端接受的数据
while True:
time.sleep(60)
创建了一个客户端,这个客户端会监听 zk的test1,只要往zk的test1发送数据,这个客户端就会接收数据并且打印出来
# 往zk客户端test1发送数据
from kazoo.client import KazooClient
import json
zk = KazooClient(hosts="ZK服务器IP:2181, ZK服务器IP:2182, ZK服务器IP:2183")
zk.start()
znode = {
"username": "aaaaaaa",
"passowrd": "bbbbbbbb"
}
znode = json.dumps(znode)
znode = bytes(znode, encoding="utf-8")
zk.set("/test1",znode)
只要运行这个脚本,zk的客户端,就会接收到
{ "username": "aaaaaaa","passowrd": "bbbbbbbb"}
参考:
https://www.cnblogs.com/qingyunzong/category/1182705.html
https://www.cnblogs.com/iforever/p/9095095.html
https://www.jianshu.com/p/11199dd5487e
http://www.likuli.com/archives/746/ (重要)
https://blog.csdn.net/java_66666/article/details/81015302