首頁 >後端開發 >Python教學 >python socket程式設計入門

python socket程式設計入門

高洛峰
高洛峰原創
2016-10-18 11:14:351069瀏覽

python 寫server的步驟:

1. 第一步是建立socket物件。呼叫socket構造函數。如:

socket = socket.socket( family, type )

family參數代表地址家族,可為AF_INET或AF_UNIX。 AF_INET家族包含Internet位址,AF_UNIX家族用於同一台機器上的進程間通訊。

type參數代表套接字類型,可為SOCK_STREAM(流套接字)和SOCK_DGRAM(資料報套接字)。

2. 第二步是將socket綁定到指定位址。這是透過socket物件的bind方法來實現的:

socket.bind( address )

由AF_INET所建立的套接字,address位址必須是雙元素元組,格式是(host,port)。 host代表主機,port代表連接埠號碼。如果連接埠號碼正在使用、主機名稱不正確或連接埠已保留,bind方法將引發socket.error異常。

3. 第三步是使用socket套接字的listen方法接收連線請求。

socket.listen( backlog )

backlog指定最多允許多少個客戶連接到伺服器。它的值至少為1。收到連線請求後,這些請求需要排隊,如果佇列滿,就拒絕請求。

4. 第四步是伺服器套接字透過socket的accept方法等待客戶請求一個連線。

connection, address = socket.accept()

調 用accept方法時,socket會時入「waiting」狀態。客戶請求連線時,方法建立連線並返回伺服器。 accept方法傳回一個含有兩個元素的 元組(connection,address)。第一個元素connection是新的socket對象,伺服器必須透過它與客戶通訊;第二個元素 address是客戶的Internet位址。

5. 第五步是處理階段,伺服器和客戶端透過send和recv方法通訊(傳輸 資料)。伺服器呼叫send,並採用字串形式向客戶發送訊息。 send方法傳回已傳送的字元個數。伺服器使用recv方法從客戶接收訊息。當呼叫recv 時,伺服器必須指定一個整數,它對應到可透過本次方法呼叫來接收的最大資料量。 recv方法在接收資料時會進入「blocked」狀態,最後傳回一個字元 字串,用它表示收到的資料。如果發送的資料量超過了recv所允許的,則資料會被截短。多餘的資料將緩衝於接收端。以後呼叫recv時,多餘的資料會從緩衝區 刪除(以及自上次呼叫recv以來,客戶可能發送的其它任何資料)。

6. 傳輸結束,伺服器呼叫socket的close方法關閉連線。

python編寫client的步驟:

1. 建立一個socket以連接伺服器:socket = socket.socket( family, type )

2.使用socket的connect方法連接伺服器。對於AF_INET家族,連線格式如下:

socket.connect( (host,port) )

host代表伺服器主機名稱或IP,port代表伺服器程序所綁定的連接埠號碼。如連接成功,客戶就可透過套接字與伺服器通信,如果連接失敗,會引發socket.error異常。

3. 處理階段,客戶和伺服器將透過send方法和recv方法通訊。

4. 傳輸結束,客戶透過呼叫socket的close方法關閉連線。

下面給個簡單的例子:

server.py

if __name__ == '__main__':
    import socket
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.bind(('localhost', 8001))
    sock.listen(5)
    while True:
        connection,address = sock.accept()
        try:
            connection.settimeout(5)
            buf = connection.recv(1024)
            if buf == '1':
                connection.send('welcome to server!')
            else:
                connection.send('please go out!')
        except socket.timeout:
            print 'time out'
        connection.close()

client.py

if __name__ == '__main__':
    import socket
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.connect(('localhost', 8001))
    import time
    time.sleep(2)
    sock.send('1')
    print sock.recv(1024)
    sock.close()

在終端運行server.py,然後執行clien.py,會在終端機上列印「welcome to server!"。如果更改client.py的sock.send('1')為其它值在終端會列印”please go out!“,更改time.sleep(2)為大於5的數值, 伺服器將會逾時。

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn