二、go微服务项目“商城项目实战开发”第二步grpc和gin的直连调用

文章目录

  • 商城项目实战开发-GRPC和GIN的直连调用
  • 01、本次课程微服务的技术栈
  • 02、用户服务接口定义和实现登录
    • 1、密码问题
      • 01、MD5的方式
      • 02、加盐的方式
      • 03、动态盐
      • 04、使用加盐框架passwordEncoder
    • 2、用户服务接口的暴露
    • 3、Grpc的实现步骤
        • 1.定义暴露接口
        • 2.编写user的调用文件
        • 3.编写测试案例
  • 03、user-web接口的gin的整合和搭建
  • 04、gin如何调用grpc接口
  • 05、用户服务整合微服务注册中心组件—Nacos
  • 06、用户服务整合微服务配置中心组件—Nacos

商城项目实战开发-GRPC和GIN的直连调用

在这里插入图片描述

01、本次课程微服务的技术栈

  • grpc
  • consoul
  • gateway
  • protobuf
  • gorm/ent/sqlx/xorm/beego
  • gin
  • apifox
  • vue/vite/typescript/uniapp

整体架构如下:

在这里插入图片描述

02、用户服务接口定义和实现登录

1、密码问题

  • 对称加密
    • rsa
  • 非对称加密
    • rsa
    • des
  • 不可逆加密
    • md5
    • shaxxx

01、MD5的方式

为什么选择MD5。因为md5是不可逆。只能加密不能解密。

package utilsimport ("crypto/md5""encoding/hex""io"
)/*** MD5加密* @author feige* @date 2024-04-08* @version 1.0* @desc*/
func Md5(value string) string {hash := md5.New()_, _ = io.WriteString(hash, value)return hex.EncodeToString(hash.Sum(nil))
}

真的安全吗?https://www.somd5.com/ 通过解密发现md5并不可靠,怎么办,它又是如何解密的呢?

如何处理呢?加盐。

02、加盐的方式

加盐其实就是让密码变的有“味道”

package mainimport ("fmt""kuangstudy-mall/apis/user-web/utils"
)func main() {fmt.Println(utils.Md5("kuangstudyxxxxxx123456"))
}

这里的:kuangstudyxxxxx 就的盐,但是这个属于静态盐。不安全。为什么呢?而且这个盐一定要稍微复杂一点,不太过于简单,否则很容易被破解掉,

这个静态盐会存在几个问题

  • 大家盐一样的
    • A—-123456 –kuangstudyxxxxx — fc5867e066a370165cf1b57e38b61180
    • B—-123456 –kuangstudyxxxxx — fc5867e066a370165cf1b57e38b61180
    • 在后台的数据库中很容易就可以被识别出来,A和B设置的密码都是一样的。这样就不安全
  • 静态盐对于内部来说是不安全。很容易被泄露。一旦泄露密码就不安全了。
  • 怎么办—-动态盐

03、动态盐

  • 注册的时候,给每个用户生成一个 UUID

    • A—-123456 –uuid (dc336722ed0c44bdae2c7f9f39764278) — xxxxxxxx
    • B—-123456 –uuid (f5a919aae4fd40ea950f8c1abb9fccae)— xxxxxxx
  • 登录解密的时候

    • A 输入账号,根据账号查询出每个用户自己盐和加密的密码
    • 用户输入的密码 + 每个用户自己盐 =加密==真实加密密码
    • 真实加密密码 和 数据库的密码去比较 如果相等就说明密码是正确的,反之输入密码有误,

04、使用加盐框架passwordEncoder

  • 动态盐需要使用额外的列来存在的盐值,所以就浪费的数据存储空间。如何解决这个问题。可以使用组件框架:passwordencoder

  • https://github.com/anaskhan96/go-password-encoder


/*
*
注册时候把密码加密
采用组合的方式存在到password列,就可以让slat列不需要定义了
*/
func PasswordEncoder(pwd string) string {options := &password.Options{16, 100, 32, sha512.New}salt, encodedPwd := password.Encode(pwd, options)return fmt.Sprintf("$pbkdf2-sha512$%s$%s", salt, encodedPwd)
}/*
*
在验证的时候,根据账号把数据库中存储的encodePwd查询出来
和 用户输入密码进行验证,如果是正确的就返回true, 否则返回 false
*/
func PasswordVerfiy(pwd string, encodePwd string) bool {options := &password.Options{16, 100, 32, sha512.New}passwordInfo := strings.Split(encodePwd, "$")return password.Verify(pwd, passwordInfo[2], passwordInfo[3], options)
}

