Twisted Socket 立即发送消息

Question

我正在制作一个与 Twisted 套接字通信的 iPhone 应用程序，当我要发送一条消息时它工作得很好。但是，我的问题是我需要向应用程序发送许多不同的信息。这是我的代码。

            if numrows == 1:
                #Did login
                msg = "%s: Login Credentials Success" % _UDID
                print msg
                for c in self.factory.clients:
                    c.message(msg)
                    time.sleep(0.5)

                for result in results:
                    for i in range(1, 6):
                        msg = "%s:L%d;%s" % (_UDID, i, result[i])
                        print msg
                        for c in self.factory.clients:
                            c.message(msg)
                            time.sleep(0.5)
            else:
                msg = "%s: Login Credentials Failed" % _UDID
                print msg
                for c in self.factory.clients:
                    c.message(msg)
                    time.sleep(0.5)

            cursor.close()
            database.close()

        #print msg

        #for c in self.factory.clients:
            #c.message(msg)

def message(self, message):
    self.transport.write(message)

假设我只发送第一个 msg，并且所有其他 msg 都不存在连同 print 和每个 msg 下面的方法，消息登录凭据成功将被发送到应用程序。但是，如果像您看到的那样放入其余部分，则不会发生任何事情，因为它会一次发送所有内容，即使在代码中添加 time.sleep 也是如此。

应用每 0.05 秒或更短时间检查一次响应。即使登录凭据在顶部，它也不会通过，因为之后会发送更多信息，但是如果没有凭据消息之后的所有信息，它也会通过。

我很想找到这个问题的答案。我已经尝试了我能想到的一切。应用程序不是问题，是 Python。

谢谢。

Answer 1

冒着自相矛盾的冒犯风险，您可能需要重新检查您的应用不是问题的说法。听起来您希望完全控制每个传出 TCP 数据包的内容，并且您的应用依赖数据包边界来确定消息边界。一般来说，这不是一个很好的联网方法。一些网络中介可能会在此过程中拆分（碎片）甚至合并数据包，这会使您的应用程序感到困惑。请记住，TCP 不是数据包协议：它是一种流协议，因此您只能真正保证您发送的八位位组将按顺序接收（如果有的话）。

处理不同大小的消息的一种常用方法是在每条消息前面加上一个 X 位大端大小字段，说明后面的消息有多大。通信的接收端首先读取 X 位，然后读取 'size' 八位位组以获取完整消息（阻塞直到该点，并将任何附加信息留在缓冲区中以供下一个消息处理程序获取）。

我不介意为您的 Twisted 代码提供更多帮助，但很可能它已经正确编写。至少，我建议不要立即尝试使 Twisted 刷新网络写入缓冲区。虽然它可能有助于使您的代码看起来可以正常工作，但它实际上只是隐藏了稍后会出现的问题。

Answer 2

您的问题似乎是 Twisted 缓冲了您写入它的数据。

显然，在不重构大量代码的情况下，没有简单的方法可以强制数据自行发送。见Twisted transport.write 和Using Twisted's twisted.web classes, how do I flush my outgoing buffers?。

在粘贴之前不知道您的代码是什么样的，根据最后一个链接的接受答案：

• 定义 wait 函数，就像它在接受的答案中一样
• 确保你的类继承自http.Request
• 用defer.inlineCallbacks装饰你的方法message
• 在message 方法上调用write 后添加yield wait(N)（对于您必须测试和确定的N 值）

我没有足够的 Twisted 经验，不知道需要哪些步骤，哪些只是原始答案的代码中的一部分，不适用于您的代码。

尽管如此，重新编写 iPhone 应用程序以接受在单个消息中包含多次写入时发送的消息类型是可能的（并且更容易）。