ZK服务管理中心

ZK基础类及服务的注册与发现：

package top.letsgogo.util;

import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.serialize.SerializableSerializer;
import org.apache.zookeeper.CreateMode;

import java.util.List;
import java.util.Map;

/**
 * @author panteng
 * @description
 * @date 17-6-9.
 */
public class ZkManager {
    private static String ZKServers = "10.38.164.80:2181,10.38.164.80:2182,10.38.164.80:2183";
    private static ZkClient zkClient = new ZkClient(ZKServers, 10000, 10000, new SerializableSerializer());

    /**
     * 遍历所有节点
     *
     * @param currentPath
     * @param nodes
     */
    public static void getAllNodesAndVlue(String currentPath, Map<String, Object> nodes) {
        try {
            List<String> stringList = zkClient.getChildren(currentPath);
            for (String childPath : stringList) {
                if ("/".equals(currentPath)) {
                    childPath = currentPath + childPath;
                } else {
                    childPath = currentPath + "/" + childPath;
                }
                try {
                    if (childPath.indexOf("zookeeper") > -1) {
                        continue;
                    }
                    Object nodeVlue = zkClient.readData(childPath);
                    nodes.put(childPath, nodeVlue);
                } catch (Exception e) {
                    System.out.println("node路径：" + childPath);
                    e.printStackTrace();
                }
                getAllNodesAndVlue(childPath, nodes);
            }
        } catch (Exception e) {
            if (e.getMessage().indexOf("KeeperErrorCode = NoNode for") > -1) {
                return;
            }
        }
    }

