Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Jan 23 19:29

    bluca on master

    Refer to zmq_socket because the… Fix minor typo Merge pull request #3789 from s… (compare)

  • Jan 23 19:29
    bluca closed #3789
  • Jan 23 19:11
    std-any-emplace opened #3789
  • Jan 23 11:37
    bluca closed #3766
  • Jan 23 11:37
    bluca commented #3766
  • Jan 23 11:25
    colletted commented #3766
  • Jan 23 09:34
    bluca commented #3766
  • Jan 23 09:34

    bluca on master

    Problem: Issue #3766 states tha… Problem: No relicense agreement… Problem: preious commit contain… and 1 more (compare)

  • Jan 23 09:34
    bluca closed #3788
  • Jan 23 00:16
    colletted synchronize #3788
  • Jan 23 00:09
    colletted opened #3788
  • Jan 22 10:32
    stale[bot] labeled #3318
  • Jan 22 10:32
    stale[bot] commented #3318
  • Jan 21 19:18
    jakecobb commented #3786
  • Jan 21 15:19
    sigiesec commented #3786
  • Jan 21 14:42
    jakecobb commented #3786
  • Jan 21 13:38
    nightlark commented #3787
  • Jan 21 10:46
    sigiesec labeled #3786
  • Jan 21 10:46
    sigiesec labeled #3786
  • Jan 21 10:46
    sigiesec labeled #3786
Ghost
@ghost~5da165fcd73408ce4fcd9e88
hey @sappo , have you looked those link ^ ?
ekoczwara
@ekoczwara
Hi there! I have an issue with zmq_poll, my measurements shows that it sometimes takes more than 20ms (for example 21974us), this single call is my bottleneck, I'm running this on linux, so I guess it boils down to poll system call, what can I do about this?
Kevin Sapper
@sappo
@Priyanshu-soni I'll check it out tomorrow.
Kevin Sapper
@sappo
@Priyanshu-soni I just ran the example here https://github.com/zeromq/jeromq/blob/master/src/test/java/guide/lbbroker.java and it works fine for me. What OS are you using?
Ghost
@ghost~5da165fcd73408ce4fcd9e88
@sappo linux
Ghost
@ghost~5da165fcd73408ce4fcd9e88
and @sappo i know that its work fine while test it as a single program, but to be honest, when i run my project it gave an error. I think there is possibility of generating an error because i used some more zmq socket port with different pattern like Publish-subscribe, Pipeline pattern etc. what you think and what you suggest ?
André Pinto
@andredasilvapinto
Hi, is there any way to use UDP with ZeroMQ in Java?
Kevin Sapper
@sappo
@andredasilvapinto yes, use https://github.com/zeromq/jzmq and if you like combine it with https://github.com/zeromq/jzmq-api but UDP currently only works with RADIO/DISH socket types
@Priyanshu-soni I need to see your code in order to give you any suggestions. Right now I'm looking for a needle in a haystack.
André Pinto
@andredasilvapinto
@sappo I was trying to use exactly that, but RADIO/DISH doesn't seem to be supported: https://github.com/zeromq/jzmq-api/blob/master/src/main/java/org/zeromq/api/SocketType.java
Kevin Sapper
@sappo
@andredasilvapinto another could be to use jczmq https://github.com/zeromq/czmq/tree/master/bindings/jni. The API though is very close the the C one that its a binding for.
I'm currently working on providing packaged jars with the native libraries for jczmq.
André Pinto
@andredasilvapinto
Isn't jzmq-api the API for that library too? I thought it was the common API for all Java implementations, and given that it doesn't seem to support RADIO/DISH wouldn't that mean that all of the Java implementations that rely on it will also lack support?
Kevin Sapper
@sappo
No, jczmq is simply a very thin auto-generated binding over czmq with no affiliation to jzmq-api at this point.
André Pinto
@andredasilvapinto
ok. I will look into that then. Thanks
André Pinto
@andredasilvapinto

I'm not able to build czmq jni (osx):

[  3%] Building C object CMakeFiles/czmqjni.dir/src/main/c/org_zeromq_czmq_Zarmour.c.o
In file included from /Users/andre.pinto/git/others/czmq/bindings/jni/src/main/c/org_zeromq_czmq_Zarmour.c:10:
In file included from /usr/local/Cellar/czmq/4.2.0/include/czmq.h:37:
/usr/local/Cellar/czmq/4.2.0/include/czmq_library.h:183:10: fatal error: 'zargs.h' file not found
#include "zargs.h"
         ^~~~~~~~~
1 error generated.
make[2]: *** [CMakeFiles/czmqjni.dir/src/main/c/org_zeromq_czmq_Zarmour.c.o] Error 1
make[1]: *** [CMakeFiles/czmqjni.dir/all] Error 2
make: *** [all] Error 2

if I comment out add_definitions (-DCZMQ_BUILD_DRAFT_API) I get use of undeclared identifier 'zproc_t' errors

