为什么从服务器与客户端不能接收消息NetMQ框架?

时间：2018-11-22 20:40:47 阅读：378 评论：0 收藏：0 [点我收藏+]

标签：pull ram vat 应用 string oid 服务器密码 frame factory

最近,我使用NetMQ发送或接收服务器和客户端之间的消息。服务器密码:

void Main()
{
  CreatePullAndPushSocket();
  Task.Factory.StartNew(()=> {
        while (true)
        {
            Thread.Sleep(1);
            if (Pull != null)
            {
                var message = Pull.ReceiveFrameString();
            }
        }
    });
}
PullSocket Pull;
PushSocket Push;
private void CreatePullAndPushSocket()
{
    Pull = new PullSocket("tcp://ip1:port1");
    Push = new PushSocket("tcp://ip2:port2");
}
public void SendMessageToClient(string message)
{
    if (Push != null)
    {
        Push.SendFrame(message);
    }
}

客户端代码:

void Main()
{
new Thread(()=> {
while (true)
{
Thread.Sleep(1);
if (Pull != null)
{
var message = Pull.ReceiveFrameString();
}
}
}).Start();
}
PullSocket Pull;
PushSocket Push;
private void CreatePullAndPushSocket()
{
Pull = new PullSocket("tcp://ip2:port2");
Push = new PushSocket("tcp://ip1:port1");
}
public void SendMessageToClient(string message)
{
if (Push != null)
{
Push.SendFrame(message);
}
}
当我运行两个应用程序中,服务器应用程序,另一个是客户端应用程序。