    /**
     * 增加不存在的节点，如果节点已经存在，返回""
     *
     * @param path
     * @param value
     * @param mode
     * @return 返回"" 表示增加失败
     */
    public static String addNode(String path, Object value, CreateMode mode) {
        try {
            if (zkClient.exists(path)) {
                return "";
            }
            return zkClient.create(path, value, mode);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "";
    }

    public static void main2(String[] arges) {
        ZkManager.addNode("/dao", "data operation", CreateMode.PERSISTENT);
        ZkManager.addNode("/service", "service provider", CreateMode.PERSISTENT);
        ZkManager.addNode("/controller", "work control", CreateMode.PERSISTENT);
        ZkManager.addNode("/dao/pool", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/service/pool", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/controller/pool", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/dao/configration", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/service/configration", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/controller/configration", "machine list", CreateMode.PERSISTENT);
        /*ZkManager.addNode("/controller/api1", "api1", CreateMode.EPHEMERAL);
        Map<String, Object> map = new HashMap<>();
        ZkManager.getAllNodesAndVlue("/", map);
        for (Map.Entry entry : map.entrySet()) {
            System.out.println("path=" + entry.getKey() + "  value=" + entry.getValue());
        }
        try {
            Thread.sleep(10000);
        } catch (Exception e) {
            e.printStackTrace();
        }*/
    }
}

ZkManager

package top.letsgogo.auto;

import com.google.common.base.Strings;
import org.apache.zookeeper.CreateMode;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import top.letsgogo.util.ZkManager;

import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author panteng
 * @description
 * @date 17-6-9.
 */
@Component
public class ServiceRegisterDiscover implements CommandLineRunner {
    @Value("${server.port}")
    private String serverPort;

    private static String serviceNamePrefix = "dao-api-";
    private static String path = "/dao/pool/" + serviceNamePrefix;
    private static Map<String, List<String>> nextServiceInfo = new HashMap<String, List<String>>();

    @Override
    public void run(String... strings) throws Exception {
        try {
            //首先注册向管理中心注册自己的服务
            String getPath = ZkManager.addNode(path + getIpAddress() + ":" + serverPort, "config", CreateMode.EPHEMERAL);
            if (!Strings.isNullOrEmpty(getPath)) {
                System.out.println(getPath + "服务注册成功");
            }
            //去管理中心发现需要调用的服务
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取本机IP
     *
     * @return
     */
    public static String getIpAddress() {
        try {
            Enumeration<NetworkInterface> allNetInterfaces = NetworkInterface.getNetworkInterfaces();
            InetAddress ip = null;
            while (allNetInterfaces.hasMoreElements()) {
                NetworkInterface netInterface = (NetworkInterface) allNetInterfaces.nextElement();
                if (netInterface.isLoopback() || netInterface.isVirtual() || !netInterface.isUp()) {
                    continue;
                } else {
                    Enumeration<InetAddress> addresses = netInterface.getInetAddresses();
                    while (addresses.hasMoreElements()) {
                        ip = addresses.nextElement();
                        if (ip != null && ip instanceof Inet4Address) {
                            return ip.getHostAddress();
                        }
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "";
    }
}

ServiceRegisterDiscover

/dao/pool/dao-api-10.38.164.80:8080服务注册成功

[zk: localhost:2181(CONNECTED) 0] ls /dao/pool
[dao-api-10.38.164.80:8080]

服务查看：

[zk: localhost:2181(CONNECTED) 1] ls /dao/pool
[dao-api-10.38.164.80:8081, dao-api-10.38.164.80:8082, dao-api-10.38.164.80:8080]

[zk: localhost:2181(CONNECTED) 0] ls /
[service, controller, dao, zookeeper]

Service

package top.letsgogo.auto;

import com.google.common.base.Strings;
import org.apache.zookeeper.CreateMode;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import top.letsgogo.util.ZkManager;

import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.util.*;

/**
 * @author panteng
 * @description
 * @date 17-6-9.
 */
@Component
public class ServiceRegisterDiscover implements CommandLineRunner {
    @Value("${server.port}")
    private String serverPort;

    private final static String serviceNamePrefix = "service-api-";
    private final static String path = "/service/pool/" + serviceNamePrefix;
    /**
     * 被调用的服务名
     */
    private final static String[] nextServiceName = new String[]{"dao-api-"};
    /**
     * 被调用的服务所在根路径，应该与nextServiceName中的一一对应
     */
    private final static String[] nextServiceRootPath = new String[]{"/dao/pool"};

    private static Map<String, List<String>> nextServiceInfo = new HashMap<String, List<String>>();

    @Override
    public void run(String... strings) throws Exception {
        try {
            //首先注册向管理中心注册自己的服务
            String getPath = ZkManager.addNode(path + getIpAddress() + ":" + serverPort, "config", CreateMode.EPHEMERAL);
            if (!Strings.isNullOrEmpty(getPath)) {
                System.out.println(getPath + "服务注册成功");
            }
            discoverNextServiceInfo();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 发现服务，并监听变化
     */
    public static void discoverNextServiceInfo() {
        //去管理中心发现需要调用的服务
        Map<String, Object> map = new HashMap<>();
        ZkManager.getAllNodesAndVlue("/", map);
        for (Map.Entry entry : map.entrySet()) {//遍历所有服务
            for (int i = 0; i < nextServiceName.length; i++) {
                String servicePath = entry.getKey().toString();
                if (servicePath.indexOf(nextServiceName[i]) > -1) {
                    List<String> serviceList = nextServiceInfo.get(nextServiceName[i]);
                    if (serviceList == null) {
                        serviceList = new ArrayList<String>();
                    }
                    serviceList.add(servicePath);
                    nextServiceInfo.put(nextServiceName[i], serviceList);
                }
            }
        }
        printNextServiceInfo();
        //监听节点变化
        for (int i = 0; i < nextServiceRootPath.length; i++) {
            ZkManager.subscribeChildChanges(nextServiceRootPath[i], new ServiceListener(nextServiceName[i]));
        }
    }

    public static void printNextServiceInfo() {
        for (Map.Entry entry : nextServiceInfo.entrySet()) {
            System.out.print("发现服务名称：" + entry.getKey() + "  服务实例：");
            for (String str : (List<String>) entry.getValue()) {
                System.out.print(str + ",  ");
            }
            System.out.println();
        }
    }

    /**
     * 获取本机IP
     *
     * @return
     */
    public static String getIpAddress() {
        try {
            Enumeration<NetworkInterface> allNetInterfaces = NetworkInterface.getNetworkInterfaces();
            InetAddress ip = null;
            while (allNetInterfaces.hasMoreElements()) {
                NetworkInterface netInterface = (NetworkInterface) allNetInterfaces.nextElement();
                if (netInterface.isLoopback() || netInterface.isVirtual() || !netInterface.isUp()) {
                    continue;
                } else {
                    Enumeration<InetAddress> addresses = netInterface.getInetAddresses();
                    while (addresses.hasMoreElements()) {
                        ip = addresses.nextElement();
                        if (ip != null && ip instanceof Inet4Address) {
                            return ip.getHostAddress();
                        }
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "";
    }

    public static Map<String, List<String>> getNextServiceInfo() {
        return nextServiceInfo;
    }

    public static void setNextServiceInfo(Map<String, List<String>> nextServiceInfo) {
        ServiceRegisterDiscover.nextServiceInfo = nextServiceInfo;
    }
}

ServiceRegisterDiscover

package top.letsgogo.auto;

import org.I0Itec.zkclient.IZkChildListener;

import java.util.List;

/**
 * @author panteng
 * @description
 * @date 17-6-10.
 */
public class ServiceListener implements IZkChildListener {
    String serviceName;

    public ServiceListener(String serviceName) {
        this.serviceName = serviceName;
    }

    @Override
    public void handleChildChange(String s, List<String> list) throws Exception {
        System.out.println("服务" + serviceName + "发生了变化");
        ServiceRegisterDiscover.getNextServiceInfo().put(serviceName, list);
        ServiceRegisterDiscover.printNextServiceInfo();
    }

    public String getServiceName() {
        return serviceName;
    }

    public void setServiceName(String serviceName) {
        this.serviceName = serviceName;
    }
}

ServiceListener

package top.letsgogo.util;

import org.I0Itec.zkclient.IZkChildListener;
import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.serialize.SerializableSerializer;
import org.apache.zookeeper.CreateMode;

import java.util.List;
import java.util.Map;

/**
 * @author panteng
 * @description
 * @date 17-6-9.
 */
public class ZkManager {
    private static String ZKServers = "10.38.164.80:2181,10.38.164.80:2182,10.38.164.80:2183";
    private static ZkClient zkClient = new ZkClient(ZKServers, 10000, 10000, new SerializableSerializer());

    /**
     * 遍历所有节点
     *
     * @param currentPath
     * @param nodes
     */
    public static void getAllNodesAndVlue(String currentPath, Map<String, Object> nodes) {
        try {
            List<String> stringList = zkClient.getChildren(currentPath);
            for (String childPath : stringList) {
                if ("/".equals(currentPath)) {
                    childPath = currentPath + childPath;
                } else {
                    childPath = currentPath + "/" + childPath;
                }
                try {
                    if (childPath.indexOf("zookeeper") > -1) {
                        continue;
                    }
                    Object nodeVlue = zkClient.readData(childPath);
                    nodes.put(childPath, nodeVlue);
                } catch (Exception e) {
                    System.out.println("node路径：" + childPath);
                    e.printStackTrace();
                }
                getAllNodesAndVlue(childPath, nodes);
            }
        } catch (Exception e) {
            if (e.getMessage().indexOf("KeeperErrorCode = NoNode for") > -1) {
                return;
            }
        }
    }

    /**
     * 增加不存在的节点，如果节点已经存在，返回""
     *
     * @param path
     * @param value
     * @param mode
     * @return 返回"" 表示增加失败
     */
    public static String addNode(String path, Object value, CreateMode mode) {
        try {
            if (zkClient.exists(path)) {
                return "";
            }
            return zkClient.create(path, value, mode);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "";
    }

    public static void subscribeChildChanges(String nodePath, IZkChildListener listener) {
        if (zkClient.exists(nodePath)) {
            zkClient.subscribeChildChanges(nodePath, listener);
        }
    }

    public static void main2(String[] arges) {
        ZkManager.addNode("/dao", "data operation", CreateMode.PERSISTENT);
        ZkManager.addNode("/service", "service provider", CreateMode.PERSISTENT);
        ZkManager.addNode("/controller", "work control", CreateMode.PERSISTENT);
        ZkManager.addNode("/dao/pool", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/service/pool", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/controller/pool", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/dao/configration", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/service/configration", "machine list", CreateMode.PERSISTENT);
        ZkManager.addNode("/controller/configration", "machine list", CreateMode.PERSISTENT);
        /*ZkManager.addNode("/controller/api1", "api1", CreateMode.EPHEMERAL);
        Map<String, Object> map = new HashMap<>();
        ZkManager.getAllNodesAndVlue("/", map);
        for (Map.Entry entry : map.entrySet()) {
            System.out.println("path=" + entry.getKey() + "  value=" + entry.getValue());
        }
        try {
            Thread.sleep(10000);
        } catch (Exception e) {
            e.printStackTrace();
        }*/
    }
}

ZkManager

/service/pool/service-api-10.232.36.21:8083服务注册成功
发现服务名称：dao-api- 服务实例：/dao/pool/dao-api-10.38.164.80:8081, /dao/pool/dao-api-10.38.164.80:8080, /dao/pool/dao-api-10.38.164.80:8082,

服务dao-api-发生了变化
发现服务名称：dao-api- 服务实例：dao-api-10.38.164.80:8081, dao-api-10.38.164.80:8082,

代码仓库：https://github.com/luckyPT/ZkManager

时间： 2024-10-17 07:39:32

ZK服务管理中心的相关文章

易宝典文章——玩转Office 365中的Exchange Online服务之三十体验全新的Office 365管理中心

Office 365管理中心即将改版,微软推出了全新的Office 365管理中,其风格和Windows 10风格匹配.接下来将展示一下关于全新的管理中心,以便先睹为快.一.主页和服务状态监视在主页中显示Modern风格的按钮,默认有"用户"."账单"."服务运行状态"等常用功能.特别是对于"服务运行状况",如果是绿色,则表示所有O365的服务运行正常,如果非绿色,可以可能有服务运行问题,可以直接点击"查看服务运行状

易宝典文章——玩转Office 365中的Exchange Online服务之三了解Office 365管理中心

继续前面的话题,现在已经有了Office 365的环境.可以很轻松的向甲方客户或公司老板进行展示了.但是在展示之前,首先要自己先对Office 365进行深入的了解和试用,否则在Q&A环节会被问得体无完肤.所以,对于Office 365的基本管理必须熟练掌握.接下来的内容将对Office 365的管理工具进行简单的浏览,以便更好的为后续的Exchange Online的管理提供基础. 一.登录到Office 365主页世纪互联版的Office 365可以通过以下URL进行登录: http://

使用SharePoint管理中心管理服务

使用SharePoint管理中心管理服务为了管理服务应用程序,场管理员要么使用管理中心,要么使用PowerShell. 管理服务应用程序页面列出了场上运行的服务,你可以管理他们. 许多服务都有自己的管理页面.本文中你将学到如何导航到这些页面,以及你可用使用功能区做的操作.本例中,我们使用托管元数据服务. 准备: 你必须具有权限访问管理中心. 开始: 1. 打开管理中心网站. 2. 在应用程序管理--管理服务应用程序. 你可以创建或编辑现有服务应用程序或者连接到另一个场的服务应用程序. 3. 通

springboot 注册服务注册中心(zk)的两种方式

在使用springboot进行开发的过程中,我们经常需要处理这样的场景:在服务启动的时候,需要向服务注册中心(例如zk)注册服务状态,以便当服务状态改变的时候,可以故障摘除和负载均衡. 我遇到过两种注册的途径: 1.在Spring的webapplication启动完成后,直接进行注册: 2.在servlet容器启动完成后,通过listener进行注册. 本文通过一个demo讲述一下这两种注册方式,使用的是传统的向zk注册的方案. 1.Spring webapplication启动完成后注册先上

Spring Cloud之整合ZK作为注册中心

Eureka已经闭源了,用zk可以替代之 Eureka 作为注册中心 Dubbo也是zk作为注册中心的 Zookeeper简介 Zookeeper是一个分布式协调工具,可以实现服务注册与发现.注册中心.消息中间件.分布式配置中心等. 公共pom: <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId&

Windows Server 2012的服务管理自动化 -启动类型设置，手动启动还是自动启动

Windows Server 2012的服务管理自动化标签:Windows 服务器 IDC机房 Windows Server 2012 一.场景描述: 运行着关键业务的windows服务器或托管在IDC机房,或宿主在自家公司的机房(DC),无论哪一种服务器管理方式,都会面临这样的情境:当运行的关键业务的服务停掉后,即使离数据中心很近,也无法及时处理,更何况出差在外或是旅行当中呢?! 基于以上,那,有没有一种方式可以自动化的管理服务呢,当服务当掉后,可以自动的无人工参于的情况下第一时间侦测到服务

学习总结-Active Directory 域服务管理03-导入资源

导入资源一.数据库分区 schema,configuration,domain 1.1)schema分区它储存着整个林中所有对象与属性的定义数据,也存储如何创建新对象与属性的规则.整个林内所有域共享一份相同的架构目录分区,它会被复制到林中所有域内的所有控制器. 1.2)configuration分区其内存储着整个AD DS的结构,例如有哪些域.有哪些站点.有哪些域控制器等数据.整个林共享一份相同的配置目录分区,它会被复制到整个林中的所有域控制器. 1.3)domain分区每一个域各自拥有一个唯

SharePoint在管理中心创建Secure Store

SharePoint在管理中心创建Secure Store SSS(Secure Store service)可以作为核心服务,因为很多其他服务都要求设置这个服务来起作用.它的作用之一就是提供安全数据库,储存和应用程序ID关联的凭据.这些ID用来访问外部数据源的内容.这是通过在Secure Store数据库创建账户来实现的.Secure Store将被用来储存ID,访问仪表板显示的数据源.这些是外部数据源如SQL Server或SAP.MOSS 2007也通过使用应用程序代理ID提供了这个功能.

IT服务管理国际标准体系学习笔记-1

第一章导言略第二章服务质量管理的原则 1.企业要求IT部门必须采用以业务为中心.质量为导向和规范一致的做法交付IT服务. 2.什么是质量? ISO 20000 对质量的定义质量是指某一个产品或服务能够满足客户所必须的那些特性. 3.什么是质量管理? 质量管理是指组织所采取的措施,用于确保其产品或服务满足客户的质量要求,并遵守任何适用于那些产品或服务的规定. 4.什么是全面质量管理? TQM是不断鼓励组织中的每个人去满足内部和外部客户的要求,以便获得竞争优势. William Edward