Socket编程
1、socket_TCP网络通信
socket : 套接字，用来实现网络编程的一种数据传输手段 socket把一些复杂的tcp/ip协议进行封装，我们就按部就班遵守socket规则进行编程 tcp协议：是传输可靠的数据通信协议（三次握手，四次挥手） 一般对于网络通信安全完整性比较高的时候：邮箱，传输文件，浏览网页，下载学习视频 udp协议：是传输不可靠的数据：会丢包 当实时性要求高到时候，直播，视频，语音
如何实现发送信息的网络通讯 1.手机（硬件接口） 2.发送信息 3.接受信息 4.关机 通讯步骤： 1.链接通畅 2.传输信息 3.关机链接 变成了python实现步骤 1.建立服务端socket 对象 2.绑定自己的ip(个人地址)以及端口号（动态端口号：1025-65535） 3.建立监听模式，设置最大的链接数 4.等待客户链接 5.接受客户端的数据/给客户端发送信息 6.关闭链接 客户端 1.创建客户端socket对象 2.链接服务端ip和端口 3.接收服务端数据/发送客户端信息 4.关闭 socket --> connect --> recv/send -> close
server.py
# socket 是内置函数，不需要下载 import socket """ socket 是套接字类, 有两个参数 socket_family ：网络地址类型： ipv4参数值 -》 AF_INET af_inet ipv6参数值 -》 AF_INET6 af_inet6 socket_type : 套接字 ：TCP协议 =》 SOCK_STREAM sock_stream UDP协议 => SOCK_DGRAM sock+dgram """ # 创建套接字对象 # 用ipv4,tcp协议的套接字 IPhone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 绑定自己ip和端口号 # bind方法来实现,这里只有一个参数值，而且必须用元组传输 IPhone.bind( ("127.0.0.1", 10086) ) # 我们这里设置最大链接数 IPhone.listen(5) # 等待客户端链接 """ accept: 这个方法调用后会有两个返回值 1. 客户端对象（数据），我们以后要用这个对象进行接受和发送 2.客户端的ip和端口号 """ # conn:就是客户端对象 # adder 地址：ip和端口 conn, adder = IPhone.accept() # 接受和发送 # 接受数据：设定最大字节数，单位为b data = conn.recv(1024) # 我们数据：在网路中数据是以数据流传输 # 我们需要编译为文档文字, decode是字符串的编译 print(data.decode("utf-8")) # 发送信息 data = input("》》》") conn.send(data.encode("utf-8")) conn.close() IPhone.close()
huxing.py
import socket # 建立客户端的对象 huxing = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 绑定是服务端ip和端口 huxing.connect( ("127.0.0.1", 10086) ) data = input("》》》") huxing.send(data.encode("utf-8")) # 这里设置数据接受的最大字节数 data = huxing.recv(1024) print(data.decode("utf-8")) huxing.close()
添加循环通信
server.py
# socket 是内置函数，不需要下载 import socket """ socket 是套接字类, 有两个参数 socket_family ：网络地址类型： ipv4参数值 -》 AF_INET ipv6参数值 -》 AF_INET6 socket_type : 套接字 ：TCP协议 =》 SOCK_STREAM UDP协议 => SOCK_DGRAM """ # 创建套接字对象 # 用ipv4,tcp协议的套接字 IPhone = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 绑定自己ip和端口号 # bind方法来实现,这里只有一个参数值，而且必须用元组传输 IPhone.bind( ("127.0.0.1", 10086) ) # 我们这里设置最大链接数 IPhone.listen(5) # 等待客户端链接 """ accept: 这个方法调用后会有两个返回值 1. 客户端对象（数据），我们以后要用这个对象进行接受和发送 2.客户端的ip和端口号 """ # conn:就是客户端对象 # adder 地址：ip和端口 conn, adder = IPhone.accept() while 1: # 接受和发送 # 接受数据：设定最大字节数，单位为b # 会有链接出错 try: data = conn.recv(1024) # 我们数据：在网路中数据是以数据流传输 # 我们需要编译为文档文字, decode是字符串的编译 print(data.decode("utf-8")) # 发送信息 data = input("》》》") conn.send(data.encode("utf-8")) except ConnectionResetError as massg: print(massg) break conn.close() IPhone.close()
huxing.py
import socket # 建立客户端的对象 huxing = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 绑定是服务端ip和端口 huxing.connect( ("127.0.0.1", 10086) ) while 1: data = input("》》》") huxing.send(data.encode("utf-8")) if data == "晚安": break if not data: continue # 这里设置数据接受的最大字节数 data = huxing.recv(1024) print(data.decode("utf-8")) huxing.close()
2、socket_UDP网络通信
服务端: 1.创建服务端socket对象 2.绑定自己的ip和端口 3.接收客户端数据/发送数据 4.关闭链接 socket --》 bind -》》 recvfrom(收)/sendto(发) - 》close 客户端： 1.创建客户端socket对象 2.发送数据，接受数据 3.关闭 c/s
server.py
# socket 是内置函数，不需要下载 import socket """ socket 是套接字类, 有两个参数 socket_family ：网络地址类型： ipv4参数值 -》 AF_INET ipv6参数值 -》 AF_INET6 socket_type : 套接字 ：TCP协议 =》 SOCK_STREAM UDP协议 => SOCK_DGRAM """ # 创建套接字对象 # 用ipv4,tcp协议的套接字 IPhone = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 绑定自己ip和端口号 # bind方法来实现,这里只有一个参数值，而且必须用元组传输 IPhone.bind( ("127.0.0.1", 10086) ) # 等待客户端链接 """ accept: 这个方法调用后会有两个返回值 1. 客户端对象（数据），我们以后要用这个对象进行接受和发送 2.客户端的ip和端口号 """ while 1: # 接受和发送 # 接受数据：设定最大字节数，单位为b # 会有链接出错 try: """ UDP不需要额外建立链接，只需要发送成功就可以建立链接 recvfrom : 也要最大字节数 1.客户端数据包 2.客户端ip和端口 """ # 我们数据：在网路中数据是以数据流传输 # 我们需要编译为文档文字, decode是字符串的编译 data, adder = IPhone.recvfrom(1024) print(data.decode("utf-8")) # 发送信息 data = input("》》》") IPhone.sendto(data.encode("utf-8"), adder) except ConnectionResetError as massg: print(massg) break IPhone.close()
huxing.py
import socket # 建立客户端的对象 huxing = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 绑定是服务端ip和端口 ipPort = ("127.0.0.1", 10086) while 1: data = input("》》》") huxing.sendto(data.encode("utf-8"), ipPort) if data == "晚安": break if not data: continue # 这里设置数据接受的最大字节数 data, adder = huxing.recvfrom(1024) print(data.decode("utf-8")) huxing.close()
3、socket响应网页(了解)
网页响应需要遵守http协议 如果不遵守就无法识别人响应（返回）信息 那么http协议格式需要我们来编写 客户端接受数据格式： 响应格式： 1.响应首行（http版本， 响应状态码） HTTP1.1 200 表示响应成功 ] \r\n 2.响应头（一大堆键值对）一般写服务器版本号，开发组，、、、、、 \r\n 3.空白行 \r\n 4.响应体 （需要返回给浏览器看的数据 （前端数据）） 请求格式： 1.请求首行(表示http版本号， 数据请求方式（get,post）) 2.请求头，可写可不写 3.请求体 静态服务器 b/s
server.py
import socket if __name__ == '__main__': tcpServerSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 需要设置端口复用(循环使用)，程序检测到关闭自动端口号 tcpServerSocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True) # 绑定端口号 # "" 默认本机地址 tcpServerSocket.bind(("", 8848)) tcpServerSocket.listen(128) while 1: try: newSocket, adder = tcpServerSocket.accept() data = newSocket.recv(4096) print(data) # 设置响应包 # 响应行 # http 1.1 是http协议版本， 200 ok 是状态码和说明信息 responseLine = "HTTP/1.1 200 ok \r\n" # 响应头, 可以编写服务器版本 responseHeader = "server：ziliangfuwuqi/1.0 \r\n" # 响应体 数据包 with open(r"ziliang.html", "r", encoding="utf-8") as f: responseBody = f.read() # 把上面的响应行，响应头，响应体三者合一，变成报文 response = responseLine+responseHeader+"\r\n"+responseBody # 组装好必须转换为二进制 responseData = response.encode("utf-8") newSocket.send(responseData) newSocket.close() except Exception as e: print(e) break
