Я пытаюсь закодировать издателя, который берет изображения из симуляции через API и публикует их через сокет tcp, чтобы несколько процессов - не обязательно на одном компьютере - могли получить доступ к изображениям, подписанным на тему.Кажется, все работает, так как я могу видеть потоковые изображения через подписчика.Единственная проблема заключается в том, что память, связанная с издателем, продолжает расти бесконечно, как с активным подписчиком, так и без него.Вот как используется издатель:
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://127.0.0.1:5556")
topic = "img_rgba"
time.sleep(2)
while(1):
[...]
socket.send_string(topic, zmq.SNDMORE)
socket.send_pyobj(image)
У вас есть какие-либо подсказки?
Большое спасибо, Марко