Go語言中使用Redis隊列主要有兩種應用場景：消息隊列和任務隊列。
消息隊列常用于異步通信和解耦系統組件。使用Redis作為消息隊列可以通過Redis的List數據結構實現。生產者通過LPUSH命令將消息推送到隊列中，消費者通過BRPOP命令阻塞地從隊列中獲取消息。以下是一個簡單的示例代碼：
package main
import (
"fmt"
"github.com/go-redis/redis"
)
func main() {
client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "",
DB: 0,
})
// 生產者
err := client.LPush("myqueue", "message1").Err()
if err != nil {
fmt.Println(err)
return
}
// 消費者
result, err := client.BRPop(0, "myqueue").Result()
if err != nil {
fmt.Println(err)
return
}
fmt.Println(result[1])
}
任務隊列常用于將耗時的任務異步地放入隊列中，然后由多個消費者并發地處理。使用Redis作為任務隊列可以通過Redis的List數據結構和多個協程實現。生產者將任務推送到隊列中，消費者協程并發地從隊列中獲取任務并處理。以下是一個簡單的示例代碼：
package main
import (
"fmt"
"github.com/go-redis/redis"
"sync"
)
func worker(id int, wg *sync.WaitGroup, client *redis.Client) {
defer wg.Done()
for {
result, err := client.BRPop(0, "myqueue").Result()
if err != nil {
fmt.Println(err)
break
}
task := result[1]
fmt.Printf("Worker %d processing task: %s\n", id, task)
// 處理任務
}
}
func main() {
client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "",
DB: 0,
})
// 生產者
err := client.LPush("myqueue", "task1", "task2", "task3").Err()
if err != nil {
fmt.Println(err)
return
}
// 消費者
var wg sync.WaitGroup
for i := 1; i <= 3; i++ {
wg.Add(1)
go worker(i, &wg, client)
}
wg.Wait()
}
以上示例代碼僅作為演示，實際應用中需要處理錯誤、增加重試機制等。另外，為了保證消息的可靠性，可以使用Redis的事務和持久化機制。
