redigo

    2熱度

    2回答

    我有1000到10,000個存儲在Redis中的密鑰,它們的值類型是列表。 當新項目添加到任何一個現有列表中時,我需要通知我的golang程序。 一旦收到通知,我需要產生一個新的goroutine並執行一個小操作。 我使用Redigo for redis連接池。 解決此問題的最佳方法是什麼,而不會重載Redis實例?

    -1熱度

    1回答

    psc := redis.PubSubConn{c} psc.Subscribe("example") func Receive() { for { switch v := psc.Receive().(type) { case redis.Message: fmt.Printf("%s: message: %s\n", v.Channel,

    2熱度

    1回答

    我已閱讀了可在此處找到的整個Redigo文檔。 https://godoc.org/github.com/garyburd/redigo/redis#pkg-variables 這裏的文檔明確指出連接不支持對Send(),Flush()或Receive()方法的併發調用。 連接不支持併發調用寫入方法 (發送,刷新)或併發調用讀取方法(接收)。 連接允許併發讀寫器。 然後它聲明由於Do方法可以是Se

    0熱度

    1回答

    我正在使用「RPUSH」命令在我的redis基礎中推入我的對象。 // object is of type interface var network bytes.Buffer gob.NewEncoder(&network) enc.Encode(object /* interface{} */) redis.String(d.Conn.Do("RPUSH", "objects",

    0熱度

    1回答

    Redigo是Redis數據庫的golang客戶端。它使用struct Pool來維護一個連接池。這個結構爲應用程序放置和並行連接保存互斥鎖。 type Pool struct { // ... IdleTimeout time.Duration mu sync.Mutex // Stack of idleConn with most recently u

    0熱度

    1回答

    當我連接的Redis服務器出現故障時,我正在努力快速失敗,希望擁有一個強大的解決方案。 我使用redigo和我設置了一個連接池,像這樣: // This has other stuff in it in the code, use it as a // central repository for things we want in memory type State struct{

    4熱度

    1回答

    我正在使用redigo library原型化golang中的redis客戶端以獲取keyspace事件的通知。我修改了redis.conf以將notify-keyspace-events設置爲「KEA」來接收所有事件。但是當我使用cli添加/更新/刪除密鑰到數據庫中時,我沒有看到任何事件在客戶端被觸發。使用redigo觸發事件 示例代碼: type RedisClient struct {

    0熱度

    1回答

    使用redigo時,我試圖使用HMGET。我在字段中傳遞一個字符串片作爲參數。它不工作,返回空結果。 func HMGET(c redis.Conn, field []string)(){ if err := c.Send("HMGET", HashName, field); err != nil { return nil, err } if er

    0熱度

    1回答

    我是redigomock的新手,並且通過文檔和Google搜索,我找不到有效的示例。我錯過了一些明顯的東西,但我希望我的測試能夠正常工作。 鑑於此代碼: var checkPasswordFailures = func(client redis.Conn, u *User) bool { var userkey = getPasswordFailKey(u) var exist

    -2熱度

    1回答

    我正在使用Go編寫使用websockets的聊天應用程序。 會有多個聊天室,這個想法是將所有連接到聊天室的websocket存儲在Redis列表中。 爲了存儲和檢索Redis中的websockets,我必須對它們進行編碼/解碼(以下是this問題),我認爲我可以使用gob。 我爲Redis使用github.com/garyburd/redigo/redis,我的websocket庫使用github