Go语言入门心法(十四): Go操作Redis实战

Go语言入门心法(一): 基础语法

Go语言入门心法(二): 结构体

Go语言入门心法(三): 接口

Go语言入门心法(四): 异常体系

 Go语言入门心法(五): 函数

Go语言入门心法(六): HTTP面向客户端|服务端编程

Go语言入门心法(七): 并发与通道

Go语言入门心法(八): mysql驱动安装报错onnection failed

Go语言入门心法(九): 引入三方依赖

Go语言入门心法(十):Go语言操作MYSQL(CRUD)|事务处理

Go语言入门心法(十一): 文件处理

 Go语言入门心法(十二): GORM映射框架

Go语言入门心法(十三): 反射认知升维

Go语言入门心法(十四): Go操作Redis实战

Go语言入门心法(十五):Go微服务实战

Go语言入门心法(十六):Go远程过程调用框架GRPC实战

go操作redis客户端官网推荐: go-redis客户端详细文档 

一:安装redis依赖包

下载远程redigo依赖到本地：
PS D:\program_file\go_workspace> go get github.com/garyburd/redigo/redis
go: downloading github.com/garyburd/redigo v1.6.4
go: module github.com/garyburd/redigo is deprecated: Use github.com/gomodule/redigo instead.
go: added github.com/garyburd/redigo v1.6.4

项目中引入依赖：
import ("fmt""github.com/garyburd/redigo/redis""time"
)

 二: go连接redis并设置相关参数

go操作redis认知升维:(1)go语言操作Redis客户端的包有很多,比如:redigo，go-redis等;redigo包的使用方法很简单;(2)通常使用Dial()函数来连接Redis,当任务完成时,应用程序必须调用Close()函数来完成操作;(3)通常使用Conn接口中的Do()方法执行Redis命令。可以使用Go的类型断言或者reply辅助函数将返回的interface{}转换为对应的类型(4)go操作redis常用设置参数：基本配置说明MaxIdle：最大的空闲连接数，表示即使没有redis连接时依然可以保持N个空闲的连接，而不被清除，随时处于待命状态。MaxActive：最大的连接数，表示同时最多有N个连接。0表示不限制。IdleTimeout：最大的空闲连接等待时间，超过此时间后，空闲连接将被关闭。如果设置成0，空闲连接将不会被关闭。应该设置一个比redis服务端超时时间更短的时间。DialConnectTimeout：连接Redis超时时间。DialReadTimeout：从Redis读取数据超时时间。DialWriteTimeout：向Redis写入数据超时时间。


