[golang gin框架] 24.Gin 商城项目-redis讲解以及操作

news2025/1/16 5:51:07

一.reids相关文章

Redis五种数据类型及其应用场景

REDIS中的缓存穿透，缓存击穿，缓存雪崩原因以及解决方案

redis实现用户签到，统计活跃用户，用户在线状态，用户留存率

[golang gin框架] 12.Gin 商城项目-base64Captcha生成图形验证码以及分布式架构中配置Captcha

[go学习笔记.第十七章.redis的使用] 1.redis的使用

linux下yum安装redis服务

二.golang中使用redis

redis介绍以及安装见: [go学习笔记.第十七章.redis的使用] 1.redis的使用
在这里使用go-redis插件来对接redis
模块： https://github.com/go-redis/redis
文档： https://redis.uptrace.dev/
安装go-redis:
下载go-redis,在main.go目录下,执行: go get github.com/redis/go-redis/v9,然后:
import (
"github.com/redis/go-redis/v9"
)
就可以使用go-redis了
下面看看redis相关代码:

1.redisCore.go

该文件中是 连接redis数据库核心代码 
package models

//redis官网: github.com/go-redis
//下载go-redis: go get github.com/redis/go-redis/v9
//连接redis数据库核心代码

import (
    "context"
    "github.com/redis/go-redis/v9"
)

//Go1.7 加入了一个新的标准库 context，它定义了 Context 类型，专门用来简化 对于处理
单个请求的多个 goroutine 之间与请求域的数据、取消信号、截止时间等相关操作
var ctx = context.Background()
//全局使用,就需要把定义成公有的
var ctxRedis = context.Background()

var (
    RedisDb *redis.Client
)

//自动初始化数据库
func init() {
    RedisDb = redis.NewClient(&redis.Options{
        Addr:     "127.0.0.1:6379",
        Password: "", // no password set
        DB:       0,  // use default DB
    })

    //连接redis
    _, err := RedisDb.Ping(ctxRedis).Result()
    //判断连接是否成功
    if err != nil {
        println(err)
    }
}

2.redisOper.go

操作redis案例说明 
package models

import (
    "context"
    "fmt"
    "time"
)

var ctx = context.Background()

type RedisOper struct {
}

//RedisDb调用上面代码中的RedisDb

//操作字符串:Set
func (r RedisOper) Set(key string, value string) error {

    err := RedisDb.Set(ctx, key, value, 0).Err()
    return err
}

//操作字符串:Get
func (r RedisOper) Get(key string) string {

    val, err := RedisDb.Get(ctx, key).Result()
    if err != nil {
        fmt.Println(err)
        return ""
    }
    return val
}

//操作列表（list）
func (r RedisOper) ListOper() {
    RedisDb.LPush(ctx, "hobby", "吃饭")
    RedisDb.LPush(ctx, "hobby", "睡觉")
    RedisDb.RPush(ctx, "hobby", "写代码")

    hobby, _ := RedisDb.LRange(ctx, "hobby", 0, -1).Result()
    fmt.Println(hobby)
}

//操作集合（set）
func (r RedisOper) SetOper() {
    RedisDb.SAdd(ctx, "hobby", "吃饭", "睡觉", "吃饭")
    RedisDb.SAdd(ctx, "hobby", "写代码")
    hobby, _ := RedisDb.SMembers(ctx, "hobby").Result()
    fmt.Println(hobby)
}


//操作哈希（hash）
func (r RedisOper) SetOper() {
    err := RedisDb.HMSet(ctx, "userinfo", map[string]interface{}{
        "username": "张三",
        "age":      "20",
    }).Err()

    if err != nil {
        fmt.Println(err)
    }
    userinfo, _ := RedisDb.HGetAll(ctx, "userinfo").Result()

    fmt.Println(userinfo)

    fmt.Println(userinfo["username"])
}

//设置过期时间
func (r RedisOper) SetExpire() {
    RedisDb.Set(ctx, "age", 20, time.Second*10)

    RedisDb.LPush(ctx, "hobby", "吃饭")
    RedisDb.Expire(ctx, "hobby", time.Second*10)
}

//删除数据
func (r RedisOper) Del() {
    RedisDb.Set(ctx, "age", 20, 0)
    RedisDb.Del(ctx, "age")
    RedisDb.LPush(ctx, "hobby", "吃饭")
    RedisDb.FlushAll(ctx)
}

3.Redis 分布式架构订阅发布

Redis 发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。
Redis 客户端可以订阅任意数量的频道。
下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1
之间的关系：
当有新消息通过 PUBLISH 命令发送给频道 channel1 时， 这个消息就会被发送给订阅它的三个客户端:

