会引发ConnectionResetError的代码

Posted 2021-01-06 ravener

服务端selectserver.py

from socket import *
from select import select

s = socket(AF_INET, SOCK_STREAM)
s.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
s.bind((‘127.0.0.1‘, 10002))
s.listen()
rlist = [s]
wlist = []
xlist = []
while True:
    print(‘Waiting for connect...‘)
    rs, ws, xs = select(rlist, wlist, xlist)
    for fb in rs:
        if fb is s:
            conn,addr = s.accept()
            print(‘connect with %s%s‘%addr)
            conn.send(‘connection stable‘.encode())
            rlist.append(conn)
        else:
            data = fb.recv(4096)
            if not data:
                print(‘%s%s断开连接‘%fb.getsockname())
                rlist.remove(fb)
                fb.close()
            else:
                print(‘从%s%s收到：‘%fb.getsockname(), data.decode())
                fb.send(‘recv checked‘.encode())

客户端selectclient.py

from socket import *

s = socket(AF_INET, SOCK_STREAM)
s.connect((‘127.0.0.1‘, 10002))
while True:
    #data = s.recv(4096)
    #print(‘server:‘, data.decode())
    si = input(‘client:‘)
    if not si:
        s.close()
        break
    data = si.encode()  
    n = s.send(data)
    print(‘发送%d字节‘%n)
    data = s.recv(4096)
    print(‘server:‘, data.decode())

在客户端断开时

Traceback (most recent call last):
File "selectserver.py", line 21, in