1 返回一个特定的网页

  1. from socket import *
  2. from threading import Thread
  4. def serve_client(client_socket):
  5.     recv_data = client_socket.recv(1024)
  6.     print("客户端发送的请求:", recv_data)  # 5
  7.     print("回复客户端...")  # 6
  8.     reply = "HTTP/1.1 200 OK\n\n"\
  9.             "<h1>MacBookPro</h1>"
  10.     client_socket.send(reply.encode("utf-8"))
  11.     print("关闭套接字...")  # 7
  12.     client_socket.close()
  14. print("创建套接字...")  # 1
  15. tcp_socket = socket(AF_INET, SOCK_STREAM)
  16. # 程序退出端口号自动释放
  17. tcp_socket.setsockopt(SOL_SOCKET, SO_REUSEADDR, True)
  18. print("绑定端口...")  # 2
  19. tcp_socket.bind(("", 16055))
  20. print("变为监听套接字,只能被动接收...")  # 3
  21. tcp_socket.listen(128)
  22. while True:
  23.     print("接受客户端请求,分配一个客服套接字...")  # 4
  24.     client_socket, client_addr = tcp_socket.accept()
  25.     print("客户端信息:", client_addr)
  26.     sub_thread = Thread(target=serve_client, args=(client_socket,), daemon=True)
  27.     sub_thread.start()
  28. tcp_socket.close()

image.png

2 返回浏览器请求的html

  1. from socket import *
  2. import re
  3. def serve_client(client_socket):
  4.     request = client_socket.recv(1024).decode("utf-8")
  5.     print("客户端发送的请求:", request)  # 5
  6.     # 读取请示中的文件名
  7.     request_lines = request.splitlines()
  8.     ret = re.match(r"[^/]+(/[^ ]*)", request_lines[0])
  9.     file_name = ""
  10.     if ret:
  11.         file_name = ret.group(1)
  12.         print("-------------", file_name)
  13.     # 设置默认界面
  14.     if file_name == "/" or file_name == "":
  15.         file_name = "/index.html"
  16.     # header是字符串，body是二进制，不能+=连在一起
  17.     print("回复客户端...")  # 6
  18.     try:
  19.         f = open("./html" + file_name, "rb")
  20.     except:  # 未找到文件
  21.         response = "HTTP/1.1 404 NOT FOUND\n\n"
  22.         response += "-----file not found-----"
  23.         client_socket.send(response.encode("utf-8"))
  24.     else:  # 成功
  25.         html_content = f.read()
  26.         f.close()
  27.         header = "HTTP/1.1 200 OK\n\n"
  28.         client_socket.send(header.encode("utf-8"))
  29.         client_socket.send(html_content)
  30.     print("关闭套接字...")  # 7
  31.     client_socket.close()
  33. print("创建套接字...")  # 1
  34. tcp_socket = socket(AF_INET, SOCK_STREAM)
  35. print("绑定端口...")  # 2
  36. tcp_socket.bind(("", 16055))
  37. print("变为监听套接字,只能被动接收...")  # 3
  38. tcp_socket.listen(128)
  39. while True:
  40.     print("接受客户端请求,分配一个客服套接字...")  # 4
  41.     client_socket, client_addr = tcp_socket.accept()
  42.     print("客户端信息:", client_addr)
  43.     serve_client(client_socket)
  44. tcp_socket.close()

3 多进程实现

  1. from socket import *
  2. import re
  3. from multiprocessing import Process
  5. def serve_client(client_socket):
  6.     request = client_socket.recv(1024).decode("utf-8")
  7.     print("客户端发送的请求:", request)  # 5
  8.     # 读取请示中的文件名
  9.     request_lines = request.splitlines()
  10.     ret = re.match(r"[^/]+(/[^ ]*)", request_lines[0])
  11.     file_name = ""
  12.     if ret:
  13.         file_name = ret.group(1)
  14.         print("-------------", file_name)
  15.         # 设置默认界面
  16.         if file_name == "/":
  17.             file_name = "/index.html"
  18.     # header是字符串，body是二进制，不能+=连在一起
  19.     print("回复客户端...")  # 6
  20.     try:
  21.         f = open("./html" + file_name, "rb")
  22.     except:  # 未找到文件
  23.         response = "HTTP/1.1 404 NOT FOUND\n\n"
  24.         response += "-----file not found-----"
  25.         client_socket.send(response.encode("utf-8"))
  26.     else:  # 成功
  27.         html_content = f.read()
  28.         f.close()
  29.         header = "HTTP/1.1 200 OK\n\n"
  30.         client_socket.send(header.encode("utf-8"))
  31.         client_socket.send(html_content)
  32.     print("关闭套接字...")  # 7
  33.     client_socket.close()
  35. if __name__ == "__main__":
  36.     print("创建套接字...")  # 1
  37.     tcp_socket = socket(AF_INET, SOCK_STREAM)
  38.     print("绑定端口...")  # 2
  39.     tcp_socket.bind(("", 16054))
  40.     print("变为监听套接字,只能被动接收...")  # 3
  41.     tcp_socket.listen(128)
  42.     while True:
  43.         print("接受客户端请求,分配一个客服套接字...")  # 4
  44.         client_socket, client_addr = tcp_socket.accept()
  45.         print("客户端信息:", client_addr)
  46.         p = Process(target=serve_client, args=(client_socket,))
  47.         p.start()
  48.         client_socket.close()
  49.     tcp_socket.close()