上面的主要目的就是把slat和password组合存储。不需要分开

2、用户服务接口的暴露

syntax = "proto3";
option go_package = ".;proto";// 开始定义用户登录相关的接口服务
service User {rpc findUserList(PageInfo) returns (UserListResponse);rpc getUserByTelephone(TelephoneRequest) returns (UserInfoResponse);rpc getUserById(IdRequest) returns (UserInfoResponse);rpc saveUser(CreateUserRequest) returns (UserInfoResponse);rpc updateUser(UpdateUserRequeest) returns (BooleanResponse);rpc checkPassword(PasswordCheckRequest) returns (CheckResponse);
}message PasswordCheckRequest{string password = 1;string encodePassword = 2;
}message BooleanResponse{bool success = 1;
}message CheckResponse{bool success = 1;
}message UpdateUserRequeest{uint64  id = 1;string  nickName = 2;string  mobile = 3;string  passWord = 4;uint64  birthDay = 5;string  gender = 6;
}message CreateUserRequest{string  nickName = 1;string  mobile = 2;string  passWord = 3;uint64  birthDay = 4;string  gender = 5;
}message IdRequest{uint64 id = 1;
}message TelephoneRequest{string telephone = 1;
}message PageInfo{uint32  pageNo = 1;uint32  pageSize = 2;
}message UserListResponse {int32 total = 1;repeated UserInfoResponse data = 2;
}message UserInfoResponse {uint64 id = 1;string passWord = 2;string mobile = 3;string nickName = 4;uint64 birthDay = 5;string gender = 6;int32 role = 7;
}

然后执行命令

protoc -I . user.proto --go_out=plugins=grpc:.

