socket
简单例子 拨打电话
服务端.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
| import socket
# 1 买手机
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# 2 绑定手机卡
phone.bind(('127.0.0.1',8081)) # ip 加端口号
# 3 开机
phone.listen(5) # 5代表最大链接数
# 4 等电话打入
print('starting....')
conn,client_addr = phone.accept()
# 5 收发消息
# 单位bytes 现在表示最大接受1024字节的数据
data = conn.recv(1024) # 1024代表接受数据的最大数
print('客户端的数据',data)
conn.send(data.upper())
# 6 挂电话
conn.close()
# 7 关机
phone.close()
|
客户端.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
| import socket
# 1 买手机
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# 2 拨号
phone.connect(('127.0.0.1',8081)) # ip 加端口号
# 3 发/收消息
phone.send('hello'.encode('utf-8'))
data = phone.recv(1024)
print(data)
# 4 关闭
phone.close()
|
通讯循环
服务端
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
| import socket
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.bind(('127.0.0.1',8081)) # ip 加端口号
phone.listen(5) # 5代表最大链接数
print('starting....')
conn,client_addr = phone.accept()
while True: # 通讯循环
data = conn.recv(1024)
print('客户端的数据',data)
conn.send(data.upper())
conn.close()
phone.close()
|
客户端
1
2
3
4
5
6
7
8
9
10
11
12
13
| import socket
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.connect(('127.0.0.1',8081)) # ip 加端口号
while True:
msg = input('>>:').strip()
phone.send(msg.encode('utf-8'))
data = phone.recv(1024)
print(data)
phone.close()
|
重复启动服务端的bug
因为端口重复占用，所以必须收到切换端口
1
2
3
4
| phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# 添加这一行代表重用端口
phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
phone.connect(('127.0.0.1',8081)) # ip 加端口号
|
客户端直接敲回车发数据的bug
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
| import socket
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.connect(('127.0.0.1',8081)) # ip 加端口号
while True:
msg = input('>>:').strip()
# bug解决
if not msg:continue
phone.send(msg.encode('utf-8'))
data = phone.recv(1024)
print(data)
phone.close()
|
客户端意外中断，服务器端在linux里会造成死循环的bug
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
| import socket
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
phone.bind(('127.0.0.1',8081)) # ip 加端口号
phone.listen(5) # 5代表最大链接数
print('starting....')
conn,client_addr = phone.accept()
while True: # 通讯循环
try:
data = conn.recv(1024)
# 针对客户端中断问题
if not data:break # 适用于linux 如果是windows就 try catch
print('客户端的数据',data)
conn.send(data.upper())
except ConnectionResetError: # 适用于windows
break
conn.close()
phone.close()
|
在不会并发的情况下——一个一个的服务用户
服务端
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
| import socket
phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
phone.bind(('127.0.0.1',8081)) # ip 加端口号
phone.listen(5) # 5代表最大链接数
print('starting....')
while True: # 链接循环
conn,client_addr = phone.accept()
while True: # 通讯循环
try:
data = conn.recv(1024)
# 针对客户端中断问题
if not data:break # 适用于linux 如果是windows就 try catch
print('客户端的数据',data)
conn.send(data.upper())
except ConnectionResetError: # 适用于windows
break
conn.close()
phone.close()
|
服务一个客户就要把对应客户端终止才能服务下一个客户