python多进程收包通信_S展翅飛

个人资料

微博

正文字体大小：大中小

python多进程收包通信

(2023-10-24 15:57:09)

标签：

分类： python

import socket

from multiprocessing import Process, Queue

def udp_receive(queue):

UDP_IP = "127.0.0.1"

UDP_PORT = 5005

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

sock.bind((UDP_IP, UDP_PORT))

while True:

data, addr = sock.recvfrom(1024)

queue.put(data)

def process_data(queue):

while True:

data = queue.get()

print("Processing data:", data)

if __name__ == '__main__':

queue = Queue()

udp_process = Process(target=udp_receive, args=(queue,))

udp_process.start()

data_process = Process(target=process_data, args=(queue,))

data_process.start()

udp_process.join()

data_process.join()

阅读┊ 收藏 ┊ 喜欢 ▼ ┊打印┊举报/Report