得到user.pb.go文件

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.33.0
// 	protoc        v3.20.3
// source: user.protopackage protoimport (context "context"grpc "google.golang.org/grpc"codes "google.golang.org/grpc/codes"status "google.golang.org/grpc/status"protoreflect "google.golang.org/protobuf/reflect/protoreflect"protoimpl "google.golang.org/protobuf/runtime/protoimpl"reflect "reflect"sync "sync"
)const (// Verify that this generated code is sufficiently up-to-date._ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)// Verify that runtime/protoimpl is sufficiently up-to-date._ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)type PasswordCheckRequest struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsPassword       string `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"`EncodePassword string `protobuf:"bytes,2,opt,name=encodePassword,proto3" json:"encodePassword,omitempty"`
}func (x *PasswordCheckRequest) Reset() {*x = PasswordCheckRequest{}if protoimpl.UnsafeEnabled {mi := &file_user_proto_msgTypes[0]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *PasswordCheckRequest) String() string {return protoimpl.X.MessageStringOf(x)
}func (*PasswordCheckRequest) ProtoMessage() {}func (x *PasswordCheckRequest) ProtoReflect() protoreflect.Message {mi := &file_user_proto_msgTypes[0]if protoimpl.UnsafeEnabled && x != nil {ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))if ms.LoadMessageInfo() == nil {ms.StoreMessageInfo(mi)}return ms}return mi.MessageOf(x)
}// Deprecated: Use PasswordCheckRequest.ProtoReflect.Descriptor instead.
func (*PasswordCheckRequest) Descriptor() ([]byte, []int) {return file_user_proto_rawDescGZIP(), []int{0}
}func (x *PasswordCheckRequest) GetPassword() string {if x != nil {return x.Password}return ""
}func (x *PasswordCheckRequest) GetEncodePassword() string {if x != nil {return x.EncodePassword}return ""
}type BooleanResponse struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsSuccess bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}func (x *BooleanResponse) Reset() {*x = BooleanResponse{}if protoimpl.UnsafeEnabled {mi := &file_user_proto_msgTypes[1]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *BooleanResponse) String() string {return protoimpl.X.MessageStringOf(x)
}func (*BooleanResponse) ProtoMessage() {}func (x *BooleanResponse) ProtoReflect() protoreflect.Message {mi := &file_user_proto_msgTypes[1]if protoimpl.UnsafeEnabled && x != nil {ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))if ms.LoadMessageInfo() == nil {ms.StoreMessageInfo(mi)}return ms}return mi.MessageOf(x)
}// Deprecated: Use BooleanResponse.ProtoReflect.Descriptor instead.
func (*BooleanResponse) Descriptor() ([]byte, []int) {return file_user_proto_rawDescGZIP(), []int{1}
}func (x *BooleanResponse) GetSuccess() bool {if x != nil {return x.Success}return false
}type CheckResponse struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsSuccess bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}func (x *CheckResponse) Reset() {*x = CheckResponse{}if protoimpl.UnsafeEnabled {mi := &file_user_proto_msgTypes[2]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *CheckResponse) String() string {return protoimpl.X.MessageStringOf(x)
}func (*CheckResponse) ProtoMessage() {}func (x *CheckResponse) ProtoReflect() protoreflect.Message {mi := &file_user_proto_msgTypes[2]if protoimpl.UnsafeEnabled && x != nil {ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))if ms.LoadMessageInfo() == nil {ms.StoreMessageInfo(mi)}return ms}return mi.MessageOf(x)
}// Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.
func (*CheckResponse) Descriptor() ([]byte, []int) {return file_user_proto_rawDescGZIP(), []int{2}
}func (x *CheckResponse) GetSuccess() bool {if x != nil {return x.Success}return false
}type UpdateUserRequeest struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsId       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`NickName string `protobuf:"bytes,2,opt,name=nickName,proto3" json:"nickName,omitempty"`Mobile   string `protobuf:"bytes,3,opt,name=mobile,proto3" json:"mobile,omitempty"`PassWord string `protobuf:"bytes,4,opt,name=passWord,proto3" json:"passWord,omitempty"`BirthDay uint64 `protobuf:"varint,5,opt,name=birthDay,proto3" json:"birthDay,omitempty"`Gender   string `protobuf:"bytes,6,opt,name=gender,proto3" json:"gender,omitempty"`
}func (x *UpdateUserRequeest) Reset() {*x = UpdateUserRequeest{}if protoimpl.UnsafeEnabled {mi := &file_user_proto_msgTypes[3]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *UpdateUserRequeest) String() string {return protoimpl.X.MessageStringOf(x)
}func (*UpdateUserRequeest) ProtoMessage() {}func (x *UpdateUserRequeest) ProtoReflect() protoreflect.Message {mi := &file_user_proto_msgTypes[3]if protoimpl.UnsafeEnabled && x != nil {ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))if ms.LoadMessageInfo() == nil {ms.StoreMessageInfo(mi)}return ms}return mi.MessageOf(x)
}// Deprecated: Use UpdateUserRequeest.ProtoReflect.Descriptor instead.
func (*UpdateUserRequeest) Descriptor() ([]byte, []int) {return file_user_proto_rawDescGZIP(), []int{3}
}func (x *UpdateUserRequeest) GetId() uint64 {if x != nil {return x.Id}return 0
}func (x *UpdateUserRequeest) GetNickName() string {if x != nil {return x.NickName}return ""
}func (x *UpdateUserRequeest) GetMobile() string {if x != nil {return x.Mobile}return ""
}func (x *UpdateUserRequeest) GetPassWord() string {if x != nil {return x.PassWord}return ""
}func (x *UpdateUserRequeest) GetBirthDay() uint64 {if x != nil {return x.BirthDay}return 0
}func (x *UpdateUserRequeest) GetGender() string {if x != nil {return x.Gender}return ""
}type CreateUserRequest struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsNickName string `protobuf:"bytes,1,opt,name=nickName,proto3" json:"nickName,omitempty"`Mobile   string `protobuf:"bytes,2,opt,name=mobile,proto3" json:"mobile,omitempty"`PassWord string `protobuf:"bytes,3,opt,name=passWord,proto3" json:"passWord,omitempty"`BirthDay uint64 `protobuf:"varint,4,opt,name=birthDay,proto3" json:"birthDay,omitempty"`Gender   string `protobuf:"bytes,5,opt,name=gender,proto3" json:"gender,omitempty"`
}func (x *CreateUserRequest) Reset() {*x = CreateUserRequest{}if protoimpl.UnsafeEnabled {mi := &file_user_proto_msgTypes[4]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *CreateUserRequest) String() string {return protoimpl.X.MessageStringOf(x)
}func (*CreateUserRequest) ProtoMessage() {}func (x *CreateUserRequest) ProtoReflect() protoreflect.Message {mi := &file_user_proto_msgTypes[4]if protoimpl.UnsafeEnabled && x != nil {ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))if ms.LoadMessageInfo() == nil {ms.StoreMessageInfo(mi)}return ms}return mi.MessageOf(x)
}// Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.
func (*CreateUserRequest) Descriptor() ([]byte, []int) {return file_user_proto_rawDescGZIP(), []int{4}
}func (x *CreateUserRequest) GetNickName() string {if x != nil {return x.NickName}return ""
}func (x *CreateUserRequest) GetMobile() string {if x != nil {return x.Mobile}return ""
}func (x *CreateUserRequest) GetPassWord() string {if x != nil {return x.PassWord}return ""
}func (x *CreateUserRequest) GetBirthDay() uint64 {if x != nil {return x.BirthDay}return 0
}func (x *CreateUserRequest) GetGender() string {if x != nil {return x.Gender}return ""
}type IdRequest struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsId uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}func (x *IdRequest) Reset() {*x = IdRequest{}if protoimpl.UnsafeEnabled {mi := &file_user_proto_msgTypes[5]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *IdRequest) String() string {return protoimpl.X.MessageStringOf(x)
}func (*IdRequest) ProtoMessage() {}func (x *IdRequest) ProtoReflect() protoreflect

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

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

相关文章

YOLOv8_obb预测流程-原理解析[旋转目标检测理论篇]

YOLOv8_obb的预测流程,主要分预处理模块、推理模块和后处理模块。这里面有很多内容是和目标检测预测流程是重合的,主要区别在于Angle分支、NMS后处理以及regularize_rboxes部分。本文也主要介绍一下这三个模块,其他模块可以结合YOLOv8预测流程-原理解析[目标检测理论篇]一起…

免费SSL证书的安全性与获取指南

SSL证书是一种数字凭证,用于加密用户与网站之间的信息交换,以确保传输的数据不被第三方窃取。它像是一个数字版的密封印章,为数据的传输过程提供了一层保护膜。 免费的SSL证书通常由CA机构提供,它们同样可以提供基础数据的加密服…

16.Redis之Redis事务

1.MySQL 事务 原子性: 把多个操作,打包成一个整体了 一致性: 事务执行之前,和之后,数据都不能离谱~ 持久性: 事务中做出的修改都会存硬盘 隔离性: 事务并发执行,涉及到的一些问题~~ 2.Redis事务 2.1 认识Redis事务 • 弱化的原⼦性: redis 没有 "回滚机制". …

.NET最新漏洞 | 某SLMS系统存在SQL注入

01阅读须知 此文所提供的信息只为网络安全人员对自己所负责的网站、服务器等(包括但不限于)进行检测或维护参考,未经授权请勿利用文章中的技术资料对任何计算机系统进行入侵操作。利用此文所提供的信息而造成的直接或间接后果和损失&#xf…

翻译《The Old New Thing》- How do I force the ECHO command to echo?

How do I force the ECHO command to echo? - The Old New Thing (microsoft.com)https://devblogs.microsoft.com/oldnewthing/20080403-00/?p22883 Raymond Chen 2008年04月03日 如何强制执行ECHO命令以进行回显? 简要 ECHO命令用于在命令行打印文本&#xff0…

统一预订,YonSuite商旅费控助力成长型企业“消灭报销”

在成长型企业快速发展的道路上,商旅管理作为连接企业内外的重要纽带,其效率与成本直接影响着企业的整体运营。面对日益增长的商旅需求,如何简化预订流程、降低管理成本、提高运营效率成为了成长型企业亟待解决的问题。用友YonSuite商旅费控以…

【权威出版】2024年新媒体、网络与电子商务国际会议(NMNE 2024)

2024年新媒体、网络与电子商务国际会议 2024 International Conference on New Media, Networking, and E-commerce 【1】会议简介 2024年新媒体、网络与电子商务国际会议即将召开,这是一次集结全球新媒体、网络与电子商务领域精英的学术盛会。 本次会议将深…

DPDK基础组件一(mbuf、ring、pktmbuf_pool)

一、rte_mbuf 此部分转自:https://zhuanlan.zhihu.com/p/616314276 1.mbuf结构 mbuf是报文中的描素的结构体,是整个转发过程中最核心的数据结构之一。主要针对于mbuf的常用API与基本原理做一个简单的介绍。 mbuf:报文内存存储结构,存储在mempool中mempool:使用环形缓冲…

Web安全:软件开发的安全问题与解决方案

「作者简介」:2022年北京冬奥会网络安全中国代表队,CSDN Top100,就职奇安信多年,以实战工作为基础对安全知识体系进行总结与归纳,著作适用于快速入门的 《网络安全自学教程》,内容涵盖系统安全、信息收集等…

jni调用so或dll区别

在Java中通过JNI(Java Native Interface)调用本地代码时,所使用的动态库文件扩展名(如 .dll 对于Windows或 .so 对于Unix-like系统)取决于你的操作系统和目标平台。 DLL(Dynamic Link Library)…

python数据预处理

PYTHON 最流行库:Numpy、Matplotlib 和 Pandas。Numpy 是满足所有数学运算所需要的库,由于代码是基于数学公式运行的,因此就会使用到它。Maplotlib(具体而言,Matplotlib.pyplot)则是满足绘图所需要的库。Pa…

小米员工自爆:35岁被裁后,投百份简历无人问津,一气之下把薪资由2W调为3W,简历改成英文,结果出乎意料

“35岁”,就像职场里一道无形的门槛,压得人喘不过气。一旦迈过这道坎,焦虑、迷茫、恐慌,接踵而至。 最近,我的朋友老张,就真切地体会到了这种“中年危机”。刚过36岁生日,他就收到了来自小米的裁…

从0到1写一个vue2项目,按需引入element-ui的引入,npm下载路由,配置路由,路由嵌套

从0到1写一个vue2项目,此篇内容有element-ui的按需引入,npm下载路由,配置路由,路由嵌套 项目是b站上找的项目链接在此https://www.bilibili.com/video/BV1QU4y1E7qo/?p8&spm_id_frompageDriver&vd_source2c599bf1d75e3f9…

Hive之聚合类开窗函数 + 滑动求和

为什么要写这样子一个主题文章呢,开窗函数毫无疑问,超级重要,但是很多人可能不会遇到一些稍微小众的业务需求,比如说滑动求和。这里带着业务,一并让大家熟悉一些,高阶函数的应用。 0,开窗函数和…

【JAVA SE】抽象类和接口

✨✨欢迎大家来到Celia的博客✨✨ 🎉🎉创作不易,请点赞关注,多多支持哦🎉🎉 所属专栏:JAVA 个人主页:Celias blog~ 目录 引言 一、抽象类 1.1 抽象类的定义 1.2 抽象方法 1.3 抽象…

大厂边缘组VS小厂核心组,要怎么选?

有问必答 最近有粉丝提问:大厂边缘组VS小厂核心组,怎么选? 这确实是个好问题,读者老爷们可以先问下自己:如果有一份月薪2W在大厂边缘组打螺丝的Offer且不加班,另外还有一份月薪2W5,在小厂核心…

华为坤灵管理型交换机S300,S500,S310,S210,S220,S200 web端开局配置

一. 准备线缆 笔记本或没有COM口的电脑,需准备转接线,并安装好随线光盘的驱动,检查设备管理器中COM口是否正常 2.连接电脑与交换机的CONSOLE口 二,准备软件putty。 Download PuTTY: latest release (0.81) 配置步骤如下: 开启HTTP服务。设置https://1…

【conda】解决conda activate无效的问题

conda activate 虚拟环境名字执行上述命令失效,提示如下信息: 经查询,原因是新版的 conda 不再使用 activate 来激活虚拟环境,而是改用: source activate 虚拟环境名退出虚拟环境还是: conda deactivate…

sqlite基本操作

简介 文章目录 简介1.数据库的安装2.数据库命令:API,创建表单代码 csprintf()getchar和scanf() 1.数据库的安装 sudo dpkg -i *.deb这个报错表明出现依赖问题 用这个命令后再试试sudo apt --fix-broken in…

计算机组成原理----浮点数的表示和运算

目录 一.浮点数的表示 1.浮点数的作用和基本原理 2.浮点数的规格化 3.浮点数的表示范围 二.IEEE 754标准 三.浮点数的加减运算 1.加减运算 2.强制类型转换 一.浮点数的表示 1.浮点数的作用和基本原理 定点数在字节数固定的情况下,能表示的数字是很有限的&…