python – 在linux中通过命名管道发送数据块

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python – 在linux中通过命名管道发送数据块，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1068字，纯文字阅读大概需要2分钟。

内容图文

我想通过命名管道发送数据块,并希望接收器知道数据块的结束位置.我应该如何使用命名管道？我应该使用某种格式来连接和拆分块(将管道总是作为字节流处理)还是有其他方法？

我已尝试在发送器处为每个数据块打开和关闭管道,但数据在接收器端连接(EOF不发送)：

for _ in range(2):
     with open('myfifo', 'bw') as f:
         f.write(b'+')

结果：

rsk@fe temp $cat myfifo 
++rsk@fe temp $

解决方法:

您可以在管道上使用某种分隔符或框架结构,或者(最好)使用多处理.像对象一样管道并通过它们运行Pickled Python对象.

第一个选项是简单地定义一个将通过管道运行的简单协议.为您发送的每个数据块添加标题,以便您知道如何处理它.例如,使用长度值系统：

import struct

def send_data(file_descriptor, data):
    length = struct.pack('>L', len(data))
    packet = "%s%s" % (length, data)
    file_descriptor.write(packet)

def read_data(file_descriptor):
    binary_length = file_descriptor.read(4)
    length = struct.unpack('>L', binary_length)[0]

    data = ''
    while len(data) < length:
        data += file_descriptor.read(length - len(data))

至于另一个选项 – 您可以尝试读取多处理模块的代码,但实际上,您只需通过管道运行cPickle.dumps的结果,然后将其读入cPickle.loads以获取Python对象.

内容总结

以上是互联网集市为您收集整理的python – 在linux中通过命名管道发送数据块全部内容，希望文章能够帮你解决python – 在linux中通过命名管道发送数据块所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端