欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Python Socket編程入門教程

 更新時間:2014年07月11日 09:24:45   投稿:junjie  
這篇文章主要介紹了Python Socket編程入門教程,本文包含一個客戶端Socket編程實(shí)現(xiàn)和一個服務(wù)器端Socket編程例子,需要的朋友可以參考下

這是用來快速學(xué)習(xí) Python Socket 套接字編程的指南和教程。Python 的 Socket 編程跟 C 語言很像。
Python 官方關(guān)于 Socket 的函數(shù)請看 http://docs.python.org/library/socket.html
基本上,Socket 是任何一種計(jì)算機(jī)網(wǎng)絡(luò)通訊中最基礎(chǔ)的內(nèi)容。例如當(dāng)你在瀏覽器地址欄中輸入 www.dbjr.com.cn 時,你會打開一個套接字,然后連接到 www.dbjr.com.cn 并讀取響應(yīng)的頁面然后然后顯示出來。而其他一些聊天客戶端如 gtalk 和 skype 也是類似。任何網(wǎng)絡(luò)通訊都是通過 Socket 來完成的。

寫在開頭

本教程假設(shè)你已經(jīng)有一些基本的 Python 編程的知識。
讓我們開始 Socket 編程吧。

創(chuàng)建 Socket

首先要做的就是創(chuàng)建一個 Socket,socket 的 socket 函數(shù)可以實(shí)現(xiàn),代碼如下:

復(fù)制代碼 代碼如下:

#Socket client example in python

import socket #for sockets

#create an AF_INET, STREAM socket (TCP)
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

print 'Socket Created'

函數(shù) socket.socket 創(chuàng)建了一個 Socket,并返回 Socket 的描述符可用于其他 Socket 相關(guān)的函數(shù)。
上述代碼使用了下面兩個屬性來創(chuàng)建 Socket:
地址簇 : AF_INET (IPv4)
類型: SOCK_STREAM (使用 TCP 傳輸控制協(xié)議)

錯誤處理

如果 socket 函數(shù)失敗了,python 將拋出一個名為 socket.error 的異常,這個異常必須予以處理:

復(fù)制代碼 代碼如下:

#handling errors in python socket programs

import socket #for sockets
import sys #for exit

try:
    #create an AF_INET, STREAM socket (TCP)
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error, msg:
    print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1]
    sys.exit();

print 'Socket Created'

好了,假設(shè)你已經(jīng)成功創(chuàng)建了 Socket,下一步該做什么呢?接下來我們將使用這個 Socket 來連接到服務(wù)器。

注意:

與 SOCK_STREAM 相對應(yīng)的其他類型是 SOCK_DGRAM 用于 UDP 通訊協(xié)議,UDP 通訊是非連接 Socket,在這篇文章中我們只討論 SOCK_STREAM ,或者叫 TCP 。

連接到服務(wù)器

連接到服務(wù)器需要服務(wù)器地址和端口號,這里使用的是 www.dbjr.com.cn 和 80 端口。

首先獲取遠(yuǎn)程主機(jī)的 IP 地址

連接到遠(yuǎn)程主機(jī)之前,我們需要知道它的 IP 地址,在 Python 中,獲取 IP 地址是很簡單的:

復(fù)制代碼 代碼如下:

import socket #for sockets
import sys #for exit

try:
    #create an AF_INET, STREAM socket (TCP)
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error, msg:
    print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1]
    sys.exit();

print 'Socket Created'

host = 'www.dbjr.com.cn'

try:
    remote_ip = socket.gethostbyname( host )

except socket.gaierror:
    #could not resolve
    print 'Hostname could not be resolved. Exiting'
    sys.exit()
   
print 'Ip address of ' + host + ' is ' + remote_ip

我們已經(jīng)有 IP 地址了,接下來需要指定要連接的端口。
代碼:

復(fù)制代碼 代碼如下:

import socket #for sockets
import sys #for exit

try:
    #create an AF_INET, STREAM socket (TCP)
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error, msg:
    print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1]
    sys.exit();

print 'Socket Created'

host = 'www.dbjr.com.cn'
port = 80

try:
    remote_ip = socket.gethostbyname( host )

except socket.gaierror:
    #could not resolve
    print 'Hostname could not be resolved. Exiting'
    sys.exit()
   
