详讲api网关之kong的基本概念及安装和使用（二）

consul的服务注册与发现
如果不知道consul的使用，可以点击上方链接，这是我写的关于consul的一篇文档。

upstream+consul实现负载均衡

我们知道，配置upstream可以实现负载均衡，而consul实现了服务注册与发现，那么接下来我们就来看看利用这两个组件怎么实现负载均衡吧。

安装consul

  • docker安装consul，注意端口,注意将consul的网络加入到kong的网络中，即--network=kong-ee-net
docker run -d --name consul \--network=kong-ee-net \-p 8500:8500 \-p 8300:8309 \-p 8301:8301 \-p8302:8302 \-p 8600:8600/udp \hashicorp/consul consul agent -dev -client=0.0.0.0

gin服务注册到consul

  • 我们启动3个gin服务，并注册到consul中，相关代码如下，注意，服务端口是随机获取的，并注册到consul中，我们几乎不需要关心端口是多少
package main
import ("fmt""gin-demo/config""gin-demo/db""gin-demo/route""gin-demo/utils""github.com/fvbock/endless"consulapi "github.com/hashicorp/consul/api"
)
// 定义服务注册的信息
type ServiceConfig struct {ID      stringName    stringTags    []stringPort    intAddress string
}// consul的服务地址
var consulIp = "127.0.0.1:8500"// 注册
func RegisterSevice(s ServiceConfig) error {consulConfig := consulapi.DefaultConfig()consulConfig.Address = consulIp//获取到客户端client, err := consulapi.NewClient(consulConfig)if err != nil {fmt.Printf("create consul client : %v\n", err.Error())return err}registration := &consulapi.AgentServiceRegistration{ID:      s.ID,Name:    s.Name,Port:    s.Port,Tags:    s.Tags,Address: s.Address,}if err := client.Agent().ServiceRegister(registration); err != nil {fmt.Printf("register to consul error: %v\n", err.Error())return err}return nil
}func main() {//配置文件config.InitConfig()//sql初始化db.NewDb().InitAllSql()//启动r := route.InitRoute()//随机获取一个可用端口_, port := utils.RandomPort()//注册到consulconsulPort := fmt.Sprintf("%d", port)service := ServiceConfig{ID:      consulPort,Name:    "blog_service",Tags:    []string{"blog"},Port:    port,Address: "192.168.11.20",}err := RegisterSevice(service)if err != nil {fmt.Printf("register to consul error: %v\n", err.Error())}//启动gin服务addr := fmt.Sprintf(":%d", port)err = endless.ListenAndServe(addr, r)if err != nil {return}
}

  • 启动完毕之后，我们访问consul的web页面已注册成功http://127.0.0.1:8500/ui/dc1/services/blog_service/instances
    在这里插入图片描述

  • 我们使用dns的方式访问一下

dig @127.0.0.1 -p 8600 blog_service.service.consul

在这里插入图片描述

kong里面配置consul

  • 通过docker network inspect kong-ee-net 查看consul的ip为172.23.0.4
  • 这里我们需要删除原来的kong容器，并使用以下命令创建一个新看kong，需要注意的是，由于你指定了KONG_DNS_RESOLVER，那么原来指定的KONG_PG_HOST就不可以再用dns的方式，因为consul里面并没有这个域名，会导致服务启动报错。所以要直接指定ip。
docker run -d --name kong \--network=kong-ee-net \-e "KONG_DATABASE=postgres" \-e "KONG_DNS_RESOLVER=192.168.11.20:8600" \-e "KONG_PG_HOST=172.23.0.2" \-e "KONG_PG_USER=kong" \-e "KONG_PG_PASSWORD=kong" \-e "KONG_CASSANDRA_CONTACT_POINTS=kong-database" \-e "KONG_PROXY_ACCESS_LOG=/dev/stdout" \-e "KONG_ADMIN_ACCESS_LOG=/dev/stdout" \-e "KONG_PROXY_ERROR_LOG=/dev/stderr" \-e "KONG_ADMIN_ERROR_LOG=/dev/stderr" \-e "KONG_ADMIN_LISTEN=0.0.0.0:8001, 0.0.0.0:8444 ssl" \-p 8000:8000 \-p 8443:8443 \-p 8001:8001 \-p 8444:8444 \kong-oss:latest

  • 启动之后，我们会再konga里面看到下面这行，这个时候，我们在kong里面配置的域名都会被 consul解析
    在这里插入图片描述

  • 我们配置blog_service.service.consul给service，就是咱们原来创建的blog的service
    在这里插入图片描述

  • 我们现在多访问几次接口 http://127.0.0.1:8000/v1/blog/detail?id=12，返回数据正常，我们多访问几次，查看三台服务的日志，均收到了请求
    在这里插入图片描述

在这里插入图片描述

jwt实现权限校验

一般情况下，上游api服务都需要客户端有身份验证，并且不影响错误的请求或者无认证的请求通过，那么此时，我们可以利用kong的jwt插件来实现，直接在网关这一层过滤掉请求

consumers

一个consumer可以代表一个微服务或者一个应用。为什么？因为你想给一个应用配置插件服务的话，比如说jwt认证，这个插件怎么样才能作用到这个应用上面呢？就是需要创建一个consumer，插件作用于consumer，consumer绑定应用。

  • 接下来我们创建一个consumer
    在这里插入图片描述
  • 添加jwt认证
    在这里插入图片描述
  • 全局配置jwt，配置header头的token名
    在这里插入图片描述
  • 此时我们再来访问http://127.0.0.1:8000/v1/blog/detail?id=12，已经不通过了
    在这里插入图片描述
  • 那么我们先手动构造一个token来验证一下，有两点需要注意，一个是jwt，是我们配置的验证名称，一个是iss
    在这里插入图片描述
  • 我们通过https://jwt.io/生成token,payload如下，注意secret去consumer中获取
{"sub": "1234567890","name": "John Doe","iat": 1516239022,"iss":"jwt"
}

项目中引入jwt

  • 关于怎么使用jwt，我在jwt讲解这篇文章中说过。
  • 注意两个地方，一个是jwt的秘钥kong和gin必须保持一致
  • 一个是issuer必须保持一致，相关代码如下
package middlewareimport ("gin-demo/service""github.com/gin-gonic/gin""github.com/golang-jwt/jwt/v5""log""strings""time"
)// 定义自己的秘钥 所有的服务必须用一个秘钥才能正确解析token
// 注意注意:这个秘钥必须和kong保持一致
var privateKey = []byte("FLHzZzGqZPlSzKgNyq4wXg4bKUhFRsH1")// UserClaims 我们声明一个结构体,里面包含我们想要保存的信息
type UserClaims struct {Uid                  int64jwt.RegisteredClaims // 内嵌标准的声明
}// GenToken 生成token
func GenToken(uid int64) (string, error) {//初始化结构体claims := UserClaims{Uid: uid,RegisteredClaims: jwt.RegisteredClaims{//设置过期时间ExpiresAt: jwt.NewNumericDate(time.Now().Add(time.Second * 3600)),//颁发时间IssuedAt: jwt.NewNumericDate(time.Now()),//主题Subject: "Token",//注意这里 发行人要和kong保持一致Issuer: "jwt",},}//生成token  使用hs256 加密 结构体,然后再用秘钥对其做数字签名return jwt.NewWithClaims(jwt.SigningMethodHS256, claims).SignedString(privateKey)
}// 解析token
func ParseToken(c *gin.Context) {claims := new(UserClaims)xtoken := c.GetHeader("x-token")tokenString := strings.Split(xtoken, " ")if len(xtoken) == 0 || len(tokenString) < 2 {service.ErrorResponse(c, 9999, "请先登录!")return}log.Printf("解析到的token是:%v", tokenString)token, err := jwt.ParseWithClaims(tokenString[1], claims, keyFunc)log.Printf("解析到的token是:%v", err)if err != nil {c.Abort()service.ErrorResponse(c, 9999, "用户名密码错误!")return}//建议token是否有效if token.Valid {log.Printf("解析到的uid是:%d", claims.Uid)c.Set("uid", claims.Uid)c.Next()} else {c.Abort()service.ErrorResponse(c, 9999, "用户名密码错误!")return}
}func keyFunc(token *jwt.Token) (interface{}, error) {return privateKey, nil
}

在这里插入图片描述

  • 结果
    在这里插入图片描述

  • 失败结果，kong直接拦截，并未到达服务层实例在这里插入图片描述

流量控制

  • 我们现在来配置一个每秒接收5个请求的限制
    在这里插入图片描述
  • 然后我们用jmeter测试一下，一秒内模拟10个用户发送10个请求
    在这里插入图片描述
  • 查看结果
    在这里插入图片描述

黑白名单

  • 我们可以选择指定给service或者route添加插件，下图我给route添加了插件
    在这里插入图片描述
  • 再次访问接口
    在这里插入图片描述

总结

kong的相关功能就演示完毕了，其他功能比如反爬策略，协议转换感兴趣的小伙伴们可以自己探索一下。

相关参考

相关参考
相关参考
官方文档
中文文档
相关文档
相关文档

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

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

相关文章

政安晨的机器学习笔记——示例演绎在TensorFlow中使用 CSV数据（基于Colab的Jupyter笔记）（1.5万字长文超详细）

政安晨的机器学习笔记——示例演绎在TensorFlow中使用 CSV数据（基于Colab的Jupyter笔记）（1.5万字长文超详细）

本笔记提供了如何在 TensorFlow 中使用 CSV 数据的示例&#xff1a;用 tf.data 加载 CSV 数据。 其中包括两个主要部分&#xff1a; 从磁盘加载数据将数据预处理为适合训练的形式。 本笔记侧重于加载&#xff0c;并提供了一些关于预处理的快速示例。 设置 import pandas a…
阅读更多...
深度学习：数据驱动的人工智能革命

深度学习：数据驱动的人工智能革命

文章目录 每日一句正能量前言什么是深度学习推动AI发展不同阶段的“三大驱动 ”1、技术驱动&#xff1a;算法和计算力是主要驱动力2、计算力的三驾马车&#xff1a;芯片、超级计算机、云计算3、数据驱动&#xff1a;描绘个性化画像&#xff1b; 后记 每日一句正能量 一般青年的…
阅读更多...
MySQL事务原理-相关日志

MySQL事务原理-相关日志

文章目录 前言一、什么是事务&#xff1f;1.1 事务概念1.2 事务的四大特性1.3 事务的隔离级别 二、实现原理2.1 TODO2.2 TODO 前言 事务是由MySQL的引擎来实现的&#xff0c;通过show engines命令查看MySQL存储引擎类别&#xff0c;观察只有InnoDB存储引擎支持事务。 一、什么…
阅读更多...
客户端和服务端的简介

客户端和服务端的简介

Client 和 Server 客户端&#xff08;Client&#xff09; 或称用户端&#xff0c;是指与服务器相对应&#xff0c;为客户提供本地服务的程序。除了一些只在本地运行的应用程序之外&#xff0c;一般安装在客户机上&#xff0c;需要与服务端互相配合运行。例如&#xff1a;下载 Q…
阅读更多...
PSQL常用操作

PSQL常用操作

目录 前言 准备工作 添加postgres用户 初始化数据库 启动服务 创建数据库 psql连接数据库 常规操作 数据库 schema相关 插件 其他 前言 老折腾&#xff0c;还是记录点啥吧...... 基于本地PG数据库(打包为绿色版本了)&#xff0c;实操记录&#xff0c;版本pgsql12…
阅读更多...
Java学习-面向对象-继承

Java学习-面向对象-继承

继承是什么&#xff1f; 示例&#xff1a; packagejava_jicheng_demo1; publicclassA{ //创建公开的成员变量&#xff0c;方法 publicStringnane; publicintage; publicvoidprint1(){ System.out.println("666"); } //创建私有的成员变量&#xff0c;方法 privateStr…
阅读更多...
Springboot 自定义参数配置化，密钥，密码，文件保存路径

Springboot 自定义参数配置化，密钥，密码，文件保存路径

application.properties 和 application.yml 都是一样的配置方法&#xff0c;只是格式不一样 定义配置文件 server.port8080 image.save.pathE:\ #自定义文件保存路径读取配置文件 Value("${image.save.path}")private String filePath;//E:\优化配置文件 如果我参…
阅读更多...
【服务器搭建】快速完成幻兽帕鲁服务器的搭建及部署【零基础上手】

【服务器搭建】快速完成幻兽帕鲁服务器的搭建及部署【零基础上手】

推荐阅读 CSDN主页GitHub开源地址Unity3D插件分享简书地址我的个人博客 大家好&#xff0c;我是佛系工程师☆恬静的小魔龙☆&#xff0c;不定时更新Unity开发技巧&#xff0c;觉得有用记得一键三连哦。 一、前言 教程详戳&#xff1a;不需要懂技术&#xff0c;1分钟幻兽帕鲁服…
阅读更多...
深度学习入门笔记（二）神经元的结构

深度学习入门笔记（二）神经元的结构

神经网络的基本单元是神经元&#xff0c;本节我们介绍神经元的结构。 2.1 神经元 一个神经元是由下面 5 部分组成的&#xff1a; 输入&#xff1a;x1,x2,…,xk。权重&#xff1a;w1,w2,…,wk。权重的个数与神经元输入的个数相同。偏移项&#xff1a;可省略。激活函数&#…
阅读更多...
SpringBoot数据访问复习

SpringBoot数据访问复习

SpringBoot数据访问复习 数据访问准备 引入jdbc所需要的依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jdbc</artifactId></dependency> 原理分析 导入的启动器引入了两个…
阅读更多...
今日早报 每日精选15条新闻简报 每天一分钟 知晓天下事 2月3日，星期六

今日早报 每日精选15条新闻简报 每天一分钟 知晓天下事 2月3日，星期六

每天一分钟&#xff0c;知晓天下事&#xff01; 2024年2月3日 星期六 农历腊月廿四 南小年 1、 气象局&#xff1a;将雨雪冰冻三级应急响应提升为二级&#xff0c;针对性做好春运气象保障服务。 2、 教育部&#xff1a;鼓励银龄教师投身西部地区、民族地区民办学校。 3、 四部…
阅读更多...
Three.js学习2：页面引入 Three.js

Three.js学习2：页面引入 Three.js

一、关于 Three.js 的版本 随着页面3D化应用越来越多&#xff0c;近两年 Three.js 处于飞速发展之中。现在 Three.js 几乎每个月都会发布一个新的版本&#xff0c;会增加新的 API&#xff0c;废掉一些旧的功能之类的。 可以从 Three.js 官网 Three.js – JavaScript 3D Libra…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023