5

我在让 ac# zeromq 客户端使用订阅发布模式从 c++ 服务器接收消息时遇到问题。

服务器设置是一个传输层，具有两种类型的传输策略（PublishSubsribe 和 RequestReply）。这些是用 c++ 编码的，并使用 3.2.0 libzmq。

class PublishSubsribe : public ITransportStrategy
{
private:
     zmq::context_t _context;
     zmq::socket_t _socket;

public:

    PublishSubsribe(std::string url)
        :
    _context(1),
    _socket(_context, ZMQ_PUB)
    {
        std::cout << "Binding  " << url << std::endl;
        _socket.bind(url.c_str());
    }

    virtual void Wait()
    {
        boost::this_thread::sleep(boost::posix_time::milliseconds(100));
    }

    virtual void Send(zmq::message_t& message) 
    {
        _socket.send(outMessage) ;
    }
    ..
};  
class RequestReply : public ITransportStrategy
{
private:
     zmq::context_t _context;
     zmq::socket_t _socket;

public:

    RequestReply(std::string url)
        :
    _context(1),
    _socket(_context, ZMQ_REP)
    {
        _socket.bind(url.c_str());
    }

    virtual void Send(zmq::message_t& message) 
    {
        _socket.send(message);
    }

    virtual void Wait()
    {
        zmq_msg_t request;
        zmq_msg_init (&request);
        zmq_msg_recv (&request, _socket, 0);
        zmq_msg_close (&request);
    }
    ..
};

当客户端是 c#/c++ 时，请求/回复模式有效。让我认为没有编码问题......虽然可能是错误的。此外，我在 C++ 中有一个客户端订阅者，它确实接收来自发布者的消息。

简而言之，我在 PubSub 中的 c# 客户端

//Bundled libzmq version: **3.2.2-rc2**  

        using (ZmqContext context = ZmqContext.Create())
        using (ZmqSocket client = context.CreateSocket(SocketType.SUB))
        {
            client.Connect("tcp://192.168.2.12:5555");

            client.SubscribeAll();
            while (true)
            {
                var msg = client.Receive(Encoding.UTF8);
                Console.WriteLine("Received Pub/Sub: yes");

            }
        }

没有收到任何消息，并且我尝试了所有编码，尽管 UTF8 适用于 ReqRep。

4

1 回答 1

2

您提到您在 C# 和 C++ 项目中使用的 libzmq 版本不同，这可能是问题所在吗？我在无意中使用 libzmq 2.x 和 3.x 时遇到了同样的问题

还有任何同步代码可以确保您在订阅者连接后发布消息（请参阅 ZMQ 指南中的“慢加入者综合症”）？

于 2012-12-04T22:37:22.307 回答