作者 |?阿里云智能事業(yè)群技術專家 牛秋霖（冬島）

成都創(chuàng)新互聯(lián)公司-專業(yè)網站定制、快速模板網站建設、高性價比臨高網站開發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫,直接使用。一站式臨高網站制作公司更省心,省錢,快速模板網站建設找我們，業(yè)務覆蓋臨高地區(qū)。費用合理售后完善，10年實體公司更值得信賴。

導讀：通過前面的一系列文章你已經知道如何基于 kubectl 來操作 Knative 的各種資源。但是如果想要在項目中集成 Knative 僅僅使用 kubectl 這種命令的方式是不夠的，還需要在代碼中基于 Knative Serving SDK 進行集成開發(fā)。本篇文章中，阿里云智能事業(yè)群技術專家冬島將從 Knative Serving SDK 入手，介紹如何基于 Knative SDK 進行 serverless 開發(fā)。

Golang Context

在正式開始介紹 Knative Serving SDK 之前，我們先簡單介紹一下 Golang Context 的機理。因為在 Knative Serving 中 client、Informer 的初始化和信息傳遞完全是基于 Golang Context 實現(xiàn)的。

Golang 是從 1.7 版本開始引入的 Context ，Golang 的 Context 可以很好的簡化多個 goroutine 之間以及請求域間的數(shù)據(jù)傳遞、取消信號和截至時間等相關操作。Context 主要有兩個作用：

1. 傳輸必要的數(shù)據(jù)；
2. 進行協(xié)調控制，比如終止 goroutein、設置超時時間等。

Context 定義

Context 本身是一個接口。

type Context interface {
    Deadline() (deadline time.Time, ok bool)
    Done() <-chan struct{}
    Err() error
    Value(key interface{}) interface{}
}

這個接口中定義了四個方法，下面分別介紹：

• Deadline 方法是獲取設置的截止時間的意思，到了這個時間點，Context 會自動發(fā)起取消請求；
• Done 方法返回一個只讀的 chan，如果該方法返回的 chan 可以讀取，則意味著 parent Context 已經發(fā)起了取消請求, 此時應該做清理操作，然后退出 goroutine 并釋放資源；
• Err 方法返回取消的錯誤原因；
• Value 方法獲取該 Context 上綁定的值，是一個鍵值對。所以要通過一個 Key 才可以獲取對應的值，這個值是線程安全的。

關于 Context 主要記住一點：可以通過 Value 傳遞數(shù)據(jù)，Value 是一個鍵值對結構。更多詳細的介紹可以參見下面這些文章：

• Concurrency Patterns in Go
• How to correctly use context.Context in Go 1.7
• Using context cancellation in Go
• Go Context

Knative Serving client 源碼淺析

在 Context 的這些特性中，Knative Serving 中重度依賴的是 Value 功能。以 ?Service 的 Informer 初始化為例進行說明，這里可以看到源碼。

Informer “構造函數(shù)”是在 init 函數(shù)中自動注冊到 injection.Default 中的。當 Informer “構造函數(shù)”被調用之后會自動把生成的 Informer 注入到 Context 中 context.WithValue(ctx, Key{}, inf), inf.Informer()。

從上圖中可以看到：Informer 初始化的時候需要調用 factory，而 factory 本身是從 ?Context 中獲取的。下面我們再看看 factory 是怎么初始化的。factory 的初始化。

上圖可以發(fā)現(xiàn)，factory 也是把“構造函數(shù)”注冊到 injection.Default 中，并會將生成的 SharedInformerFactory 注入到 Context 中。而且 factory 中使用的 client (鏈接 kube-apiserver 使用的對象)也是從 Context 獲取到的。

可以說 Knative Serving SDK 初始化的過程是面向 Context 編程的。關鍵對象是自動注入到 Context，在使用的時候從 Context 中取出。

順帶提一點，Knative Serving 的日志對象也是在 Context 保存的，當需要打印日志的時候先通過 logger := logging.FromContext(ctx) 從 Context 中拿到 logger，然后就可以使用了。這樣做的好處是可以通過管理 logger 對象，比如做 trace 功能。

如下所示是基于 logger 打印出來的日志，可以看到對于同一個請求的處理是可以通過 traceID 進行追蹤的。下面這段日志都是對 577f8de5-cec9-4c17-84f7-f08d39f40127 這個 ?trace 的處理。

