項目要用到通信協議，強行學習了一波HTTP協議

報文格式

請求格式

HTTP請求由狀態(tài)行、請求頭、請求正文三部分組成：

• 狀態(tài)行：包括請求方式Method、資源路徑URL、協議版本Version；
• 請求頭：包括一些訪問的域名、用戶代理、Cookie等信息；
• 請求正文：就是HTTP請求的數據。

請求方式Method一般有GET、POST、PUT、DELETE，含義分別是獲取、修改、上傳、刪除，其中GET方式僅僅為獲取服務器資源，方式較為簡單，因此在請求方式為GET的HTTP請求數據中，請求正文部分可以省略，直接將想要獲取的資源添加到URL中。

圖片.png

圖片.png

上面這張圖是Fiddle捕獲的一個實際請求報文，它清晰的展示了HTTP 消息的結構。詳情如下：

• 請求行：即第一排用空格分割成的三個小塊，分別對應請求方法、請求URL、HTTP協議版本三個部分。
• 請求頭：從第二行開始到倒數第二行都是我們的請求頭（headers）。
• 消息主體：截圖的最后一行是請求體，也就是我們要發(fā)送的數據的主體，消息主體（entity-body）。
• 也就是說一個正常的post請求主要由請求行，請求頭，消息主體組成。接下來我們來了解一下什么是Content-Type。

Content-Type的格式種類

四種最常用的編碼方式，基本上形成了相應的規(guī)范，即基本固定的Content-Type取值application/x-www-form-urlencoded（默認格式）、application/json、text/xml、multipart/form-data，與默認傳遞的urlencoded、json格式、xml格式、文件格式一 一對應。

應答格式

HTTP響應由三部分組成：狀態(tài)行、響應頭、響應正文；

• 狀態(tài)行：包括協議版本Version、狀態(tài)碼Status Code、回應短語；
• 響應頭：包括搭建服務器的軟件，發(fā)送響應的時間，回應數據的格式等信息；

• 響應正文：就是響應的具體數據

  
  
  圖片.png

使用輪子

Python Requests 快速上手
https://2.python-requests.org//zh_CN/latest/user/quickstart.html
Python實現簡單HTTP服務器
https://www.cnblogs.com/xinyangsdut/p/9099623.html
Python Http Post請求四種請求體的Python實現
https://www.cnblogs.com/Detector/p/9404391.html

使用socket創(chuàng)建簡單的客戶端和服務端

客戶端

client.py

# -*- coding: utf-8 -*-
"""
Created on Fri Jul  5 17:00:36 2019

@author: Administrator
"""

import socket 

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 連接服務端
s.connect(('127.0.0.1', 9999))

# 請求 | 發(fā)送數據到服務端
s.sendall(b'hello')

# 響應 | 接受服務端返回到數據
data = s.recv(1024)

print(data) # hello

# 關閉 socket
s.close()

服務端

# -*- coding: utf-8 -*-
"""
Spyder Editor

This is a temporary script file.
"""

import socket 

# socket.AF_INET (IPV4)
# socket.SOCK_STREAM (TCP)
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 監(jiān)聽 IP:port
s.bind(('127.0.0.1', 9999))

# 最大允許連接數量
s.listen(3)

# 死循環(huán)，重復的處理著每個客戶端的請求
while True:

# 阻塞 每當有客戶端的請求過來開始執(zhí)行
# 連接處理 （已完成三次握手）并獲取資源對象 | conn 請求對象 | addr 客戶端地址 ip: port
conn, addr = s.accept() 

# 請求處理 | 讀取客戶端發(fā)送過來的數據 | recv(1024) 指定每次讀取 1024 字節(jié)，當數據較長時可以通過 while 循環(huán)讀取
data = conn.recv(1024).decode('utf-8')

# 響應處理 | 把客服端發(fā)送過來的數據又轉發(fā)回去
conn.sendall(data.encode('utf-8'))

# 關閉客戶端連接
conn.close()

HTTP服務端

# -*- coding: utf-8 -*-
"""
Created on Mon Jul  8 09:02:54 2019

@author: Administrator
"""

# coding:utf-8

import socket
import json

from multiprocessing import Process

def handle_client(client_socket):
    """
    處理客戶端請求
    """
    request_data = client_socket.recv(1024)
    print("request data:", request_data)
    # 構造響應數據
    response_start_line = "HTTP/1.1 200 OK\r\n"
    response_headers = "Server: My server\r\n"
    response_body = "<h1>Python HTTP Test</h1>"
    datas={"param1": "Detector", "param2": "cnblogs"}
    response = response_start_line + response_headers + "\r\n" + datas

    # 向客戶端返回響應數據
    client_socket.send(bytes(response, "utf-8"))

    # 關閉客戶端連接
    client_socket.close()


if __name__ == "__main__":
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.bind(("", 8000))
    server_socket.listen(128)
    

    while True:
        client_socket, client_address = server_socket.accept()
        
        print("[%s, %s]用戶連接上了" % client_address)
        handle_client_process = Process(target=handle_client, args=(client_socket,))
        handle_client_process.start()
        client_socket.close()

C端TCP/IP 服務器

#include<iostream>
#include<winsock.h>
#pragma comment(lib,"ws2_32.lib")
using namespace std;
void initialization();
int server() {
    //定義長度變量
    int send_len = 0;
    int recv_len = 0;
    int len = 0;
    //定義發(fā)送緩沖區(qū)和接受緩沖區(qū)
    char send_buf[100];
    char recv_buf[100];
    memset(send_buf, 0, sizeof(send_buf));
    memset(recv_buf, 0, sizeof(recv_buf));
    //定義服務端套接字，接受請求套接字
    SOCKET s_server;
    SOCKET s_accept;
    //服務端地址客戶端地址
    SOCKADDR_IN server_addr;
    SOCKADDR_IN accept_addr;
    initialization();
    //填充服務端信息
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
    server_addr.sin_port = htons(8001);
    //創(chuàng)建套接字
    s_server = socket(AF_INET, SOCK_STREAM, 0);
    if (bind(s_server, (SOCKADDR *)&server_addr, sizeof(SOCKADDR)) == SOCKET_ERROR) {
        cout << "bing faild!" << endl;
        WSACleanup();
    }
    else {
        cout << "bing success!" << endl;
    }
    //設置套接字為監(jiān)聽狀態(tài)
    if (listen(s_server, SOMAXCONN) < 0) {
        cout << "listen faild!" << endl;
        WSACleanup();
    }
    else {
        cout << "listen success!" << endl;
    }
    cout << "listening...." << endl;
    //接受連接請求
    len = sizeof(SOCKADDR);
    s_accept = accept(s_server, (SOCKADDR *)&accept_addr, &len);
    if (s_accept == SOCKET_ERROR) {
        cout << "listen faild!" << endl;
        WSACleanup();
        return 0;
    }
    cout << "connect..." << endl;
    //接收數據
    while (1) {
        recv_len = recv(s_accept, recv_buf, 1, 0);
        if (recv_len <= 0) {
            cout << "rec failed!" << endl;
            break;
        }
        else {
            cout << "client:" << recv_buf << endl;
        }
        /*cout << "please cin:";
        cin >> send_buf;*/
        //send_len = send(s_accept, send_buf, 100, 0);
        //if (send_len < 0) {
        //  cout << "send failed!" << endl;
        //  break;
        //}
    }
    //關閉套接字
    closesocket(s_server);
    closesocket(s_accept);
    //釋放DLL資源
    WSACleanup();
    return 0;
}

void initialization() {
    //初始化套接字庫
    WORD w_req = MAKEWORD(2, 2);//版本號
    WSADATA wsadata;
    int err;
    err = WSAStartup(w_req, &wsadata);
    if (err != 0) {
        cout << "init faied!" << endl;
    }
    else {
        cout << "init success!" << endl;
    }
    //檢測版本號
    if (LOBYTE(wsadata.wVersion) != 2 || HIBYTE(wsadata.wHighVersion) != 2) {
        cout << "version error!" << endl;
        WSACleanup();
    }
    else {
        cout << "version right!" << endl;
    }
    //填充服務端地址信息

}