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.189.140:27080,172.17.189.141:27081",
		Size:        12,
		DbName:      "mixdata",
		//UserName:    "root",
		//Password:    "root",
		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)
	}
}