更换成http协议

service/conf/influxdb_conf.go

@@ -7,11 +7,11 @@ import (
 
 func NewClient() client.Client {
 
-	conf := client.UDPConfig{
-		Addr: "172.20.6.33:8089",
+	conf := client.HTTPConfig{
+		Addr: "http://172.20.6.33:8086",
 	}
 
-	con, err := client.NewUDPClient(conf)
+	con, err := client.NewHTTPClient(conf)
 
 	if err != nil {
 		log.Fatal(err)

service/msg_process.go

@@ -93,6 +93,7 @@ func batchWrite(pointArray []*client.Point) {
 
 	points.AddPoints(pointArray)
 	err = c.Write(points)
+	fmt.Println("写入数据",len(pointArray))
 	if err != nil {
 		log.Fatal(err)
 	}