實(shí)現(xiàn)一個(gè)簡(jiǎn)單的常駐任務(wù)是容易的,寫(xiě)一個(gè)while True就可以了,但是同時(shí)要能接收外界傳來(lái)的參數(shù),就稍微有點(diǎn)復(fù)雜.

我第一個(gè)想到的是網(wǎng)絡(luò)編程中的server/client模式

server作為常駐進(jìn)程,可以接受client傳來(lái)的各種參數(shù)進(jìn)行處理

服務(wù)端:server.py

import sockets = socket.socket(socket.AF_INET, socket.SOCK_STREAM)s.bind((’127.0.0.1’, 10001))s.listen(5)def do_some(): passdef do_other(): passdef tcplink(sock, addr): print(’Accept new connection from %s:%s...’ % addr) sock.send(b’Welcome!’) while True: data = sock.recv(1024) time.sleep(1) if not data or data.decode(’utf-8’) == ’exit’: break data_str = data.decode(’utf-8’) data_list = data_str.split(’,’) if len(data_list) == 3: do_some() else: do_other() sock.send((’processing, %s!’ % s3).encode(’utf-8’)) sock.close()if __name__ == ’__main__’: while True: # 接受一個(gè)新連接: data, addr = s.accept() # 創(chuàng)建新線程來(lái)處理TCP連接: t = threading.Thread(target=tcplink, args=(data, addr)) t.start()

服務(wù)端實(shí)現(xiàn)完了,下面我們來(lái)實(shí)現(xiàn)客戶(hù)端client.py,客戶(hù)端支持傳入?yún)?shù)或從文件讀取參數(shù),來(lái)向客戶(hù)端發(fā)送請(qǐng)求

import socketimport sysif __name__ == ’__main__’: param = sys.argv[1] c_list = [] if param.endswith(’txt’): with open(param, ’r’) as file: for line in file.readlines():c_list.append(line.strip().encode(’utf8’)) else: c = param.encode(’utf8’) c_list.append(c) s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.connect((’127.0.0.1’, 10001)) print(s.recv(1024).decode(’utf-8’)) for data in c_list: s.send(data) print(s.recv(1024).decode(’utf-8’)) s.send(b’exit’) s.close()

這樣通過(guò)兩個(gè)腳本,一個(gè)實(shí)現(xiàn)了常駐進(jìn)程,一個(gè)實(shí)現(xiàn)了傳入?yún)?shù),就可以不斷接受外界請(qǐng)求

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。