案例演示:

redis_pub.go是一个发布的频道端,发布消息,redis_sub1.go,redis_sub2.go,redis_sub3.go是三个客户端,订阅redis_pub.go这个频道端对应频道发布的消息,当频道端发布消息时,三个订阅的客户端会各自订阅频道收到的消息.代码如下:

redis_pub.go

package main

import (
    "context"
    "fmt"
    "github.com/go-redis/redis/v9"
)

var ctx = context.Background()

func main() {
    //连接redis数据库
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // no password set
        DB:       0,  // use default DB
    })

    _, err := rdb.Ping(ctx).Result()
    if err != nil {
        fmt.Println("redis数据库连接失败")
    } else {
        fmt.Println("redis数据库连接成功...")
    }

    //发布消息:
    rdb.Publish(ctx, "ch", "我是ch的数据...")

    rdb.Publish(ctx, "ch2", "我是ch2的数据...")
}
假如redis_sub1.go订阅了ch这个频道,redis_sub2.go,redis_sub3.go订阅了ch,ch2这两个频道,对应的代码如下:

redis_sub1.go

package main

import (
    "context"
    "fmt"
    "github.com/go-redis/redis/v9"
)

var ctx = context.Background()

func main() {
    //连接redis数据库
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // no password set
        DB:       0,  // use default DB
    })

    _, err := rdb.Ping(ctx).Result()
    if err != nil {
        fmt.Println("redis数据库连接失败")
    } else {
        fmt.Println("redis数据库连接成功...")
    }
    //订阅消息
    pubsub := rdb.Subscribe(ctx, "ch")
    ch := pubsub.Channel()
    for msg := range ch {
        fmt.Println(msg.Channel, msg.Payload)
    }
}

redis_sub2.go,redis_sub3.go

package main

import (
    "context"
    "fmt"
    "github.com/go-redis/redis/v9"
)

var ctx = context.Background()

func main() {
    //连接redis数据库
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // no password set
        DB:       0,  // use default DB
    })

    _, err := rdb.Ping(ctx).Result()
    if err != nil {
        fmt.Println("redis数据库连接失败")
    } else {
        fmt.Println("redis数据库连接成功...")
    }
    //订阅消息
    pubsub := rdb.Subscribe(ctx, "ch")
    ch := pubsub.Channel()
    for msg := range ch {
        fmt.Println(msg.Channel, msg.Payload)
    }
   //订阅消息
    pubsub2 := rdb.Subscribe(ctx, "ch2")
    ch2 := pubsub2.Channel()
    for msg2 := range ch2 {
        fmt.Println(ms2g.Channel, msg2.Payload)
    }
}

三.项目中使用redis

  1. 修改redisCore.go核心代码

(1).redis配置修改

把redis配置放入conf/app.ini下,app.ini增加如下代码: 
[redis]
ip          = localhost
port        = 6379
database    = 1
redisEnable = true

(2).完善redisCore.go

package models

//redis官网: github.com/go-redis
//下载go-redis: go get github.com/redis/go-redis/v9
//连接redis数据库核心代码

import (
    "context"
    "fmt"
    "github.com/redis/go-redis/v9"
    "gopkg.in/ini.v1"
    "os"
)

//全局使用,就需要把定义成公有的
var ctxRedis = context.Background()

var (
    RedisDb *redis.Client
)

//是否开启redis
var redisEnable bool

//自动初始化数据库
func init() {
    //加载配置文件
    config, iniErr := ini.Load("./conf/app.ini")
    if iniErr != nil {
        fmt.Printf("Fail to read file: %v", iniErr)
        os.Exit(1)
    }
    //获取redis配置
    ip := config.Section("redis").Key("ip").String()
    port := config.Section("redis").Key("port").String()
    redisEnable, _ = config.Section("redis").Key("redisEnable").Bool()
    
    //判断是否开启redis
    if redisEnable {
        RedisDb = redis.NewClient(&redis.Options{
            Addr:     ip + ":" + port,
            Password: "", // no password set
            DB:       0,  // use default DB
        })

        //连接redis
        _, err := RedisDb.Ping(ctxRedis).Result()
        //判断连接是否成功
        if err != nil {
            println(err)
        }
    }
}

2.创建redisCache.go

里面重构Set,Get方法 
package models

import (
    "encoding/json"
    "time"
)

type RedisCache struct {
}