package mainimport ("fmt""github.com/garyburd/redigo/redis""time"
)/*
go操作redis认知升维:(1)go语言操作Redis客户端的包有很多,比如:redigo，go-redis等;redigo包的使用方法很简单;(2)通常使用Dial()函数来连接Redis,当任务完成时,应用程序必须调用Close()函数来完成操作;(3)通常使用Conn接口中的Do()方法执行Redis命令。可以使用Go的类型断言或者reply辅助函数将返回的interface{}转换为对应的类型(4)go操作redis常用设置参数：基本配置说明MaxIdle：最大的空闲连接数，表示即使没有redis连接时依然可以保持N个空闲的连接，而不被清除，随时处于待命状态。MaxActive：最大的连接数，表示同时最多有N个连接。0表示不限制。IdleTimeout：最大的空闲连接等待时间，超过此时间后，空闲连接将被关闭。如果设置成0，空闲连接将不会被关闭。应该设置一个比redis服务端超时时间更短的时间。DialConnectTimeout：连接Redis超时时间。DialReadTimeout：从Redis读取数据超时时间。DialWriteTimeout：向Redis写入数据超时时间。
*/
func main() {// 1.连接到redisconn, err := redis.Dial("tcp", "192.168.1.111:6379")// 设置操作的数据库redis.DialDatabase(0)redis.DialConnectTimeout(time.Duration(1000) * time.Millisecond)redis.DialWriteTimeout(time.Duration(1000) * time.Millisecond)if err != nil {fmt.Println("connection redis server : ", err)return}println()fmt.Println("redis连接成功......")fmt.Println(conn)// 关闭连接defer conn.Close()}

 运行效果：

GOROOT=D:\program_file_worker\go1.20 #gosetup
GOPATH=D:\program_file_worker\go1.20\bin;C:\Users\Administrator\go #gosetup
D:\program_file_worker\go1.20\bin\go.exe build -o C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis.exe org.jd.data/org.jd.data/redis #gosetup
C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis.exe

redis连接成功......
&{{0 0} 0 <nil> 0xc000068048 0 0xc000078060 0 0xc000076080 [0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0] [0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0]}

Process finished with the exit code 0


 

三:go操作redis命令执行读写数据

package mainimport ("fmt""github.com/garyburd/redigo/redis"
)
/*go操作redis读写*/
func main() {conn, err := redis.Dial("tcp", "192.168.1.111:6379")if err != nil {fmt.Println("connection redis error: ", err.Error())return}// 延迟执行关闭函数defer conn.Close()_, err = conn.Do("SET", "bookName", "go语言从入门到放弃实战")if err != nil {fmt.Println("redis set error:", err.Error())}bookName, err := redis.String(conn.Do("GET", "bookName"))if err != nil {fmt.Println("redis get error:", err.Error())} else {fmt.Printf("获取bookName：%s \n", bookName)}}

运行效果：

GOROOT=D:\program_file_worker\go1.20 #gosetup
GOPATH=D:\program_file_worker\go1.20\bin;C:\Users\Administrator\go #gosetup
D:\program_file_worker\go1.20\bin\go.exe build -o C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis__1_.exe D:\program_file\go_workspace\org.jd.data\redis\OOPRedisToGrammarSetFindData.go #gosetup
C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_org_jd_data_org_jd_data_redis__1_.exe
获取bookName：go语言从入门到放弃实战

Process finished with the exit code 0
 

四:go引入连接池支持

一个数据库服务器只拥有有限的连接资源，一旦所有的连接资源都在使用，那么其它需要连接的资源就只能等待释放连接资源。所以，在连接资源有限的情况下，提高单位时间的连接的使用效率，缩短连接时间，就能显著缩短请求时间。

所以就有了连接池的概念，在初始化时，创建一定数量的连接，先把所有连接存起来，然后，谁需要使用，从这里取走，干完活立马放回来。 如果请求数超出连接池容量，那么就排队等待或者直接丢弃掉。这样就可以省掉每次都创建和关闭连接的资源消耗和时间。

如果不使用连接池，那么，每次传输数据，我们都需要耗费大量的系统资源进行创建连接，收发数据，关闭连接。很明显，重复创建连接 关闭连接这样的消耗是可以节省。

下载远程依赖：

PS D:\program_file\go_workspace> go get github.com/gomodule/redigo/redis
go: downloading github.com/gomodule/redigo v1.8.9
go: added github.com/gomodule/redigo v1.8.9
 

项目模块中引入依赖:

import "github.com/gomodule/redigo/redis"
package main/*redis连接池操作
*/
import ("fmt"redisPoll "github.com/gomodule/redigo/redis""time"
)type Redis struct {pool *redisPoll.Pool
}var redis *Redisfunc initRedisPool() {redis = new(Redis)redis.pool = &redisPoll.Pool{MaxIdle:     256,MaxActive:   0,IdleTimeout: time.Duration(120),Dial: func() (redisPoll.Conn, error) {return redisPoll.Dial("tcp","192.168.1.111:6379",redisPoll.DialReadTimeout(time.Duration(1000)*time.Millisecond),redisPoll.DialWriteTimeout(time.Duration(1000)*time.Millisecond),redisPoll.DialConnectTimeout(time.Duration(1000)*time.Millisecond),redisPoll.DialDatabase(0),//red.DialPassword(""),)},}
}func ExecCommand(cmd string, key interface{}, args ...interface{}) (interface{}, error) {con := redis.pool.Get()if err := con.Err(); err != nil {return nil, err}defer con.Close()parma := make([]interface{}, 0)parma = append(parma, key)if len(args) > 0 {for _, v := range args {parma = append(parma, v)}}return con.Do(cmd, parma...)
}func main() {initRedisPool()ExecCommand("set", "userName", "老杨,欢迎来到Go操作Redis的世界!")fmt.Print(2)result, err := ExecCommand("get", "userName")if err != nil {fmt.Print(err.Error())}str, _ := redisPoll.String(result, err)fmt.Println(str)}

运行效果：

GOROOT=D:\program_file_worker\go1.20 #gosetup
GOPATH=D:\program_file_worker\go1.20\bin;C:\Users\Administrator\go #gosetup
D:\program_file_worker\go1.20\bin\go.exe build -o C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_OOPRedisToGrammarPool_go.exe D:\program_file\go_workspace\org.jd.data\redis\OOPRedisToGrammarPool.go #gosetup
C:\Users\Administrator\AppData\Local\Temp\GoLand\___go_build_OOPRedisToGrammarPool_go.exe
2老杨,欢迎来到Go操作Redis的世界!

Process finished with the exit code 0


 

 更详细的go操作redis查找官方文档：

go语言操作redis详细文档

go-redis客户端操作redis详细文档见官网

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/119668.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

SpringMVC 异常处理器

SpringMVC 异常处理器

1、基于配置的异常处理 SpringMVC提供了一个处理控制器方法执行过程中所出现的异常的接口&#xff1a;HandlerExceptionResolver HandlerExceptionResolver接口的实现类有&#xff1a;DefaultHandlerExceptionResolver和SimpleMappingExceptionResolver SpringMVC提供了自定…
阅读更多...
【ARM Cortex-M 系列 4 番外篇 -- 常用 benchmark 介绍】

【ARM Cortex-M 系列 4 番外篇 -- 常用 benchmark 介绍】

文章目录 1.1 CPU 性能测试 MIPS 计算1.1.1 Cortex-M7 CPI 1.2 benchmark 小节1.3.1 Geekbenck 介绍 1.3 编译参数配置 1.1 CPU 性能测试 MIPS 计算 每秒百万指令数 (MIPS)&#xff1a;在数据压缩测试中&#xff0c;MIPS 每秒测量一次 CPU 执行的低级指令的数量。越高越好&…
阅读更多...
D71X-16Q手柄蝶阀型号解析

D71X-16Q手柄蝶阀型号解析

D71X-16Q型号字母含义解析 D71X-16Q是德特森阀门常用的手柄蝶阀型号字母分别代表的意思是: D——代表阀门类型《蝶阀》 7——代表连接方式《对夹》 1——代表结构形式《中线》 X——代表阀座材质《橡胶》 -代表分隔键 16——代表公称压力《1.6MPA》 Q——代表阀体材料《…
阅读更多...
美创科技列为IDC中国数据安全市场代表厂商

美创科技列为IDC中国数据安全市场代表厂商

近日&#xff0c;国际权威IT咨询机构IDC发布《中国数据安全市场发展趋势&#xff0c;2023》报告&#xff0c;报告针对中国数据安全市场的发展现状进行调研&#xff0c;明确了最终用户数据安全建设的痛点、难点&#xff0c;阐述了市场中各技术服务提供商的服务方案和优势。 美创…
阅读更多...
如何恢复u盘删除文件?2023最新分享四种方法恢复文件

如何恢复u盘删除文件?2023最新分享四种方法恢复文件

U盘上删除的文件怎么恢复&#xff1f;使用U盘存储文件是非常方便的&#xff0c;例如&#xff1a;在办公的时候&#xff0c;会使用U盘来存储网络上查找到的资料、产品说明等。在学习的时候&#xff0c;会使用U盘来存储教育机构分享的教学视频、重点知识等。而随着U盘存储文件的概…
阅读更多...
css步骤条

css步骤条

html 代码以及样式 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>css步骤条</title><style>.steps {display: flex;justify-content: space-between;padding: 0;margin: 20px 10px;lis…
阅读更多...
数据结构笔记——树和图（王道408）（持续更新）

数据结构笔记——树和图（王道408）（持续更新）

文章目录 传送门前言树&#xff08;重点&#xff09;树的数据结构定义性质 二叉树的数据结构定义性质储存结构 二叉树算法先中后序遍历层次展开法递归模拟法 层次遍历遍历序列逆向构造二叉树 线索二叉树&#xff08;难点&#xff09;定义线索化的本质 二叉树线索化线索二叉树中…
阅读更多...
Elasticsearch分词器-中文分词器ik

Elasticsearch分词器-中文分词器ik

文章目录 使用standard analysis对英文进行分词使用standard analysis对中文进行分词安装插件对中文进行友好分词-ik中文分词器下载安装和配置IK分词器使用ik_smart分词器使用ik_max_word分词器 借助Nginx实现ik分词器自定义分词网络新词 ES官方文档Text Analysis 使用standard…
阅读更多...
ES修改字段类型详解

ES修改字段类型详解

一、需求概述 ES修改字段类型是指在已有的索引中&#xff0c;通过特定的操作方式将某个字段的类型修改为其它类型。当ES在建立索引的时候&#xff0c;已经确定好了每个字段的类型&#xff0c;而如果在建立后发现类型不符需求&#xff0c;就需要修改字段类型。 二、修改字段类…
阅读更多...
react-typescript-demo

react-typescript-demo

1.使用 Context 来存储数据
阅读更多...
elasticSearch put全局更新和单个字段更新语法

elasticSearch put全局更新和单个字段更新语法

1、如下&#xff1a;更新改类型未doc(文档)的全局字段数据 注意&#xff1a;如果你使用的是上面的语句&#xff0c;但是只写了id和title并赋值&#xff0c;图片上其他字段没有填写&#xff0c;执行命令后&#xff0c;则会把原文档中的其他字段都给删除了&#xff0c;你会发现查…
阅读更多...
Linux虚拟网络设备—Veth Pair

Linux虚拟网络设备—Veth Pair

veth是Virtual Ethernet Device的缩写&#xff0c;是一种成对出现的Linux虚拟网络接口设备。它最常用的功能是用于将不同的Linux network namespaces 命名空间网络连接起来&#xff0c;让二个namespaces之间可以进行通信。我们可以简单的把veth pair理解为用一根网线&#xff0…
阅读更多...
Redux 数据仓库

Redux 数据仓库

Redux 数据仓库 解决React 数据管理&#xff08;状态管理&#xff09; &#xff0c;用于中大型&#xff0c;数据比较庞大&#xff0c;组件之间数据交互多的情况下使用。 作者&#xff1a;如果你不知道是否需要使用Redux,那么你就不需要它&#xff01; 解决组件的数据通信。 …
阅读更多...
ESB优势2019-架构师（六十二）

ESB优势2019-架构师（六十二）

分布式数据数据库系统除了包含集中式数据库系统的模式结构外&#xff0c;还增加了几个模式级别&#xff0c;其中&#xff08;&#xff09;定义了分布式数据库中数据的整体逻辑结构、使得数据使用方便&#xff0c;如同没有分布一样。 分片模式全局外模式分布模式全局概念模式 …
阅读更多...
VisualStudio[WPF/.NET]基于CommunityToolkit.Mvvm架构开发

VisualStudio[WPF/.NET]基于CommunityToolkit.Mvvm架构开发

一、创建 "WPF应用程序" 新项目 项目模板选择如下&#xff1a; 暂时随机填一个目标框架&#xff0c;待会改&#xff1a; 二、修改“目标框架” 双击“解决方案资源管理器”中<项目>CU-APP, 打开<项目工程文件>CU-APP.csproj, 修改目标框架TargetFramew…
阅读更多...
跳跃游戏(动态规划)

跳跃游戏(动态规划)

给你一个非负整数数组 nums &#xff0c;你最初位于数组的 第一个下标 。数组中的每个元素代表你在该位置可以跳跃的最大长度。 判断你是否能够到达最后一个下标&#xff0c;如果可以&#xff0c;返回 true &#xff1b;否则&#xff0c;返回 false 。 示例 1&#xff1a; 输…
阅读更多...
企业出海：深入测评华为云云连接

企业出海：深入测评华为云云连接

随着全球化不断发展&#xff0c;中国企业也不断向海外拓展业务&#xff0c;然而出海企业面临不同以往的困难和挑战&#xff0c;在其中不可避免面临的跨境网络时延问题&#xff0c;如何选择区域进行部署企业业务&#xff0c;减少时延问题也成为需要重点考虑的问题。九河云结合测…
阅读更多...
YModem协议总结

YModem协议总结

《YModem协议总结》 目录 第1章 YModem协议简介 4 1.1 基本介绍 4 1.2 YModem基本介绍 4 第2章 YModem传输协议 5 2.1 起始帧的数据格式 5 2.2 数据帧的数据格式 5 2.3 结束帧数据结构 6 2.4 文件传输过程 6 2.5 CRC的计算 7 附录A 附录 8 A.1 附录 8 第1章 YModem协议简…
阅读更多...
【嵌入式项目应用】__cJSON在单片机的使用

【嵌入式项目应用】__cJSON在单片机的使用

目录 前言 一、JSON和cJson 二、cJSON是如何表示JSON数据的 三、如何封装完整的JSON数据 1. 先将串口打通&#xff0c;方便电脑查看log日志。 2. 增加cjson.c文件&#xff0c;已经在main.c中 3. 准备打包如下的JSON包 4. 代码部分&#xff0c;先将几个部分初始化指针 …
阅读更多...
web - Tomcat服务器

web - Tomcat服务器

文章目录 目录 文章目录 前言 一 . CS和BS的异同 二 . 什么是Tomcat 二 . Tomcat安装 四 . Tomcat目录结构 bin目录: 用于存放二进制的可执行文件 config目录 server.xml&#xff1a;配置整个服务器信息。例如修改端口号。默认HTTP请求的端口号是&#xff1a;8080 lib目录 log…
阅读更多...
最新文章

Copyright @ 2022~2023