本文介绍了扭曲套接字立即发送消息的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我正在制作一个与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立即刷新网络写入缓冲区。虽然它可能会帮助您的代码看起来正常工作,但现在,它实际上只是隐藏了以后会浮出水面的问题。
这篇关于扭曲套接字立即发送消息的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!