pythonsocket代理伺服器
Ⅰ python 2.7中有沒有socketserver這個模塊
Python提供了兩個基本的socket模塊。一個是socket,它提供了標準的BSD Socket API;另一個是socketServer,它提供了伺服器中心類,可以簡化網路伺服器的開發。
本文簡要介紹socket模塊包含的類及其使用。
1.開始了解socket模塊前,先熟悉下Python的網路編程模塊主要支持的兩種Intent協議:TCP和UDP。TCP協議是一種面向連接的可靠協議,用於建立機器之間的雙向通信流。UDP協議是一種較低級別的、以數據包為基礎的協議(無連接傳輸模式)。與TCP不同,UDP信息不可靠。
他們的區別如下圖所示:左圖為TCP連接協議,右圖為UDP連接協議
2.socket模塊的部分類方法介紹
類方法
說明
socket.socket(family, type[,proto])
創建並返回一個新的 socket對象
socket.getfqdn(name)
將使用點號分隔的 IP地址字元串轉換成一個完整的域名
socket.gethostbyname(hostname)
將主機名解析為一個使用點號分隔的 IP地址字元串
socket.gethostbyname_ex(name)
它返回一個包含三個元素的元組,從左到右分別是給定地址的主要的主機名、同一IP地址的可選的主機名的一個列表、關於同一主機的同一介面的其它IP地址的一個列表(列表可能都是空的)。
socket.gethostbyaddr(address)
作用與gethostbyname_ex相同,只是你提供給它的參數是一個IP地址字元串
Socket.getservbyname(service,protocol)
它要求一個服務名(如'telnet'或'ftp')和一個協議(如'tcp'或'udp'),返回服務所使用的埠號
socket.fromfd(fd, family, type)
從現有的文件描述符創建一個 socket對象
3.socket對象的部分方法介紹
實例方法
說明
sock.bind( (adrs, port) )
將 socket綁定到一個地址和埠上
sock.accept()
返回一個客戶機 socket(帶有客戶機端的地址信息)
sock.listen(backlog)
將 socket設置成監聽模式,能夠監聽 backlog 外來的連接請求
sock.connect( (adrs, port) )
將 socket連接到定義的主機和埠上
sock.recv( buflen[, flags] )
從 socket中接收數據,最多 buflen 個字元
sock.recvfrom( buflen[, flags] )
從 socket中接收數據,最多 buflen 個字元,同時返回數據來源的遠程主機和埠號
sock.send( data[, flags] )
通過 socket發送數據
sock.sendto( data[, flags], addr )
通過 socket發送數據
sock.close()
關閉 socket
sock.getsockopt( lvl, optname )
獲得指定 socket 選項的值
sock.setsockopt( lvl, optname, val )
設置指定 socket選項的值
4.編寫socket測試程序
(a)編寫server的步驟
第一步是創建socket對象。調用socket構造函數。如:
socket = socket.socket( family, type )
family參數代表地址家族,可為AF_INET或AF_UNIX。AF_INET家族包括Internet地址,AF_UNIX家族用於同一台機器上的進程間通信。
type參數代表套接字類型,可為SOCK_STREAM(流套接字)和SOCK_DGRAM(數據報套接字)。
第二步是將socket綁定到指定地址。這是通過socket對象的bind方法來實現的:
socket.bind( address )
由AF_INET所創建的套接字,address地址必須是一個雙元素元組,格式是(host,port)。host代表主機,port代表埠號。如果埠號正在使用、主機名不正確或埠已被保留,bind方法將引發socket.error異常。
第三步是使用socket套接字的listen方法接收連接請求。
socket.listen( backlog )
backlog指定最多允許多少個客戶連接到伺服器。它的值至少為1。收到連接請求後,這些請求需要排隊,如果隊列滿,就拒絕請求。
第四步是伺服器套接字通過socket的accept方法等待客戶請求一個連接。
connection, address = socket.accept()
調 用accept方法時,socket會時入「waiting」狀態。客戶請求連接時,方法建立連接並返回伺服器。accept方法返回一個含有兩個元素的元組(connection,address)。第一個元素connection是新的socket對象,伺服器必須通過它與客戶通信;第二個元素 address是客戶的Internet地址。
第 五步是處理階段,伺服器和客戶端通過send和recv方法通信(傳輸 數據)。伺服器調用send,並採用字元串形式向客戶發送信息。send方法返回已發送的字元個數。伺服器使用recv方法從客戶接收信息。調用recv 時,伺服器必須指定一個整數,它對應於可通過本次方法調用來接收的最大數據量。recv方法在接收數據時會進入「blocked」狀態,最後返回一個字元 串,用它表示收到的數據。如果發送的數據量超過了recv所允許的,數據會被截短。多餘的數據將緩沖於接收端。以後調用recv時,多餘的數據會從緩沖區 刪除(以及自上次調用recv以來,客戶可能發送的其它任何數據)。
傳輸結束,伺服器調用socket的close方法關閉連接。
(b)編寫client的步驟
首先創建一個socket以連接伺服器:socket =socket.socket( family, type )
使用socket的connect方法連接伺服器。對於AF_INET家族,連接格式如下:
socket.connect( (host,port) )
host代表伺服器主機名或IP,port代表伺服器進程所綁定的埠號。如連接成功,客戶就可通過套接字與伺服器通信,如果連接失敗,會引發socket.error異常。
處理階段,客戶和伺服器將通過send方法和recv方法通信。
傳輸結束,客戶通過調用socket的close方法關閉連接。
5.實例源碼:python socket半雙工聊天
(a)tcpserver.py
[python] view plain
# -*- coding: cp936 -*-
#file:tcpserver.py
import socket
from time import ctime
import sys
bufsize = 1024
host = '127.0.0.1'
port = 8100
address = (host,port)
server_sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server_sock.bind(address)
server_sock.listen(1)
while True:
print 'waiting for connection...'
clientsock,addr = server_sock.accept()
print 'received from :',addr
while True:
data = clientsock.recv(bufsize)
print ' 收到---->%s\n%s' %(ctime(),data)
data = raw_input("發送----->")
clientsock.send(data)
clientsock.close()
server_sock.close()
(b)tcpclient.py
[python] view plain
## -*- coding: cp936 -*-
##file:tcpclient.py
from socket import *
from time import ctime
bufsize = 1024
host = '127.0.0.1'
port = 8100
addr = (host,port)
client_sock = socket(AF_INET,SOCK_STREAM)
client_sock.connect(addr)
while True:
data = raw_input("發送---->")
if not data:
break
else:
client_sock.send(data)
data = client_sock.recv(bufsize)
print '收到---->%s\n%s' %(ctime(),data)
client_sock.close()
Ⅱ Python 之 Socket編程(TCP/UDP)
socket(family,type[,protocal]) 使用給定的地址族、套接字類型、協議編號(默認為0)來創建套接字。
有效的埠號: 0~ 65535
但是小於1024的埠號基本上都預留給了操作系統
POSIX兼容系統(如Linux、Mac OS X等),在/etc/services文件中找到這些預留埠與的列表
面向連接的通信提供序列化、可靠的和不重復的數據交付,而沒有記錄邊界。意味著每條消息都可以拆分多個片段,並且每個消息片段都能到達目的地,然後將它們按順序組合在一起,最後將完整的信息傳遞給等待的應用程序。
實現方式(TCP):
傳輸控制協議(TCP), 創建TCP必須使用SOCK_STREAM作為套接字類型
因為這些套接字(AF_INET)的網路版本使用網際網路協議(IP)來搜尋網路中的IP,
所以整個系統通常結合這兩種協議(TCP/IP)來進行網路間數據通信。
數據報類型的套接字, 即在通信開始之前並不需要建議連接,當然也無法保證它的順序性、可靠性或重復性
實現方式(UDP)
用戶數據包協議(UDP), 創建UDP必須使用SOCK_DGRAM (datagram)作為套接字類型
它也使用網際網路來尋找網路中主機,所以是UDP和IP的組合名字UDP/IP
注意點:
1)TCP發送數據時,已建立好TCP連接,所以不需要指定地址。UDP是面向無連接的,每次發送要指定是發給誰。
2)服務端與客戶端不能直接發送列表,元組,字典。需要字元串化repr(data)。
TCP的優點: 可靠,穩定 TCP的可靠體現在TCP在傳遞數據之前,會有三次握手來建立連接,而且在數據傳遞時,有確認、窗口、重傳、擁塞控制機制,在數據傳完後,還會斷開連接用來節約系統資源。
TCP的缺點: 慢,效率低,佔用系統資源高,易被攻擊 TCP在傳遞數據之前,要先建連接,這會消耗時間,而且在數據傳遞時,確認機制、重傳機制、擁塞控制機制等都會消耗大量的時間,而且要在每台設備上維護所有的傳輸連接,事實上,每個連接都會佔用系統的CPU、內存等硬體資源。 而且,因為TCP有確認機制、三次握手機制,這些也導致TCP容易被人利用,實現DOS、DDOS、CC等攻擊。
什麼時候應該使用TCP : 當對網路通訊質量有要求的時候,比如:整個數據要准確無誤的傳遞給對方,這往往用於一些要求可靠的應用,比如HTTP、HTTPS、FTP等傳輸文件的協議,POP、SMTP等郵件傳輸的協議。 在日常生活中,常見使用TCP協議的應用如下: 瀏覽器,用的HTTP FlashFXP,用的FTP Outlook,用的POP、SMTP Putty,用的Telnet、SSH QQ文件傳輸.
UDP的優點: 快,比TCP稍安全 UDP沒有TCP的握手、確認、窗口、重傳、擁塞控制等機制,UDP是一個無狀態的傳輸協議,所以它在傳遞數據時非常快。沒有TCP的這些機制,UDP較TCP被攻擊者利用的漏洞就要少一些。但UDP也是無法避免攻擊的,比如:UDP Flood攻擊……
UDP的缺點: 不可靠,不穩定 因為UDP沒有TCP那些可靠的機制,在數據傳遞時,如果網路質量不好,就會很容易丟包。
什麼時候應該使用UDP: 當對網路通訊質量要求不高的時候,要求網路通訊速度能盡量的快,這時就可以使用UDP。 比如,日常生活中,常見使用UDP協議的應用如下: QQ語音 QQ視頻 TFTP ……
Ⅲ 如何使用python::SocketServer.socket.ssl模塊
現在記錄HTTPS服務端的編寫。
importssl,socket,time
if__name__=="__main__":
context=ssl.SSLContext(ssl.PROTOCOL_SSLv23)
#context.load_cert_chain(certfile=『key_pub.pem』,keyfile=『key_priv.pem')#可以分開定義公鑰和私鑰文件,也可以合並成一個文件
context.load_cert_chain(certfile=』cert.pem')
bindsocket=socket.socket()
bindsocket.bind(('127.0.0.1',443))
bindsocket.listen(5)
newsocket,fromaddr=bindsocket.accept()
connstream=context.wrap_socket(newsocket,server_side=True)
try:
data=connstream.recv(1024)
print(data)
buf='HiNN%f '%time.time()
buf=buf.encode()
connstream.send(buf)
finally:
connstream.shutdown(socket.SHUT_RDWR)
connstream.close()
bindsocket.close()
此例沒有使用socketserver框架,目的在於測試ssl模塊的用法。
繼續,用框架實現HTTPS服務
importsocketserver,ssl,time
classMyHTTPSHandler_socket(socketserver.BaseRequestHandler):
defhandle(self):
context=ssl.SSLContext(ssl.PROTOCOL_SSLv23)
context.load_cert_chain(certfile="cert.pem")
SSLSocket=context.wrap_socket(self.request,server_side=True)
self.data=SSLSocket.recv(1024)
print(self.data)
buf='testHTTPSServerHandler<br>%f'%time.time()
buf=buf.encode()
SSLSocket.send(buf)
if__name__=="__main__":
port=443
httpd=socketserver.TCPServer(('localhost『,port),MyHTTPSHandler_socket)
print(』httpsservingatport',port)
httpd.serve_forever()
說明:handle()函數負責所有與客戶端的通信。客戶端連接過來之後,ssl模塊載入證書,並用SSLSocket對socket進行封裝,屏蔽底層的加密通信細節。
下面再給出HTTPS文件伺服器代碼,文件訪問功能由SimpleHTTPRequestHandler實現,數據加密傳輸由ssl實現。
importsocketserver,ssl,time,http.server
classMyHTTPS_SimpleHTTPRequestHandler(http.server.SimpleHTTPRequestHandler):
defsetup(self):
print('setup')
context=ssl.SSLContext(ssl.PROTOCOL_SSLv23)
context.load_cert_chain(certfile=『cert.pem』)
SSLSocket=context.wrap_socket(self.request,server_side=True)
self.rfile=SSLSocket.makefile('rb',self.rbufsize)
self.wfile=SSLSocket.makefile('wb',self.wbufsize)
if__name__=="__main__":
port=443
httpd=socketserver.TCPServer(("localhost",port),MyHTTPS_SimpleHTTPRequestHandler)
print('httpsservingatport',port)
httpd.serve_forever()
最後,要指出的是setup()和handle()都是在客戶端開始連接之後才被調用,從順序上來說setup()先於handle()。
Ⅳ python爬蟲 如何自己用雲伺服器上搭建代理伺服器 並使用requests測試代理
1、簡介
使用同一個ip頻繁爬取一個網站,久了之後會被該網站的伺服器屏蔽。所以這個時候需要使用代理伺服器。通過ip欺騙的方式去爬取網站
可以使用http://yum.iqianyue.com.com/proxy中找到很多伺服器代理地址
2、應用
# *-*coding:utf-8*-*
from urllib import request
def use_porxy(porxy_addr,url):
porxy = request.ProxyHandler({'http':porxy_addr})
opener = request.build_opener(porxy, request.ProxyHandler)
request.install_opener(opener)
data = request.urlopen(url).read().decode('utf-8')
return data
data = use_porxy("114.115.182.59:128","http://www..com")
print(len(data))
Ⅳ python socket如何連接到華為雲伺服器
這篇文章主要介紹了python使用socket連接遠程伺服器的方法,涉及Python中socket通信的基本技巧,具有一定參考借鑒價值,需要的朋友可以參考下
本文實例講述了python使用socket連接遠程伺服器的方法。分享給大家供大家參考。具體如下:
import socket
print "Creating socket...",
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
print "done."
print "Looking up port number...",
port = socket.getservbyname('http', 'tcp')
print "done."
print "Connecting to remote host on port %d..." % port,
s.connect(("www.jb51.net", port))
print "done."