Method serverRegisterFun

Connect/server_handler.go:153–184

* * @brief: 把raft和kvraft的挂到RPC上 */

()

 * @brief: 把raft和kvraft的挂到RPC上
 */
func (cfg *ServerConfig) serverRegisterFun() {
	// 注册RPC时只要结构体中有不符合要求的成员函数存在就会打印日志,挺烦的
	// 把RaftKv挂到RPC上
	err := rpc.Register(cfg.kvserver)
	if err != nil {
		// RPC会把全部函数中满足规则的函数注册，如果存在不满足规则的函数则会返回err
		log.Println(err.Error())
	} else {
		log.Println("INFO : Kvserver has been successfully registered.")
	}

	// 把Raft挂到RPC上
	err1 := rpc.Register(cfg.kvserver.GetRaft())
	if err1 != nil {
		log.Println(err1.Error())
	} else {
		log.Println("INFO : Raft has been successfully registered.")
	}

	// 通过函数把mathutil中提供的服务注册到http协议上，方便调用者可以利用http的方式进行数据传输
	rpc.HandleHTTP()

	// 在特定的端口进行监听
	listen, err2 := net.Listen("tcp", cfg.MyPort)
	if err2 != nil {
		log.Println(err2.Error())
	}
	go func() {
		// 调用方法去处理http请求
		http.Serve(listen, nil)
	}()
}

/*
 * @brief: 检查从json中解析的字段是否符合规定