Zookeeper — сервис регистрации и обнаружения

ZooKeeper

Недавно я изучаю zookeeper.Как служба распределенной координации, она имеет множество применений, таких как регистрация и обнаружение службы, распределенные блокировки, выборы кластера, центры конфигурации и т. д. Сегодня я сначала реализую функцию регистрации и обнаружения службы zookeeper через демонстрацию.

идеи

zookeeper服务注册与发现

  • Зарегистрируйте информацию об услугах продукта на узле zookeeper.
  • Затем получите информацию об узле и сохраните ее (эта статья хранится в списке)
  • Механизм Watcher отслеживает изменения данных в List и обновляет данные (если сервис продукта 2 зависнет, он будет удален механизмом мониторинга)
  • Используйте алгоритмы, такие как опрос или хеширование, для получения данных в списке для вызовов службы заказа (балансировка нагрузки).
    zk节点

регистрационная служба

Получите экземпляр zookeeper и создайте корневой узел и дочерние узлы.Дочерние узлы являются временными последовательными узлами, которые используются для сохранения IP-адреса, соответствующего службе.

package com.ooliuyue.product.zk;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.Stat;


/**
 * @Auther: ly
 * @Date: 2019/4/19 11:53
 */

public class ServiceRegister {

    private  static final String BASE_SERVICE = "/service";
    private  static final String SERVICE_NAME = "/product";

