第二十七天- 网络通信协议 TCP UDP 缓冲区

 1 #加入一条socket配置，重用ip和端口
 2 import socket
 3 from socket import SOL_SOCKET,SO_REUSEADDR
 4 sk = socket.socket()
 5 sk.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #在bind前加，允许地址重用
 6 sk.bind(('127.0.0.1',8898))  #把地址绑定到套接字
 7 sk.listen()          #监听链接
 8 conn,addr = sk.accept() #接受客户端链接
 9 ret = conn.recv(1024)   #接收客户端信息
10 print(ret)              #打印客户端信息
11 conn.send(b'hi')        #向客户端发送信息
12 conn.close()       #关闭客户端套接字
13 sk.close()        #关闭服务器套接字(可选)

 1 import socket
 2 
 3 server = socket.socket()
 4 ip_port = ('127.0.0.1',8081)
 5 server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)  # 固定写法,允许地址重用,若还报错OSerror,系统原因,改端口
 6 
 7 server.bind(ip_port)
 8 server.listen()  # 监听 可跟参数 n 代表监听n+1次 如,listen(3),意思是我连接着一个,后面还有3排队,共4个.
 9 
10 while 1:
11     conn,addr = server.accept()  # 阻塞等待连接
12     while 1:
13         server_msg = input('>>>>> ')
14         server_msg = server_msg.encode('utf-8')
15         conn.send(server_msg)  # 发消息
16         if server_msg == 'byebye':  # 多个客户端连接时,结束前一个后，跳出当前循环到上一个while，重新获得连接
17             break
18 
19         from_client_msg = conn.recv(1024)  # 接消息
20         from_client_msg = from_client_msg.decode('utf-8')
21         if from_client_msg == 'byebye':
22             break
23         print('来自客户端的消息：',from_client_msg)
24     conn.close()

 1 import socket
 2 
 3 client = socket.socket()
 4 server_ip = ('127.0.0.1',8081)
 5 client.connect(server_ip)
 6 
 7 while 1:
 8     from_server_msg = client.recv(1024)
 9     from_server_msg = from_server_msg.decode('utf-8')
10     print('来自服务器>>>',from_server_msg)
11     if from_server_msg == 'byebye':
12         break
13 
14     client_msg = input('>>>>> ')
15     client_msg = client_msg.encode('utf-8')
16     client.send(client_msg)
17     if client_msg == 'byebye':
18         break
19 
20 client.close()

 1 # 再来一份即可
 2 import socket
 3 
 4 client = socket.socket()
 5 server_ip = ('127.0.0.1',8081)
 6 client.connect(server_ip)
 7 
 8 while 1:
 9     from_server_msg = client.recv(1024)
10     from_server_msg = from_server_msg.decode('utf-8')
11     print('来自服务器>>>',from_server_msg)
12     if from_server_msg == 'byebye':
13         break
14 
15     client_msg = input('>>>>> ')
16     client_msg = client_msg.encode('utf-8')
17     client.send(client_msg)
18     if client_msg == 'byebye':
19         break
20 
21 client.close()

 1 import socket
 2 import time
 3 
 4 server = socket.socket()
 5 ip_port = ('127.0.0.1',8083)
 6 server.bind(ip_port)
 7 server.listen()
 8 conn,addr = server.accept()  # 等待conn
 9 
10 dic = {'张三':'123','赵四':'345','王八':'567'}
11 
12 client_msg = conn.recv(1024)
13 client_msg = client_msg.decode('utf-8')  # 还原成字典
14 client_msg = eval(client_msg)
15 print(client_msg)
16 time.sleep(5)
17 
18 for k in dic:
19     if {k:dic[k]} == client_msg:
20         conn.send('登录成功！'.encode('utf-8'))
21     else:
22         conn.send('用户名或密码错误!'.encode('utf-8'))

 1 import socket
 2 
 3 client = socket.socket()
 4 server_ip = ('127.0.0.1',8083)
 5 client.connect(server_ip)
 6 
 7 k = input('请输入账户：')
 8 v = input('请输入密码：')
 9 # 存入字典，发送给服务端
10 msg = {k:v}
11 client.send(str(msg).encode('utf-8'))
12 
13 from_server_msg = client.recv(1024)
14 print(from_server_msg.decode('utf-8'))

 1 import socket
 2 
 3 talk_server = socket.socket(type=socket.SOCK_DGRAM)
 4 ip_port = ('127.0.0.1',8086)
 5 talk_server.bind(ip_port)
 6 
 7 while 1:
 8     from_client_msg,addr = talk_server.recvfrom(1024)
 9     from_client_msg = from_client_msg.decode('utf-8')
10     print('来自客户端>>>',from_client_msg)
11     if from_client_msg == 'byebye':
12         break
13 
14     msg = input('>>> ')
15     if 'sb'in from_client_msg:
16         msg2 = from_client_msg.replace('sb', 'alexsb')
17         talk_server.sendto((msg+msg2).encode('utf-8'),addr)
18     else:
19         talk_server.sendto(msg.encode('utf-8'), addr)
20 
21 talk_server.close()

 1 # udp下复制多个以下代码即可实现多客户端 
 2 
 3 import socket
 4 
 5 talk_client = socket.socket(type=socket.SOCK_DGRAM)
 6 server_ip_port = ('127.0.0.1',8086)
 7 
 8 while 1:
 9     msg = input('>>>')
10     if msg == 'byebye':
11         break
12     msg = msg.encode('utf-8')
13     talk_client.sendto(msg,server_ip_port)
14 
15     from_server_msg,addr = talk_client.recvfrom(1024)
16     print('来自服务端>>>',from_server_msg.decode('utf-8'))
17 
18 talk_client.close()