前言

接口需要提供給其他業(yè)務(wù)組訪問(wèn)，但是 RPC 協(xié)議不同無(wú)法內(nèi)調(diào)，對(duì)方問(wèn)能否走 HTTP 接口，怎么辦？

微信(公眾號(hào)、小程序)等第三方回調(diào)接口只支持 HTTP 接口，怎么辦

我相信你在實(shí)際工作中都會(huì)遇到如上問(wèn)題，在 gRPC 中都是有解決方案的，本章節(jié)將會(huì)進(jìn)行介紹 🤔

為什么可以同時(shí)提供 HTTP 接口

關(guān)鍵一點(diǎn)，gRPC 的協(xié)議是基于 HTTP/2 的，因此應(yīng)用程序能夠在單個(gè) TCP 端口上提供 HTTP/1.1 和 gRPC 接口服務(wù)(兩種不同的流量)

怎么同時(shí)提供 HTTP 接口

檢測(cè)協(xié)議

if r.ProtoMajor == 2 && strings.Contains(r.Header.Get("Content-Type"), "application/grpc") {

server.ServeHTTP(w, r)

} else {

mux.ServeHTTP(w, r)

}

流程

檢測(cè)請(qǐng)求協(xié)議是否為 HTTP/2

判斷 Content-Type 是否為 application/grpc(gRPC 的默認(rèn)標(biāo)識(shí)位)

根據(jù)協(xié)議的不同轉(zhuǎn)發(fā)到不同的服務(wù)處理

gRPC

TLS

在前面的章節(jié)，為了便于展示因此沒(méi)有簡(jiǎn)單封裝

在本節(jié)需復(fù)用代碼，重新封裝了，可詳見(jiàn)：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，寫(xiě)入文件內(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)建一個(gè)新的 ServeMux，ServeMux 本質(zhì)上是一個(gè)路由表。它默認(rèn)實(shí)現(xiàn)了 ServeHTTP，因此返回 Handler 后可直接通過(guò) HandleFunc 注冊(cè) pattern 和處理邏輯的方法

http.ListenAndServeTLS：可簡(jiǎn)單的理解為提供監(jiān)聽(tīng) HTTPS 服務(wù)的方法，重點(diǎn)的協(xié)議判斷轉(zhuǎn)發(fā)，也在這里面

其實(shí)，你理解后就會(huì)覺(jué)得很簡(jiǎn)單，核心步驟：判斷 -> 轉(zhuǎn)發(fā) -> 響應(yīng)。我們改變了前兩步的默認(rèn)邏輯，僅此而已

Client

在 simple_http_server 目錄下新建 client.go，寫(xiě)入文件內(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())

}

驗(yàn)證

gRPC Client

$ go run client.go

2018/10/04 14:56:56 resp: gRPC HTTP Server

HTTP/1.1 訪問(wèn)

總結(jié)

通過(guò)本章節(jié)，表面上完成了同端口提供雙服務(wù)的功能，但實(shí)際上，應(yīng)該是加深了 HTTP/2 的理解和使用，這才是本質(zhì)

拓展

如果你有一個(gè)需求，是要同時(shí)提供 RPC 和 RESTful JSON API 兩種接口的，不要猶豫，點(diǎn)進(jìn)去：gRPC + gRPC Gateway 實(shí)踐

問(wèn)題

你以為這個(gè)方案就萬(wàn)能了嗎，不。Envoy Proxy 的支持就不完美，無(wú)法同時(shí)監(jiān)聽(tīng)一個(gè)端口的兩種流量 😤

參考

本系列示例代碼

系列目錄

總結(jié)

以上是生活随笔為你收集整理的为什么grpc不支持php,带入gRPC：让你的服务同时提供 HTTP 接口的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。