1. package main
    3. import (
    4.     "bytes"
    5.     "encoding/json"
    6.     "io/ioutil"
    7.     "log"
    8.     "math/rand"
    9.     "net/http"
    10.     "time"
    11. )
    13. type MetricValue struct {
    14.     Metric       string            `json:"metric"`
    15.     Nid          string            `json:"nid"`
    16.     Endpoint     string            `json:"endpoint"`
    17.     Timestamp    int64             `json:"timestamp"`
    18.     Step         int64             `json:"step"`
    19.     ValueUntyped interface{}       `json:"value"`
    20.     Value        float64           `json:"-"`
    21.     CounterType  string            `json:"counterType"`
    22.     Tags         string            `json:"tags"`
    23.     TagsMap      map[string]string `json:"tagsMap"` //保留2种格式，方面后端组件使用
    24. }
    26. func main() {
    27.     log.SetFlags(log.Ldate | log.Ltime | log.Lshortfile)
    29.     t1 := time.NewTicker(10 * time.Second)
    30.     for {
    31.         //数据上报的api
    32.         url := "http://127.0.0.1:7900/api/transfer/push"
    33.         resp, err := push(url, getMetricValues())
    34.         if err != nil {
    35.             log.Println(err)
    36.         }
    37.         log.Println(string(resp))
    38.         <-t1.C
    39.     }
    40. }
    42. func getMetricValues() []*MetricValue {
    43.     ret := []*MetricValue{}
    44.     now := time.Now().Unix()
    45.     ts := now - now%10 // 对齐时间戳
    46.     r1 := rand.Intn(20)
    47.     tagsMap := make(map[string]string) //自定义的tag
    49.     ret = append(ret, &MetricValue{
    50.         Nid:          "41", //页面上鼠标移动到节点上看到的节点ID
    51.         Metric:       "mock.qps",
    52.         ValueUntyped: float64(1),
    53.         Timestamp:    ts,
    54.         CounterType:  "GAUGE",
    55.         Step:         10,
    56.         TagsMap:      tagsMap,
    57.     })
    59. }
    61. func push(url string, v interface{}) (response []byte, err error) {
    62.     bs, err := json.Marshal(v)
    63.     if err != nil {
    64.         return response, err
    65.     }
    67.     bf := bytes.NewBuffer(bs)
    69.     resp, err := http.Post(url, "application/json", bf)
    70.     if err != nil {
    71.         return response, err
    72.     }
    74.     defer resp.Body.Close()
    75.     return ioutil.ReadAll(resp.Body)
    77. }