DataService/qyxy_info/main.go

package main

import (
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
	"log"
	"net/http"
)

var (
	MgoTool *mongodb.MongodbSim

	ConChan chan bool // 并发通道
)

func init() {
	MgoTool = &mongodb.MongodbSim{
		MongodbAddr: "172.17.4.187:27082,172.17.145.163:27083", // 127.0.0.1:27083
		Size:        12,
		DbName:      "mixdata",
		UserName:    "SJZY_RWESBid_Other",
		Password:    "SJZY@O17t8herB3B",
	}
	MgoTool.InitPool()

	ConChan = make(chan bool, 10)
}

func main() {
	http.HandleFunc("/getInfo", GetQyxyInfo)
	http.HandleFunc("/getInfoBulk", GetQyxyInfoBulk)
	err := http.ListenAndServe(":8889", nil)
	if err != nil {
		log.Fatal("ListenAndServe: ", err)
	}
}