2019-11-19 Python

一、55_長連接

"""單進(jìn)程-單線程-非阻塞-長連接"""

import socket

import re

def service_client(new_socket, request):

"""為客戶端返回數(shù)據(jù)"""

? ? # 1、接收瀏覽器發(fā)送過來的請求, 即http請求

# -->例GET /index.html HTTP/1.1 .....

# http://127.0.0.1:7890/

# http://127.0.0.1:7890/index.html

# request = new_socket.recv(1024).decode("utf-8")

? ? """【.decode:解碼】"""

? ? # print("-*-" * 20)

# print(request)

? ? request_lines = request.splitlines()

print("")

print("-*-" *20)

print(request_lines)

# GET / HTTP/1.1

# GET /index.html HTTP/1.1

# get post put del.....

? ? ret = re.match(r"[^/]+/([^ ]*)", request_lines[0])

file_name =""

? ? if ret:

file_name = ret.group(1)

print("*" *50, file_name)

if file_name =="/":

file_name ='/inedx.html'

? ? # 2、返回http格式的數(shù)據(jù)給瀏覽器

? ? try:

# f = open("../buickmall/indexhtml", "rb")

? ? ? ? f =open("../buickmall" + file_name, "rb")

"""【rb:二進(jìn)制讀】"""

? ? except:

response ="HTTP/1.1 404 NOT FOUND\r\n"

? ? ? ? response +="\r\n"

? ? ? ? response +="---file not found---"

? ? ? ? new_socket.send(response.encode("utf-8"))

"""如果網(wǎng)址或(進(jìn)程)出錯時該給用戶顯示什么"""

? ? else:

html_content = f.read()

f.close()

# 2.2 準(zhǔn)備給瀏覽器發(fā)送的數(shù)據(jù) :Body

? ? ? ? response_body += html_content

# 2.1 準(zhǔn)備給瀏覽器發(fā)送的數(shù)據(jù) :Header

? ? ? ? response_header ="HTTP/1.1 200 OK\r\n"

? ? ? ? response_header +="Content-Length:%d\r\n" %len(response_body)

response +="\r\n"

? ? ? ? """【\r\n: 換行(兼容所有的瀏覽器)】"""

? ? ? ? response = response_header.encode("utf-8") + response_body

# 將Response發(fā)送給瀏覽器

? ? ? ? new_socket.send(response)

# 關(guān)閉套接字

# new_socket.close()

def main():

"""用來整體控制"""

? ? # 1、創(chuàng)建套接字

? ? tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

"""選擇讓服務(wù)端先關(guān)閉"""

? ? # 2尿贫、綁定; 參數(shù)("任意服務(wù)端ip", 端口)

? ? tcp_server_socket.bind(("", 7890))

# 3、變?yōu)楸O(jiān)聽的套接字; 【listen:最大鏈接數(shù)】

? ? tcp_server_socket.listen(128)

tcp_server_socket.setblocking(False)# 套接字變?yōu)榉亲枞?/p>

? ? client_socket_list =list()

while True:

# 4、等待新客戶端的連接; 變量【新客戶端的套接字, 客戶端的IP锥咸、端口】

? ? ? ? try:

new_socket, client_addr = tcp_server_socket.accept()

except Exception as ret:

pass

? ? ? ? else:

new_socket.setblocking(False)

client_socket_list.append(new_socket)

for client_socketin client_socket_list:

try:

recv_data = client_socket.recv(1024).decode("utf-8")

except Exception as ret:

pass

? ? ? ? ? ? else:

if recv_data:

# 5、為這個客戶端服務(wù)

? ? ? ? ? ? ? ? ? ? service_client(client_socket, recv_data)

else:

client_socket.close()

client_socket_list.remove(client_socket)

# 6细移、關(guān)閉監(jiān)聽套接字

? ? tcp_server_socket.close(new_socket)

if __name__ =='__main__':

main()

二搏予、56_epoll的原理

單進(jìn)程服務(wù)器-epoll【Linux服務(wù)器采用方式】

1、共享內(nèi)存

2弧轧、事件通知雪侥;而不是輪詢

(答辯題)

