Method StartServer

Connect/server_handler.go:250–287

* * @brief: 再调用这个函数的时候开始服务, * @return: 三种返回类型：路径解析错误;connectAll连接出现问题;成功 */

()

 * @return: 三种返回类型：路径解析错误;connectAll连接出现问题;成功
 */
func (cfg *ServerConfig) StartServer() error {
	var flag bool = false
	if len(ServerListeners) == 1 {
		// 正确读取配置文件;这里注意,checkJsonParser是检查范围和字符串的格式,解析的过程会把int转string之间的错误解析出来
		flag = ServerListeners[0]("Config/server_config.json", cfg)
		if !flag { // 文件打开失败
			log.Printf("Open config File Error!")
			return ErrorInStartServer(parser_error)
		}

		// 从json中取出的字段格式错误
		if ParserErr := cfg.checkJsonParser(); ParserErr != nil {
			log.Println(ParserErr.Error())
			return ErrorInStartServer(parser_error)
		}

		// 填充cfg.Persister
		cfg.fillPersister()

	} else {
		log.Printf("ERROR : [%d] ServerListeners Error!\n", cfg.me)
		// 这种情况只有在调用服务没有启动read_server_config.go的init函数时会出现
		return ErrorInStartServer(Listener_error)
	}

	// 这里初始化的原因是要让注册的结构体是后面运行的结构体
	cfg.kvserver = BaseServer.StartKVServerInit(cfg.me, cfg.persister, cfg.MaxRaftState, transformChubbyGomap2uint32(cfg.ChubbyGoMapStrategy))
	cfg.kvserver.StartRaftServer(&cfg.ServersAddress)

	cfg.serverRegisterFun()
	if err := cfg.connectAll(); err != nil {
		log.Println(err.Error())
		return ErrorInStartServer(connect_error)
	}
	cfg.kvserver.StartKVServer(cfg.peers) // 启动服务
	log.Printf("INFO : [%d] The connection is successful and the service has started successfully!\n", cfg.me)
	return nil
}

/*
 * @brief: 返回一个Config结构体，用于开始一个服务