0mq 入门

#encoding=utf-8
#   Hello World client in Python
#   Connects REQ socket to tcp://localhost:5555
#   Sends "Hello" to server, expects "World" back
#
import zmq

context = zmq.Context()

#欢迎信息
print "正在连接hello world服务器"
socket = context.socket(zmq.REQ) #socket 模式通讯
socket.connect ("tcp://localhost:5555") # 连接到本地的5555端口

#发出10次请求，每次等待服务器的一个响应
for request in range (1,10):
    print "客户端发送请求", request,"..."
    socket.send ("土鳖，你好吗？")

    #获取服务器响应
    message = socket.recv()
    print "客户端收到回复", request, "[", message, "]"

#encoding=utf-8
#   Hello World server in Python
#   Binds REP socket to tcp://*:5555
#   Expects "Hello" from client, replies with "World"
#
import zmq
import time

context = zmq.Context()
socket = context.socket(zmq.REP) #socket模式通讯
socket.bind("tcp://*:5555") #监听5555端口，等待请求

while True:
    #等待从客户端发送的请求
    message = socket.recv()
    print "服务器收到请求: ", message

    #干点啥，鳖喜欢睡，所以睡会
    time.sleep (1)

    #向客户端发送请求
    socket.send("土鳖不好:(")

    class Program
    {
        static void Main(string[] args)
        {
            //构建服务器和客户端线程
            var client = new Thread(ClientThread);
            var server = new Thread(ServerThread);

            //开始执行线程
            server.Start();
            client.Start();

            //等待线程执行完毕
            server.Join();
            client.Join();
        }

        private static void ClientThread()
        {
            Thread.Sleep(10);

            using (var context = ZmqContext.Create())
            using (var socket = context.CreateSocket(SocketType.REQ))
            {
                //连接服务器
                socket.Connect("tcp://localhost:8989");
                //发送消息
                string msg = "土鳖，你好吗";
                socket.SendFrame(new Frame(Encoding.UTF8.GetBytes(msg)));
                Console.WriteLine("客户端发送请求：" + msg);
                var buffer = new byte[100];
                int size = socket.Receive(buffer);
                string recvMsg = Encoding.UTF8.GetString(buffer, 0, size);
                Console.WriteLine("客户端收到回复：" + recvMsg);
            }
        }

        private static void ServerThread()
        {
            //创建上下文和socket
            using (var context = ZmqContext.Create())
            using (var socket = context.CreateSocket(SocketType.REP))
            {
                //服务器监听8989端口
                socket.Bind("tcp://*:8989");
                //接收客户端请求
                Frame request = socket.ReceiveFrame();
                string msg = Encoding.UTF8.GetString(request);
                Console.WriteLine("服务端收到请求：" + msg);

                string sendMsg = "土鳖不好:(";
                socket.SendFrame(new Frame(Encoding.UTF8.GetBytes(sendMsg)));
                Console.WriteLine("服务端发送回复：" + sendMsg);
            }
        }
    }