print 'Ip address of ' + host + ' is ' + remote_ip

#Connect to remote server
s.connect((remote_ip , port))

print 'Socket Connected to ' + host + ' on ip ' + remote_ip

現(xiàn)在運(yùn)行程序

復(fù)制代碼 代碼如下:

$ python client.py
Socket Created
Ip address of www.dbjr.com.cn is 61.145.122.155
Socket Connected to www.dbjr.com.cn on ip 61.145.122.155

這段程序創(chuàng)建了一個 Socket 并進(jìn)行連接,試試使用其他一些不存在的端口(如81)會是怎樣?這個邏輯相當(dāng)于構(gòu)建了一個端口掃描器。
已經(jīng)連接上了,接下來就是往服務(wù)器上發(fā)送數(shù)據(jù)。

友情提示

使用 SOCK_STREAM/TCP 套接字才有“連接”的概念。連接意味著可靠的數(shù)據(jù)流通訊機(jī)制,可以同時有多個數(shù)據(jù)流??梢韵胂蟪梢粋€數(shù)據(jù)互不干擾的管道。另外一個重要的提示是:數(shù)據(jù)包的發(fā)送和接收是有順序的。
其他一些 Socket 如 UDP、ICMP 和 ARP 沒有“連接”的概念,它們是無連接通訊,意味著你可從任何人或者給任何人發(fā)送和接收數(shù)據(jù)包。

發(fā)送數(shù)據(jù)

sendall 函數(shù)用于簡單的發(fā)送數(shù)據(jù),我們來向 oschina 發(fā)送一些數(shù)據(jù):

復(fù)制代碼 代碼如下:

import socket #for sockets
import sys #for exit

try:
    #create an AF_INET, STREAM socket (TCP)
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error, msg:
    print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1]
    sys.exit();

print 'Socket Created'

host = 'www.dbjr.com.cn'
port = 80

try:
    remote_ip = socket.gethostbyname( host )

except socket.gaierror:
    #could not resolve
    print 'Hostname could not be resolved. Exiting'
    sys.exit()
   
print 'Ip address of ' + host + ' is ' + remote_ip

#Connect to remote server
s.connect((remote_ip , port))

print 'Socket Connected to ' + host + ' on ip ' + remote_ip

#Send some data to remote server
message = "GET / HTTP/1.1\r\n\r\n"

try :
    #Set the whole string
    s.sendall(message)
except socket.error:
    #Send failed
    print 'Send failed'
    sys.exit()

print 'Message send successfully'

上述例子中,首先連接到目標(biāo)服務(wù)器,然后發(fā)送字符串?dāng)?shù)據(jù) "GET / HTTP/1.1\r\n\r\n" ,這是一個 HTTP 協(xié)議的命令,用來獲取網(wǎng)站首頁的內(nèi)容。

接下來需要讀取服務(wù)器返回的數(shù)據(jù)。

接收數(shù)據(jù)

recv 函數(shù)用于從 socket 接收數(shù)據(jù):

復(fù)制代碼 代碼如下:

#Socket client example in python

import socket #for sockets
import sys #for exit

#create an INET, STREAMing socket
try:
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error:
    print 'Failed to create socket'
    sys.exit()
   
print 'Socket Created'

host = 'jb51.net';
port = 80;

try:
    remote_ip = socket.gethostbyname( host )

except socket.gaierror:
    #could not resolve
    print 'Hostname could not be resolved. Exiting'
    sys.exit()

#Connect to remote server
s.connect((remote_ip , port))

print 'Socket Connected to ' + host + ' on ip ' + remote_ip

#Send some data to remote server
message = "GET / HTTP/1.1\r\nHost: jb51.net\r\n\r\n"

try :
    #Set the whole string
    s.sendall(message)
except socket.error:
    #Send failed
    print 'Send failed'
    sys.exit()

print 'Message send successfully'

#Now receive data
reply = s.recv(4096)

print reply

下面是上述程序執(zhí)行的結(jié)果:

復(fù)制代碼 代碼如下:

$ python client.py
Socket Created
Ip address of jb51.net is 61.145.122.
Socket Connected to jb51.net on ip 61.145.122.155
Message send successfully
HTTP/1.1 301 Moved Permanently
Server: nginx
Date: Wed, 24 Oct 2012 13:26:46 GMT
Content-Type: text/html
Content-Length: 178
Connection: keep-alive
Keep-Alive: timeout=20
Location: http://www.dbjr.com.cn/

