ZMQ PUB SUB потерянное соединение TCP на стороне PUB - PullRequest
Новая
       16

ZMQ PUB SUB потерянное соединение TCP на стороне PUB

2 голосов
/ 19 марта 2019

Я использую шаблон zmq PUB-SUB, чтобы заметить, что рабочие пришли после нескольких дней, потерявших TCP CONNECTION на пабе прошлой ночью. Я создаю ОДИН ПАБ на сервере и у меня есть 230 СУБ-клиентов. среди них 90 SUB-клиентов имеют медленную проблему получения из-за высокой загрузки ЦП после получения сообщений паба. PUB потерял TCP-соединения для этих 90 сабов.

pyzmq: 17.0.0

питон: 2.7.5

В моем проекте программы медленный SUB должен быть нормальным, потому что рабочий дескриптор медленный, а HWM должен защищать шаблон PUB-SUB. Любое предложение? 

[root@localhost apolo]#  netstat -an|grep "127.0.0.1:5000         ESTABLISHED"|wc -l
230
[root@localhost apolo]#  netstat -an|grep "0 127.0.0.1:5000"|wc -l
141

PUB код 

 zmq_publish = context.socket(zmq.PUB)
 zmq_publish.bind("tcp://127.0.0.1:5000")

СУБ-код 

zmq_subscripe = context.socket(zmq.SUB)
zmq_subscripe.connect("tcp://127.0.0.1:5000")
...