ZMQ ZMQ_STREAM 遇到问题不解。求指点 socket 通讯

sytpb

1. void* context = zmq_ctx_new ();
   
2.         void* socket = zmq_socket (context, ZMQ_STREAM);
   
3. 
   
4.     int rc = zmq_connect (socket, "tcp://192.168.4.186:5000");
   
5.     assert(rc == 0);
   
6. 
   
7.         int sn = zmq_send(socket,szBufLoginSH,iBufLoginLenSH+1,ZMQ_DONTWAIT);

复制代码

用zmq 给server 端发消息，对方非zmq .    connect 正常server 发送消息client 能收到， 但是client 发送server 死活收不到，但是发送函数返回值还是正确的。   


不太懂。。

wenlq

显然要配套才行

sytpb

uint8_t id[256];  
    size_t id_size;
rc = zmq_getsockopt(socket, ZMQ_IDENTITY, id, &id_size);
   
    zmq_send(socket, id, id_size, ZMQ_DONTWAIT);
    int sn = zmq_send(socket,sndbuf,nLen,ZMQ_DONTWAIT);

ZMQ_STREAM

A socket of type ZMQ_STREAM is used to send and receive TCP data from a non-ØMQ peer, when using the tcp:// transport. A ZMQ_STREAM socket can act as client and/or server, sending and/or receiving TCP data asynchronously.

When receiving TCP data, a ZMQ_STREAM socket shall prepend a message part containing the identity of the originating peer to the message before passing it to the application. Messages received are fair-queued from among all connected peers.

When sending TCP data, a ZMQ_STREAM socket shall remove the first part of the message and use it to determine the identity of the peer the message shall be routed to, and unroutable messages shall cause an EHOSTUNREACH or EAGAIN error.

To open a connection to a server, use the zmq_connect call, and then fetch the socket identity using the ZMQ_IDENTITY zmq_getsockopt call.

To close a specific client connection, as a server, send the identity frame followed by a zero-length message (see EXAMPLE section).

sytpb

你上面这样发送才可以， send 数据之前先要send identity 一次。