[ZooKeeper.net] 1 模仿dubbo实现一个简要的http服务的注册 基于webapi

 public sealed class ZooKeeperFactory : IZooKeeperFactory
    {
        public static IZooKeeperFactory Instance = new ZooKeeperFactory();
        private ZooKeeperFactory() { }
        //创建一个Zookeeper实例，第一个参数为目标服务器地址和端口，第二个参数为Session超时时间，第三个为节点变化时的回调方法     
        public ZooKeeper Connect(string address)
        {
            return Connect(address, new TimeSpan(0, 0, 0, 30), new Watcher());
        }
        public ZooKeeper Connect(string address, TimeSpan timeoutSpan)
        {
            return Connect(address, timeoutSpan, new Watcher());
        }
        public ZooKeeper Connect(string address, TimeSpan timeoutSpan, IWatcher watcher)
        {
            return new ZooKeeper(address, timeoutSpan, watcher);
        }
        public ZooKeeper Connect(string address, TimeSpan timeoutSpan, IWatcher watcher, long sessionId, byte[] password)
        {
            return new ZooKeeper(address, timeoutSpan, watcher, sessionId, password);
        }
    }

 internal class Watcher : IWatcher
    {
        public void Process(WatchedEvent @event)
        {
            if (@event.Type == EventType.NodeChildrenChanged)
            {
                // Console.WriteLine(@event.Path + "   此路径节点变化了！");
            }
            if (@event.Type == EventType.NodeDataChanged)
            {
                // Console.WriteLine(@event.Path + "   此路径节点变化了！");
            }
            if (@event.Type == EventType.NodeDeleted)
            {
                // Console.WriteLine(@event.Path + "   此路径节点变化了！");
            }
           
        }
    }

public class UserServicesController : ApiController
    {
        [Route("User/sayhello")]
        public string sayhello()
        {
            return "hello world!";
        }
        [Route("User/saybye")]
        public string saybye()
        {
            return "byebye world!";
        }
    }

 public class ScanConfig
    {

        private String connectString = "127.0.0.1:2181";
        private ZooKeeper zk = null;
        public ScanConfig()
        {
            init();
        }
        public void init()
        {
            try
            {
                //初始化zk客户端
                buildZKclient();
                //绑定服务父节点  services名称
                registBiz();
                //得到所有服务地址
                List<String> services = getServicePath();
                //把服务注册到zk
                registBizServices(services);
            }
            catch (Exception)
            {
                //日志记录 
            }
        }

        /// <summary>
        /// 初始化连接
        /// </summary>
        private void buildZKclient()
        {
            IZooKeeperFactory _factory = ZooKeeperFactory.Instance;
            zk = _factory.Connect(connectString, new TimeSpan(0, 0, 0, 30));
        }

        /// <summary>
        /// 绑定父节点
        /// </summary>
        private void registBiz()
        {
            if (zk.Exists("/" + WebApiConfig.bizCode, true) == null)
            {
                //创建一个目录节点,不进行ACL权限控制，节点为永久性的  
                zk.Create("/" + WebApiConfig.bizCode, ("Test:" + WebApiConfig.bizCode).GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
            }
        }
        /// <summary>
        ///   通过注解得到所有Api服务地址
        /// </summary>
        /// <returns></returns>
        private List<String> getServicePath()
        {
            List<String> PathString = new List<string>();
            Collection<ApiDescription> ApiString = GlobalConfiguration.Configuration.Services.GetApiExplorer().ApiDescriptions;
            foreach (var api in ApiString)
            {
                PathString.Add(api.RelativePath.Replace("/", "."));
            }
            return PathString;
        }
        /// <summary>
        ///  把服务注册到zk
        /// </summary>
        /// <param name="Services">所有Api服务地址</param>
        private void registBizServices(List<String> Services)
        {
            //获取服务IP地址端口
            IPAddress[] IPList = System.Net.Dns.GetHostEntry(System.Net.Dns.GetHostName()).AddressList;
            string hostName = IPList[0].ToString();
            //创建临时节点 会话断开 节点自动消失
            foreach (var apiname in Services)
            {
                if (zk.Exists("/" + WebApiConfig.bizCode + "/" + apiname, true) == null)
                {
                    //创建一个目录节点,不进行ACL权限控制，节点为永久性的   服务名称 
                    zk.Create("/" + WebApiConfig.bizCode + "/" + apiname, ("Test:" + WebApiConfig.bizCode).GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Persistent);
                }
                //创建一个目录节点,不进行ACL权限控制，节点为临时性的  服务提供者ip地址 
                zk.Create("/" + WebApiConfig.bizCode + "/" + apiname + "/" + hostName, ("Test:" + WebApiConfig.bizCode).GetBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.Ephemeral);
            }
        }



    }