package main

import (
	. "dataIdentify/service"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/os/gctx"
	"gopkg.in/natefinch/lumberjack.v2"
	"io"
	"log"
	"net/http"
	"net/rpc"
	"os"
)

func main() {
	var logger *lumberjack.Logger
	ctx := gctx.New()
	g.Config().MustGet(ctx, "logger").Struct(&logger)
	writers := []io.Writer{logger}
	if g.Config().MustGet(ctx, "logger.console").Bool() {
		writers = append(writers, os.Stdout)
	}
	// 启动RPC服务
	rpcService := new(DataIdentify)
	rpc.Register(rpcService)
	rpc.HandleHTTP()
	port := g.Config().MustGet(ctx, "port").String()
	log.Println("rpc server started on " + port)
	if err := http.ListenAndServe(port, nil); err != nil {
		log.Fatalln("rpc server error", err)
	}

}