jb51.net 回應(yīng)了我們所請求的 URL 的內(nèi)容,很簡單。數(shù)據(jù)接收完了,可以關(guān)閉 Socket 了。

關(guān)閉 socket

close 函數(shù)用于關(guān)閉 Socket:

復(fù)制代碼 代碼如下:
s.close()

這就是了。

讓我們回顧一下

上述的示例中我們學(xué)到了如何:
1. 創(chuàng)建 Socket
2. 連接到遠(yuǎn)程服務(wù)器
3. 發(fā)送數(shù)據(jù)
4. 接收回應(yīng)

當(dāng)你用瀏覽器打開 www.dbjr.com.cn 時,其過程也是一樣。包含兩種類型,分別是客戶端和服務(wù)器,客戶端連接到服務(wù)器并讀取數(shù)據(jù),服務(wù)器使用 Socket 接收進(jìn)入的連接并提供數(shù)據(jù)。因此在這里 www.dbjr.com.cn 是服務(wù)器端,而你的瀏覽器是客戶端。
接下來我們開始在服務(wù)器端做點(diǎn)編碼。

服務(wù)器端編程

服務(wù)器端編程主要包括下面幾步:
1. 打開 socket
2. 綁定到一個地址和端口
3. 偵聽進(jìn)來的連接
4. 接受連接
5. 讀寫數(shù)據(jù)
我們已經(jīng)學(xué)習(xí)過如何打開 Socket 了,下面是綁定到指定的地址和端口上。

綁定 Socket

bind 函數(shù)用于將 Socket 綁定到一個特定的地址和端口,它需要一個類似 connect 函數(shù)所需的 sockaddr_in 結(jié)構(gòu)體。
示例代碼:

復(fù)制代碼 代碼如下:

import socket
import sys

HOST = '' # Symbolic name meaning all available interfaces
PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print 'Socket created'

try:
    s.bind((HOST, PORT))
except socket.error , msg:
    print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1]
    sys.exit()
   
print 'Socket bind complete'

綁定完成后,就需要讓 Socket 開始偵聽連接。很顯然,你不能將兩個不同的 Socket 綁定到同一個端口之上。

連接偵聽

綁定 Socket 之后就可以開始偵聽連接,我們需要將 Socket 變成偵聽模式。socket 的 listen 函數(shù)用于實(shí)現(xiàn)偵聽模式:

復(fù)制代碼 代碼如下:

s.listen(10)
print 'Socket now listening'

listen 函數(shù)所需的參數(shù)成為 backlog,用來控制程序忙時可保持等待狀態(tài)的連接數(shù)。這里我們傳遞的是 10,意味著如果已經(jīng)有 10 個連接在等待處理,那么第 11 個連接將會被拒絕。當(dāng)檢查了 socket_accept 后這個會更加清晰。

接受連接
示例代碼:

復(fù)制代碼 代碼如下:

import socket
import sys

HOST = '' # Symbolic name meaning all available interfaces
PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print 'Socket created'

try:
    s.bind((HOST, PORT))
except socket.error , msg:
    print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1]
    sys.exit()
   
print 'Socket bind complete'

s.listen(10)
print 'Socket now listening'

#wait to accept a connection - blocking call
conn, addr = s.accept()

#display client information
print 'Connected with ' + addr[0] + ':' + str(addr[1])

輸出
運(yùn)行該程序?qū)@示:

復(fù)制代碼 代碼如下:
$ python server.py
Socket created
Socket bind complete
Socket now listening

現(xiàn)在這個程序開始等待連接進(jìn)入,端口是 8888,請不要關(guān)閉這個程序,我們來通過 telnet 程序來進(jìn)行測試。
打開命令行窗口并輸入:

復(fù)制代碼 代碼如下:
$ telnet localhost 8888

It will immediately show
$ telnet localhost 8888
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Connection closed by foreign host.


而服務(wù)器端窗口顯示的是:
復(fù)制代碼 代碼如下:
$ python server.py
Socket created
Socket bind complete
Socket now listening
Connected with 127.0.0.1:59954