    public static void register(String address,int port) {
        /**
         * 在zk创建根节点path,在根节点下创建临时子节点用于存放服务ip和端口
         */
        try {
            String path = BASE_SERVICE + SERVICE_NAME;
            ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181",5000,(watchedEvent) -> {});
            System.out.println(zooKeeper);
            Thread.sleep(2000);
            Stat exists = zooKeeper.exists(BASE_SERVICE + SERVICE_NAME, false);
            //先判断服务根路径是否存在
            if (exists == null){
                zooKeeper.create(BASE_SERVICE + SERVICE_NAME,"".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            }
            //将服务的ip和端口作为临时带序号的子节点
            String server_path = address+":"+port;
            zooKeeper.create(path + "/child",server_path.getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
            System.out.println("product服务注册成功");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

При инициализации контейнера вызывается функция register() для установки значения дочернего узла zk (URL-адрес службы).

package com.ooliuyue.product.listen;

import com.ooliuyue.product.zk.ServiceRegister;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import java.net.InetAddress;
import java.util.Properties;

/**
 * @Auther: ly
 * @Date: 2019/4/19 10:43
 */

public class InitListener implements ServletContextListener {

    @Override
    //容器初始化的时候会调用
    public void  contextInitialized(ServletContextEvent sce) {
        Properties properties = new Properties();
        try {
            properties.load(InitListener.class.getClassLoader().getResourceAsStream("application.properties"));
            //获得IP
            String hostAddress = InetAddress.getLocalHost().getHostAddress();
            //获得端口
            int port = Integer.valueOf(properties.getProperty("server.port"));
            ServiceRegister.register(hostAddress,port);

        } catch (Exception e) {
            e.printStackTrace();
        }


    }
    public void contextDestroyed(ServletContextEvent sce) {
    }

}

Запустите сервис и протестируйте его, если вам нужно запустить ZooKeeper

package com.ooliuyue.product.controller;

import com.ooliuyue.product.pojo.Product;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;

/**
 * @Auther: ly
 * @Date: 2019/4/19 09:52
 */

@RequestMapping("/product")
@RestController
public class ProductController {

    @RequestMapping("/get/{id}")
    public Object getProduct(HttpServletRequest request, @PathVariable("id") String id){
        int localPort = request.getLocalPort();
        return new Product(id,"productName:" + localPort);
    }
}

Два продукта и услуги успешно запущены

Просмотр узлов с помощью инструментов

обнаружение службы

Получите служебную информацию, сохраненную на узле zk, и сохраните ее в списке, а также механизм наблюдения для отслеживания изменений данных в списке.

package com.ooliuyue.order.listener;

import com.ooliuyue.order.utils.LoadBalance;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import java.util.ArrayList;
import java.util.List;

/**
 * @Auther: ly
 * @Date: 2019/4/19 16:26
 */

public class InitListener implements ServletContextListener {

    private  static final String BASE_SERVICE = "/service";
    private  static final String SERVICE_NAME = "/product";
    private ZooKeeper zooKeeper;

    private void init(){
        try {
            //连接zk,获得列表信息
            //watcher机制：监控获取到的服务列表的变化
            zooKeeper = new ZooKeeper("127.0.0.1:2181",5000,(watchedEvent) -> {
                if (watchedEvent.getType() == Watcher.Event.EventType.NodeChildrenChanged
                        && watchedEvent.getPath().equals(BASE_SERVICE+SERVICE_NAME)) {
                    System.out.println("***注册到zk的服务信息发生变化***");
                    updateServerList();
                }
            });
            //第一次连接的时候要返回的列表
            updateServerList();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void updateServerList() {
        List<String> list = new ArrayList<>();
        try {
            List<String> children = zooKeeper.getChildren(BASE_SERVICE + SERVICE_NAME,true);
            for(String subNode : children) {
                byte[] data = zooKeeper.getData(BASE_SERVICE + SERVICE_NAME + "/" + subNode, false, null);
                String host  = new String(data,"utf-8");
                list.add(host);
            }
            //将获取的服务端口和IP保存List中
            LoadBalance.SERVICE_LIST = list;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    @Override
    public void  contextInitialized(ServletContextEvent sce) {
        init();
    }

    @Override
    public void contextDestroyed(ServletContextEvent sce) {
    }


}

Получите услугу продукта, внедрив случайный алгоритм для вызова службы заказа (эквивалентно загрузке)

package com.ooliuyue.order.utils;

import java.util.List;

/**
 * @Auther: ly
 * @Date: 2019/4/22 14:00
 */

public abstract class LoadBalance {

    public volatile static List<String> SERVICE_LIST;

    public abstract String chooseServiceHost();
}


package com.ooliuyue.order.utils;

import org.springframework.util.CollectionUtils;

import java.util.Random;

/**
 * @Auther: ly
 * @Date: 2019/4/22 14:02
 */

//实现了一个随机的算法（随机获取订单服务）
public class RandomLoadBalance extends LoadBalance {


    @Override
    public String chooseServiceHost() {
        String result = "";
        if (!CollectionUtils.isEmpty(SERVICE_LIST)) {
            int nextInt = new Random().nextInt(SERVICE_LIST.size());
            result = SERVICE_LIST.get(nextInt);
        }
        return result;
    }
}

результат тестового звонка

package com.ooliuyue.order.controller;

import com.ooliuyue.order.pojo.Order;
import com.ooliuyue.order.utils.LoadBalance;
import com.ooliuyue.order.utils.RandomLoadBalance;
import com.ooliuyue.product.pojo.Product;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

/**
 * @Auther: ly
 * @Date: 2019/4/19 10:02
 */

@RequestMapping("/order")
@RestController
public class OrderController {

    @Resource
    private RestTemplate restTemplate;

    private LoadBalance loadBalance = new RandomLoadBalance();

    @RequestMapping("/get/{id}")
    public Object getOrder(HttpServletRequest request, @PathVariable("id") String id){
        //随机获取host
        String host = loadBalance.chooseServiceHost();
        Product product = restTemplate.getForObject("http://" + host + "/product/get/1", Product.class);
        return new Order(id,"ordername",product);

    }
}

Если вы инициируете несколько запросов, вы обнаружите, что одна из служб вызывается случайным образом.

Наблюдательный механизм

Удалить информацию об услуге в Списке

Кодовый адрес: git

Категории