The response to browser only sent if I CTRL+C the running ZeroMQ Application but I don't know why.
// Send Response
socket.send(frames[0], zmq::send_flags::sndmore);
socket.send(zmq::str_buffer("HTTP/1.0 200 OK\r\nContent-Type: text/plain\r\n\r\nHello, World!"), zmq::send_flags::none);
// Close Connection with Browser
socket.send(frames[0], zmq::send_flags::sndmore);
socket.send(zmq::buffer(std::string_view("\0")), zmq::send_flags::none);
can you tell me if Bitcoin still uses zeromq?
Seems like it https://github.com/bitcoin/bitcoin/blob/master/doc/zmq.md
I've just noticed that libzmq sub sockets performs prefix match filtering when I use TCP, reading spec 29 the section describing the SUB socket does allow it
MAY, depending on the transport, filter messages according to subscriptions, using a prefix match algorithm.
My question is how can I know which transports libzmq will try to prefix match for? I can't find it in the documentation for setsockopt
Hello @sappo , @cite-reader ,
could you please help me out from this problem :java.lang.IndexOutOfBoundsException: Index: 2, Size: 2
at java.util.ArrayList.rangeCheck(ArrayList.java:659)
at java.util.ArrayList.get(ArrayList.java:435)
at zmq.socket.pubsub.Dist.distribute(Dist.java:162)
at zmq.socket.pubsub.Dist.sendToMatching(Dist.java:138)
at zmq.socket.pubsub.XPub.xsend(XPub.java:253)
at zmq.SocketBase.send(SocketBase.java:718)
at org.zeromq.ZMQ$Socket.send(ZMQ.java:3205)
at org.zeromq.ZMQ$Socket.sendMore(ZMQ.java:3131)
I am using PUB/SUB pattern in multithreading.
When i try to publish event, i am getting this error.
using jeromq-0.5.2
import org.json.JSONObject;
import org.zeromq.SocketType;
import org.zeromq.ZContext;
import org.zeromq.ZMQ;
import org.zeromq.ZMQException;
import java.math.BigDecimal;
import java.util.Arrays;
public class RatePublisher {
private static final ZContext context = new ZContext();
private static final ZMQ.Socket publisher = context.createSocket(SocketType.PUB);
private static String zmqAddress = "tcp://localhost:5563";
static {
publisher.bind(zmqAddress);
}
public static void publish(String name, String ident, BigDecimal rate, BigDecimal changePercentage) throws InterruptedException {
try {
JSONObject jsonObject = new JSONObject();
jsonObject.put("name", name);
jsonObject.put("ident", ident);
jsonObject.put("rate", rate);
jsonObject.put("changed_percentage", changePercentage);
publisher.sendMore("rate");
publisher.send(jsonObject.toString());
} catch (ZMQException e) {
e.printStackTrace();
throw new InterruptedException();
}
}
public static void close() throws InterruptedException {
try {
context.destroy();
} catch (Exception e) {
throw new InterruptedException();
}
}
}After that Multiple thread are using this publish method.
publish method like this :RatePublisher.publish("test", pair, rate, changePercentage);
import org.json.JSONObject;
import org.zeromq.SocketType;
import org.zeromq.ZContext;
import org.zeromq.ZMQ;
import org.zeromq.ZMQException;
import java.math.BigDecimal;
import java.util.Arrays;
public class RatePublisher {
private static final ZContext context = new ZContext();
private static final ZMQ.Socket publisher = context.createSocket(SocketType.PUB);
private static String zmqAddress = "tcp://localhost:5563";
static {
publisher.bind(zmqAddress);
}
public static void publish(String name, String ident, BigDecimal rate, BigDecimal changePercentage) throws InterruptedException {
try {
JSONObject jsonObject = new JSONObject();
jsonObject.put("name", name);
jsonObject.put("ident", ident);
jsonObject.put("rate", rate);
jsonObject.put("changed_percentage", changePercentage);
publisher.sendMore("rate");
publisher.send(jsonObject.toString());
} catch (ZMQException e) {
e.printStackTrace();
throw new InterruptedException();
}
}
public static void close() throws InterruptedException {
try {
context.destroy();
} catch (Exception e) {
throw new InterruptedException();
}
}
}
public class A
{
public static void main(String[] args)
{
int i = 100;
while(i>0) {
RatePublisher.publish("test", pair, rate, changePercentage);
i--;
}
}
}
public class B
{
public static void main(String[] args)
{
int i = 100;
while(i>0) {
RatePublisher.publish("test", pair, rate, changePercentage);
i--;
}
}
}
public class C
{
public static void main(String[] args)
{
int i = 100;
while(i>0) {
RatePublisher.publish("test", pair, rate, changePercentage);
i--;
}
}
}
public class D
{
public static void main(String[] args)
{
int i = 100;
while(i>0) {
RatePublisher.publish("test", pair, rate, changePercentage);
i--;
}
}
}
1 reply
Hi all, I have a question.
I am building an app with a microservice application and one of those applications is a system monitor to monitor the health of my applications. The apps are sending heartbeats and pings to the system monitor through zmq.
One time, the system monitor did not receive any messages coming from the apps and I had few edits on the code, one of which that fixed the problem is to set the multicast rate in the socket options to 1 billion.
May I ask what the multicast rate is for? How does it affect the sending and receiving of messages? Thank you.
We are facing a ZMQ proxy crash every 3 days and when we look at the system graphs we don't see any CPU or memory spikes. From the code, we have gracefully handled the socket's initialization and termination.
And adding socket.setsockopt(zmq.UNSUBSCRIBE, topic.encode('utf-8')) before closing the socket seems helping us in this. Does the UNSUBSCRIBE helps in releasing any resources other than close() ?
We are facing a ZMQ proxy crash every 3 days and when we look at the system graphs we don't see any CPU or memory spikes. From the code, we have gracefully handled the socket's initialization and termination.
And adding socket.setsockopt(zmq.UNSUBSCRIBE, topic.encode('utf-8')) before closing the socket seems helping us in this. Does the UNSUBSCRIBE helps in releasing any resources other than close() ?
@ashokchowdary863 you'll have better luck getting that question answered on the mailing list
