要進(jìn)行網(wǎng)絡(luò)通信,需要建立起通信雙方的連接,連接的雙方分別稱為客戶端和服務(wù)端,在Python中,使用套接字socket來(lái)建立起網(wǎng)絡(luò)連接。
套接字包含在socket模塊中:
import socket socket.socket()
對(duì)于客戶端和服務(wù)端,都是使用socket來(lái)建立連接的,但是在使用行為上,客戶端和服務(wù)端會(huì)有一些不一樣。
服務(wù)端建立需要四個(gè)步驟:新建socket、綁定IP和端口(bind)、監(jiān)聽(tīng)連接(listen)、接受連接(accept)。
客戶端建立則簡(jiǎn)單一些,僅需兩個(gè)步驟:新建socket、連接服務(wù)端(connect)。
當(dāng)網(wǎng)絡(luò)連接上以后,客戶端和服務(wù)端就可以進(jìn)行數(shù)據(jù)通信了,套接字通過(guò)send()函數(shù)發(fā)送數(shù)據(jù),通過(guò)recv()函數(shù)接收數(shù)據(jù)。
先看服務(wù)端的過(guò)程,新建一個(gè)server.py的文件:
import socket server = socket.socket() # 1. 新建socket server.bind(('127.0.0.1', 8999)) # 2. 綁定IP和端口(其中127.0.0.1為本機(jī)回環(huán)IP) server.listen(5) # 3. 監(jiān)聽(tīng)連接 s, addr = server.accept() # 4. 接受連接 print('connect addr:{}'.format(addr)) content =s.recv(1024) print(str(content, encoding='utf-8')) # 接受來(lái)自客戶端的消息,并編碼打印出來(lái) s.close()
如上,服務(wù)端就編寫完畢,接下來(lái)是編寫客戶端,新建一個(gè)client.py的文件:
import socket client = socket.socket() # 1. 新建socket client.connect(('127.0.0.1', 8999)) # 2. 連接服務(wù)端(注意,IP和端口要和服務(wù)端一致) client.send(bytes('Hello World. Hello Socket', encoding='utf-8')) # 發(fā)送內(nèi)容,注意發(fā)送的是字節(jié)字符串。 client.close()
接著在一個(gè)終端先運(yùn)行服務(wù)端:
python server.py
然后再在另外一個(gè)終端運(yùn)行客戶端:
python client.py
在服務(wù)端的終端,將會(huì)輸出以下信息:
connect addr:('127.0.0.1', 50382) b'Hello World. Hello Socket'
請(qǐng)改造server.py和client.py文件,實(shí)現(xiàn)一個(gè)echo服務(wù)器,使得client.py可以循環(huán)接收用戶輸入并發(fā)送給服務(wù)端,服務(wù)端在收到消息后,也把消息原樣返回給client。
1. 請(qǐng)同學(xué)在本地編寫代碼練習(xí)
2. 通過(guò)input()可以接收用戶的輸入。
參考答案:
服務(wù)端:
import socket server = socket.socket() # 1. 新建socket server.bind(('127.0.0.1', 8999)) # 2. 綁定IP和端口(其中127.0.0.1為本機(jī)回環(huán)IP) server.listen(5) # 3. 監(jiān)聽(tīng)連接 s, addr = server.accept() # 4. 接受連接 print('connect addr:{}'.format(addr)) while True: content =s.recv(1024) if len(content) == 0: break s.send(content) print(str(content, encoding='utf-8')) # 接受來(lái)自客戶端的消息,并打印出來(lái) s.close()
客戶端:
import socket client = socket.socket() # 1. 新建socket client.connect(('127.0.0.1', 8999)) # 2. 連接服務(wù)端(注意,IP和端口要和服務(wù)端一致) while True: content = input('>>> ') client.send(bytes(content, 'utf-8')) # 發(fā)送內(nèi)容,注意發(fā)送的是字節(jié)字符串。 content = client.recv(1024) print(str(content, encoding='utf-8')) client.close()
請(qǐng)驗(yàn)證,完成請(qǐng)求
由于請(qǐng)求次數(shù)過(guò)多,請(qǐng)先驗(yàn)證,完成再次請(qǐng)求
打開微信掃碼自動(dòng)綁定
綁定后可得到
使用 Ctrl+D 可將課程添加到書簽
舉報(bào)