java接收端

@RequestMapping("/inserPortInfo")
@ResponseBody
public void testInsert(@RequestBody String temp) {
    JSONObject obj=JSON.parseObject(temp);
    Map<String, String> tagsMap = new HashMap<>();
    Map<String, Object> fieldsMap = new HashMap<>();
    Iterator it =obj.getJSONObject("fields").entrySet().iterator();
    while (it.hasNext()) {
        Map.Entry<String, Object> entry = (Map.Entry<String, Object>) it.next();
        fieldsMap.put(entry.getKey(), entry.getValue());
    }
    Iterator it2 =obj.getJSONObject("tag").entrySet().iterator();
    while (it2.hasNext()) {
        Map.Entry<String, Object> entry2 = (Map.Entry<String, Object>) it2.next();
        tagsMap.put(entry2.getKey(), (String) entry2.getValue());
    }
    System.out.println("influxDB start time :" + System.currentTimeMillis());
    influxDBConnect.insert("usage", tagsMap, fieldsMap);
}

 go请求端

func portOrPid() {
   config := common.InitConfig("./config/test.txt")
   port := config["ports"]
   arr := strings.Split(port, ",")
   for _, item := range arr {
      if item !=""{
         port, _ := strconv.Atoi(item)
         if common.PortInUse(port) == -1 {
            println("根据端口号未获取进程信息，端口号或进程号：%d", common.PortInUse(port))
         } else {
            tags, fields :=common.GetPidInfo(int32(common.PortInUse(port)))
            tags ["ipv4"] = GetOutboundIP()
            tags ["port"] = common.GetPortInfo(item).Port
            tags ["bz"] = common.GetPortInfo(item).Bz
            client := &http.Client{Timeout: 10 * time.Second}
            tempJson := make(map[string]interface{})
            tempJson["tag"]=tags
            tempJson["fields"]=fields
            tempJson["dbName"]="test_dbname"
            jsonStr, _ :=json.Marshal(tempJson)
            resp, _ := client.Post("http://10.102.110.93:8080/inserPortInfo", "application/json", bytes.NewBuffer(jsonStr))
            resp.Body.Close()
            fmt.Println("插入成功！")
         }
      }
   }
}