扭曲套接字立即发送消息

Twisted Socket Send Message Immediately(扭曲套接字立即发送消息)
本文介绍了扭曲套接字立即发送消息的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我正在制作一个与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)
假设我只发送第一个消息,而其他消息并不与打印一起存在,并且对于每个消息下面的方法,将向应用程序发送登录凭据成功的消息。但如果像你看到的那样放入其余部分,什么都不会发生,因为它会一次性发送所有消息,即使设置了时间。在代码中睡眠。

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

我急于找到这个问题的答案。我已经试过我能想到的一切了。问题不在这个应用程序,而是这个巨蟒。

谢谢。

推荐答案

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

处理不同大小的消息的一种常见方法是在每个消息前加上一个X位大端大小字段,说明下一条消息有多大。通信的接收端首先读取X位,然后再读取‘SIZE’二进制八位数以获得完整的消息(在此之前一直阻塞,并在缓冲区中保留任何附加信息以供下一个消息处理程序获取)。

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

这篇关于扭曲套接字立即发送消息的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!

相关文档推荐

Leetcode 234: Palindrome LinkedList(Leetcode 234:回文链接列表)
How do I read an Excel file directly from Dropbox#39;s API using pandas.read_excel()?(如何使用PANDAS.READ_EXCEL()直接从Dropbox的API读取Excel文件?)
subprocess.Popen tries to write to nonexistent pipe(子进程。打开尝试写入不存在的管道)
I want to realize Popen-code from Windows to Linux:(我想实现从Windows到Linux的POpen-code:)
Reading stdout from a subprocess in real time(实时读取子进程中的标准输出)
How to call type safely on a random file in Python?(如何在Python中安全地调用随机文件上的类型?)