{"level":"info","ts":"2019-08-28T20:24:39.871+0800","caller":"controller/service.go:67","msg":"Reconcile: default/helloworld-go","knative.dev/traceid":"be5ec711-6ca3-493c-80ed-dddfa21fd576","knative.dev/key":"default/helloworld-go"}
{"level":"info","ts":"2019-08-28T20:24:39.871+0800","caller":"controller/controller.go:339","msg":"Reconcile succeeded. Time taken: 487.347μs.","knative.dev/traceid":"90653eda-644b-4b1e-8bdb-4a1a7a7ff0d8","knative.dev/key":"eci-test/helloworld-go"}
{"level":"info","ts":"2019-08-28T20:24:39.871+0800","caller":"controller/service.go:106","msg":"service: default/helloworld-go route: default/helloworld-go ","knative.dev/traceid":"be5ec711-6ca3-493c-80ed-dddfa21fd576","knative.dev/key":"default/helloworld-go"}
{"level":"info","ts":"2019-08-28T20:24:39.872+0800","caller":"controller/service.go:67","msg":"Reconcile: eci-test/helloworld-go","knative.dev/traceid":"22f6c77d-8365-4773-bd78-e011ccb2fa3d","knative.dev/key":"eci-test/helloworld-go"}
{"level":"info","ts":"2019-08-28T20:24:39.872+0800","caller":"controller/service.go:116","msg":"service: default/helloworld-go revisions: 1 ","knative.dev/traceid":"be5ec711-6ca3-493c-80ed-dddfa21fd576","knative.dev/key":"default/helloworld-go"}
{"level":"info","ts":"2019-08-28T20:24:39.872+0800","caller":"controller/service.go:118","msg":"service: default/helloworld-go revision: default/helloworld-go-cgt65 ","knative.dev/traceid":"be5ec711-6ca3-493c-80ed-dddfa21fd576","knative.dev/key":"default/helloworld-go"}
{"level":"info","ts":"2019-08-28T20:24:39.872+0800","caller":"controller/controller.go:339","msg":"Reconcile succeeded. Time taken: 416.527μs.","knative.dev/traceid":"be5ec711-6ca3-493c-80ed-dddfa21fd576","knative.dev/key":"default/helloworld-go"}
{"level":"info","ts":"2019-08-28T20:24:39.872+0800","caller":"controller/service.go:106","msg

使用 Knative Serving SDK

介紹完 Knative Serving client 的初始化過程，下面我們看一下應該如何在代碼中用 Knative Serving SDK 進行編碼。
示例參見：https://github.com/knative-sample/serving-controller/blob/v0.1/cmd/app/app.go

這個示例中首先使用配置初始化 *zap.SugaredLogger?對象，然后基于 ctx := signals.NewContext() 生成一個 Context。signals.NewContext()?作用是監(jiān)聽 SIGINT 信號，也就是處理 CTRL+c 指令。這里用到了 Context 接口的 Done 函數(shù)機制。

構造 Informer

接著使用 ctx, informers := injection.Default.SetupInformers(ctx, cfg) 構造出所有的 informer，然后調用下面這段代碼執(zhí)行注入，把 informer 注入到 Context 中。

// Start all of the informers and wait for them to sync.
    logger.Info("Starting informers.")
    if err := controller.StartInformers(ctx.Done(), informers...); err != nil {
        logger.Fatalw("Failed to start informers", err)
    }

從 Context 中獲取 Informer

實例代碼： https://github.com/knative-sample/serving-controller/blob/v0.1/pkg/controller/controller.go

如上所示，所有的 informer 都是從 Context 中獲取的。

最后 Controller 初始化一個 Reconciler 接口，接口的定義如下, 里面只有一個 Reconcile 函數(shù)。這個使用方式和 sigs.k8s.io/controller-runtime 使用的邏輯是一樣的。如果你之前寫過 Operator 之類的功能，對這個操作應該不會陌生。

// Reconciler is the interface that controller implementations are expected
// to implement, so that the shared controller.Impl can drive work through it.
type Reconciler interface {
    Reconcile(ctx context.Context, key string) error
}

在 Reconcile 中調用 Knative API

代碼示例： https://github.com/knative-sample/serving-controller/blob/v0.1/pkg/controller/service.go

現(xiàn)在就可以在 Reconcile 中通過 c.serviceLister.Services(namespace).Get(name) 這種方式直接操作 Seving 資源了。

至此，我們已經把基于 Knative Seving 開發(fā) Serverless 應用的關鍵脈梳理了一遍。更詳細的代碼示例請參見：https://github.com/knative-sample/serving-controller ，這里面有完整可以運行的代碼。

小結

本文從 Knative Serving client 的初始化過程開始展開，介紹了 Knative informer 的設計以及使用方法。通過本文你可以了解到：

• Knative Serving client 的設計思路
• 如何基于 Knative Serving SDK 進行二次開發(fā)
• 通過 Knative Serving 學習到如何面向 Context 編程
• Knative Serving 集成開發(fā)示例： https://github.com/knative-sample/serving-controller

歡迎加入 Knative 交流群

掃描下方二維碼添加小助手，拉你進群！

另外有需要云服務器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

本文名稱：KnativeServing進階:KnativeServingSDK-創(chuàng)新互聯(lián)
URL標題：http://jinyejixie.com/article6/coidog.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供域名注冊、響應式網站、企業(yè)網站制作、虛擬主機、網站內鏈、企業(yè)建站

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)