nanomsg

    2热度

    2回答

    我一直在使用zeromq一段时间并广泛使用多部分消息。在C++中,我使用zmq_sendiov/zmq_recviov发送/ recv多部分消息。好处是我可以将每个消息的'框架'放在一个iovec中,并且一次使用呼叫发送/ recv。 最近我决定给nanomsg一个尝试,我意识到nanomsg有nn_sendmsg/nn_sendmsg它也使用iovec。问题是:nanomsg确保接收到的iove

    1热度

    1回答

    我正在尝试写一个测量员响应者模式。但它抛出的错误: nanomsg.NanoMsgAPIError: Operation cannot be performed in this state from nanomsg import * s1 = Socket(SURVEYOR) s1.bind('ipc://bob') s1.send(b'hello nanomsg') print(s1.

    0热度

    1回答

    我希望能使用类似nanomsg(或ZeroMQ)。特别是管道模式。我想根据数据进行负载平衡,而不是发送数据的循环方法。 有什么建议吗?

    1热度

    1回答

    我正在使用C#数据绑定为nanomsg。我有一个外部程序在url ipc:// report_data上发送Google Protocol Buffer消息,我的订阅者连接到同一个确切的url。所以,我希望我的订阅者能够检索在该URL上发送的任何数据,但事实并非如此。我使用函数Receive()并且没有任何东西通过。只有一种类型的消息通过该URL传递,所以我不关心这个话题。有没有人有nanomsg

    2热度

    1回答

    我想在macOS上用LuaRocks安装nn。但运行 sudo luarocks install nn //I use sudo because otherwise I don't have permission to install 当我收到错误 lnn.c:4:9: fatal error: 'nanomsg/nn.h' file not found include ^1 error g

    2热度

    1回答

    我正试图学习nanomsg库。 我正在使用版本C和Python的代码示例。我试图用Python脚本来订阅C服务,但没有任何事情发生。 这里是我的两个代码: 的Python用户 from __future__ import print_function from nanomsg import Socket, PAIR, PUB s2 = Socket(PAIR) while(True):

    1热度

    1回答

    我在调用全局级声明的套接字功能时遇到问题。 from nanomsg import Socket, PAIR, PUB s2 = Socket(PAIR) s2.connect('tcp://127.0.0.1:49234') s2.send(b'connect') def myfunc(): global s2 s2.send(b'Got here!') my

    0热度

    1回答

    我尝试建立nanomsg为Android ~/work/android-ndk-r10e/ndk-build ,我有错误: In file included from /home/roman/work/Nano/app/jni/src/utils/efd.c:28:0: /home/roman/work/Nano/app/jni/src/utils/efd_eventfd.inc:27:25

    4热度

    1回答

    我所经历的nanomsg使用率IPC,并想用SURVEY -archetype架构描述here。 在这里,进程作为客户端和服务器运行并交换数据。现在服务器已经下面的代码(在所提供的链接也列): int server (const char *url) { int sock = nn_socket (AF_SP, NN_SURVEYOR); assert (sock >= 0)

    0热度

    1回答

    我正尝试在mingw上构建nanomsg,使用mxe从ubuntu进行交叉编译。目标主机是x86_64。我建立它很好,但它不会链接。我得到像 undefined reference to 'imp__nn_freemsg' 我认为这是一个静态库问题。我再次使用 ./configure --enable-static --disable-shared ... 同样的问题。链接libn​​an