//设置
func (r RedisCache) Set(key string, value interface{}, expiration int) {
    if redisEnable {  //判断是否开启redis
        v, err := json.Marshal(value)  //value是一个空接口类型,里面可以是字符串,切片,结构体,所以转成json保存
        if err == nil {
            //RedisDb:调用redisCore.go中的RedisDb
            RedisDb.Set(ctxRedis, key, string(v), time.Second*time.Duration(expiration))
        }
    }
}

//获取
func (r RedisCache) Get(key string, obj interface{}) bool {
    if redisEnable { //判断是否开启redis
        valueStr, err1 := RedisDb.Get(ctxRedis, key).Result()
        if err1 == nil && valueStr != "" {
            err2 := json.Unmarshal([]byte(valueStr), obj)
            return err2 == nil
        }
    }
    return false
}

3.商品首页控制器IndexController.go使用redis

package frontend

//首页

import (
    "github.com/gin-gonic/gin"
    "gorm.io/gorm"
    "goshop/models"
    "net/http"
    "strings"
)

type IndexController struct {
}

func (con IndexController) Index(c *gin.Context) {
    //实例化redisCache结构体
    redisCache := models.RedisCache{}

    //获取顶部导航列表
    topNavList := []models.Nav{}
    //判断redis中是否存在数据
    if hasTopNavList := redisCache.Get("topNavList", &topNavList); !hasTopNavList {  //不存在数据,则从数据中获取数据,并把数据保存到redis
        models.DB.Where("status = 1 AND position = 1").Find(&topNavList)
        redisCache.Set("topNavList", topNavList, 3600)
    }

    //获取网站轮播图数据
    focusList := []models.Focus{}
    if hasFocusList := redisCache.Get("focusList", &focusList); !hasFocusList {
        models.DB.Where("status = 1 AND focus_type = 1").Find(&focusList)
        redisCache.Set("focusList", focusList, 3600)
    }

    //获取分类数据
    goodsCateList := []models.GoodsCate{}
    if hasGoodsCateList := redisCache.Get("goodsCateList", &goodsCateList); !hasGoodsCateList {
        //获取分类列表以及下级分类,并进行排序
        models.DB.Where("pid = ? AND status = ?", 0, 1).Order("sort DESC").Preload("GoodsCateItems", func(db *gorm.DB) *gorm.DB {
            return db.Where("goods_cate.status = 1").Order("goods_cate.sort DESC")
        } ).Find(&goodsCateList)
        redisCache.Set("goodsCateList", goodsCateList, 3600)
    }

    //获取中间导航
    middleNavList := []models.Nav{}
    if hasMiddleNavList := redisCache.Get("middleNavList", &middleNavList); !hasMiddleNavList {
        models.DB.Where("status = ? AND position = ? ", 1, 2).Find(&middleNavList)
        redisCache.Set("middleNavList", middleNavList, 3600)
        //循环,获取中间导航对应的商品数据
        for i:= 0; i < len(middleNavList);i++{
            //获取管理商品
            //替换字符串中的中文逗号strings.ReplaceAll()
            relation := strings.ReplaceAll(middleNavList[i].Relation, "，", ",")
            //把字符串转换成切片
            relationIds := strings.Split(relation, ",")
            //获取对应的商品信息
            goodsList := []models.Goods{}
            models.DB.Where("status = ?", 1).Where("id in ?", relationIds).Select("id, title, goods_img, price").Find(&goodsList)
            middleNavList[i].GoodsItems = goodsList
        }
    }

    //获取手机分类下面的商品
    phoneList := []models.Goods{}
    if hasPhoneList := redisCache.Get("phoneList", &phoneList); !hasPhoneList {
        phoneList := models.GetGoodsByCategory(23, "best", 10)
        redisCache.Set("phoneList", phoneList, 3600)
    }

    c.HTML(http.StatusOK, "frontend/index/index.html", gin.H{
        "topNavList": topNavList,
        "focusList": focusList,
        "goodsCateList": goodsCateList,
        "middleNavList": middleNavList,
        "phoneList": phoneList,
    })
}

[上一节][golang gin框架] 23.Gin 商城项目-前台templates模板分离,首页,顶部导航,轮播图 左侧分类数据渲染

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

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

相关文章

KDXJ-8 SF6气体泄漏报警在线检测系统

KDXJ-8 SF6气体泄漏报警在线检测系统

一、功能特点 1. 定量测量SF6&#xff08;六氟化硫&#xff09;气体浓度&#xff1b; 2. 定量测量O2&#xff08;氧气&#xff09;气体浓度&#xff1b; 3. 定量测量大气温湿度&#xff1b; 4. 可根据需要设置SF6和O2气体浓度的报警点&#xff1b; 5. 后台监控&#xff1b; 6.…
阅读更多...
【通过加载plist文件显示分组数据 Objective-C语言】

