2

我有两个简单的组件，它们应该使用 REQ/REP ZeroMQ 模式相互通信。服务器（REP 套接字）是使用 pyzmq 在 Python 中实现的：

import zmq

def launch_server():
    print "Launching server"
    with zmq.Context.instance() as ctx:
        socket = ctx.socket(zmq.REP)
        socket.bind('tcp://127.0.0.1:5555')

        while True:
            msg = socket.recv()
            print "EOM\n\n"

使用 NetMQ 库用 C# 编写的客户端（REQ 套接字）：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using NetMQ;


namespace PyNetMQTest
{
    class Program
    {

        static void Main(string[] args)
        {
            string msg;
            NetMQ.Sockets.RequestSocket socket = new NetMQ.Sockets.RequestSocket();
            socket.Connect("tcp://127.0.0.1:5555");
            for(int i=0; i<5; i++)
                socket.SendFrame("test_"+i);
        }
    }
}

通过与使用 Python 实现的 REQ 套接字通信，Python 服务器实现已经过测试并且工作正常。但是 C# REQ 套接字在循环的第一次迭代中抛出以下错误，并且没有任何消息到达服务器：

NetMQ.dll 中出现“NetMQ.FiniteStateMachineException”类型的未处理异常附加信息：Req.XSend - 无法发送另一个请求

堆栈跟踪：

at NetMQ.Core.Patterns.Req.XSend(Msg& msg)
   at NetMQ.Core.SocketBase.TrySend(Msg& msg, TimeSpan timeout, Boolean more)
   at NetMQ.NetMQSocket.TrySend(Msg& msg, TimeSpan timeout, Boolean more)
   at NetMQ.OutgoingSocketExtensions.Send(IOutgoingSocket socket, Msg& msg, Boolean more)
   at NetMQ.OutgoingSocketExtensions.SendFrame(IOutgoingSocket socket, String message, Boolean more)
   at PyNetMQTest.Program.Main(String[] args) in d:\users\emes\documents\visual studio 2015\Projects\PyNetMQ Test\PyNetMQTest\Program.cs:line 20
   at System.AppDomain._nExecuteAssembly(RuntimeAssembly assembly, String[] args)
   at System.AppDomain.ExecuteAssembly(String assemblyFile, Evidence assemblySecurity, String[] args)
   at Microsoft.VisualStudio.HostingProcess.HostProc.RunUsersAssembly()
   at System.Threading.ThreadHelper.ThreadStart_Context(Object state)
   at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
   at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
   at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
   at System.Threading.ThreadHelper.ThreadStart()

这是我使用 ZMQ 的第一步，C# 代码取自库文档。是什么让代码抛出这个错误？

我在用：

  • pyzmq 14.7
  • 网络MQ 3.3.3.4
  • .NET 4.6

====================== 解决方案======================

正如@somdoron 在他的回答中所解释的那样，根本原因是两个套接字都需要完成发送/接收的完整周期，然后才能被重用。事实上，在 python 中实现的 REP 套接字也没有改变它的状态，所以错误出现在 python 和 C# 代码中。这是固定代码：

REP 插座

import zmq

def launch_server():
    print "Launching server"
    with zmq.Context.instance() as ctx:
        socket = ctx.socket(zmq.REP)
        socket.bind('tcp://127.0.0.1:5555')

        while True:
            msg = socket.recv()
            socket.send("reply to "+msg)
            print "EOM\n\n"

请求套接字

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using NetMQ;


namespace PyNetMQTest
{
    class Program
    {

        static void Main(string[] args)
        {

            NetMQ.Sockets.RequestSocket socket = new NetMQ.Sockets.RequestSocket();
            socket.Connect("tcp://127.0.0.1:5555");

            string msg, reply;

            while (true)
            {
                Console.WriteLine("Type message: ");
                msg = Console.ReadLine();
                Console.WriteLine("Sending : " + msg);
                socket.SendFrame(msg);
                reply = socket.ReceiveFrameString();
                Console.WriteLine("Received: " + reply + Environment.NewLine);
            }
        }
    }
}
4

1 回答 1

6

Request 和 Response 套接字是状态机，Request 必须先 Send 再调用 Receive，不能连续调用 5 个 Send。

使用 Response 则相反，您必须先调用 Receive。

如果一侧仅发送而另一侧仅接收，则可以使用 Push-Pull 模式而不是 Req-Rep。如果需要双向通信，您还可以使用 Dealer-Router。无论如何，Req-Rep 的使用似乎是不正确的。

于 2016-10-05T08:13:44.530 回答