用Python操作Named pipe命

# named pipe Client
#encoding: utf-8

import os
import time

write_path = "/tmp/server_in.pipe"
read_path = "/tmp/server_out.pipe"

counter = 1

f = os.open( write_path, os.O_SYNC | os.O_CREAT | os.O_RDWR )
print "Client open f", f

rf = None

while True:
    # Client发送请求
    req = "%s "%counter 
    len_send = os.write( f, req )
    print "request", req, len_send

    counter += 1
    
    if rf == None:
        # *要点1：在这里第一次打开read_path，实际这里的open是一个阻塞操作
        # 打开的时机很重要。如果在程序刚开始，没发送请求就打开read_path，肯定会阻塞住
        rf = os.open( read_path, os.O_RDONLY )
        print "client opened rf", rf

    # 接收Server回应
    s = os.read( rf, 1024 )
    if len(s) == 0:
        # 一般来说，是管道被意外关闭了，比如Server退出了
        break

    print "received", s

    # 这个例子里没有sleep，客户端以最高速度发送数据，可以观察执行效果


os.close( f )
os.close( rf )

#named pipe Server
#encoding: utf-8

import os, time

read_path = "/tmp/server_in.pipe"
write_path = "/tmp/server_out.pipe"

try:
    # 创建命名管道
    os.mkfifo( write_path )
    os.mkfifo( read_path )
except OSError, e:
    # 如果命名管道已经创建过了，那么无所谓
    print "mkfifo error:", e

# 写入和读取的文件，正好和Client相反
rf = os.open( read_path, os.O_RDONLY )
f = os.open( write_path, os.O_SYNC | os.O_CREAT | os.O_RDWR )

while True:
    # 接收请求
    s = os.read( rf, 2 )
    if len(s) == 0:
        # 没有收到字符，一般是唯一的发送方被关闭了。
        # 这里可以休息一下继续，对后续消息没有任何影响，也不会丢包。
        time.sleep( 1 )
        continue

    # 如果收到的字符串带一个s，打印出来
    # 用于调试和测试
    if "z" in s:
        print "received", s

    # 在请求前面加一个s字母，返回
    os.write( f, "s%s"%s )

os.close( f )
os.close( rf )