go中利用hmset替换hset来提高redis的存取效率及并发goroutine可能遇到的问题

chenbaoke · · 1662 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

go 中直接利用hset向redis存入数据效率较低,当要存入的数据已知时,可以利用hmset 来替换hset进行存储。

var args []interface{}{"myhash"}
for key,value := range fvs {
    args = append(args, key, value)
}
_, err := conn.Do("HMSET", args...)

注:fvs为对应的key,value的map映射,将该映射关系存入到redis中名字为myhash的域中, args...表示args slice中的顺序的所有元素。


hmset存储速度相对hset已经很快,但是利用go中goroutine并发hmset能取得更好的存储效果吗?答案是否定的。

当利用多个(10个)goroutine进行并发hmset时,如

for i:=0;i<10;i++{

   go func(){

    ......

        _, err = conn.Do("hmset", args...)

        if err != nil {
              fmt.Println(err)
         }

    ......

   }

}


此时便会出现错误:use of closed network connection

错误原因:hmset对redis进行写操作时,只能对一个hash表有一个写操作,不能同时多个写操作。

解决办法:

       在执行hmset命令之前加锁,执行完之后解锁即可。本例解决方案如下:

import "sync"

var l sync.Mutex

for i:=0;i<10;i++{

   go func(){

    ......

       l.Lock()

        _, err = conn.Do("hmset", args...)

        if err != nil {
              fmt.Println(err)
         }

      l.Unlock()

    ......

   }
}


利用加锁方法变能够确保每次只有一个进行hmset对redis进行写操作。

1662 次点击  ∙  1 赞  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传