Go 工作佇列範例

本範例會建立一個能顯示 HTML 表單的應用程式。您需在對話方塊中輸入字串,然後按一下 [Add]。應用程式會計算您以這種方式輸入任何字串的次數。

應用程式會執行下列程序:

  • 當您按一下 [Add] 時,表單會使用 HTTP POST 要求,將字串傳送至正在 App Engine 中執行的應用程式。此時,應用程式會將字串與工作綁定成套件,再傳送至預設佇列 。
  • 佇列會將工作轉發至內含且對應於 /worker 這個網址的工作處理常式,接下來,這個處理常式會以非同步的方式將字串寫入於資料儲存庫。
  • 傳送 HTTP GET 要求會顯示一份您所輸入之字串組成的清單,以及您 Add 每個字串的方式 (新增方式包括直接鍵入,以及在下拉式方塊中點擊)。

將此應用程式部署至 App Engine:

  1. 將下列內容複製到名為 queue.yaml 的檔案中。這會將工作處理率從每秒 5 件的預設值變更為每秒 3 件。

    queue:
    - name: default
      rate: 3/s
    
  2. 將同一個目錄中的下列內容複製到您隨意命名的檔案中 (檔名結尾必須是 .go)。這是應用程式的程式碼,其中包括工作處理常式。

    
    package counter
    
    import (
    	"html/template"
    	"net/http"
    
    	"google.golang.org/appengine"
    	"google.golang.org/appengine/datastore"
    	"google.golang.org/appengine/log"
    	"google.golang.org/appengine/taskqueue"
    )
    
    func init() {
    	http.HandleFunc("/", handler)
    	http.HandleFunc("/worker", worker)
    }
    
    type Counter struct {
    	Name  string
    	Count int
    }
    
    func handler(w http.ResponseWriter, r *http.Request) {
    	ctx := appengine.NewContext(r)
    	if name := r.FormValue("name"); name != "" {
    		t := taskqueue.NewPOSTTask("/worker", map[string][]string{"name": {name}})
    		if _, err := taskqueue.Add(ctx, t, ""); err != nil {
    			http.Error(w, err.Error(), http.StatusInternalServerError)
    			return
    		}
    	}
    	q := datastore.NewQuery("Counter")
    	var counters []Counter
    	if _, err := q.GetAll(ctx, &counters); err != nil {
    		http.Error(w, err.Error(), http.StatusInternalServerError)
    		return
    	}
    	if err := handlerTemplate.Execute(w, counters); err != nil {
    		http.Error(w, err.Error(), http.StatusInternalServerError)
    		return
    	}
    	// OK
    }
    
    func worker(w http.ResponseWriter, r *http.Request) {
    	ctx := appengine.NewContext(r)
    	name := r.FormValue("name")
    	key := datastore.NewKey(ctx, "Counter", name, 0, nil)
    	var counter Counter
    	if err := datastore.Get(ctx, key, &counter); err == datastore.ErrNoSuchEntity {
    		counter.Name = name
    	} else if err != nil {
    		log.Errorf(ctx, "%v", err)
    		return
    	}
    	counter.Count++
    	if _, err := datastore.Put(ctx, key, &counter); err != nil {
    		log.Errorf(ctx, "%v", err)
    	}
    }
    
    var handlerTemplate = template.Must(template.New("handler").Parse(handlerHTML))
    
    const handlerHTML = `
    {{range .}}
    <p>{{.Name}}: {{.Count}}</p>
    {{end}}
    <p>Start a new counter:</p>
    <form action="/" method="POST">
    <input type="text" name="name">
    <input type="submit" value="Add">
    </form>
    `
    
  3. 將同一個目錄中的下列內容複製到名為 app.yaml 的檔案中。隨即完成在 App Engine 中使用該應用程式的設定:

    runtime: go
    api_version: go1
    
    handlers:
    - url: /worker/.*
      script: _go_app
      login: admin
    - url: /.*
      script: _go_app
  4. 請確認您的 Google Cloud Platform 專案確實已備妥 App Engine 應用程式,您也已經初始化並設定該專案的 gcloud 指令。

  5. 使用 gcloud app deploy 指令,將應用程式部署於 App Engine。

  6. 使用 gcloud app browser 指令查看應用程式執行情形。

本頁內容對您是否有任何幫助?請提供意見:

傳送您對下列選項的寶貴意見...

這個網頁
Go 適用的 App Engine 標準環境