使用cryptgo构建Golang实时加密货币价格监控终端应用

cryptgo是一个用于构建加密货币监控终端应用的Go语言库，它提供了简洁的API来获取实时加密货币价格数据。下面我将介绍如何使用cryptgo创建一个功能完善的加密货币价格监控工具。

安装cryptgo

首先需要安装cryptgo库：

go get github.com/pdepip/go-cryptgo

基本使用示例

package main

import (
	"fmt"
	"time"
	
	"github.com/pdepip/go-cryptgo/cryptgo"
)

func main() {
	// 创建新的Cryptgo客户端
	client := cryptgo.New()
	
	// 设置要监控的加密货币对
	pairs := []string{"BTC-USD", "ETH-USD", "XRP-USD"}
	
	// 设置刷新间隔(秒)
	refreshInterval := 5
	
	// 启动实时价格监控
	for {
		// 清屏(Unix-like系统)
		fmt.Print("\033[H\033[2J")
		
		// 获取并显示价格
		for _, pair := range pairs {
			ticker, err := client.GetTicker(pair)
			if err != nil {
				fmt.Printf("Error fetching %s: %v\n", pair, err)
				continue
			}
			
			fmt.Printf("%-8s: $%-10.2f 24h Change: %-6.2f%%\n", 
				pair, 
				ticker.Price, 
				ticker.PercentChange24h)
		}
		
		// 添加分隔线
		fmt.Println("\n" + time.Now().Format("2006-01-02 15:04:05"))
		fmt.Println("----------------------------")
		
		// 等待下一次刷新
		time.Sleep(time.Duration(refreshInterval) * time.Second)
	}
}

高级功能实现

1. 添加价格警报功能

func setupPriceAlerts(client *cryptgo.Cryptgo) {
	alerts := map[string]float64{
		"BTC-USD": 50000.0,
		"ETH-USD": 3000.0,
	}
	
	go func() {
		for {
			for pair, threshold := range alerts {
				ticker, err := client.GetTicker(pair)
				if err != nil {
					continue
				}
				
				if ticker.Price >= threshold {
					fmt.Printf("\nALERT: %s reached $%.2f!\n", pair, ticker.Price)
					// 这里可以添加声音提醒或其他通知方式
				}
			}
			time.Sleep(30 * time.Second)
		}
	}()
}

2. 多交易所价格比较

func compareExchanges(client *cryptgo.Cryptgo, pair string) {
	exchanges := []string{"binance", "coinbase", "kraken"}
	
	fmt.Printf("\nExchange comparison for %s:\n", pair)
	for _, exchange := range exchanges {
		ticker, err := client.GetExchangeTicker(pair, exchange)
		if err != nil {
			fmt.Printf("%-10s: error\n", exchange)
			continue
		}
		
		fmt.Printf("%-10s: $%-10.2f Volume: $%-15.2f\n", 
			exchange, 
			ticker.Price, 
			ticker.Volume24h)
	}
}

3. 历史价格图表(ASCII)

func showPriceHistory(client *cryptgo.Cryptgo, pair string, hours int) {
	history, err := client.GetHistory(pair, hours)
	if err != nil {
		fmt.Printf("Error getting history for %s: %v\n", pair, err)
		return
	}
	
	fmt.Printf("\nPrice history for %s (last %d hours):\n", pair, hours)
	
	min, max := getMinMax(history.Prices)
	scale := 10.0 // 图表高度
	
	for i := len(history.Prices) - 1; i >= 0; i-- {
		price := history.Prices[i]
		height := int((price - min) / (max - min) * scale)
		
		fmt.Printf("%-8.2f |", price)
		for j := 0; j < height; j++ {
			fmt.Print("#")
		}
		fmt.Println()
	}
}

func getMinMax(prices []float64) (min, max float64) {
	min, max = prices[0], prices[0]
	for _, p := range prices {
		if p < min {
			min = p
		}
		if p > max {
			max = p
		}
	}
	return min, max
}

完整应用示例

package main

import (
	"fmt"
	"time"
	
	"github.com/pdepip/go-cryptgo/cryptgo"
)

func main() {
	client := cryptgo.New()
	pairs := []string{"BTC-USD", "ETH-USD", "SOL-USD"}
	refreshInterval := 5
	
	// 设置价格警报
	setupPriceAlerts(client)
	
	for {
		fmt.Print("\033[H\033[2J") // 清屏
		
		// 显示实时价格
		for _, pair := range pairs {
			ticker, err := client.GetTicker(pair)
			if err != nil {
				fmt.Printf("Error fetching %s: %v\n", pair, err)
				continue
			}
			
			fmt.Printf("%-8s: $%-10.2f 24h Change: %-6.2f%%\n", 
				pair, 
				ticker.Price, 
				ticker.PercentChange24h)
		}
		
		// 显示时间戳
		fmt.Println("\n" + time.Now().Format("2006-01-02 15:04:05"))
		fmt.Println("----------------------------")
		
		// 每30秒显示一次交易所比较
		if time.Now().Second()%30 < 5 {
			compareExchanges(client, "BTC-USD")
		}
		
		// 每分钟显示一次价格历史
		if time.Now().Second() < 5 {
			showPriceHistory(client, "BTC-USD", 24)
		}
		
		time.Sleep(time.Duration(refreshInterval) * time.Second)
	}
}

注意事项

1. cryptgo可能需要API密钥才能访问某些交易所的数据
2. 频繁请求可能导致API限制，建议合理设置刷新间隔
3. 生产环境中应考虑添加错误处理和重试机制
4. 对于更复杂的可视化，可以考虑集成termui或tview等终端UI库

这个示例展示了cryptgo库的基本用法和一些高级功能实现。你可以根据需要扩展更多功能，如添加更多加密货币对、实现更复杂的警报逻辑或集成到更大的应用中。