萌新求问!报错一直找不到原因runtime error: invalid memory address or nil pointer dereference

调用淘宝查询ip的 api,已经筛选出来一堆ip

package main
import (
  "fmt"
  "net/http"
  "time"
  "encoding/json"
)
type IPInfo struct {
  Code int `json:"code"`
  Data IP `json:"data`
}
type IP struct {
  IP    string `json:"ip"`
  Country  string `json:"country"`
  Region  string `json:"region"`
  City   string `json:"city"`
  Count   int `json:"count"`
}
func WebServerBase() {
  fmt.Println("server base go!")
  //第一个参数为客户端发起http请求时的接口名,第二个参数是一个func,负责处理这个请求。
  http.HandleFunc("/result", handleTask)
  //服务器要监听的主机地址和端口号
  err := http.ListenAndServe(":8081", nil)
  if err != nil {
    fmt.Println("ListenAndServe error: ", err.Error())
  }
}
func handleTask(w http.ResponseWriter, req *http.Request) {
  fmt.Println("handleTask is running...")
  //添加响应头,解决跨域请求问题
  w.Header().Set("Access-Control-Allow-Origin", "*")
  //模拟延时
  time.Sleep(time.Second * 2)
  var count= count_go()
  m := make(map[string]interface{})
  arrList := make([]interface{}, 0)
  for k, v := range count {
    var a = TabaoAPI(k) //a是一个struct对象,ipInfo
    a.Data.Count = v       ************报错
    fmt.Println(&a)
    arr1 := make(map[string]interface{}) 
    arr1["ip"] = a.Data.IP       ************报错
    arr1["country"] = a.Data.Country************报错
    arr1["count"] = a.Data.Count   ************报错
    arrList = append(arrList, arr1)
    m["mydata"] = arrList
  }
    bt, _ := json.Marshal(m)
    fmt.Println(string(bt))
    fmt.Fprintf(w,string(bt)[:])
}

ip提取整理

