Python常駐任務(wù)實現(xiàn)接收外界參數(shù)代碼解析
實現(xiàn)一個簡單的常駐任務(wù)是容易的,寫一個while True就可以了,但是同時要能接收外界傳來的參數(shù),就稍微有點復(fù)雜.
我第一個想到的是網(wǎng)絡(luò)編程中的server/client模式
server作為常駐進程,可以接受client傳來的各種參數(shù)進行處理
服務(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():
pass
def do_other():
pass
def 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:
# 接受一個新連接:
data, addr = s.accept()
# 創(chuàng)建新線程來處理TCP連接:
t = threading.Thread(target=tcplink, args=(data, addr))
t.start()
服務(wù)端實現(xiàn)完了,下面我們來實現(xiàn)客戶端client.py,客戶端支持傳入?yún)?shù)或從文件讀取參數(shù),來向客戶端發(fā)送請求
import socket
import sys
if __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()
這樣通過兩個腳本,一個實現(xiàn)了常駐進程,一個實現(xiàn)了傳入?yún)?shù),就可以不斷接受外界請求
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
PyQt5重寫QComboBox的鼠標(biāo)點擊事件方法
今天小編就為大家分享一篇PyQt5重寫QComboBox的鼠標(biāo)點擊事件方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2019-06-06
Python實現(xiàn)統(tǒng)計給定字符串中重復(fù)模式最高子串功能示例
Pytorch對Himmelblau函數(shù)的優(yōu)化詳解
在 Jupyter 中重新導(dǎo)入特定的 Python 文件(場景分析)

