2

我有一台服务器需要获取指令以在另一台机器上为客户端运行进程。

客户端发送作业消息，服务器处理作业，然后发送回结果。

我尝试使用 NetMQ 请求响应模式（见下文）

这适用于 1 个客户端，但如果第二个客户端在前一个客户端作业完成之前发送请求 - 我收到错误消息。

我真的需要能够接收来自客户的临时消息，并在完成后发送结果。显然，我使用了错误的模式，但阅读 ZeroMQ 文档并没有突出显示更合适的模式。

namespace Utils.ServerMQ
{
    class ServerMQ
    {
        public static void Go()
        {
            using (var responseSocket = new ResponseSocket("@tcp://*:393"))
            {
                while (true)
                {
                    Console.WriteLine("Server waiting");
                    var message = responseSocket.ReceiveFrameString();

                    Console.WriteLine("Server Received '{0}'", message);

                    //System.Threading.Thread.Sleep(1000);
                    var t2 = Task.Factory.StartNew(() =>
                    {
                        RunProcMatrix(message, responseSocket);
                    });

                }
            }
        }

        public static void RunProcMatrix(object state, ResponseSocket responseSocket)
        {
            var process = new Process
            {
                StartInfo = new ProcessStartInfo
                {
                    FileName = Path.Combine(@"H:\Projects\Matrix\Matrix\bin\Debug\", "Matrix001.exe"),
                    Arguments = (string)state,
                    WindowStyle = ProcessWindowStyle.Normal,
                    CreateNoWindow = false
                }
            };
            process.Start();
            process.WaitForExit();


            responseSocket.SendFrame((string)state);
        }
    }
}
4

1 回答 1

1

您希望在服务器端有一个 ROUTER 套接字，这样它就可以一次接收多个请求。（指南）客户端的REQ套接字仍然可以，除非服务器可以任意向它们推送数据，那么它们需要是DEALER套接字。

请注意，对于 REQ/RESP 之外的套接字，您需要手动处理消息信封（指示其目的地的消息的第一帧）。指导

0MQ 文档非常密集......我不怪你没有从他们那里直觉到这一点:)

NetMQ 文档中的这个示例是完整的 ROUTER-DEALER：https ://netmq.readthedocs.io/en/latest/router-dealer/#router-dealer ，您可以只使用路由器端，它应该可以工作。

于 2018-10-31T15:28:47.550 回答