package main
import (
 "net"
 "fmt"
 "bytes"
 "net/http"
 "io/ioutil"
 "encoding/json"
 "strings"
 "strconv"
 "regexp"
 "math/big"
 "io"
 "os"
 "bufio"
 "reflect"
)
type IPInfo struct {
 Code int `json:"code"`
 Data IP `json:"data`
}
type IP struct {
 IP string `json:"ip"`
 Country string `json:"country"`
 Region string `json:"region"`
 City string `json:"city"`
 Count int `json:"count"`
}
//string转int
func InetAtoN(ip string) int64 {
 ret := big.NewInt(0)
 ret.SetBytes(net.ParseIP(ip).To4())
 return ret.Int64()
}
//struct转map
func Struct2Map(obj interface{}) map[string] interface{} {
 t := reflect.TypeOf(obj)
 v := reflect.ValueOf(obj)
 var data = make(map[string]interface{})
 for i := 0; i < t.NumField(); i++ {
 data[t.Field(i).Name] = v.Field(i).Interface()
 }
 return data
}
//int转ip
func inet_ntoa(ipnr int64) net.IP {
 var bytes [4]byte
 bytes[0] = byte(ipnr & 0xFF)
 bytes[1] = byte((ipnr >> 8) & 0xFF)
 bytes[2] = byte((ipnr >> 16) & 0xFF)
 bytes[3] = byte((ipnr >> 24) & 0xFF)
 return net.IPv4(bytes[3], bytes[2], bytes[1], bytes[0])
}
//ip(string)转int
func inet_aton(ipnr net.IP) int64 {
 bits := strings.Split(ipnr.String(), ".")
 b0, _ := strconv.Atoi(bits[0])
 b1, _ := strconv.Atoi(bits[1])
 b2, _ := strconv.Atoi(bits[2])
 b3, _ := strconv.Atoi(bits[3])
 var sum int64
 sum += int64(b0) << 24
 sum += int64(b1) << 16
 sum += int64(b2) << 8
 sum += int64(b3)
 return sum
}
//判断是否为公网IP
func IsPublicIP(IP net.IP) bool {
 if IP.IsLoopback() || IP.IsLinkLocalMulticast() || IP.IsLinkLocalUnicast() {
 return false
 }
 if ip4 := IP.To4(); ip4 != nil {
 switch true {
 case ip4[0] == 10:
 return false
 case ip4[0] == 172 && ip4[1] >= 16 && ip4[1] <= 31:
 return false
 case ip4[0] == 192 && ip4[1] == 168:
 return false
 default:
 return true
 }
 }
 return false
}
//判断ip地址区间
func IpBetween(from net.IP, to net.IP, test net.IP) bool {
 if from == nil || to == nil || test == nil {
 fmt.Println("An ip input is nil") // or return an error!?
 return false
 }
 from16 := from.To16()
 to16 := to.To16()
 test16 := test.To16()
 if from16 == nil || to16 == nil || test16 == nil {
 fmt.Println("An ip did not convert to a 16 byte") // or return an error!?
 return false
 }
 if bytes.Compare(test16, from16) >= 0 && bytes.Compare(test16, to16) <= 0 {
 return true
 }
 return false
}
// https://ip.awk.sh/api.php?ip=
//通过淘宝接口查询相关信息
func TabaoAPI(ip string) *IPInfo {
 //url := "http://ip.taobao.com/service/getIpInfo.php?ip="
 url := "https://ip.awk.sh/api.php?ip="
 url += ip
 resp, err := http.Get(url)
 if err != nil {
 return nil
 }
 defer resp.Body.Close()
 out, err := ioutil.ReadAll(resp.Body)
 if err != nil {
 return nil
 }
 var result IPInfo
 if err := json.Unmarshal(out, &result); err != nil {
 return nil
 }
 return &result
}
func JudgeIp(ip string) bool {
 if m, _ := regexp.MatchString("^[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}$", ip); !m {
 err := fmt.Errorf("Not validate IP address :"+string(ip) )
 fmt.Println(err)
 return false
 }
 return true
}
// 通过map主键唯一的特性过滤重复元素
func RemoveRepByMap(slc []string) []string {
 result := []string{}
 tempMap := map[string]string{} // 存放不重复主键
 for _, e := range slc{
 l := len(tempMap)
 tempMap[e] = ""
 if len(tempMap) != l{ // 加入map后,map长度变化,则元素不重复
 result = append(result, e)
 }
 }
 return result
}
var ipv4count = 0
var intranetcount =0
var notipcount =0
//从文本获取ip进行整理
func ReadIPStatic(filename string,ipMap map[string]int) map[string]int {
 f, err := os.Open(filename)
 if err != nil {
 fmt.Print(err)
 }
 buf := bufio.NewReader(f)
 for {
 line,err := buf.ReadString('\n')
 if err!=nil|| io.EOF == err{
 break
 }
 //line = strings.TrimSpace(line)
 if line=="\n" {continue}
 ip := strings.Split(line,"/")[2]
 if IsPublicIP(inet_ntoa(InetAtoN(ip))) { //判断是否为ipv4
 _, ok := ipMap[ip]
 if ok == true {
 ipMap[ip]++ //如果已经存在,则value+1
 } else {
 ipMap[ip] = 1 //如果没有存在,则创建
 }
 ipv4count++
 }else {
 intranetcount++
 }
 }
 return ipMap
}
//从counter上获取到的ip,动态分析(未完成) iplong为
func ReadIPdynamic(iplong []string ,ipMap map[string]int) map[string]int {
 ipMap["0"] = 0
 for i:=0;i< len(iplong);i++ {
 ipline := iplong[i]
 ip := strings.Split(ipline, "/")[2]
 if IsPublicIP(inet_ntoa(InetAtoN(ip))) { //判断是否为ipv4
 //fmt.Println(ip)
 _, ok := ipMap[ip]
 if ok == true {
 ipMap[ip]++ //如果已经存在,则value+1
 } else {
 ipMap[ip] = 1 //如果没有存在,则创建
 }
 } else {
 //fmt.Println(ip)
 }
 }
 return ipMap
}
func count_go() map[string]int{
 //ipfs_countergo()
 var ipMap map[string]int
 ipMap = make(map[string]int)
 var mymap = ReadIPStatic("1.log",ipMap)
 for k,_ := range mymap{
 if(!JudgeIp(k)){ //删除多余的字符串
 delete(mymap,k)
 notipcount++
 ipv4count--
 }
 }
 for k,v := range mymap{
 fmt.Println(k,"===",v)
 }
 fmt.Println("公网ip节点数:",ipv4count,"内网ip节点数:",intranetcount,"无效ip节点数: ",notipcount)
 return mymap
}

错误如下http: panic serving 127.0.0.1:65522: runtime error: invalid memory address or nil pointer dereference
goroutine 16 [running]:
net/http.(*conn).serve.func1(0xc0423e2640)
C:/Go/src/net/http/server.go:1697 +0xd7
panic(0x996060, 0xf255b0)
C:/Go/src/runtime/panic.go:491 +0x291
main.handleTask(0xe64140, 0xc04221e0e0, 0xc04211a400)
C:/Users/Administrator.erica-PC/Desktop/IPFS/ipfs-counter-master/server.go:35 +0x2a2
net/http.HandlerFunc.ServeHTTP(0xb88ad8, 0xe64140, 0xc04221e0e0, 0xc04211a400)
C:/Go/src/net/http/server.go:1918 +0x4b
net/http.(*ServeMux).ServeHTTP(0xf4ab20, 0xe64140, 0xc04221e0e0, 0xc04211a400)
C:/Go/src/net/http/server.go:2254 +0x137
net/http.serverHandler.ServeHTTP(0xc04206aea0, 0xe64140, 0xc04221e0e0, 0xc04211a400)
C:/Go/src/net/http/server.go:2619 +0xbb
net/http.(*conn).serve(0xc0423e2640, 0xe64b80, 0xc042106440)
C:/Go/src/net/http/server.go:1801 +0x724
created by net/http.(*Server).Serve
C:/Go/src/net/http/server.go:2720 +0x28f

• 编辑
• 预览