使用gopensky库实时获取航空ADS-B和Mode S数据

OpenSky Network是一个提供实时航空数据的平台，包括ADS-B和Mode S信息。gopensky是一个Go语言的客户端库，用于与OpenSky Network API交互。

安装gopensky

首先安装gopensky库：

go get github.com/opensky-network/go-opensky

基本使用示例

1. 获取所有飞行状态

package main

import (
	"fmt"
	"log"
	"time"

	"github.com/opensky-network/go-opensky"
)

func main() {
	// 创建OpenSky客户端
	client := opensky.NewClient(nil)

	// 获取所有飞行状态
	states, _, err := client.States.GetStates(nil)
	if err != nil {
		log.Fatal(err)
	}

	fmt.Printf("获取到 %d 架飞机的状态\n", len(*states.States))
	for _, state := range *states.States {
		fmt.Printf("呼号: %s, 高度: %.0f米, 速度: %.0fkm/h\n", 
			state.Callsign, 
			state.GeoAltitude, 
			state.Velocity*3.6) // 转换为km/h
	}
}

2. 获取特定区域的飞行状态

func getFlightsInArea() {
	client := opensky.NewClient(nil)
	
	// 定义感兴趣的区域 (minLat, maxLat, minLon, maxLon)
	area := &opensky.StatesOptions{
		Lamin: opensky.Float64(45.0),  // 最小纬度
		Lomin: opensky.Float64(8.0),   // 最小经度
		Lamax: opensky.Float64(48.0),  // 最大纬度
		Lomax: opensky.Float64(12.0),  // 最大经度
	}
	
	states, _, err := client.States.GetStates(area)
	if err != nil {
		log.Fatal(err)
	}
	
	fmt.Printf("在指定区域内有 %d 架飞机\n", len(*states.States))
}

3. 获取特定飞机的轨迹

func getAircraftTrack() {
	client := opensky.NewClient(nil)
	
	// 使用飞机的ICAO24地址
	icao24 := "abc123" // 替换为实际ICAO24地址
	
	// 设置时间范围 (可选)
	start := time.Now().Add(-24 * time.Hour)
	end := time.Now()
	
	track, _, err := client.Tracks.GetTrack(icao24, &opensky.TracksOptions{
		Time: opensky.Int64(start.Unix()),
		EndTime: opensky.Int64(end.Unix()),
	})
	
	if err != nil {
		log.Fatal(err)
	}
	
	fmt.Printf("飞机 %s 的轨迹点数量: %d\n", icao24, len(*track.Path))
	for _, point := range *track.Path {
		fmt.Printf("时间: %s, 位置: %.4f,%.4f, 高度: %.0f米\n",
			time.Unix(int64(point[3]), 0).Format(time.RFC3339),
			point[1], // 经度
			point[2], // 纬度
			point[4], // 高度
		)
	}
}

高级功能

1. 使用认证获取更多数据

func getFlightsWithAuth() {
	// 使用OpenSky账户认证 (可在https://opensky-network.org注册)
	client := opensky.NewClient(&opensky.ClientOptions{
		Username: "your_username",
		Password: "your_password",
	})
	
	// 认证用户可以获取更多数据
	states, _, err := client.States.GetStates(nil)
	if err != nil {
		log.Fatal(err)
	}
	
	// 处理数据...
}

2. 实时监控特定飞机

func monitorAircraft(icao24 string) {
	client := opensky.NewClient(nil)
	
	for {
		states, _, err := client.States.GetStates(nil)
		if err != nil {
			log.Println("获取状态错误:", err)
			time.Sleep(10 * time.Second)
			continue
		}
		
		for _, state := range *states.States {
			if state.Icao24 == icao24 {
				fmt.Printf("飞机 %s 当前位置: %.4f,%.4f, 高度: %.0f米\n",
					icao24,
					state.Longitude,
					state.Latitude,
					state.GeoAltitude,
				)
			}
		}
		
		time.Sleep(30 * time.Second) // 每30秒检查一次
	}
}

注意事项

1. OpenSky API有使用限制，匿名用户每分钟约10次请求，认证用户更多
2. 某些数据字段可能为空，需要做空值检查
3. 对于生产环境，建议添加错误处理和重试逻辑
4. 坐标系统使用WGS84
5. 高度单位是米，速度单位是米/秒

通过gopensky库，你可以方便地集成航空数据到你的Go应用程序中，用于飞行跟踪、数据分析等场景。