0

私はGoogle AppEngineとto Goとto Webスタックを初めて使用するため、ここで間違っている可能性が非常に高いですが、理解できません:)

サーバーがクライアントにプッシュし、JS ハンドラーが HTML 要素を更新する Go で単純な時計アプリを作成しようとしています。TaskQueue API を使用してサーバー側の更新を再スケジュールし、デフォルトのキュー頻度を 1 秒に 1 回に変更しました。サーバーは、タスク URL がヒットした回数と現在の時刻を含むペイロード文字列を送信します。予想どおり、ヒット カウントは 1 秒あたり 1 の割合で更新されますが、タイム スタンプはほとんど変化しません。dev_appserver コンソールに表示されるログ出力は正しいようです

INFO     2012-07-05 03:04:31,955 dev_appserver.py:2952] "POST /update HTTP/1.1" 200 -
INFO     2012-07-05 03:04:31,985 dev_appserver.py:2952] "POST /update HTTP/1.1" 200 -
INFO     2012-07-05 03:04:32,015 dev_appserver.py:2952] "POST /update HTTP/1.1" 200 -
INFO     2012-07-05 03:04:32,043 dev_appserver.py:2952] "POST /update HTTP/1.1" 200 -

以下にコードを貼り付けました (ペーストビンの方が良いですか?)。

乾杯！ブラッド

package clock

import (
    "fmt"
    "appengine"
    "appengine/channel"
    "appengine/datastore"
    "appengine/taskqueue"
    "html/template"
    "net/http"
    "time"
//  "appengine/user"
)

type Greeting struct {
    Author  string
    Content string
    Date    time.Time
}

func init() {
    http.HandleFunc("/", root)
    http.HandleFunc("/update", update)
}

type TemplateFiller struct {
    Time      string
    Token     string
}

var clientId string = "clockclient"

func root(w http.ResponseWriter, r *http.Request) {
    c := appengine.NewContext(r)
    q := datastore.NewQuery("Greeting").Order("-Date").Limit(10)
    greetings := make([]Greeting, 0, 10)
    if _, err := q.GetAll(c, &greetings); err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
        return
    }

    token, _ := channel.Create(c, clientId);
    tf := TemplateFiller{time.Now().String(), token}

    if err := guestbookTemplate.Execute(w, tf); err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
    }

    reschedule(c)
}

func reschedule(c appengine.Context) {
    t := taskqueue.NewPOSTTask("/update", map[string][]string{"token": {clientId}})
        if _, err := taskqueue.Add(c, t, ""); err != nil {
            return
        }
}

var hits int = 0

func update(w http.ResponseWriter, r *http.Request) {
    c := appengine.NewContext(r)
    channel.Send(c, clientId, fmt.Sprintln(hits) + time.Now().Format(time.RFC3339))
    hits = hits + 1
    //channel.Send(c, clientId, time.Now().Format(time.RFC3339))
    reschedule(c)
}

var guestbookTemplate = template.Must(template.New("").Parse(guestbookTemplateHTML))

const guestbookTemplateHTML = `
<html>
  <script type="text/javascript" src="/_ah/channel/jsapi"></script>
  <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.2/jquery.min.js"></script>
  <body>
<div id="timediv">No time</div>

<script type="text/javascript">
$(document).ready(function(){

   onMessage = function(msg) {
      $("#timediv").html(msg.data);
   }

    channel = new goog.appengine.Channel('{{.Token}}');
    socket = channel.open();
    //socket.onopen = onOpened;
    socket.onmessage = onMessage;
    //socket.onerror = onError;
    //socket.onclose = onClose;
 });

</script>

  </body>
</html>
`
4

1 に答える 1

2
  1. dev_server キューとタイミングは、運用サーバーの動作 (タイミングに関して) とはまったく異なります。
  2. キューに依存して一定の安定したタイマーの割り込みを行うのは非常に悪い考えです。
于 2012-07-05T07:07:48.787 に答える