python Socket网络编程实现网络编程实现C/S模式和模式和P2P
主要介绍了python Socket网络编程实现C/S模式和P2P,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的
朋友们下面随着小编来一起学习学习吧
C/S模式模式
由于网络课需要实现Socket网络编程,所以简单实现了一下,C/S模式分别用TCP/IP协议与UDP协议实现,下面将分别讲解。
TCP/IP协议协议
TCP/IP协议是面向连接的,即客户端与服务器需要先建立连接后才能传输数据,以下是服务器端的代码实现。
服务端:
import socket
from threading import Thread
def deal(sock,addr):
print('Accept new connection from {}:{}'.format(addr[0],addr[1]))
sock.send('与服务器连接成功!'.encode('utf-8'))
while True:
data = sock.recv(1024).decode('utf-8') #1024为接收数据的最大大小
print('receive from {}:{} :{}'.format(addr[0],addr[1],data))
sock.send('信息已成功收到'.encode('utf-8'))
##创建tcp/IPV4协议的socket
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#为socket绑定端口
s.bind(('127.0.0.1',10240))
#监听端口,参数5为等待的最大连接量
s.listen(5)
print("Waiting for connection...")
while True:
sock,addr = s.accept()
t1 = Thread(target=deal,args=(sock,addr))
t1.start()
#断开与该客户端的连接
sock.close()
s.close()
需要注意的是,服务器在等待客户端连接时,即accept()函数这里是阻塞的,如下代码每次只能接受一个客户端的连接。
while True:
#接受一个新连接,accept等待并返回一个客户端连接
sock,addr = s.accept()
print('Accept new connection from {}:{}'.format(addr[0],addr[1]))
#给客户端发送消息
sock.send('连接成功!'.encode('utf-8'))
while True:
data = sock.recv(1024).decode('utf-8') #1024为接收数据的最大大小
print('receive from {}:{} :{}'.format(addr[0],addr[1],data))
sock.send('信息已成功收到'.encode('utf-8'))
#断开与该客户端的连接
sock.close()
也就是说如果采用以上方式,一个客户端与服务器建立连接后,服务器就会进入一个死循环去收发该客户端的信息,因此需要引入多线程,每与一个客户端建立连接,就
为其创建一个线程用于控制信息的收发,这样便可以接受多个客户端的连接了。
客户端:
import socket
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
##建立连接
s.connect(('127.0.0.1',10240))
#接收客户端连接成功服务器发来的消息
print(s.recv(1024).decode('utf-8'))
while True:
data = input('发送给服务器:')
if len(data)>0:
s.send(data.encode('utf-8'))
print('form sever:{}'.format(s.recv(1024).decode('utf-8')))
s.close()
客户端是比较简单的,需要与服务器建立连接后,再进行收发信息,这里不再赘述了。
UDP协议协议
UDP协议是面向无连接的,即服务器与客户端不需要提前建立连接,只需要向指定的端口直接发送数据即可。
服务端
import socket
#为服务器创建socket并绑定端口 SOCK_DGRAM指定了socket的类型为udp
s = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
s.bind(('127.0.0.1',7890))
print('Waiting for data...')
#upd无需监听
while True:
data,addr = s.recvfrom(1024)
print('Recevie from {}:{} :{}'.format(addr[0],addr[1],data.decode('utf-8')))
#sendto的另一个参数为客户端socket地址
s.sendto('信息已成功收到!'.encode('utf-8'),addr)