【通过加载plist文件显示分组数据 Objective-C语言】

一、展示汽车品牌数据 1.首先，我们还是先把控制器调成3.5英寸，再把模拟器调成iPhone4S， 2.然后呢，我们要先把素材拷进来， 我们要展示，要把一个plist文件中的数据展示到我们的这个UITableView里面，所以说，首先，是要把我们的plist文件拷进来， 找到我们这个plist文件…
阅读更多...
爱智EdgerOS之深入解析在爱智应用中如何使用Socket.IO轻松实现双向通信

爱智EdgerOS之深入解析在爱智应用中如何使用Socket.IO轻松实现双向通信

一、什么是 Socket.IO&#xff1f; Socket.IO 是一个基于事件通信的实时应用程序框架&#xff0c;它在即时通讯、通知和消息推送&#xff0c;实时分析等场景中有广泛的应用。Socket.IO 包括两个部分&#xff1a; 在 Server 端的模块&#xff08;JSRE 已提供了 socket.io 模块&…
阅读更多...
Onnx 转Ncnn

Onnx 转Ncnn

Onnx 转Ncnn 算法工程师给了onnx,需要转成ncnn才能用到安卓上去&#xff0c;步骤如下 简化onnx 算法给了.onnx后缀的文件&#xff0c;100多兆&#xff0c;太大&#xff0c;第一步&#xff0c;先简化&#xff1a; conda env list 查看conda环境&#xff08;前提是之前已经配…
阅读更多...
企业级实践：分布式系统中的可靠消息最终一致性方案

企业级实践：分布式系统中的可靠消息最终一致性方案

背景 公司由于业务爆发式增长&#xff0c;新上了许多业务系统&#xff0c;例如&#xff1a;本地生活、社区团购、旅投B2B、旅投B2C等系统&#xff1b;同时&#xff0c;由于业务系统越来越多&#xff0c;为了运营方便&#xff0c;把分销、营销、订单、会员等多个业务系统公共业…
阅读更多...
Babel零基础教程

Babel零基础教程

参考https://www.jiangruitao.com/babel/ 写的非常好&#xff0c;本人只是为了方便查找&#xff0c;记录在自己博客上&#xff0c;原文可以去该链接拜读 1、 Babel 简介 Babel是什么&#xff1f; Babel是一个工具集&#xff0c;主要用于将ES6版本的JavaScript代码转为ES5等向…
阅读更多...
遗传算法的概念和python实现

遗传算法的概念和python实现

遗传算法是一个非常经典的智能算法&#xff0c;主要用于解决优化问题。本文主要简单介绍一些原理&#xff0c;同时给出一个基于python实现的&#xff0c;用于解决实数内优化问题的模板。 本文参考&#xff1a; 原理&#xff1a;遗传算法入门详解 - 知乎 简单介绍 遗传算法就…
阅读更多...
服务型企业如何使用飞项实现项目化管理？

服务型企业如何使用飞项实现项目化管理？

服务型企业的业务模式一般都是按项目来运作的&#xff0c;其业务分为售前&#xff0c;售中和售后三个阶段&#xff0c;分别由不同部门和人员对客户进行个性化服务。在这个过程中需要对人、流程和知识的高效统筹管理&#xff0c;即项目的整体管理&#xff0c;因此存在着不小的挑…
阅读更多...
Nvidia Jetson Orin: SPE/AON Cortex-R5 固件开发

Nvidia Jetson Orin: SPE/AON Cortex-R5 固件开发

Nvidia Jetson Orin: SPE/AON Cortex-R5 固件开发 写在最前边开发/下载 SPE 固件关于修改DTS 写在最前边 SPE 只能控制 AON GPIO 最多32个PIN 开发/下载 SPE 固件 S1&#xff1a;打开 https://developer.nvidia.com/embedded/jetson-linux S2&#xff1a;这里下载 S3&#x…
阅读更多...
Linux环境使用日志切割工具-cronolog

Linux环境使用日志切割工具-cronolog

Linux环境使用日志切割工具 需明白的点&#xff1a;1.安装 2.如何使用 一、安装cronolog 1.首先检查是否存在cronolog 命令&#xff1a;whereis cronolog 或 which cronolog 2.不存在则安装 安装方式&#xff1a; a.yum 安装&#xff1a;yum install cronolog b. 源码安装&am…
阅读更多...
C/C++|物联网开发入门+项目实战|指针|嵌入式C语言高级|C语言内存空间的使用-数组-学习笔记（10）

