29 lines
589 B
Go
29 lines
589 B
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
red "github.com/redis/go-redis/v9"
|
|
)
|
|
|
|
func main() {
|
|
client := red.NewClient(&red.Options{
|
|
Addr: "127.0.0.1:6379", // Redis地址
|
|
Password: "", // 密码（如果有的话）
|
|
DB: 0, // 使用默认DB
|
|
})
|
|
defer client.Close()
|
|
|
|
ctx := context.Background()
|
|
for i := 0; i < 100; i++ {
|
|
val, err := client.XAdd(ctx, &red.XAddArgs{
|
|
Stream: "test_stream",
|
|
Values: map[string]interface{}{
|
|
"key1": "value1",
|
|
"key2": i + 1,
|
|
},
|
|
}).Result()
|
|
fmt.Printf("val: %v, err: %v\n", val, err)
|
|
}
|
|
}
|