如何使用Go语言和Redis开发高并发系统

package main

import "fmt"

func main() {
    go func() {
        fmt.Println("Hello, goroutine!")
    }()

    fmt.Println("Hello, main function!")
}

package main

import (
    "fmt"
    "GitHub.com/gomodule/redigo/redis"
)

func main() {
    conn, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {
        fmt.Println("Failed to connect to Redis server")
        return
    }

    // 设置键值对
    _, err = conn.Do("SET", "name", "Alice")
    if err != nil {
        fmt.Println("Failed to set key-value")
        return
    }

    // 获取键值对
    name, err := redis.String(conn.Do("GET", "name"))
    if err != nil {
        fmt.Println("Failed to get key-value")
        return
    }

    fmt.Println("Name:", name)
}

package main

import (
    "fmt"
    "sync"

    "github.com/gomodule/redigo/redis"
)

type Counter struct {
    mutex sync.Mutex
    count int
    pool  *redis.Pool
}

func (c *Counter) Incr() error {
    c.mutex.Lock()
    defer c.mutex.Unlock()

    conn := c.pool.Get()
    defer conn.Close()

    _, err := conn.Do("INCR", "counter")
    if err != nil {
        return err
    }

    return nil
}

func (c *Counter) Get() (int, error) {
    c.mutex.Lock()
    defer c.mutex.Unlock()

    conn := c.pool.Get()
    defer conn.Close()

    count, err := redis.Int(conn.Do("GET", "counter"))
    if err != nil {
        return 0, err
    }

    return count, nil
}

func main() {
    pool := &redis.Pool{
        MaxActive:   10,
        MaxIdle:     5,
        IdleTimeout: 60,
        Dial: func() (redis.Conn, error) {
            return redis.Dial("tcp", "localhost:6379")
        },
    }

    counter := &Counter{
        mutex: sync.Mutex{},
        count: 0,
        pool:  pool,
    }

    // 并发增加计数器
    var wg sync.WaitGroup
    for i := 0; i < 100; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            counter.Incr()
        }()
    }
    wg.Wait()

    // 输出最终结果
    count, err := counter.Get()
    if err != nil {
        fmt.Println("Failed to get counter value")
        return
    }
    fmt.Println("Counter:", count)
}