【ZeroMQ】消息模式

1、請求/應答模式(REP/REQ)

該模式特征：

• 服務器使用REP類型套接字而客戶端使用REQ類型套接字
• 客戶端發送請求和接收答復，而服務器則接收請求並發送答復
• 客戶端可以連接到一個或多個服務器。在這種情況下，請求會在所有的服務器（Reps）之間循環，一個請求被發送到某個服務器，下一個請求則被發送到下個服務器，如此進行下去。
• 基於狀態的模式：客戶端在發送另一個請求之前，必須先接收前一個請求的答復。而服務器在接收另一個請求之前，必須答復前一個請求。

//服務器端代碼
        private static void Main(string[] args)
        {
            using (var context = ZContext.Create())
            {
                using (var resp = new ZSocket(context, ZSocketType.REP))
                {
                    resp.Bind("tcp://*:5555");
                    while (true)
                    {
                        ZFrame reply = resp.ReceiveFrame();
                        string message = reply.ReadString();

                        Console.WriteLine("Receive message {0}", message);

                        resp.Send(new ZFrame(message));

                        if (message == "exit")
                        {
                            break;
                        }
                    }
                }
            }
        }

//客戶端代碼
        static void Main(string[] args)
        {
            using (var context = new ZContext())
            using (var requester = new ZSocket(context, ZSocketType.REQ))
            {
                // Connect
                requester.Connect("tcp://127.0.0.1:5555");

                while(true)
                {
                    Console.WriteLine("Please enter your message:");
                    string message = Console.ReadLine();
                    requester.Send(new ZFrame(message));

                    // Send
                    //requester.Send(new ZFrame(requestText));

                    // Receive
                    using (ZFrame reply = requester.ReceiveFrame())
                    {
                        Console.WriteLine("Received: {0} {1}!", message, reply.ReadString());
                        if ("exit" == reply.ReadString())
                        {
                            break;
                        }
                    }
                }
            }
        }

 

2、發布/訂閱模式Publish/Subscribe(PUB/SUB)

該模式具有一下特征：

• 發布者使用PUB類型套接字和訂閱者則使用SUB類型套接字
• 一個發布者可以有一個或者多個訂閱者
• 一個訂閱者可以連接到一個或者多個發布者
• 發布者發送消息而訂閱者接收消息
• 訂閱者可以使用SubscribeAll方法訂閱所有的發布者消息，可以使用Subscrube方法訂閱某個特定的消息，這時要將所感興趣的發布者的消息前綴作為參數。對消息的過濾發生在訂閱者端，即發布者將其所有的消息發送給訂閱者，而訂閱者負責將不需要的消息丟棄。
• 訂閱者可以用UnsubscribeAll方法取消所有訂閱，也可以使用Unsubscribe方法加上消息前綴來退訂某個發布者。
• 發布者將消息發送到已連接的所有訂閱者。
• 如果發布者沒有和任何訂閱者連接，那么消息將會被丟棄。
• 如訂閱者連接到多個發布者，那么它會均勻的接收所有發布者的消息（公平隊列）。

//發布者
        static void Publisher()
        {
            using (var context = new ZContext())
            using (var publisher = new ZSocket(context, ZSocketType.PUB))
            {
                publisher.Bind("tcp://127.0.0.1:5555");
                Random random = new Random();
                while (true)
                {
                    string message = string.Format("Random: {0}", random.Next(20));
                    publisher.Send(new ZFrame(message));
                    Console.WriteLine("Send:{0}", message);
                    Thread.Sleep(1000);
                }
            }
        }

//訂閱者
        static void Subscribe()
        {
            using (var context = new ZContext())
            using (var subscribe = new ZSocket(context, ZSocketType.SUB))
            {
               subscribe.SubscribeAll();
                subscribe.Connect("tcp://127.0.0.1:5555");
                while (true)
                { 
                   
                    using (ZFrame replay = subscribe.ReceiveFrame())
                    {
                        Console.WriteLine("REceive: {0}", replay.ReadString());
                    }
                }
                
            }
        }

 

3、管道模式(Push/Pull)

當需要進行並行數據處理時，通常會用到該模式。管道模式使用場景如下所示：

• 1.首先任務分發器通常以循環方式將消息（任務）推送給工作單元（每個工作單元有不同任務）
• 2.接收到消息時工作單元會先對其進行處理，然后將它推送給接收消息（任務）的某種任務收集器。
• 3.收集器以公平排隊的方法從期連接的所有工作單元那接收消息。

該模式具有一下特征：

• 任務分發器使用PUSH類型的套接字。它綁定到端點，並等待工作單元的連接。
• 工作單元有兩個套接字，一個使用PULL類型連接到任務分發器，另一個則是PUSH類型，負責和收集器的連接。
• 任務收集器使用PULL類型套接字。它綁定到端點，並等待接收工作單元的連接。
•