我們可看到客戶端已經(jīng)成功連接到服務(wù)器。
上面例子我們接收到連接并立即關(guān)閉,這樣的程序沒什么實(shí)際的價值,連接建立后一般會有大量的事情需要處理,因此讓我們來給客戶端做出點(diǎn)回應(yīng)吧。
sendall 函數(shù)可通過 Socket 給客戶端發(fā)送數(shù)據(jù):

復(fù)制代碼 代碼如下:

import socket
import sys

HOST = '' # Symbolic name meaning all available interfaces
PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print 'Socket created'

try:
    s.bind((HOST, PORT))
except socket.error , msg:
    print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1]
    sys.exit()
   
print 'Socket bind complete'

s.listen(10)
print 'Socket now listening'

#wait to accept a connection - blocking call
conn, addr = s.accept()

print 'Connected with ' + addr[0] + ':' + str(addr[1])

#now keep talking with the client
data = conn.recv(1024)
conn.sendall(data)

conn.close()
s.close()

繼續(xù)運(yùn)行上述代碼,然后打開另外一個命令行窗口輸入下面命令:

復(fù)制代碼 代碼如下:
$ telnet localhost 8888
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
happy
happy
Connection closed by foreign host.

可看到客戶端接收到來自服務(wù)器端的回應(yīng)內(nèi)容。
上面的例子還是一樣,服務(wù)器端回應(yīng)后就立即退出了。而一些真正的服務(wù)器像 www.dbjr.com.cn 是一直在運(yùn)行的,時刻接受連接請求。
也就是說服務(wù)器端應(yīng)該一直處于運(yùn)行狀態(tài),否則就不能成為“服務(wù)”,因此我們要讓服務(wù)器端一直運(yùn)行,最簡單的方法就是把 accept 方法放在一個循環(huán)內(nèi)。

一直在運(yùn)行的服務(wù)器

對上述代碼稍作改動:

復(fù)制代碼 代碼如下:

import socket
import sys

HOST = '' # Symbolic name meaning all available interfaces
PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print 'Socket created'

try:
    s.bind((HOST, PORT))
except socket.error , msg:
    print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1]
    sys.exit()
   
print 'Socket bind complete'

s.listen(10)
print 'Socket now listening'

#now keep talking with the client
while 1:
    #wait to accept a connection - blocking call
    conn, addr = s.accept()
    print 'Connected with ' + addr[0] + ':' + str(addr[1])
   
    data = conn.recv(1024)
    reply = 'OK...' + data
    if not data:
        break
   
    conn.sendall(reply)

conn.close()
s.close()

很簡單只是加多一個 while 1 語句而已。
繼續(xù)運(yùn)行服務(wù)器,然后打開另外三個命令行窗口。每個窗口都使用 telnet 命令連接到服務(wù)器:

復(fù)制代碼 代碼如下:
$ telnet localhost 5000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
happy
OK .. happy
Connection closed by foreign host.

服務(wù)器所在的終端窗口顯示的是:
復(fù)制代碼 代碼如下:
$ python server.py
Socket created
Socket bind complete
Socket now listening
Connected with 127.0.0.1:60225
Connected with 127.0.0.1:60237
Connected with 127.0.0.1:60239

你看服務(wù)器再也不退出了,好吧,用 Ctrl+C 關(guān)閉服務(wù)器,所有的 telnet 終端將會顯示 "Connection closed by foreign host."
已經(jīng)很不錯了,但是這樣的通訊效率太低了,服務(wù)器程序使用循環(huán)來接受連接并發(fā)送回應(yīng),這相當(dāng)于是一次最多處理一個客戶端的請求,而我們要求服務(wù)器可同時處理多個請求。

處理多個連接

為了處理多個連接,我們需要一個獨(dú)立的處理代碼在主服務(wù)器接收到連接時運(yùn)行。一種方法是使用線程,服務(wù)器接收到連接然后創(chuàng)建一個線程來處理連接收發(fā)數(shù)據(jù),然后主服務(wù)器程序返回去接收新的連接。
下面是我們使用線程來處理連接請求:

復(fù)制代碼 代碼如下:
import socket
import sys
from thread import *

HOST = '' # Symbolic name meaning all available interfaces
PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print 'Socket created'

#Bind socket to local host and port
try:
    s.bind((HOST, PORT))
