客户端/服务器架构
服务端提供服务
客户端请求服务
套接字:通信端点
套接字是计算机网络数据结构,它体现了“通信端点”的概念。
在任何类型的通信开始之前,网络应用程序必须创建套接字。
可以将它们比作电话插孔,没有它将无法进行通信。
Python 中的网络编程
socket()模块函数
要创建套接字,必须使用 socket.socket()函数,它一般的语法如下。
socket(socket_family, socket_type, protocol=0)
socket_family 是 AF_UNIX 或 AF_INET
socket_type 是 SOCK_STREAM或 SOCK_DGRAM
protocol 通常省略,默认为 0
使用以下方式创建TCP/UDP套接字:
from socket import *
TCPSock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
UDPSpck=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
套接字对象(内置)方法
常见的套接字对象方法和属性
创建TCP服务器
#!/usr/bin/env/python3
#-*- coding:utf8 -*-
import socket
import sys
Server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 创建服务端套接字
HOST = '127.0.0.1'
PORT = 9999
ADDRS=(HOST,PORT)
Server.bind(ADDRS) #绑定IP,Port
Server.listen(2) #最大连接数
print("正在监听:%s:%d"%(HOST,PORT))
while True: #服务器无限循环
Client, addr = Server.accept() #接受客户端连接
print("连接来自:%s" % str(addr)) #打印客户端连接IP
msg = 'Wlecome to here!\n'
#send()和recv()的数据格式都是bytes。
# (str和bytes的相互转化,用encode()和decode(),或者用bytes()和str())
while True:
Client.send(msg.encode("utf-8")) # 发送欢迎标语
msg = Client.recv(1024) #接受并输出信息
print("接收到客户端数据:%s" % msg.decode("utf-8"))
msg=input('输入>') # 输入信息
Client.close()
Server.close()
创建TCP客户端
#!/usr/bin/env/python3
#-*- coding:utf8 -*-
import socket
Client= socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 创建客户端套接字
HOST = '127.0.0.1'
PORT = 9999
ADDRS=(HOST,PORT)
Client.connect(ADDRS) # 连接服务器
while True:
msg = Client.recv(1024)
print("接受到服务端数据:%s" % msg.decode("utf-8"))
msg = input('输入>')
Client.send(msg.encode("utf-8"))
Client.close()
运行结果:
创建UDP服务器
#!/usr/bin/env python3
#-*- coding:utf8 -*-
import socket
HOST='127.0.0.1'
PORT=9999
ADDR=(HOST,PORT)
BUFSIZE=1024
Server=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
Server.bind(ADDR)
print("正在监听 %s:%d" % (HOST,PORT) )
while True:
msg,ADDR=Server.recvfrom(BUFSIZE)
print("接收到来自客户端的数据:%s" % msg.decode("utf-8"))
msg=input('输入>')
Server.sendto(msg.encode("utf-8"),ADDR)
Server.close()
创建UDP客户端
#!/usr/bin/env python3
#-*- coding:utf8 -*-
import socket
HOST='127.0.0.1'
PORT=9999
ADDR=(HOST,PORT)
BUFSIZE=1024
Client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
while True:
msg = input('输入>')
Client.sendto(msg.encode("utf-8"),ADDR)
msg,ADDR=Client.recvfrom(BUFSIZE)
print("接收到服务端的数据:%s" % msg.decode("utf-8"))
Client.close()
运行结果: