這款軟件有幾種客戶端, Java/Perl/C,卻沒有Python的客戶端.

故,本人奉上一個實現,歡迎指正!!

代碼:

#Verion 1.0

#Author wendal(wendal1985@gmail.com)

#If you find a bug, pls mail me

import sys,httplib

ERROR = 'HTTPSQS_ERROR'

GET_END = 'HTTPSQS_GET_END'

PUT_OK = 'HTTPSQS_PUT_OK'

PUT_ERROR = 'HTTPSQS_PUT_ERROR'

PUT_END = 'HTTPSQS_PUT_END'

RESET_OK = 'HTTPSQS_RESET_OK'

RESET_ERROR = 'HTTPSQS_RESET_ERROR'

MAXQUEUE_OK = 'HTTPSQS_MAXQUEUE_OK'

MAXQUEUE_CANCEL = 'HTTPSQS_MAXQUEUE_CANCEL'

SYNCTIME_OK = 'HTTPSQS_SYNCTIME_OK'

SYNCTIME_CANCEL = 'HTTPSQS_SYNCTIME_CANCEL'

class Httpsqs(object):

def __init__(self,host,port=1218):

self.host = host

self.port = port

def get(self,poolName):

conn = httplib.HTTPConnection(self.host,self.port)

conn.request("GET", "/?opt=get&name;=" + poolName)

r = conn.getresponse()

if r.status == httplib.OK :

data = r.read()

conn.close()

return data

return ''

def put(self,poolName,data):

conn = httplib.HTTPConnection(self.host,self.port)

conn.request("POST", "/?opt=put&name;="+poolName,data)

r = conn.getresponse()

if r.status == httplib.OK :

data = r.read()

return data

return ''

def status(self,poolName):

conn = httplib.HTTPConnection(self.host,self.port)

conn.request("GET", "/?opt=status&name;="+poolName)

r = conn.getresponse()

if r.status == httplib.OK :

data = r.read()

return data

return ''

def status_json(self,poolName):

conn = httplib.HTTPConnection(self.host,self.port)

conn.request("GET", "/?opt=status_json&name;="+poolName)

r = conn.getresponse()

if r.status == httplib.OK :

data = r.read()

return data

return ''

def reset(self,poolName):

conn = httplib.HTTPConnection(self.host,self.port)

conn.request("GET", "/?opt=reset&name;="+poolName)

r = conn.getresponse()

if r.status == httplib.OK :

data = r.read()

return data

return ''

def maxlen(self,poolName,num):

conn = httplib.HTTPConnection(self.host,self.port)

conn.request("GET", "/?opt=maxqueue&name;="+poolName+"#="+str(num))

r = conn.getresponse()

if r.status == httplib.OK :

data = r.read()

return data

return ''

def synctime(self,poolName,num):

conn = httplib.HTTPConnection(self.host,self.port)

conn.request("GET", "/?opt=synctime&name;="+poolName+"#="+str(num))

r = conn.getresponse()

if r.status == httplib.OK :

data = r.read()

return data

return ''

def isOK(data):

if data is '' :

return False

if data is ERROR :

return False

if data is GET_END :

return False

if data is PUT_ERROR :

return False

if data is RESET_ERROR :

return False

if data is MAXQUEUE_CANCEL :

return False

if data is SYNCTIME_CANCEL :

return False

return True

測試代碼就不貼,需要的話就下載zip包吧.

因為Httpsqs本身就是基于Http協議的,故各種客戶端實現都只是封裝一下,本python客戶端也不例外.

blog comments powered by Disqus

總結

以上是生活随笔為你收集整理的python能做哪些客户端_发布一个Httpsqs的Python客户端的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。