package com.test;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import com.test.distributed.ImWorker;
import com.test.distributed.PeerManager;

/**
 * zookeeper集群测试
 * @author 程就人生
 * @date 2020年1月13日
 */
@SpringBootApplication
public class ZookeeperDemo1Application implements CommandLineRunner{

	@Value("${server.port}")
	private int port;
		
	public static void main(String[] args) {		
		//获取application的上下文
		SpringApplication.run(ZookeeperDemo1Application.class, args);
	}

	/**
	 * 项目启动后，将节点加入到zookeeper，保证一个服务器一个节点
	 */
	@Override
	public void run(String... args) throws Exception {
		//组装节点信息
        ImWorker.getInst().setLocalNode("localhost", port);
    	//节点初始化
        ImWorker.getInst().init();
    	//启动节点的管理，节点之间的通信
        PeerManager.getInst().init(); 
	}

}