André Pinto
@andredasilvapinto
ok, building czmq instead of relying on the brew package works
André Pinto
@andredasilvapinto
however, if I try to create a RADIO socket I get an error
Assertion failed: (socktype >= 0 && socktype <= ZMQ_STREAM), function zsys_sockname, file src/zsys.c, line 476.
I guess I need to build czmq with RADIO/DISH support? But I have no idea how to do that
anyway, it seems UDP support in Java is really not ready for production use yet. thanks for your help though
leone
@xiasc01
image.png
What's the mistake, who is tell me , very thanks
Doron Somech
@somdoron
try to build with cmake, it probably works best on windows
Juan Pablo Garcia
@juanpagfe
Hello. Do any of you have a transparent proxy made using zmq?
Doron Somech
@somdoron
Im using nodejs with zeromq as the API proxy, communicating with majordomo to services
Mirko K
@Qgel
Hi. I'm currently building an application using ZMQ (PUB-SUB) where latency is important to me. I did some measurements and noticed that latency drops significantly as soon as I put some load (i.e. unreleated messages) on the sockets, which leads me to believe there might be some buffering (in ZMQ or maybe the OS?) going on that I'm unaware of. Any tips where I should look if I want to minimize latency also in the low-load case?
lat_load.png
zoobab "NO Software Patents"
@zoobab_twitter
pong
Will submit Glard to fosdem, the last IOT project I did with Pieter
zoobab "NO Software Patents"
@zoobab_twitter
2 zmq talks in the IOT devroom
Mirko K
@Qgel
I have posted a StackOverflow question with some more information and some example code to reproduce the issue if anyone wants to take a look: https://stackoverflow.com/questions/59323533/low-load-on-zmq-sockets-significantly-increases-latency
Aero Blue
@aeroblue
Hi, the last zyre release was in 2017, any plans of doing another one any time soon?
Kevin Sapper
@sappo
Yes, we could do another release. I like to fix the JNI bindings before. I'll work on it after Christmas.
Aero Blue
@aeroblue
great,
thanks
iqbaldzone
@iqbaldzone
Hey Guy, i am switching from jzmq to jeromq, I am using jeromq 0.5.1 version and i got this warning Warning:(31, 26) java: createSocket(int) in org.zeromq.ZContext has been deprecated. any have idea what i need to use.
iqbaldzone
@iqbaldzone
ROUTER in org.zeromq.ZMQ has been deprecated :PUSH in org.zeromq.ZMQ has been deprecated : SUB in org.zeromq.ZMQ has been deprecated : PAIR in org.zeromq.ZMQ has been deprecated
iqbaldzone
@iqbaldzone
@sappo could you please help here
dkonik
@dkonik

Hi peeps, hopefully this is the right place to ask this question. I just discovered zmq a couple of days ago while trying to find a networking/message sending solution, and have been reading through the docs and guide. I'm trying to wrap my head around/better understand how to use the different socket types to solve certain scenarios, and was wondering if someone with experience could give their opinion/feedback?

The specific scenario is something like the following (I'm going to make up a scenario related to camera video streams in a house, just to be more concrete):

  • A single server, which has video streams of multiple rooms of a house (kitchen, living room, etc).
  • At any point, a number of clients can connect to the server and request one or more streams from the server. So one client might connect and say, I want the stream of the kitchen and the living room. As is typical for video streams, this does not have to be reliable, but (and this is critical), this stream must be as low latency as possible. Every millisecond counts. This is priority zero, and why I am even looking at switching networking solutions, the current one is too slow.
  • The relationship is not so unidirectional, however, as in addition to simply receiving data, a client can also send messages to the server, telling it to, say, move the camera in a room, but only if they are actually streaming the video for that room. These messages are small, infrequent, but should be reliable. Latency not critical here.
  • There are also infrequent, reliable, latency uncritical messages that the server sends to the client.

That roughly sums up the scenario. What I've come up with:

  • Client-Server pattern for initial handshake/connections, as well as all client->server communication, and all reliable server->client communications.
  • Radio-Dish pattern for the streams

So roughly, something like this:
A client sets up a ZMQ_CLIENT socket, connects to the server, says they want the "kitchen" stream. The server sets up the ZMQ_RADIO socket (if this is first client, otherwise already exists) and the group, and sends the group name to the client. The client then sets up a ZMQ_DISH socket, and begins receiving the stream.

Does this seem like I am following the patterns that zmq sets up in an intended way? If not, any feedback?

dkonik
@dkonik
Also, wondering if I am misunderstanding something, or if the guide is out of date with respect to some of the documentation, as the guide says Don't share ZeroMQ sockets between threads. ZeroMQ sockets are not threadsafe, while the documentation says Following are the thread safe sockets: * ZMQ_CLIENT * ZMQ_SERVER * ZMQ_DISH * ZMQ_RADIO * ZMQ_SCATTER * ZMQ_GATHER. These all look like newer/draft socket types, so is it just that the newer ones have been implemented in thread safe manners while the older ones have not?
Doron Somech
@somdoron
You can share the thread-safe sockets between threads
your design looks good to me, I would add that you don't really need to set up the socket or group. The client can just connect (to a RADIO) using DISH and start streaming over the correct group (e.g KITCHEN)
You can also use UDP for the RADIO-DISH if you prefer unreliable protocol and TCP for the CLIENT-SERVER
dkonik
@dkonik
Awesome, thanks!
Himanshu Baghel
@hibaghel
image.png
hey can anyone help me with this issue
i have download and extracted libzmq-v141-x64-4_3_2
Doron Somech
@somdoron
which OS?
Himanshu Baghel
@hibaghel
windows 10
PauloSantosJunior
@PauloSantosJunior
Anyone have benchmark about zeromq and windows tcp/ip implementation, i know they are not equivalent implementation?