11

我想使用 ZeroMQ（java 绑定，jzmq）将客户端连接到服务器，但我非常需要 TCP 信息，例如客户端请求的 TCP/IP 地址！问题是，为了能够在网络中宣布服务，我需要获取请求的 TCP 地址才能将客户端重定向到该服务。在这种情况下，代理是一个中央“服务注册中心”。但是，在双方都有 ZeroMQ 服务时，我看不到检索该信息的选项。

我现在要做的是使用标准套接字与代理建立一个虚拟连接，在建立连接后，我获取用于此连接的 IP 地址并再次关闭连接。检索到的 IP 地址现在正用于使用随机端口上的 ZeroMQ 套接字对其进行绑定。

我认为这个解决方案是有史以来最丑陋的解决方案，所以：这个问题的更好解决方案是什么？

问候。

4

4 回答 4

7

0MQ 不提供对等点的地址，原因有很多。它也不是很有用，因为您真正想要的是接收连接的端点，而不是建立连接的地址。

我通常做的，它足够优雅，是将服务绑定到一个临时端口，获取一个完整的连接端点（“tcp://ipaddress:port”）并以某种方式发送该字符串，要么广播给对等方，要么中央注册表等以及我的服务名称。然后，想要重新连接的对等方可以获取服务名称，查找我的端点，然后连接回我。

于 2013-01-30T11:11:30.963 回答
5

在 ZMQ 4.x 中，您可以获得字符串属性“Peer-Address”或“Identity”属性。http://api.zeromq.org/4-2:zmq-msg-gets

身份在 connect() 之前在另一个对等方中设置。http://api.zeromq.org/4-2:zmq-setsockopt#toc20

例如，

const char *identityString = "identity";
zmq::context_t context(1);
zmq::socket_t socket(context, ZMQ_REQ);
socket.setsockopt(ZMQ_IDENTITY, identityString, strlen(identityString));
socket.connect("tcp://127.0.0.1:5555");

然后是另一边：

while(1)
{
    zmq::message_t request;
    if (socket.recv(&request, ZMQ_NOBLOCK))
    {
        const char* identity = request.gets("Identity");
        const char* peerAddress = request.gets("Peer-Address");
        printf("Received from %s %s\n", peerAddress, identity);
        break;
    }
}

我正在使用 CppZmq 顺便说一句，您应该能够轻松找到相关调用。

于 2018-07-02T06:03:17.410 回答
1

深入研究libzmq代码，我发现该库将接收到它的文件描述符附加到每个消息实例。

这对我有用

    int sockfd = zmq_msg_get(&msg, ZMQ_SRCFD);

    sockaddr_in addr;
    socklen_t asize = sizeof(addr);
    getpeername(sockfd, (sockaddr*)&addr, &asize);

    std::cout << inet_ntoa(addr.sin_addr) << ":" << addr.sin_port << std::endl;

请注意，FD 可以并且将被其他连接重用。

于 2020-12-01T11:13:59.213 回答
0

我正在使用 CZMQ 绑定使用 api 的 4.2.1 版本，我找到了适合我的案例的解决方案 (ZMQ_STREAM)。它通过在连接之前设置一个 id 来工作。

相关的套接字选项是“ZMQ_CONNECT_RID”。

ZMQ api 通过 zmq_setsockopt()

CZMQ api 通过 zsock_set_connect_rid()

一些带有经过编辑的 ips 的代码。

const char endpoint1[] = "tcp://1.2.3.4:12345"
const char endpoint2[] = "tcp://5.6.7.8:12345"

zsock_t *stream = zsock_new(ZMQ_STREAM);
zsock_set_connect_rid(stream, endpoint1);
zsock_connect(stream, endpoint1);
zsock_set_connect_rid(stream, endpoint2);
zsock_connect(stream, endpoint2);

然后，如果有连接，我会收到这两条消息。第一帧是 id，第二帧在 ZMQ_STREAM 套接字的连接/断开时为空。

[留言1]

[019] tcp://1.2.3.4:12345
[000]

[留言2]

[019] tcp://5.6.7.8:12345
[000]

另一种选择是使用zmq_socket_monitor()或czmq zmonitor。这是我的第一个解决方案之一，但我正在寻找更轻的东西。我能够以这种方式获取端点，而无需直接在套接字上设置 id。

zmonitor zactor 使订阅套接字事件成为可能，然后它发送一条包含 3 帧的消息：

[009] CONNECTED
[002] 14
[021] tcp://127.0.0.1:33445
于 2017-02-23T16:28:44.453 回答