前言
- 接口需要提供給其他業(yè)務(wù)組訪問询刹，但是 RPC 協(xié)議不同無法內(nèi)調(diào)谜嫉，對方問能否走 HTTP 接口，怎么辦凹联？
- 微信（公眾號沐兰、小程序）等第三方回調(diào)接口只支持 HTTP 接口，怎么辦
我相信你在實際工作中都會遇到如上問題蔽挠，在 gRPC 中都是有解決方案的住闯，本章節(jié)將會進(jìn)行介紹 ??
為什么可以同時提供 HTTP 接口
關(guān)鍵一點，gRPC 的協(xié)議是基于 HTTP/2 的澳淑，因此應(yīng)用程序能夠在單個 TCP 端口上提供 HTTP/1.1 和 gRPC 接口服務(wù)（兩種不同的流量）
怎么同時提供 HTTP 接口
檢測協(xié)議
if r.ProtoMajor == 2 && strings.Contains(r.Header.Get("Content-Type"), "application/grpc") {
server.ServeHTTP(w, r)
} else {
mux.ServeHTTP(w, r)
}
流程
- 檢測請求協(xié)議是否為 HTTP/2
- 判斷 Content-Type 是否為 application/grpc（gRPC 的默認(rèn)標(biāo)識位）
- 根據(jù)協(xié)議的不同轉(zhuǎn)發(fā)到不同的服務(wù)處理
gRPC
TLS
在前面的章節(jié)比原，為了便于展示因此沒有簡單封裝
在本節(jié)需復(fù)用代碼，重新封裝了杠巡，可詳見：go-grpc-example
目錄結(jié)構(gòu)
新建 simple_http_client量窘、simple_http_server 目錄，目錄結(jié)構(gòu)如下：
go-grpc-example
├── client
│ ├── simple_client
│ ├── simple_http_client
│ └── stream_client
├── conf
├── pkg
│ └── gtls
├── proto
├── server
│ ├── simple_http_server
│ ├── simple_server
│ └── stream_server
Server
在 simple_http_server 目錄下新建 server.go氢拥，寫入文件內(nèi)容：
package main
import (
"context"
"log"
"net/http"
"strings"
"github.com/EDDYCJY/go-grpc-example/pkg/gtls"
pb "github.com/EDDYCJY/go-grpc-example/proto"
"google.golang.org/grpc"
)
type SearchService struct{}
func (s *SearchService) Search(ctx context.Context, r *pb.SearchRequest) (*pb.SearchResponse, error) {
return &pb.SearchResponse{Response: r.GetRequest() + " HTTP Server"}, nil
}
const PORT = "9003"
func main() {
certFile := "../../conf/server/server.pem"
keyFile := "../../conf/server/server.key"
tlsServer := gtls.Server{
CertFile: certFile,
KeyFile: keyFile,
}
c, err := tlsServer.GetTLSCredentials()
if err != nil {
log.Fatalf("tlsServer.GetTLSCredentials err: %v", err)
}
mux := GetHTTPServeMux()
server := grpc.NewServer(grpc.Creds(c))
pb.RegisterSearchServiceServer(server, &SearchService{})
http.ListenAndServeTLS(":"+PORT,
certFile,
keyFile,
http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
if r.ProtoMajor == 2 && strings.Contains(r.Header.Get("Content-Type"), "application/grpc") {
server.ServeHTTP(w, r)
} else {
mux.ServeHTTP(w, r)
}
return
}),
)
}
func GetHTTPServeMux() *http.ServeMux {
mux := http.NewServeMux()
mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte("eddycjy: go-grpc-example"))
})
return mux
}
- http.NewServeMux：創(chuàng)建一個新的 ServeMux蚌铜，ServeMux 本質(zhì)上是一個路由表。它默認(rèn)實現(xiàn)了 ServeHTTP嫩海，因此返回 Handler 后可直接通過 HandleFunc 注冊 pattern 和處理邏輯的方法
- http.ListenAndServeTLS：可簡單的理解為提供監(jiān)聽 HTTPS 服務(wù)的方法厘线，重點的協(xié)議判斷轉(zhuǎn)發(fā)，也在這里面
其實出革，你理解后就會覺得很簡單，核心步驟：判斷 -> 轉(zhuǎn)發(fā) -> 響應(yīng)渡讼。我們改變了前兩步的默認(rèn)邏輯骂束，僅此而已
Client
在 simple_http_server 目錄下新建 client.go，寫入文件內(nèi)容：
package main
import (
"context"
"log"
"google.golang.org/grpc"
"github.com/EDDYCJY/go-grpc-example/pkg/gtls"
pb "github.com/EDDYCJY/go-grpc-example/proto"
)
const PORT = "9003"
func main() {
tlsClient := gtls.Client{
ServerName: "go-grpc-example",
CertFile: "../../conf/server/server.pem",
}
c, err := tlsClient.GetTLSCredentials()
if err != nil {
log.Fatalf("tlsClient.GetTLSCredentials err: %v", err)
}
conn, err := grpc.Dial(":"+PORT, grpc.WithTransportCredentials(c))
if err != nil {
log.Fatalf("grpc.Dial err: %v", err)
}
defer conn.Close()
client := pb.NewSearchServiceClient(conn)
resp, err := client.Search(context.Background(), &pb.SearchRequest{
Request: "gRPC",
})
if err != nil {
log.Fatalf("client.Search err: %v", err)
}
log.Printf("resp: %s", resp.GetResponse())
}
驗證
gRPC Client
$ go run client.go
2018/10/04 14:56:56 resp: gRPC HTTP Server
HTTP/1.1 訪問
總結(jié)
通過本章節(jié)成箫，表面上完成了同端口提供雙服務(wù)的功能展箱，但實際上，應(yīng)該是加深了 HTTP/2 的理解和使用蹬昌，這才是本質(zhì)
拓展
如果你有一個需求混驰，是要同時提供 RPC 和 RESTful JSON API 兩種接口的，不要猶豫皂贩，點進(jìn)去：gRPC + gRPC Gateway 實踐
問題
你以為這個方案就萬能了嗎栖榨，不。Envoy Proxy 的支持就不完美明刷，無法同時監(jiān)聽一個端口的兩種流量 ??
參考
本系列示例代碼
系列目錄
- 帶入gRPC：gRPC及相關(guān)介紹
- 帶入gRPC：gRPC Client and Server
- 帶入gRPC：gRPC Streaming, Client and Server
- 帶入gRPC：TLS 證書認(rèn)證
- 帶入gRPC：基于 CA 的 TLS 證書認(rèn)證
- 帶入gRPC：Unary and Stream interceptor
- 帶入gRPC：讓你的服務(wù)同時提供 HTTP 接口
- 帶入gRPC：對 RPC 方法做自定義認(rèn)證
- 帶入gRPC：gRPC Deadlines
原文地址：帶入gRPC：讓你的服務(wù)同時提供 HTTP 接口
項目地址：https://github.com/EDDYCJY/go...