except socket.error , msg:
    print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1]
    sys.exit()
   
print 'Socket bind complete'

#Start listening on socket
s.listen(10)
print 'Socket now listening'

#Function for handling connections. This will be used to create threads
def clientthread(conn):
    #Sending message to connected client
    conn.send('Welcome to the server. Type something and hit enter\n') #send only takes string
   
    #infinite loop so that function do not terminate and thread do not end.
    while True:
       
        #Receiving from client
        data = conn.recv(1024)
        reply = 'OK...' + data
        if not data:
            break
   
        conn.sendall(reply)
   
    #came out of loop
    conn.close()

#now keep talking with the client
while 1:
    #wait to accept a connection - blocking call
    conn, addr = s.accept()
    print 'Connected with ' + addr[0] + ':' + str(addr[1])
   
    #start new thread takes 1st argument as a function name to be run, second is the tuple of arguments to the function.
    start_new_thread(clientthread ,(conn,))

s.close()

運(yùn)行上述服務(wù)端程序,然后像之前一樣打開三個終端窗口并執(zhí)行 telent 命令:

復(fù)制代碼 代碼如下:
$ telnet localhost 8888
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Welcome to the server. Type something and hit enter
hi
OK...hi
asd
OK...asd
cv
OK...cv

服務(wù)器端所在終端窗口輸出信息如下:
復(fù)制代碼 代碼如下:
$ python server.py
Socket created
Socket bind complete
Socket now listening
Connected with 127.0.0.1:60730
Connected with 127.0.0.1:60731

線程接管了連接并返回相應(yīng)數(shù)據(jù)給客戶端。
這便是我們所要介紹的服務(wù)器端編程。

結(jié)論

到這里為止,你已經(jīng)學(xué)習(xí)了 Python 的 Socket 基本編程,你可自己動手編寫一些例子來強(qiáng)化這些知識。
你可能會遇見一些問題:Bind failed. Error Code : 98 Message Address already in use,碰見這種問題只需要簡單更改服務(wù)器端口即可。

相關(guān)文章

  • Python字典的基礎(chǔ)操作

    Python字典的基礎(chǔ)操作

    這篇文章主要介紹了Python字典的基礎(chǔ)操作,Python中的字典數(shù)據(jù)類型和現(xiàn)實(shí)中的字典很像,它是以鍵值對(鍵和值的組合)的方式把數(shù)據(jù)組織到一起,可以通過鍵找到與之對應(yīng)的值并進(jìn)行操作,下面來看文章金額提內(nèi)容吧,需要的朋友可以參考一下
    2021-11-11
  • python 使用遞歸的方式實(shí)現(xiàn)語義圖片分割功能

    python 使用遞歸的方式實(shí)現(xiàn)語義圖片分割功能

    這篇文章主要介紹了python 使用遞歸的方式實(shí)現(xiàn)語義圖片分割,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2020-07-07
  • Python文件操作之二進(jìn)制文件詳解

    Python文件操作之二進(jìn)制文件詳解

    下面小編就為大家?guī)硪黄褂肞ython文件操作之二進(jìn)制文件。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2021-09-09
  • python list是否包含另一個list所有元素的實(shí)例

    python list是否包含另一個list所有元素的實(shí)例

    今天小編就為大家分享一篇python list是否包含另一個list所有元素的實(shí)例,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2018-05-05
  • Python數(shù)據(jù)結(jié)構(gòu)列表

    Python數(shù)據(jù)結(jié)構(gòu)列表

    這篇文章主要介紹了Python數(shù)據(jù)結(jié)構(gòu)列表,本文重點(diǎn)內(nèi)容主要是對列表數(shù)據(jù)結(jié)構(gòu)的使用,在Python中,序列是一組按順序排列的值。Python?有?3?種內(nèi)置的序列類型:字符串、?元組和列表,下面一起進(jìn)入文章了解更詳細(xì)內(nèi)容吧,需要的小伙伴可以參考一下</P><P>
    2021-12-12
  • 解決python 3 urllib 沒有 urlencode 屬性的問題

    解決python 3 urllib 沒有 urlencode 屬性的問題

    今天小編就為大家分享一篇解決python 3 urllib 沒有 urlencode 屬性的問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2019-08-08
  • 最新評論