Golang操作Redis的实现示例

文阁發表於 2025-11-7 11:32:47

<div id="navCategory"><h5 class="catalogue">目录</h5><ul class="first_class_ul"><li><a href="#_label0">一. Redis介绍</a></li><ul class="second_class_ul"><li><a href="#_lab2_0_0">1.1 简介</a></li><li><a href="#_lab2_0_1">1.2 Redis优势</a></li><li><a href="#_lab2_0_2">1.3 redis的使用</a></li></ul><li><a href="#_label1">二. 链接Redis</a></li><ul class="second_class_ul"></ul><li><a href="#_label2">三. String类型的Set，Get操作</a></li><ul class="second_class_ul"></ul><li><a href="#_label3">四. String批量操作</a></li><ul class="second_class_ul"></ul><li><a href="#_label4">五. 设置过期时间</a></li><ul class="second_class_ul"></ul><li><a href="#_label5">六. List队列操作</a></li><ul class="second_class_ul"></ul><li><a href="#_label6">七.  Hash表</a></li><ul class="second_class_ul"></ul><li><a href="#_label7">八. Redis连接池</a></li><ul class="second_class_ul"></ul></ul></div><p class="maodian"><a name="_label0"></a></p><h2>一. Redis介绍</h2>
<p class="maodian"><a name="_lab2_0_0"></a></p><h3>1.1 简介</h3>
<p>Redis是完全开源免费的，遵循BSD协议，是一个高性能的key-value数据库。</p>
<p>Redis与其它的key-value缓存产品有以下三个特点：</p>
<ul><li>Redis支持数据持久化，可以见内存中的数据报错在磁盘中，重启的时候可以再次加载进行使用。</li><li>Redis不仅仅支持简单的key-value类型的数据，同时还提供string，list(链表)，set(集合)，hash表等数据结构的存储。</li><li>Redis支持数据备份，即master-slave模式的数据备份。</li></ul>
<p class="maodian"><a name="_lab2_0_1"></a></p><h3>1.2 Redis优势</h3>
<ul><li>性能极高——Redis能读的速度是110000次/秒，写的速度是81000次/秒，单机可以达到15w qps，通常适合做缓存。</li><li>丰富的数据类型——Redis支持二进制案例的strings，lists，hashes，sets及ordered sets数据类型操作。</li><li>原子——Redis的所有操作都是原子的，意思就是要么成功执行，要么失败完全不执行。单个操作是原子的。多操作也支持事务，即原子性，通过MULTI和EXEC指令包起来。</li><li>丰富的特性——Redis还支持publish/subscribe，通知，key过期等特性。</li></ul>
<p>Redis与其它的key-value存储有什么不同？</p>
<p>Redis有着更为复杂的数据结构并且提供对他们的原子操作，这是一个不同于其它数据库的进化路径。Redis的数据类型都是基于基本数据结构的同时对程序员透明，无需进行额外的抽象。</p>
<p>Redis运行在内存中但是可以持久化到磁盘，所以对不同数据集进行高速读写时需要权衡内存，因为数据量不能大于内存大小。在内存数据库方面的另一个优点是，相比在磁盘上相同的复杂数据结构，在内存中操作起来简单，这样Redis可以做很多内部复杂性很强的事情。同时，在磁盘格式方面他们是紧凑的以追加的方式产生，因为他们不需要进行随机访问。</p>
<p class="maodian"><a name="_lab2_0_2"></a></p><h3>1.3 redis的使用</h3>
<p>使用第三方开源的redis库：<span>github.com/garyburd/redigo/redis</span></p>
<p><span>命令行输入：</span></p>
<div class="jb51code"><pre class="brush:go;">go get github.com/garyburd/redigo/redis</pre></div>
<p class="maodian"><a name="_label1"></a></p><h2>二. 链接Redis</h2>
<div class="jb51code"><pre class="brush:go;">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("conn redis fail ", err)
return
}
defer c.Close()

