python socket coding
?
python 編寫(xiě)server的步驟:
1、第一步是創(chuàng)建socket對(duì)象。調(diào)用socket構(gòu)造函數(shù)。如:
socket = socket.socket( family, type )
family參數(shù)代表地址家族,可為AF_INET或AF_UNIX。AF_INET家族包括Internet地址,AF_UNIX家族用于同一臺(tái)機(jī)器上的進(jìn)程間通信。
type參數(shù)代表套接字類(lèi)型,可為SOCK_STREAM(流套接字)和SOCK_DGRAM(數(shù)據(jù)報(bào)套接字)。
2、第二步是將socket綁定到指定地址。這是通過(guò)socket對(duì)象的bind方法來(lái)實(shí)現(xiàn)的:
socket.bind( address )
由AF_INET所創(chuàng)建的套接字,address地址必須是一個(gè)雙元素元組,格式是(host,port)。host代表主機(jī),port代表端口號(hào)。如果端口號(hào)正在使用、主機(jī)名不正確或端口已被保留,bind方法將引發(fā)socket.error異常。
3、第三步是使用socket套接字的listen方法接收連接請(qǐng)求。
socket.listen( backlog )
backlog指定最多允許多少個(gè)客戶(hù)連接到服務(wù)器。它的值至少為1。收到連接請(qǐng)求后,這些請(qǐng)求需要排隊(duì),如果隊(duì)列滿(mǎn),就拒絕請(qǐng)求。
4、第四步是服務(wù)器套接字通過(guò)socket的accept方法等待客戶(hù)請(qǐng)求一個(gè)連接。
connection, address = socket.accept()
調(diào) 用accept方法時(shí),socket會(huì)時(shí)入“waiting”狀態(tài)。客戶(hù)請(qǐng)求連接時(shí),方法建立連接并返回服務(wù)器。accept方法返回一個(gè)含有兩個(gè)元素的 元組(connection,address)。第一個(gè)元素connection是新的socket對(duì)象,服務(wù)器必須通過(guò)它與客戶(hù)通信;第二個(gè)元素 address是客戶(hù)的Internet地址。
5、第五步是處理階段,服務(wù)器和客戶(hù)端通過(guò)send和recv方法通信(傳輸 數(shù)據(jù))。服務(wù)器調(diào)用send,并采用字符串形式向客戶(hù)發(fā)送信息。send方法返回已發(fā)送的字符個(gè)數(shù)。服務(wù)器使用recv方法從客戶(hù)接收信息。調(diào)用recv 時(shí),服務(wù)器必須指定一個(gè)整數(shù),它對(duì)應(yīng)于可通過(guò)本次方法調(diào)用來(lái)接收的最大數(shù)據(jù)量。recv方法在接收數(shù)據(jù)時(shí)會(huì)進(jìn)入“blocked”狀態(tài),最后返回一個(gè)字符 串,用它表示收到的數(shù)據(jù)。如果發(fā)送的數(shù)據(jù)量超過(guò)了recv所允許的,數(shù)據(jù)會(huì)被截短。多余的數(shù)據(jù)將緩沖于接收端。以后調(diào)用recv時(shí),多余的數(shù)據(jù)會(huì)從緩沖區(qū) 刪除(以及自上次調(diào)用recv以來(lái),客戶(hù)可能發(fā)送的其它任何數(shù)據(jù))。
6、傳輸結(jié)束,服務(wù)器調(diào)用socket的close方法關(guān)閉連接。
python編寫(xiě)client的步驟:
1、創(chuàng)建一個(gè)socket以連接服務(wù)器:socket = socket.socket( family, type )
2、使用socket的connect方法連接服務(wù)器。對(duì)于AF_INET家族,連接格式如下:
socket.connect( (host,port) )
host代表服務(wù)器主機(jī)名或IP,port代表服務(wù)器進(jìn)程所綁定的端口號(hào)。如連接成功,客戶(hù)就可通過(guò)套接字與服務(wù)器通信,如果連接失敗,會(huì)引發(fā)socket.error異常。
4、處理階段,客戶(hù)和服務(wù)器將通過(guò)send方法和recv方法通信。
5、傳輸結(jié)束,客戶(hù)通過(guò)調(diào)用socket的close方法關(guān)閉連接。
例子:
server.py
client.py
import socket s=socket.socket() s.connect(('127.0.0.1',5200)) #與服務(wù)器程序ip地址和端口號(hào)相同 data=s.recv(512) s.send('hihi') s.close() print 'the data received is',data----------
?
無(wú)論是tcp協(xié)議的socket還是udp協(xié)議的socket,都是通過(guò)socket.socket(socket.AF_INET,socket.SOCK_STREAM/SOCK_DGRAM) 創(chuàng)建
第一個(gè)參數(shù)一般都是填寫(xiě)socket.AF_INET
第二個(gè)參數(shù)
Tcp: SOCK_STREAM
Udp:SOCK_DGRAM
?
?簡(jiǎn)單代碼:
client.py
import socketimport time
if __name__=='__main__':
sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
addr=('localhost',2000)
sock.connect(addr)
time.sleep(2)
try:
while True:
sock.send(raw_input('>>'))
buff=sock.recv(1024)
print 'get: %s %s' % (buff,time.ctime())
except Exception,e:
print "Error:",e
sock.close() 復(fù)制代碼
?
services.py
import socket
import datetime
if __name__=='__main__':
sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sock.bind(('127.0.0.1',2000))
sock.listen(5)
while True:
connection,address=sock.accept()
connection.settimeout(10000)
while True:
try:
buf=connection.recv(1024)
print 'get: %s %s' % (buf,datetime.datetime.now())
if buf=='exit':
break
connection.send(raw_input('>>'))
except socket.timeout:
print 'time out'
connection.close() 復(fù)制代碼
Udp協(xié)議與tcp協(xié)議差不多,只是關(guān)鍵字不同而已
?
總結(jié)
以上是生活随笔為你收集整理的python socket coding的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: Ubuntu 11.10 安装Adobe
- 下一篇: ML、DL相关资源