三、55_長短鏈接

Tcp長連接和短連接(服務(wù)器一般都是長連接)

一精绎、HTTP/1.0:【短連接】

為了獲取一個新的數(shù)據(jù)需要, 每次都要三次握手四次揮手

二速缨、HTTP/1.1:【長連接】

通過一個套接字獲取多個數(shù)據(jù)

四、57_epoll實(shí)現(xiàn)http

"""epoll實(shí)現(xiàn)http"""

import socket

import re

import select

def service_client(new_socket, request):

"""為客戶端返回數(shù)據(jù)"""

? ? # 1代乃、接收瀏覽器發(fā)送過來的請求, 即http請求

# -->例GET /index.html HTTP/1.1 .....

# http://127.0.0.1:7890/

# http://127.0.0.1:7890/index.html

# request = new_socket.recv(1024).decode("utf-8")

? ? """【.decode:解碼】"""

? ? # print("-*-" * 20)

# print(request)

? ? request_lines = request.splitlines()

print("")

print("-*-" *20)

print(request_lines)

# GET / HTTP/1.1

# GET /index.html HTTP/1.1

# get post put del.....

? ? ret = re.match(r"[^/]+/([^ ]*)", request_lines[0])

file_name =""

? ? if ret:

file_name = ret.group(1)

print("*" *50, file_name)

if file_name =="/":

file_name ='/inedx.html'

? ? # 2旬牲、返回http格式的數(shù)據(jù)給瀏覽器

? ? try:

# f = open("../buickmall/indexhtml", "rb")

? ? ? ? f =open("../buickmall" + file_name, "rb")

"""【rb:二進(jìn)制讀】"""

? ? except:

response ="HTTP/1.1 404 NOT FOUND\r\n"

? ? ? ? response +="\r\n"

? ? ? ? response +="---file not found---"

? ? ? ? new_socket.send(response.encode("utf-8"))

"""如果網(wǎng)址或(進(jìn)程)出錯時該給用戶顯示什么"""

? ? else:

html_content = f.read()

f.close()

# 2.2 準(zhǔn)備給瀏覽器發(fā)送的數(shù)據(jù) :Body

? ? ? ? response_body += html_content

# 2.1 準(zhǔn)備給瀏覽器發(fā)送的數(shù)據(jù) :Header

? ? ? ? response_header ="HTTP/1.1 200 OK\r\n"

? ? ? ? response_header +="Content-Length:%d\r\n" %len(response_body)

response +="\r\n"

? ? ? ? """【\r\n: 換行(兼容所有的瀏覽器)】"""

? ? ? ? response = response_header.encode("utf-8") + response_body

# 將Response發(fā)送給瀏覽器

? ? ? ? new_socket.send(response)

# 關(guān)閉套接字

# new_socket.close()

def main():

"""用來整體控制"""

? ? # 1、創(chuàng)建套接字

? ? tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

"""選擇讓服務(wù)端先關(guān)閉"""

? ? # 2搁吓、綁定; 參數(shù)("任意服務(wù)端ip", 端口)

? ? tcp_server_socket.bind(("", 7890))

# 3原茅、變?yōu)楸O(jiān)聽的套接字; 【listen:最大鏈接數(shù)】

? ? tcp_server_socket.listen(128)

tcp_server_socket.setblocking(False)# 套接字變?yōu)榉亲枞?/p>

# 創(chuàng)建一個epoll對象

? ? epl = select.epoll()

# 將監(jiān)聽的套接字FD注冊到epoll中

? ? epl.register(tcp_server_socket.fileno(), select.EPOLLIN)

"""【register:注冊【fileno():FD】"""

? ? fd_event_dict =dict()

while True:

fd_event_list = epl.poll()

"""poll():默認(rèn)會阻塞,數(shù)據(jù)到來時,os時件通知的方式告訴程序"""

? ? ? ? # [(fd, event),(),.....] 【fd:文件描述符(是一個數(shù)字)】

# 參數(shù)fd: 套接字對應(yīng)的文件描述符】

# 參數(shù)event: 此fd是什么事件; 標(biāo)記這個東西是可以收的還是發(fā)的】

