golang实现ip访问限制及提交次数

go get github.com/go-redis/redis/v8

package main

import (
	"context"
	"fmt"
	"log"
	"net/http"
	"strconv"
	"time"

	"github.com/go-redis/redis/v8"
)

// Redis client
var rdb *redis.Client

// 初始化 Redis 客户端
func initRedis() {
	rdb = redis.NewClient(&redis.Options{
		Addr:     "localhost:6379", // Redis 地址
		Password: "",               // Redis 密码（如果有）
		DB:       0,                // 使用的 Redis 数据库
	})
}

// 获取客户端的 IP 地址
func getIP(r *http.Request) string {
	// 尝试从 X-Forwarded-For 或 X-Real-IP 获取真实 IP
	ip := r.Header.Get("X-Forwarded-For")
	if ip == "" {
		ip = r.Header.Get("X-Real-IP")
	}
	if ip == "" {
		ip = r.RemoteAddr
	}
	return ip
}

// 中间件：IP 访问限制
func rateLimitMiddleware(next http.HandlerFunc) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		ctx := context.Background()
		ip := getIP(r)
		key := "rate_limit:" + ip

		// 获取 Redis 中的访问次数
		count, err := rdb.Get(ctx, key).Result()
		if err == redis.Nil {
			// 如果没有记录，设置计数为1，并设置过期时间
			err := rdb.Set(ctx, key, 1, time.Minute).Err() // 1 分钟限制
			if err != nil {
				http.Error(w, "Redis error", http.StatusInternalServerError)
				return
			}
		} else if err != nil {
			http.Error(w, "Redis error", http.StatusInternalServerError)
			return
		} else {
			// 将访问次数转换为整数
			countInt, _ := strconv.Atoi(count)
			if countInt >= 10 { // 假设限制为每分钟最多10次
				http.Error(w, "Too Many Requests", http.StatusTooManyRequests)
				return
			}

			// 递增计数
			rdb.Incr(ctx, key)
		}

		next.ServeHTTP(w, r)
	}
}

// 示例处理器：提交处理
func submitHandler(w http.ResponseWriter, r *http.Request) {
	fmt.Fprintf(w, "Request successful")
}

func main() {
	// 初始化 Redis
	initRedis()

	// 创建 HTTP 服务器并添加中间件
	http.HandleFunc("/submit", rateLimitMiddleware(submitHandler))

	log.Println("Server is running on port 8080...")
	http.ListenAndServe(":8080", nil)
}