題目如下：spam系統(tǒng)，假設(shè)我們可以獲得線上的實(shí)時(shí)請(qǐng)求（按時(shí)間順序）每個(gè)請(qǐng)求包含如下信息：時(shí)間（unix時(shí)間戳）用戶名動(dòng)作（提問、回答、評(píng)論）內(nèi)容依次考慮如何解決以下問題：1.當(dāng)發(fā)現(xiàn)動(dòng)作頻率較高的用戶時(shí)，輸出報(bào)警（1分鐘內(nèi)超過10次評(píng)論、回答、提問）2.當(dāng)發(fā)現(xiàn)一個(gè)用戶連續(xù)發(fā)重復(fù)的內(nèi)容時(shí)，輸出報(bào)警（連續(xù)發(fā)了10個(gè)相同的評(píng)論、回答、提問）3.使用你覺得最優(yōu)美的方法將上面的策略與程序分離開。使得上面的策略可以隨時(shí)更新而不用修改程序。要求:服務(wù)監(jiān)聽一個(gè)端口，使用測(cè)試程序模擬用戶行為不斷向服務(wù)發(fā)送請(qǐng)求，請(qǐng)求格式為json，如：{"time":1323333"user":"xxx","action":"answer","content":"abcde"}服務(wù)輸出報(bào)警格式如下xxx,"頻繁提問"一下是我的代碼：client.pyimportsocketimportjsonimporttimeimportgeventimportrandomdefgenerateContents():"""隨機(jī)生成內(nèi)容"""chars=[chr(c)forcinrange(ord('a'),ord('z')+1)]result=[''.join(random.sample(chars,5))foriinrange(3)]returnresultclassWorker():def__init__(self,name,socket):self.name=nameself.socket=socketself.actions=['question','answer','comment']self.contents=generateContents()def__call__(self):while1:data=self._generateData()data=json.dumps(data)self._request(data)def_request(self,data):s=self.socket.socket()socket=self.socket.gethostname()port=1234s.connect((socket,port))s.recv(1024)s.send(data)s.close()gevent.sleep(random.randint(1,3)*0.5)def_generateData(self):data={}data['time']=time.time()data['user']=self.namedata['action']=random.choice(self.actions)data['content']=random.choice(self.contents)returndataif__name__=='__main__':threads=[gevent.spawn(Worker(chr(i),socket))foriinrange(ord('a'),ord('f'))]gevent.joinall(threads)server.pyimportsocketimportjsonfromfunctoolsimportwrapsfromMyExamineimportMyExaminedefrun():s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)host=''port=1234s.bind((host,port))s.listen(10)while1:c,addr=s.accept()c.send('Thisisasimpleserver'.encode('utf-8'))rec=c.recv(1024)do_something(rec)c.close()defformat2Json(func):deff(*args):data=json.loads(args[0])func(data)returnf@format2Json@MyExaminedefdo_something(data):"""模擬后臺(tái)處理用戶發(fā)來的請(qǐng)求"""printdataif__name__=='__main__':run()MyExamine.pyfrombaseExamineimportBaseExaminefromcollectionsimportdequeclassMyExamine(BaseExamine):def__init__(self,func):self.rateCache={}self.timesCache={}self.func=funcdefexamineRate(self,data):userQueue=self.rateCache.setdefault(data['user'],deque())whileuserQueue:item=userQueue.pop()ifdata['time']-item['time']10:self.showWarning('User:%s頻繁操作'.decode('utf8')%data['user'])defexamineContentTimes(self,data):userActions=self.timesCache.setdefault(data['user'],{})contentTimes=self.timesCache.setdefault(data['action'],{})key=data['content']contentTimes[key]=contentTimes.get(key,0)+1ifcontentTimes[key]>10:self.showWarning('User:%s%s%s超過10次'.decode('utf8')%(data['user'],data['action'],key))defshowWarning(self,msg):print'\033[;31m'+msg+'\033[0m'def__call__(self,*args):data=args[0]self.examineRate(data)self.examineContentTimes(data)self.func(*args)baseExamine.pyclassBaseExamine():"""模板方法的基類"""def__init__(self,func):passdef__call__(self,*args):pass求大神指點(diǎn)，謝謝！