這個類還沒有完成国拇，不過己經(jīng)實現(xiàn)session的保存鼓黔，http認(rèn)證键耕，發(fā)送數(shù)據(jù)翼闹，接收數(shù)據(jù)的功能
代碼如下
# -*- coding: utf8 -*-
import http;
import urllib3
import urllib
import urllib.request
from Action.SYS.Log import *
from Action.SYS.ShowProcess import *
from io import BytesIO
import sys
import re
import time
import requests.sessions
import http.cookiejar
from requests.auth import HTTPBasicAuth
import requests
from Action.File.FileEvent import *
from Action.SYS.get import *
class HTTP2():
? ? __httpPool=None
? ? __timeout = 30;
? ? __httpCode=0
? ? __httpConnectionCode=0
? ? __curl=None
? ? __file=None
? ? __get=None
? ? __debug=False
? ? __httpdownloadfilesize=0
? ? __lostConnectStart=0
? ? __httpdownloadcontinue=''
? ? __lostConnectSkipTime=10
? ? __lostConnectCounter=3
? ? __status=0
? ? __body=''
? ? __uploadfiles={}
? ? __proxy={}
? ? __auth={}
? ? __cookieFile=''
? ? __cookie=''
? ? __request=None
? ? data="";
? ? def __init__(self,timeout,debug=False):
? ? ? ? self.__timeout=timeout;
? ? ? ? self.__file=FileEvent()
? ? ? ? self.__get=get()
? ? ? ? self.__debug=debug
? ? ? ? self.__request=requests.session()
? ? def __writeCookie(self,cookie=""):
? ? ? ? try:
? ? ? ? ? ? self.__file.writeFile(self.__cookieFile,cookie)
? ? ? ? except Exception as e:
? ? ? ? ? ? msg = "write data[%s] to cookie[%s] error(%s)" % (str(cookie),self.__cookieFile, str(e))
? ? ? ? ? ? Log.debug(self.__debug, msg)
? ? ? ? ? ? Log.log('error', msg)
? ? def setProxy(self,proxys={"http":"httpurl","https":"https url"}):
? ? ? ? self.__proxy=proxys
? ? ? ? return self
? ? def auth(self,username,password):
? ? ? ? self.__auth=HTTPBasicAuth(username,password)
? ? ? ? return self
? ? def setCookiePath(self,path="/home/***/tmp/cookie.txt"):
? ? ? ? try:
? ? ? ? ? ? self.__cookieFile=path
? ? ? ? ? ? self.__file.writeFile(self.__cookieFile,"","w")
? ? ? ? except Exception as e:
? ? ? ? ? ? self.__cookieFile="cookie.txt"
? ? ? ? ? ? msg = "create cookie[%s] error(%s)" % (self.__cookieFile, str(e))
? ? ? ? ? ? Log.debug(self.__debug, msg)
? ? ? ? ? ? Log.log('error', msg)
? ? ? ? return self
? ? def query(self, url, method="POST|GET", data="{'name':'value'}", headers={},cookies={}):
? ? ? ? r=None
? ? ? ? if method=="" or method=="GET":
? ? ? ? ? ? try:
? ? ? ? ? ? ? ? r=self.__request.get(url,headers=headers,cookies=cookies,proxies=self.__proxy,auth=self.__auth)
? ? ? ? ? ? ? ? self.__status=r.status_code
? ? ? ? ? ? ? ? self.__body=str(r.content,encoding='utf-8')
? ? ? ? ? ? except Exception as e:
? ? ? ? ? ? ? ? msg="request.get(%s) error(%s)" %(url,str(e))
? ? ? ? ? ? ? ? Log.debug(self.__debug,msg)
? ? ? ? ? ? ? ? Log.log('error',msg)
? ? ? ? else:
? ? ? ? ? ? try:
? ? ? ? ? ? ? ? r=self.__request.post(url,data,files=self.__uploadfiles,headers=headers,cookies=cookies,proxies=self.__proxy,auth=self.__auth)
? ? ? ? ? ? ? ? self.__status = r.status_code
? ? ? ? ? ? ? ? self.__body = str(r.content, encoding='utf-8')
? ? ? ? ? ? except Exception as e:
? ? ? ? ? ? ? ? msg="request.post(%s) data[%s] error(%s)" %(url,str(data),str(e))
? ? ? ? ? ? ? ? Log.debug(self.__debug,msg)
? ? ? ? ? ? ? ? Log.log('error',msg)
? ? ? ? #print(self.__request.cookies.get_dict())
? ? ? ? return self
? ? def get_status(self):
? ? ? ? return self.__status
? ? def get_body(self):
? ? ? ? return self.__body
未經(jīng)本人同意
代碼不得任意轉(zhuǎn)發(fā)
更不得用于商業(yè)用途