4 多线程实现

  1. from socket import *
  2. import re
  3. from threading import Thread
  5. def serve_client(client_socket):
  6.     request = client_socket.recv(1024).decode("utf-8")
  7.     print("客户端发送的请求:", request)  # 5
  8.     # 读取请示中的文件名
  9.     request_lines = request.splitlines()
  10.     ret = re.match(r"[^/]+(/[^ ]*)", request_lines[0])
  11.     file_name = ""
  12.     if ret:
  13.         file_name = ret.group(1)
  14.         print("-------------", file_name)
  15.         # 设置默认界面
  16.         if file_name == "/":
  17.             file_name = "/index.html"
  18.     # header是字符串，body是二进制，不能+=连在一起
  19.     print("回复客户端...")  # 6
  20.     try:
  21.         f = open("./html" + file_name, "rb")
  22.     except:  # 未找到文件
  23.         response = "HTTP/1.1 404 NOT FOUND\n\n"
  24.         response += "-----file not found-----"
  25.         client_socket.send(response.encode("utf-8"))
  26.     else:  # 成功
  27.         html_content = f.read()
  28.         f.close()
  29.         header = "HTTP/1.1 200 OK\n\n"
  30.         client_socket.send(header.encode("utf-8"))
  31.         client_socket.send(html_content)
  32.     print("关闭套接字...")  # 7
  33.     client_socket.close()
  35. if __name__ == "__main__":
  36.     print("创建套接字...")  # 1
  37.     tcp_socket = socket(AF_INET, SOCK_STREAM)
  38.     print("绑定端口...")  # 2
  39.     tcp_socket.bind(("", 16054))
  40.     print("变为监听套接字,只能被动接收...")  # 3
  41.     tcp_socket.listen(128)
  42.     while True:
  43.         print("接受客户端请求,分配一个客服套接字...")  # 4
  44.         client_socket, client_addr = tcp_socket.accept()
  45.         print("客户端信息:", client_addr)
  46.         p = Thread(target=serve_client, args=(client_socket,))
  47.         p.start()
  48.     tcp_socket.close()

5 gevent实现

  1. from socket import *
  2. import re
  3. import gevent
  4. from gevent import monkey
  5. import time
  6. monkey.patch_all()
  7. def serve_client(client_socket):
  8.     request = client_socket.recv(1024).decode("utf-8")
  9.     print("客户端发送的请求:", request)  # 5
  10.     # 读取请示中的文件名
  11.     request_lines = request.splitlines()
  12.     ret = re.match(r"[^/]+(/[^ ]*)", request_lines[0])
  13.     file_name = ""
  14.     if ret:
  15.         file_name = ret.group(1)
  16.         print("-------------", file_name)
  17.         # 设置默认界面
  18.         if file_name == "/":
  19.             file_name = "/index.html"
  20.     # header是字符串，body是二进制，不能+=连在一起
  21.     print("回复客户端...")  # 6
  22.     try:
  23.         f = open("./html" + file_name, "rb")
  24.     except:  # 未找到文件
  25.         response = "HTTP/1.1 404 NOT FOUND\n\n"
  26.         response += "-----file not found-----"
  27.         client_socket.send(response.encode("utf-8"))
  28.     else:  # 成功
  29.         html_content = f.read()
  30.         f.close()
  31.         header = "HTTP/1.1 200 OK\n\n"
  32.         client_socket.send(header.encode("utf-8"))
  33.         client_socket.send(html_content)
  34.     print("关闭套接字...")  # 7
  35.     client_socket.close()
  37. if __name__ == "__main__":
  38.     print("创建套接字...")  # 1
  39.     tcp_socket = socket(AF_INET, SOCK_STREAM)
  40.     tcp_socket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
  41.     print("绑定端口...")  # 2
  42.     tcp_socket.bind(("", 7890))
  43.     print("变为监听套接字,只能被动接收...")  # 3
  44.     tcp_socket.listen(128)
  45.     while True:
  46.         print("接受客户端请求,分配一个客服套接字...")  # 4
  47.         client_socket, client_addr = tcp_socket.accept()
  48.         print("客户端信息:", client_addr)
  49.         gevent.spawn(serve_client, client_socket)
  50.         time.sleep(0.01)
  51.     tcp_socket.close()