C/C++|物联网开发入门+项目实战|指针|嵌入式C语言高级|C语言内存空间的使用-数组-学习笔记（10）

参考&#xff1a;麦子学院-嵌入式C语言高级-内存空间 2-3 : C语言内存空间的使用-数组 内存分配的一种形式 数组的定义及初始化 定义一个空间: 1、大小 2、读取方式 数组名[]:升级为连续空间的名称&#xff0c; [m]的作用域只在申请的时候起作用 每个多大&#xff1f;数组…
阅读更多...
太给力了，这款java表单设计器可提高办公协作效率！

太给力了，这款java表单设计器可提高办公协作效率！

随着办公自动化的快速发展&#xff0c;java表单设计器的应用价值和突出优势也逐渐成为企业提高办公效率的好帮手。传统的表单操作起来费时费力&#xff0c;效率不高&#xff0c;逐渐满足不了日益繁多的业务需求了&#xff0c;在广大用户的呼声和市场发展下&#xff0c;简洁、灵…
阅读更多...
ESP32学习五-启动流程

ESP32学习五-启动流程

一、简介 在ESP32的开发中&#xff0c;通常我们会从app_main函数中开始我们的代码开发。但是为什么是app_main呢&#xff1f;app_main又是从哪里被调用的&#xff1f;app_main之前又做了什么操作呢&#xff1f;今天我们就来详细分析一下。 官方参考文档&#xff1a;应用程序的启…
阅读更多...
柔性作业车间生产调度中MK算例文本各行数字表示的含义以及算例的数据

柔性作业车间生产调度中MK算例文本各行数字表示的含义以及算例的数据

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 MK算例其他MK02~MK10柔性作业车间数据 MK算例 Brandimarte给出了10组柔性作业车间的实例分别是MK01~Mk10&#xff0c;下方即为MK01的实例数据 10 6 26 2 1…
阅读更多...
Kubernetes Operator开发

Kubernetes Operator开发

Kubernetes Operator开发 1.kubebuilder 创建项目 2.Crontroller开发与部署 开发环境准备 kubebuilder 介绍 CRD的开发与部署 Crontroller开发与部署 Operator功能设计 借助operator完成 和企业内部注册中心打通 这里以Traefiketcd的模式为例进行演示说明 在这里etcd provi…
阅读更多...
现在学习云计算，还有出路吗？

现在学习云计算，还有出路吗？

现在学习云计算&#xff0c;还有出路吗&#xff1f; 当然有出路&#xff0c;现在正是学习云计算的好时机。只要你专业技术过关&#xff0c;有一定的项目经验&#xff0c;有的企业甚至接受应届生&#xff1b;其次是具备一定的职业素养&#xff0c;学历在大专及以上&#xff0c;年…
阅读更多...
潇洒郎： git配置、拉取、提交代码

潇洒郎： git配置、拉取、提交代码

git配置拉取代码 git 配置全局变量 git config --global user.name "xuxiaosa" git config --global user.email "xuxiaosamigu.cn" 配置ssh key 1、打开git-bash 输入ssh-keygen 一直回车&#xff0c;会提示文件保存的地址 id_rsa,id_rsa.pub两个文…
阅读更多...
谷粒商城二十二订单服务支付

谷粒商城二十二订单服务支付

我们支付暂时只开发支付宝&#xff0c; 按照正规的流程&#xff0c;我们的系统要接入支付宝&#xff0c;肯定是需要大量的审核过程&#xff0c;而且需要我们的项目上线。 那现在我们就想测试该怎么办&#xff1f;支付宝为我们提供了沙箱环境&#xff0c;我们可以在应用未上线之…
阅读更多...
易观千帆 | 2023年3月银行APP月活跃用户规模盘点

易观千帆 | 2023年3月银行APP月活跃用户规模盘点

易观&#xff1a;2023年3月手机银行服务应用活跃人数53289.05万&#xff0c;环比增长2.15%&#xff0c;同比增长8.87%。 2023年3月信用卡服务应用活跃人数10800.71万&#xff0c;环比增长1.87%&#xff0c;同比增长18.64%。 2023年3月城商行手机银行服务应用活跃人数3827.43万&…
阅读更多...
【项目篇1】一个在线OJ系统

【项目篇1】一个在线OJ系统

目录 一、前言&#xff1a;项目背景 功能1&#xff1a;能够管理题目 功能2&#xff1a;可以展示题目列表 功能3&#xff1a;题目详情页 功能4&#xff1a;可以令用户提交代码&#xff0c;并验证提交的情况 注意事项&#xff1a; 功能5&#xff1a;反馈运行的结果 二、项…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023