Python 調用multiprocessing模塊下面的Process類方法(實現服務器、客戶端併發)-UDP協議

#基於UDP協議的multiprocessing自定義通訊
服務端:
from multiprocessing import Process
import socket

def task(server):    #通訊循環
    while True:
        data, client_addr = server.recvfrom(1024)
        print('===>', data, client_addr)
        server.sendto(data.upper(), client_addr)

if __name__ == '__main__':
    server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 數據報協議-》udp
    server.bind(('127.0.0.1', 8080))
    # data, client_addr = server.recvfrom(1024)
    p=Process(target=task,args=(server,))   #鏈接循環
    p.start()

--------------------------------------------------------------------------------
客戶端:

import socket

client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) #數據報協議-》udp

while True:
    msg=input('>>: ').strip() #msg=''
    client.sendto(msg.encode('utf-8'),('127.0.0.1',8080))
    data,server_addr=client.recvfrom(1024)
    print(data)
    
client.close()
相關文章
相關標籤/搜索