dataPkgRemoveRepeat/main.go

package main

import (
	. "dataPkgRemoveRepeat/config"
	. "dataPkgRemoveRepeat/service"
	"fmt"
	"log"
	"net/http"
	"net/rpc"

	. "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/logger"
)

func main() {
	logger.SetConsole(false)
	logger.SetRollingDaily("./logs", "dprr.log")
	go func() {
		TimeTask.MemUsage()
		TimeTask.Start()
	}()
	rpc.Register(&RemoveRepeat{})
	rpc.HandleHTTP()
	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		reqType := Int64All(r.FormValue("reqType"))
		if reqType <= 0 || reqType > 3 {
			fmt.Fprint(w, "无效参数reqType")
			return
		}
		if reqType == 3 { //内存信息
			fmt.Fprint(w, TimeTask.PrintMemUsage())
			return
		} else if reqType == 2 { //清理
			appid := r.FormValue("appid")
			if appid == "" {
				fmt.Fprint(w, "无效参数appid")
				return
			}
			TimeTask.ClearInvalidData(map[string]bool{appid: true})
		} else if reqType == 1 { //全量
			appid := r.FormValue("appid")
			entId := Int64All(r.FormValue("entid"))
			if appid == "" || entId == 0 {
				fmt.Fprint(w, "无效参数appid、entid")
				return
			}
			TimeTask.LoadFull([]string{appid}, []int64{entId})
		}
		fmt.Fprint(w, "success")
	})
	// 设置监听的端口
	log.Println("ListenAndServe", Config.Port)
	err := http.ListenAndServe(Config.Port, nil)
	if err != nil {
		log.Fatalln(err)
	}
}