zoukankan      html  css  js  c++  java
  • 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()
  • 相关阅读:
    [POI2000]病毒
    枪战(maf)
    禅与园林艺术(garden)
    The Cave
    集合选数
    BZOJ3990 排序(sort)
    区间(interval)
    太空飞船(spaceship)
    数表( table )
    Printed Circuit Board (board)
  • 原文地址:https://www.cnblogs.com/yangzhizong/p/9296859.html
Copyright © 2011-2022 走看看