Go实战--golang中使用redis(redigo和go-redis/redis)
生命不止,继续 go go go !!! 以前介绍过golang中如何使用sqlite3: 今天跟大家分享的是如何在golang中使用redis数据库。 何为redis官网: Redis is an in-memory database open-source software project implementing a networked,in-memory key-value store with optional durability. Redis 优势 丰富的数据类型 – Redis支持二进制案例的 Strings,Lists,Hashes,Sets 及 Ordered Sets 数据类型操作。 原子 – Redis的所有操作都是原子性的,同时Redis还支持对几个操作全并后的原子性执行。 丰富的特性 – Redis还支持 publish/subscribe,通知,key 过期等等特性。 Redis与其他key-value存储有什么不同? Redis运行在内存中但是可以持久化到磁盘,所以在对不同数据集进行高速读写时需要权衡内存,因为数据量不能大于硬件内存。在内存数据库方面的另一个优点是,相比在磁盘上相同的复杂的数据结构,在内存中操作起来非常简单,这样Redis可以做很多内部复杂性很强的事情。同时,在磁盘格式方面他们是紧凑的以追加的方式产生的,因为他们并不需要进行随机访问。 windows安装redis这里只简单介绍一下Windows上redis的安装: 下载 这里可以下载msi文件和zip文件,两者区别就是msi文件是安装文件,安装的过程中会帮助我们配好环境变量,所以推荐。 这里需要提示一下安装过程中,如果修改了端口号,一定要记住: 启动服务端 redis-server.exe redis.windows.conf
一切没问题会出现下面的提示: 启动客户端 redis-cli.exe -h 127.0.0.1 -p 6379
测试: 127.0.0.1:6379> set mykey abc
OK 127.0.0.1:6379> get mykey
"abc"
开源库redigo的使用github地址: 文档地址: 获取: go get github.com/garyburd/redigo/redis
连接redis package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
c,err := redis.Dial("tcp","127.0.0.1:6379")
if err != nil {
fmt.Println("Connect to redis error",err)
return
}
defer c.Close()
}
读写 package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
c,err)
return
}
defer c.Close()
_,err = c.Do("SET","mykey","superWang")
if err != nil {
fmt.Println("redis set failed:",err)
}
username,err := redis.String(c.Do("GET","mykey"))
if err != nil {
fmt.Println("redis get failed:",err)
} else {
fmt.Printf("Get mykey: %v n",username)
}
}
如何设置过期呢,可以使用SET的附加参数: package main
import (
"fmt"
"time"
"github.com/garyburd/redigo/redis"
)
func main() {
c,"superWang","EX","5")
if err != nil {
fmt.Println("redis set failed:",username)
}
time.Sleep(8 * time.Second)
username,err = redis.String(c.Do("GET",username)
}
}
输出: 批量写入读取 MGET key [key …] 批量写入读取对象(Hashtable) 检测值是否存在 package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
c,err)
}
is_key_exit,err := redis.Bool(c.Do("EXISTS","mykey1"))
if err != nil {
fmt.Println("error:",err)
} else {
fmt.Printf("exists or not: %v n",is_key_exit)
}
}
输出: 删除 package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
c,username)
}
_,err = c.Do("DEL","mykey")
if err != nil {
fmt.Println("redis delelte failed:",username)
}
}
输出: 读写json到redis package main
import (
"encoding/json"
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
c,err)
return
}
defer c.Close()
key := "profile"
imap := map[string]string{"username": "666","phonenumber": "888"}
value,_ := json.Marshal(imap)
n,err := c.Do("SETNX",key,value)
if err != nil {
fmt.Println(err)
}
if n == int64(1) {
fmt.Println("success")
}
var imapGet map[string]string
valueGet,err := redis.Bytes(c.Do("GET",key))
if err != nil {
fmt.Println(err)
}
errShal := json.Unmarshal(valueGet,&imapGet)
if errShal != nil {
fmt.Println(err)
}
fmt.Println(imapGet["username"])
fmt.Println(imapGet["phonenumber"])
}
设置过期时间 // 设置过期时间为24小时
n,_ := rs.Do("EXPIRE", 24*3600)
if n == int64(1) {
fmt.Println("success")
}
列表操作 redis 127.0.0.1:6379> LPUSH runoobkey redis
(integer) 1
redis 127.0.0.1:6379> LPUSH runoobkey mongodb
(integer) 2
redis 127.0.0.1:6379> LPUSH runoobkey mysql
(integer) 3
redis 127.0.0.1:6379> LRANGE runoobkey 0 10
1) "mysql" 2) "mongodb" 3) "redis"
代码实现: package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
c,err = c.Do("lpush","runoobkey","redis")
if err != nil {
fmt.Println("redis set failed:",err)
}
_,"mongodb")
if err != nil {
fmt.Println("redis set failed:",err)
}
_,"mysql")
if err != nil {
fmt.Println("redis set failed:",err)
}
values,_ := redis.Values(c.Do("lrange","0","100"))
for _,v := range values {
fmt.Println(string(v.([]byte)))
}
}
输出: 管道 请求/响应服务可以实现持续处理新请求,即使客户端没有准备好读取旧响应。这样客户端可以发送多个命令到服务器而无需等待响应,最后在一次读取多个响应。这就是管道化(pipelining),这个技术在多年就被广泛使用了。距离,很多POP3协议实现已经支持此特性,显著加速了从服务器下载新邮件的过程。 连接支持使用Send(),Flush(),Receive()方法支持管道化操作 Send(commandName string,args ...interface{}) error
Flush() error
Receive() (reply interface{},err error)
Send向连接的输出缓冲中写入命令。Flush将连接的输出缓冲清空并写入服务器端。Recevie按照FIFO顺序依次读取服务器的响应。下例展示了一个简单的管道: c.Send("SET","foo","bar")
c.Send("GET","foo")
c.Flush()
c.Receive() // reply from SET
v,err = c.Receive() // reply from GET
Do方法组合了Send,Flush和 Receive方法。Do方法先写入命令,然后清空输出buffer,最后接收全部挂起响应包括Do方发出的命令的结果。如果任何响应中包含一个错误,Do返回错误。如果没有错误,Do方法返回最后一个响应。 开源库go-redis/redis的使用github地址: 文档地址: 获取: go get -u github.com/go-redis/redis
应用: package main
import (
"fmt"
"github.com/go-redis/redis"
)
func main() {
client := redis.NewClient(&redis.Options{
Addr: "127.0.0.1:6379",Password: "",// no password set
DB: 0,// use default DB
})
pong,err := client.Ping().Result()
fmt.Println(pong,err)
err = client.Set("key","value", 0).Err()
if err != nil {
panic(err)
}
val,err := client.Get("key").Result()
if err != nil {
panic(err)
}
fmt.Println("key",val)
val2,err := client.Get("key2").Result()
if err == redis.Nil {
fmt.Println("key2 does not exists")
} else if err != nil {
panic(err)
} else {
fmt.Println("key2",val2)
}
}
输出: (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |