锐客网

  1. 首页 > 睿知 > it技术 > >

go语言实现http协议的简单介绍

IT技术http

go语言实现一个简单的简单网关网关=反向代理 负载均衡 各种策略，技术实现也有多种多样，有基于 nginx 使用 lua 的实现 ， 比如 openresty、kong；也有基于 zuul 的通用网关；还有就是 golang 的网关，比如 tyk 。
这篇文章主要是讲如何基于 golang 实现一个简单的网关 。
转自： troy.wang/docs/golang/posts/golang-gateway/
整理：go语言钟文文档:
启动两个后端 web 服务（代码）
这里使用命令行工具进行测试
具体代码
直接使用基础库 httputil 提供的NewSingleHostReverseProxy即可，返回的reverseProxy对象实现了serveHttp方法 ， 因此可以直接作为 handler 。
具体代码
director中定义回调函数，入参为*http.Request ， 决定如何构造向后端的请求，比如 host 是否向后传递，是否进行 url 重写 ， 对于 header 的处理，后端 target 的选择等 ， 都可以在这里完成 。
director在这里具体做了：
modifyResponse中定义回调函数，入参为*http.Response，用于修改响应的信息，比如响应的 Body，响应的 Header 等信息 。
最终依旧是返回一个ReverseProxy，然后将这个对象作为 handler 传入即可 。
参考 2.2 中的NewSingleHostReverseProxy，只需要实现一个类似的、支持多 targets 的方法即可，具体实现见后面 。
作为一个网关服务，在上面 2.3 的基础上，需要支持必要的负载均衡策略，比如：
随便 random 一个整数作为索引，然后取对应的地址即可，实现比较简单 。
具体代码
使用curIndex进行累加计数，一旦超过 rss 数组的长度，则重置 。
具体代码
轮询带权重，如果使用计数递减的方式，如果权重是5,1,1那么后端 rs 依次为a,a,a,a,a,b,c,a,a,a,a…，其中 a 后端会瞬间压力过大；参考 nginx 内部的加权轮询，或者应该称之为平滑加权轮询，思路是：
后端真实节点包含三个权重：
操作步骤：
具体代码
一致性 hash 算法 ， 主要是用于分布式 cache 热点/命中问题；这里用于基于某 key 的 hash 值，路由到固定后端，但是只能是基本满足流量绑定，一旦后端目标节点故障 ， 会自动平移到环上最近的那么个节点 。
实现：
具体代码
每一种不同的负载均衡算法 ， 只需要实现添加以及获取的接口即可 。
然后使用工厂方法，根据传入的参数，决定使用哪种负载均衡策略 。
具体代码
作为网关，中间件必不可少 ， 这类包括请求响应的模式，一般称作洋葱模式，每一层都是中间件，一层层进去，然后一层层出来 。
中间件的实现一般有两种 ， 一种是使用数组，然后配合 index 计数；一种是链式调用 。
具体代码
http.ServeMuxHTTP协议全称超文本传输协议（HyperText Transfer Protocol）是互联网上应用最为广泛的一种网络协议，它详细规定了浏览器和WWW服务器之间通信的规则 ， 通过Internet传送WWW文档的数据传送协议 。
Web服务是HTTP协议的一个服务 ， HTTP协议承载在TCP协议之上 。Web服务工作流程
基于HTTP构建的服务标准模型包括客户端和服务端，HTTP请求从客户端发出 ， 服务端接收到请求后进行处理，然后将响应返回给客户端 。
HTTP服务端核心工作是如何接收来自客户端的请求 ， 并向客户端返回响应 。当HTTP服务器接收到客户端请求时，首先会进入路由模块，路由又称为服务复用器（Multiplexer），路由的工作在于请求找到对应的处理器（Handler），处理器对接收到的请求进行对应处理后，构建响应并返回给客户端 。
Go语言通过引入 net/http 包来实现HTTP网络访问，并提供HTTP客户端和服务端的实现 。
创建HTTP服务需经过2个阶段
例如：创建HTTP服务
理解HTTP服务关键点在于路由器和处理器
服务复用器
处理器
http.ServeMux 内部使用一个 map 映射来保存所有处理器，http.muxEntry 是一个多路复用器入口实体 。
可以发现在 http.muxEntry 字段中存在着 http.Handler 接口类型的 h
虽然 http.ServeMux 也实现了 http.ServerHTTP() 算得上是一个 http.Handler，但 http.ServeMux 的 http.ServeHTTP() 并非用来处理请求和响应 ， 而是用来查找注册路由对应的处理器 。
当 http.ServeMux 路由器设置路由规则后，会通过它实现的 ServeHTTP() 完成请求的分发 。当路由器接收到请求后若请求的URI为 * 则会关闭连接，否则会调用自身的 Handler() 来获取对应路由的处理器，最终通过调用 h.ServeHTTP(w,r) 实现对应路由的实现逻辑 。
【go语言实现http协议的简单介绍】 路由器会根据用户请求的URL路径去匹配自身存储的在 map 中的 handler，最终调用匹配到的 handler 的 ServeHTTP() 以实现执行对应路由的处理函数 。
创建 http.ServeMux 实例的方式有两种
http.DefaultServeMux 是默认的 http.ServeMux ，会随着 net/http 包初始化而被自动初始化 。
当 http.ListenAndServe() 在没有提供其他处理器的情况下 ， 即它的入参 handler 为 nil 时内部会使用 http.DefaultServeMux。
net/http 包提供了一组快捷的注册路由的函数 http.Handle() 、 http.HandleFunc() 来配置 http.DefaultServeMux ，快捷函数会将处理器注册到 http.DefaultServeMux。
二者之间的区别在于 handler 参数上
http.Handle() 的 handler 是一个 http.Handler 接口实例，也就是说传入的 handler 必须要自己提前实现 http.Handler 接口的 ServerHTTP(ResponseWriter, *Request) 方法 。
例如：将处理器放入闭包中，将参数传入处理器 。
http.HandleFunc() 的 handler 直接是一个原型为 func(ResponseWriter, *Request) 的函数 ， 深入追踪会 HandleFunc() 会发现一个自定义的函数类型 。
因此任何具有 func(ResponseWriter, *Request) 签名的函数都能转换成为一个 http.HandlerFunc 类型的对象 。同时自定义的函数类型中已经实现了 ServeHTTP() 方法 ， 因此它也是一个 http.Handler。
例如：返回时使用一个到 http.HandlerFunc 类型的隐式转换
net/http 包提供了 http.NewServeMux() 来创建一个自定义的 http.ServeMux 实例
例如：调用 http.NewServeMux() 会创建服务复用器
例如：创建静态服务
Go中没有继承、多态 ， 可通过接口来实现 。而接口则是定义声明的函数签名，任何结构体只要实现与接口函数签名相同的方法 ， 即等同于实现了对应的接口 。
例如： http.HandleFunc() 处理函数实现实际上调用默认 http.DefaultServeMux 的 HandleFunc() 方法
例如：调用 http.Handle() 方法则第二个参数 handle 必须实现 http.Handler 接口的 ServeHTTP() 方法，也就是说只要具有 ServeHTTP() 签名方法即可作为处理器 。
例如：自定义处理器
http.HandlerFunc 自身已实现 http.Handler 接口的 ServeHTTP() 方法，因此它也是一个处理器 。
http.HandlerFunc 的作用是将自定义函数转换为 http.Handler 处理器类型 ， 当调用 http.HandlerFunc(fn) 后会强制将 fn 函数类型转换为 http.HandlerFunc 类型，这样 fn 函数就具有了 ServeHTTP() 方法，同时也就转换成为了一个 http.Handler 处理器 。因此 http.HandlerFunc 又称为适配器 。
Go语言HTTPServer开发的六种实现学完了 net/http 和 fasthttp 两个HTTP协议接口go语言实现http协议的客户端实现，接下来就要开始Server的开发，不学不知道一学吓一跳，居然这两个库还支持Server的开发，太方便了 。
相比于Java的HTTPServer开发基本上都是使用Spring或者Springboot框架 ， 总是要配置各种配置类，各种 handle 对象 。Golang的Server开发显得非常简单，就是因为特别简单，或者说没有形成特别统一的规范或者框架，我发现了很多实现方式 ， HTTP协议基于还是 net/http 和 fasthttp，但是 handle 语法就多种多样了 。
先复习一下go语言实现http协议： Golang语言HTTP客户端实践 、 Golang fasthttp实践。
在Golang语言方面，实现某个功能的库可能会比较多 ， 有机会还是要多跟同行交流，指不定就发现了更好用的库 。下面我分享我学到的六种Server开发的实现Demo 。
基于 net/http 实现，这是一种比较基础的 ， 对于接口和 handle 映射关系处理并不优雅，不推荐使用 。
第二种也是基于 net/http ，这种编写语法可以很好地解决第一种的问题，handle和path有了类似配置的语法，可读性提高了很多 。
第三个基于 net/http 和 github.com/labstack/echo ， 后者主要提供了 Echo 对象用来处理各类配置包括接口和handle映射，功能很丰富，可读性最佳 。
第四种依然基于 net/http 实现 ， 引入了 github.com/gin-gonic/gin 的路由，看起来接口和 handle 映射关系比较明晰了 。
第五种基于 fasthttp 开发 ， 使用都是 fasthttp 提供的API ， 可读性尚可，handle配置倒是更像Java了 。
第六种依然基于 fasthttp，用到了 github.com/buaazp/fasthttprouter ， 有点奇怪两个居然不在一个GitHub仓库里 。使用语法跟第三种方式有点类似，比较有条理 ， 有利于阅读 。
go语言聊天室实现（六）创建HTTP连接，并升级为长连接我们在mian函数中，首先初始化配置文件，然后新建http连接 。
这个连接创建之后，监听服务器的9999端口 。如果url的路径后缀为 "/ws",就转发到ws/ws.go中的IndexHandler方法中 。
这个方法中首先我们创建一个websocket的Upgrader实例，然后我们使用Upgrader的upgrade方法来升级一下我们的连接为长连接 。
升级完成之后会返回一个*websocket.Conn的连接，我们之后所有的关于连接的操作，都是基于该conn的 。
在该连接完成之后，我们将连接存放到一个名为Client的map中，以便之后管理更为方便 。
之后，我们启动一个goroutine来读取连接中发送的信息内容，再根据内容进行相应的操作 。
关于go语言实现http协议和的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站 。

    推荐阅读


    上一篇：如何安装Dell服务器的导轨？ dell服务器导轨怎么装

    下一篇：星空浪人经营游戏，星空浪人加能量用什么加