zookeeper
The process is as follows:
APISIX
registers an upstream and specifies the service discovery type aszookeeper
toetcd
.apisix-seed
watches the resource changes ofAPISIX
inetcd
and filters the discovery type and obtains the service name.apisix-seed
binds the service to theetcd
resource and starts watching the service in zookeeper.- The client registers the service with
zookeeper
. apisix-seed
gets the service changes inzookeeper
.apisix-seed
queries the boundetcd
resource information through the service name, and writes the updated service node toetcd
.- The
APISIX
worker watchesetcd
changes and refreshes the service node information to the memory.
- Start the Zookeeper service
- Download and compile the
apisix-seed
project.
git clone https://github.com/api7/apisix-seed.git
cd apisix-seed
go build
- Modify the
apisix-seed
configuration file, config pathconf/conf.yaml
.
etcd: # APISIX ETCD Configure
host:
prefix: /apisix
timeout: 30
discovery:
zookeeper: # Zookeeper Service Discovery
hosts:
- "127.0.0.1:2181" # Zookeeper service address
prefix: /zookeeper
weight: 100 # default weight for node
timeout: 10 # default 10s
- Start
apisix-seed
to monitor service changes
Set a route, the request path is /zk/*
, the upstream uses zookeeper as service discovery, and the service name is APISIX-ZK
.
-H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -i -d '
{
"uri": "/zk/*",
"upstream": {
"service_name": "APISIX-ZK",
"type": "roundrobin",
"discovery_type": "zookeeper"
}
- Service registration using Zookeeper CLI
- Register Service
# Login Container
docker exec -it ${CONTAINERID} /bin/bash
# Login Zookeeper Client
oot@ae2f093337c1:/apache-zookeeper-3.7.0-bin# ./bin/zkCli.sh
# Register Service
[zk: localhost:2181(CONNECTED) 0] create /zookeeper/APISIX-ZK '{"host":"127.0.0.1:1980","weight":100}'
- Successful Response
- Verify Request
- Request
curl -i http://127.0.0.1:9080/zk/hello
- Response
HTTP/1.1 200 OK
Connection: keep-alive
Content-Type: text/html; charset=utf-8
Date: Tue, 29 Mar 2022 08:51:28 GMT
Server: APISIX/2.12.0
Transfer-Encoding: chunked