Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

The receive queue of subscriber socket is getting full #913

Open
kaushik-shrestha opened this issue Mar 28, 2022 · 0 comments
Open

The receive queue of subscriber socket is getting full #913

kaushik-shrestha opened this issue Mar 28, 2022 · 0 comments

Comments

@kaushik-shrestha
Copy link

kaushik-shrestha commented Mar 28, 2022

We have one publisher and two subscriber applications utilizing ZeroMQ's Pub-Sub pattern without implementing any heartbeat mechanism.

One application is running on (10.159.251.23) that publishes messages on port 6666:
publisher.publisherSocket = zContext.createSocket(SocketType.PUB);
publisher.publisherSocket.bind("tcp://*:6666");

And on the same host (10.159.251.23) another application is running that subscribes to this port 6666:
subscriberSocket = zContext.createSocket(SocketType.SUB);
subscriberSocket.subscribe("API-PROXY.INITIATOR.RES");
subscriberSocket.connect("10.159.251.23:6666");

Additionally, there's a different host (10.159.251.22) running the same subscriber application that subscribes to this publisher application on host 10.159.251.23:6666

The subscriber application on both hosts has been running since last 7 days. However on running netstat -an we see that the receive queue of the subscriber application running on (10.159.251.23) is full:
[kaushx@mslt4wct8080 ~]$ netstat -an | grep 6666
tcp6 0 0 :::6666 :::* LISTEN
tcp6 0 0 10.159.251.23:52440 10.159.251.22:6666 ESTABLISHED
tcp6 0 2588034 10.159.251.23:6666 10.159.251.23:50172 ESTABLISHED
tcp6 4196046 0 10.159.251.23:50172 10.159.251.23:6666 ESTABLISHED

tcp6 0 0 10.159.251.23:44368 10.159.251.22:6666 ESTABLISHED
tcp6 0 0 10.159.251.23:6666 10.159.251.22:45164 ESTABLISHED
tcp6 0 0 10.159.251.23:44148 10.159.251.22:6666 ESTABLISHED
tcp6 0 0 10.159.251.23:6666 10.159.251.22:45166 ESTABLISHED

This issue keeps occurring every few weeks which get resolved only on re-starting the subscriber application. Do you have any ideas what might be going wrong? Is there any way to clear the receive queue on reaching some threshold? We're using jeromq-0.5.1

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant