首頁猿問需要幫助從 Go 消費(fèi)者將數(shù)據(jù)排入...

需要幫助從 Go 消費(fèi)者將數(shù)據(jù)排入 Redis 隊(duì)列

Go

慕田峪9158850 2022-06-01 18:04:52

我正在嘗試從我的 Go Consumer 將數(shù)據(jù)推送到 redis 隊(duì)列中。我使用的包是“github.com/kavu/go-resque”我使用的redis驅(qū)動(dòng)程序是“github.com/kavu/go-resque/go-redis”和“github.com/go-redis/redis”我的代碼如下所示："github.com/kavu/go-resque"_"github.com/kavu/go-resque/go-redis""github.com/go-redis/redis" "time" "strings" redisClient := redis.NewClient(&redis.Options{ Addr: myRedisIp, Password: "", // no password set DB: 0, // use default DB DialTimeout: 10 * time.Second,}) enqueuer := resque.NewRedisEnqueuer("go-redis", redisClient,"test-redis") _, err := enqueuer.Enqueue("resque:queue:myQueueName", "Demo::Job", 1, 2, "test") if err != nil { fmt.Println("putting into queue failed error="+err.Error()) }else{ fmt.Println("putting into queue success") }

查看完整描述

1 回答

守著一只汪

TA貢獻(xiàn)1872條經(jīng)驗(yàn) 獲得超4個(gè)贊

我終于能夠?qū)崿F(xiàn)這一點(diǎn)。分享步驟：

安裝包 Resque 包："github.com/kavu/go-resque" 另外，安裝驅(qū)動(dòng)程序包，即你希望 resque 使用的 redis 包。有多種選擇，例如：Go-redis、Godis、hoisie、redisGo 等。就我而言，我是Go-Redis。所以，我安裝了
"github.com/kavu/go-resque/go-redis"
"github.com/go-redis/redis"
然后設(shè)置redis Client
rc := redisQueue.New("Your redis server IP")
設(shè)置 resque 結(jié)構(gòu)
enqueuer := resque.NewRedisEnqueuer("redis-go", rc,"resque:")

這里，第一個(gè)參數(shù)是驅(qū)動(dòng)程序名稱，如 godis、redis-go 等。第二個(gè)參數(shù)是 redis 客戶端，即 Go-redis 客戶端或 godis 客戶端等。第三個(gè)參數(shù)是命名空間。這就是您要在 queueName 中附加的內(nèi)容。