通道API中的在线状态未触发。

Question

我正在尝试使用频道API中的Presence来处理断开/连接状态。

这里是我的一些代码。

app.yaml

handlers:
- url: /(.*\.(gif|png|jpg|ico|js|css))
  static_files: \1
  upload: (.*\.(gif|png|jpg|ico|js|css))

- url: .*
  script: main.py

inbound_services:
- channel_presence

main.py

class onConnect(webapp.RequestHandler):
  def post(self):
    for user in users:
      users = User.all().fetch(1000)
      client = client_id = self.request.get('from')
      channel.send_message(user.channel,' connected');

class onDisconnect(webapp.RequestHandler):
  def post(self):
    Mainpage()
    for user in users:
      users = User.all().fetch(1000)
      client = client_id = self.request.get('from')
      channel.send_message(user.channel, ' disconnected');

application = webapp.WSGIApplication(
                                     [('/', MainPage),
                                     ('/_ah/channel/connected/',onConnect),
                                     ('/_ah/channel/disconnected/',onDisconnect),
                                     ('/chat',handleChat)],
                                     debug=True)

Javascript

<script>
        openChannel = function(){
            var token = '{{ token }}';
            var channel = new goog.appengine.Channel(token);
            var handler = {
                  'onopen': onOpened,
                  'onmessage': onMessage,
                  'onerror': function() {},
                  'onclose': function() {}
                };
            var socket = channel.open(handler);
            socket.onopen = onOpened;
            socket.onmessage = onMessage;

            var chat = document.getElementById('chatinput');
                chat.onkeyup = function(e){
                    if(e.keyCode == 13){
                        sendChat(this.value);
                        this.value = '';
                    }
                }
        }

        sendMessage = function(path, opt_param) {
            if (opt_param) {
                path += '?' + opt_param;
            }
            var xhr = new XMLHttpRequest();
            xhr.open('POST', path, true);
            xhr.send();
        };

        onOpened = function(){
            console.log('Channel Opened');  
            var chatlog = document.getElementById('chatlog');
            var msg = document.createElement('div');
                msg.innerHTML = 'Channel Opened';
                chatlog.appendChild(msg);
            sendMessage('/chat','m='+'A User Joined.');
        }

        onMessage = function(m){
            console.log('Message Recieved');
            var chatlog = document.getElementById('chatlog');
            var msg = document.createElement('div');
            var d = new Date();
                msg.innerHTML = d.toLocaleTimeString() + ': ' + m.data;
                chatlog.appendChild(msg);
        }

        sendChat = function(msg){
            console.log(msg);
            sendMessage('/chat','m='+msg);
        }

        openChannel();
    </script>

使用这段代码时，当用户关闭浏览器或其他操作时，connect和disconnect不会被触发。

这段代码有什么问题吗？

- AlexCheuk

---

你是否实际创建了一个令牌并初始化客户端？我在你的问题中没有看到那部分的代码。 - alex

你的日志里有关于 /_ah/channel/connected 和 /_ah/channel/disconnected 的信息吗？ - Nick Johnson

你正在使用SDK 1.6.5吗？当他们刷新页面时，你是否注意到了问题？ - Anentropic

你解决过这个问题吗？我也遇到了同样的问题。 - themaestro

我有同样的问题。谷歌提供的代码不完整。 - Stubbies

Answer 1

是的，路由列表有误。将('/', MainPage)放在路由列表的末尾。来自webapp2 URI routing guide：

当应用程序接收到请求时，它会按顺序尝试匹配每个请求，直到找到一个匹配项，然后调用相应的处理程序。

- Alex Dvoretsky