? ? ? ? for fd, eventin fd_event_list:

# 4、等待新客戶端的連接; 變量【新客戶端的套接字, 客戶端的IP堕仔、端口】

? ? ? ? ? ? if fd== tcp_server_socket.fileno():

new_socket, client_addr = tcp_server_socket.accept()

"""調(diào)用accept前的東西,它得是一個套接字的對象"""

? ? ? ? ? ? ? ? epl.register(new_socket.fileno(), select.EPOLLIN)

fd_event_dict[new_socket.fileno()] = new_socket

elif event == select.EPOLLIN:

# 判斷已經(jīng)連接的客戶端是否有數(shù)據(jù)發(fā)送過來

? ? ? ? ? ? ? ? recv_data = fd_event_dict[fd].recv(1024).decode("utf-8")

if recv_data:

# 5员咽、為這個客戶端服務(wù)

? ? ? ? ? ? ? ? ? ? service_client(fd_event_dict[fd], recv_data)

else:

fd_event_dict[fd].close()

epl.unregister(fd)

del fd_event_dict[fd]

# 6、關(guān)閉監(jiān)聽套接字

? ? tcp_server_socket.close(new_socket)

if __name__ =='__main__':

main()

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末贮预,一起剝皮案震驚了整個濱河市贝室,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌仿吞,老刑警劉巖滑频,帶你破解...
    沈念sama閱讀 223,126評論 6 520
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異唤冈,居然都是意外死亡峡迷,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,421評論 3 400
  • 文/潘曉璐 我一進(jìn)店門孽江,熙熙樓的掌柜王于貴愁眉苦臉地迎上來阴孟,“玉大人,你說我怎么就攤上這事麦乞『幌剑” “怎么了琉预?”我有些...
    開封第一講書人閱讀 169,941評論 0 366
  • 文/不壞的土叔 我叫張陵,是天一觀的道長蒿褂。 經(jīng)常有香客問我圆米,道長,這世上最難降的妖魔是什么啄栓? 我笑而不...
    開封第一講書人閱讀 60,294評論 1 300
  • 正文 為了忘掉前任娄帖,我火速辦了婚禮,結(jié)果婚禮上昙楚,老公的妹妹穿的比我還像新娘近速。我一直安慰自己,他們只是感情好堪旧,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,295評論 6 398
  • 文/花漫 我一把揭開白布数焊。 她就那樣靜靜地躺著,像睡著了一般崎场。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上遂蛀,一...
    開封第一講書人閱讀 52,874評論 1 314
  • 那天谭跨,我揣著相機(jī)與錄音,去河邊找鬼李滴。 笑死螃宙,一個胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的所坯。 我是一名探鬼主播谆扎,決...
    沈念sama閱讀 41,285評論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼芹助!你這毒婦竟也來了堂湖?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 40,249評論 0 277
  • 序言:老撾萬榮一對情侶失蹤状土,失蹤者是張志新(化名)和其女友劉穎无蜂,沒想到半個月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體蒙谓,經(jīng)...
    沈念sama閱讀 46,760評論 1 321
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡斥季,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,840評論 3 343
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片酣倾。...
    茶點(diǎn)故事閱讀 40,973評論 1 354
  • 序言:一個原本活蹦亂跳的男人離奇死亡舵揭,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出躁锡,到底是詐尸還是另有隱情午绳,我是刑警寧澤,帶...
    沈念sama閱讀 36,631評論 5 351
  • 正文 年R本政府宣布稚铣,位于F島的核電站箱叁,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏惕医。R本人自食惡果不足惜耕漱,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,315評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望抬伺。 院中可真熱鬧螟够,春花似錦、人聲如沸峡钓。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,797評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽能岩。三九已至寞宫,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間拉鹃,已是汗流浹背辈赋。 一陣腳步聲響...
    開封第一講書人閱讀 33,926評論 1 275
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留膏燕,地道東北人钥屈。 一個月前我還...
    沈念sama閱讀 49,431評論 3 379
  • 正文 我出身青樓,卻偏偏與公主長得像坝辫,于是被迫代替她去往敵國和親篷就。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,982評論 2 361