socket broken pipe

tianqio

server端的代碼如下：
while True:
    sock,address = server_socket.accept()
    data = sock.recv(bufsize)
    while data != '':
        data = sock.recv(bufsize)
    print 'sock closed by peer'
    string = 'nihao,client'
    a = 0
    while True:
        a += sock.send(string)
        time.sleep(1)
        print a
    print 'write finish: %d' % a


客戶端的代碼就是連接，然后發(fā)送一段數(shù)據(jù)，然后close

問題是： 服務(wù)端在recv的時(shí)候通過while  data != '' 來控制一直讀直到socket被客戶端關(guān)閉，然后進(jìn)行寫，按照常理在第一次寫的時(shí)候就應(yīng)該出現(xiàn)broken pipe的錯(cuò)誤，但實(shí)際運(yùn)行時(shí)實(shí)在第二次寫的時(shí)候才引發(fā)該錯(cuò)誤

也是運(yùn)行時(shí)的輸出是：
sock closed by peer
12
Traceback (most recent call last):
  File "./server.py", line 25, in ?
    a += sock.send(string)
socket.error: (32, 'Broken pipe')

為什么不是第一次send的時(shí)候就出現(xiàn)broken pipe？

多謝

wudagang0123

沒看到你client的代碼，不好解釋
tcp是半關(guān)閉的，有可能是當(dāng)你send的時(shí)候，client只是關(guān)閉
了自己的發(fā)送，而還可以接收，你把time.sleep(1)放到send前面
看看是第幾次發(fā)生broken pipe的

以上為鄙人拙見，僅供參考

xiaoyu9805119

同理，再帖部分client代碼上來瞅瞅

chrisyan

寫已經(jīng)關(guān)閉的socket會得到SIGPIPE，也就是broken pipe.
當(dāng)然應(yīng)該在第二次寫的時(shí)候才會有SIGPIPE了，第一次寫會得到一個(gè)RST,通知你socket已經(jīng)不可用了，再寫的話就是SIGPIPE了。
如果你第一次寫就broken pipe，那才奇怪呢

建議你看看UNP,這個(gè)問題與python無關(guān)，和client無關(guān)，tcp就是這么規(guī)定的，c的實(shí)現(xiàn)也是這樣的.

tianqio

但從運(yùn)行的結(jié)果來看，第一次寫是成功了，也并沒有發(fā)生rst啊

chrisyan

這個(gè)....
不好意思，開始沒看輸出
如果是RST,返回值應(yīng)該是負(fù)的吧？
要不你把兩邊的代碼發(fā)上來，我來調(diào)調(diào)

tianqio

server.py

import socket,time port = 5000 server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) server_socket.bind(("", port)) server_socket.listen(5) bufsize = 4096 while True:     print 'accept'     sock,address = server_socket.accept()     data = sock.recv(bufsize)     while data != '':         print data         print 'r'         data = sock.recv(bufsize)         print 'e:data:%s' % data     print 'sock closed by peer'     print 'write'     a = 0     string = 'nihao,client'     while True:         a += sock.send(string)         print 'write finish: %d' % a

client.py

import socket,sys,time client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) client_socket.connect(('localhost',int(sys.argv[1]))) client_socket.send(sys.argv[2]) #client_socket.shutdown(2) client_socket.close() time.sleep(1000)

客戶端必須是先調(diào)用close，所以無法從客戶端來驗(yàn)證server第一次寫是否是真正的寫成功，但是server send的返回值來看，確實(shí)是寫成功了的

[ 本帖最后由 tianqio 于 2009-6-9 15:43 編輯 ]

tianqio

server監(jiān)聽5000端口
當(dāng)client調(diào)用close，但server沒有發(fā)送數(shù)據(jù)前，二者的狀態(tài)如下：

tcp        0      0 localhost.localdomain:43216 localhost.localdomain:5000  FIN_WAIT2   
tcp        0      0 localhost.localdomain:5000  localhost.localdomain:43216 CLOSE_WAIT


當(dāng)socket處于close_wait狀態(tài)時(shí)，如果發(fā)送的不是FIN，ACK 包，對端會是什么響應(yīng)？