0

我是 Google AppEngine & to Go & to Web stacks 的新手 - 所以很可能我在这里做错了，但我想不通:)

我正在尝试在 Go 中编写一个简单的时钟应用程序，其中服务器推送到客户端并且 JS 处理程序更新 HTML 元素。我正在使用 TaskQueue api 重新安排服务器端更新，并且我已将默认队列频率更改为每秒一次。服务器发送一个有效负载字符串，其中包含任务 URL 被命中的次数和当前时间。正如预期的那样，命中计数以每秒 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 -

我在下面粘贴了我的代码（pastebin 更好吗？）。

干杯! 布拉德

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 回答