6 面向对象实现

  1. #!/usr/bin/env python
  2. from socket import *
  3. from threading import Thread
  4. import sys
  6. class HttpServer():
  7.     def __init__(self, port):
  8.         self.server = socket()
  9.         self.server.setsockopt(SOL_SOCKET, SO_REUSEADDR, True)
  10.         self.server.bind(('', port))
  11.         self.server.listen()
  13.     def handle_request(self, conn: socket):
  14.         try:
  15.             data = conn.recv(4096)
  16.         except:
  17.             print('接收数据发生异常')
  18.             return
  19.         if len(data) == 0:
  20.             return
  21.         content = data.decode()
  22.         request_lines = content.split(' ', 2)
  23.         path = request_lines[1]
  24.         if path == '/':
  25.             path = '/index.html'
  26.         try:
  27.             with open('static'+path, 'rb') as f:
  28.                 response_body = f.read()
  29.             response_line = 'HTTP/1.1 200 OK\n'
  30.             response_header = 'Server: CPALyth/1.1\n'
  31.         except:
  32.             with open('static/404.html', 'rb') as f:
  33.                 response_body = f.read()
  34.             response_line = 'HTTP/1.1 404 Not Found\n'
  35.             response_header = 'Server: CPALyth/1.1\n'
  36.         response = (response_line + response_header + '\n').encode() + response_body
  37.         conn.send(response)
  39.     def start(self):
  40.         while True:
  41.             print('等待客户端...')
  42.             conn, addr = self.server.accept()
  43.             Thread(target=self.handle_request, args=(conn,), daemon=True).start()
  45. if __name__ == '__main__':
  46.     web_server = HttpServer(8000)
  47.     web_server.start()

7 实现上传图片

(1) 服务端

  1. #!/usr/bin/env python
  2. from socket import *
  3. from threading import Thread
  4. import re
  5. import base64
  7. class HttpServer():
  8.     def __init__(self, port):
  9.         self.server = socket()
  10.         self.server.setsockopt(SOL_SOCKET, SO_REUSEADDR, True)
  11.         self.server.bind(('', port))
  12.         self.server.listen()
  14.     def handle_request(self, conn: socket):
  15.         while True:
  16.             print('正在等待客户端发送消息...')
  17.             try:
  18.                 data = conn.recv(4096)
  19.             except:
  20.                 data = ''
  21.             if len(data) == 0:
  22.                 conn.close()
  23.                 return
  24.             content = data.decode()
  25.             request_line = content.split(' ', 2)
  26.             method = request_line[0]
  28.             if method == 'GET':  # 获取服务器资源
  29.                 path = request_line[1]
  30.                 self.get(conn, path)
  31.             elif method == 'POST':  # 上传文件到服务器
  32.                 ret = re.search(r'Content-type: (.+)\n', content)
  33.                 content_type = ret.group(1) if ret else None
  34.                 ret = re.search(r'\n\n(.+)', content)
  35.                 body = ret.group(1) if ret else None
  36.                 self.post(conn, content_type, body)
  38.     def get(self, conn, path):
  39.         if path == '/':
  40.             path = '/index.html'
  41.         try:
  42.             with open('static' + path, 'r', encoding='utf8') as f:
  43.                 response_body = f.read()
  44.             response_line = 'HTTP/1.1 200 OK\n'
  45.             response_header = 'Server: CPALyth/1.1\n'
  46.         except:
  47.             with open('static/404.html', 'r', encoding='utf8') as f:
  48.                 response_body = f.read()
  49.             response_line = 'HTTP/1.1 404 Not Found\n'
  50.             response_header = 'Server: CPALyth/1.1\n'
  51.         response = (response_line + response_header + '\n' + response_body).encode()
  52.         conn.send(response)
  54.     def post(self, conn, content_type, body):
  55.         if content_type == 'images/png':
  56.             body_b64 = body.encode()
  57.             img_data = base64.b64decode(body_b64)
  58.             with open('out.png', 'wb') as f:
  59.                 f.write(img_data)
  60.         response = ('HTTP/1.1 200 OK\n' + 'Server: CPALyth/1.1\n' + '\n' + '上传成功').encode()
  61.         conn.send(response)
  63.     def start(self):
  64.         while True:
  65.             print('等待客户端...')
  66.             conn, addr = self.server.accept()
  67.             Thread(target=self.handle_request, args=(conn,), daemon=True).start()
  69. if __name__ == '__main__':
  70.     web_server = HttpServer(8000)
  71.     web_server.start()

(2) 客户端

  1. from socket import *
  2. import base64
  4. class HttpClient():
  5.     def __init__(self):
  6.         self.conn = socket()
  7.         self.conn.connect(('192.168.3.67', 8000))
  9.     def get_index(self):
  10.         request_line = 'GET / HTTP/1.1\n'
  11.         request_header = 'User-Agent: Python\n'
  12.         request_body = ''
  13.         request = (request_line + request_header + '\n' + request_body).encode()
  14.         self.conn.send(request)
  15.         response = self.conn.recv(4096).decode()
  16.         print(response)
  18.     def upload_pic(self):
  19.         request_line = 'POST / HTTP/1.1\n'
  20.         request_header = 'Content-type: images/png\n'
  21.         # 图片先读取bytes, 再编码为base64, 再解码为utf8
  22.         with open('1.png', 'rb') as f:
  23.             request_body = base64.b64encode(f.read()).decode()
  24.         request = (request_line + request_header + '\n' + request_body).encode()
  25.         self.conn.send(request)
  26.         response = self.conn.recv(4096).decode()
  27.         print(response)
  29. cli = HttpClient()
  30. # cli.get_index()
  31. cli.upload_pic()