fmt.Println("conn redis succ")
}</pre></div>
<p class="maodian"><a name="_label2"></a></p><h2>三. String类型的Set，Get操作</h2>
<div class="jb51code"><pre class="brush:go;">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("conn redis fail ", err)
return
}
defer c.Close()

_, err = c.Do("Set", "abc", 100)
if err != nil {
fmt.Println("set fail", err)
return
}

//将返回结果转为int类型
r, err := redis.Int(c.Do("Get", "abc"))
if err != nil {
fmt.Println("get fail", err)
return
}
fmt.Println(r)
}</pre></div>
<p>         输出结果：</p>
<p style="text-align:center"><img alt="" src="https://img.jbzj.com/file_images/article/202511/2025110711310344.png" /></p>
<p>        命令行输出：</p>
<p style="text-align:center"><img alt="" src="https://img.jbzj.com/file_images/article/202511/2025110711310359.png" /></p>
<p class="maodian"><a name="_label3"></a></p><h2>四. String批量操作</h2>
<p style="text-align:center"><img alt="" src="https://img.jbzj.com/file_images/article/202511/2025110711310394.png" /></p>
<p class="maodian"><a name="_label4"></a></p><h2>五. 设置过期时间</h2>
<div class="jb51code"><pre class="brush:go;">package main

import (
"fmt"
"time"

"github.com/garyburd/redigo/redis"
)

func main() {
c, err := redis.Dial("tcp", "127.0.0.1:6379")
if err != nil {
fmt.Println("conn redis fail ", err)
return
}
defer c.Close()

_, err = c.Do("set", "k1", 1)
if err != nil {
fmt.Println("set fail ", err)
return
}
//设置过期时间10秒
_, err = c.Do("expire", "k1", 10)
if err != nil {
fmt.Println("expire fail", err)
return
}

r, err := redis.Int(c.Do("get", "k1"))
if err != nil {
fmt.Println("get fail ", err)
return
}
fmt.Printf("k1=%d\n", r)

time.Sleep(10 * time.Second)
//过10秒已经过期再获得失败
r, err = redis.Int(c.Do("get", "k1"))
if err != nil {
fmt.Println("get fail ", err)
return
}
fmt.Printf("k1=%d\n", r)
}</pre></div>
<p>输出：</p>
<p style="text-align:center"><img alt="" src="https://img.jbzj.com/file_images/article/202511/2025110711310352.png" /></p>
<p class="maodian"><a name="_label5"></a></p><h2>六. List队列操作</h2>
<p style="text-align:center"><img alt="" src="https://img.jbzj.com/file_images/article/202511/2025110711310310.png" /></p>
<p class="maodian"><a name="_label6"></a></p><h2>七.  Hash表</h2>
<p style="text-align:center"><img alt="" src="https://img.jbzj.com/file_images/article/202511/2025110711310346.png" /></p>
<p class="maodian"><a name="_label7"></a></p><h2>八. Redis连接池</h2>
<div class="jb51code"><pre class="brush:go;">package main

import (
"fmt"

"github.com/garyburd/redigo/redis"
)

var pool *redis.Pool

func init() {
pool = &redis.Pool{
MaxIdle: 16, //最初的连接数量
//MaxActive: 1000000, //最大连接数量
MaxActive: 0, //连接池最大连接数量，不确定可以使用0(0表示自动定义)，按需分配
IdleTimeout: 300, //连接关闭时间300秒，(300秒内不使用自动关闭)
Dial: func() (redis.Conn, error) { //要连接的数据库
return redis.Dial("tcp", "127.0.0.1:6379")
},
}
}

func main() {
c := pool.Get() //从连接池中取一个连接
_, err := c.Do("set", "k1", "v1")
if err != nil {
fmt.Println("set fail ", err)
return
}

v, err := redis.String(c.Do("get", "k1"))
if err != nil {
fmt.Println("get fail ", err)
return
}
fmt.Println(v)
pool.Close() //关闭连接池
}</pre></div>
<p style="text-align:center"><img alt="" src="https://img.jbzj.com/file_images/article/202511/2025110711310366.png" /></p>

頁: [1]

琼殿技术论坛's Archiver

Golang操作Redis的实现示例