出于好奇,我决定浏览一下 ZeroMQ 库中的几个示例。具体来说,http://zguide.zeromq.org/cs: hwclient上的“Hello World”示例
据我所知,我已正确复制了示例中的代码,并且具有以下内容:
public class Program
{
public static void Main(string[] args)
{
using(var context = new Context(1))
{
using(Socket requester = context.Socket(SocketType.REQ))
{
requester.Connect("tcp://localhost:5555");
const string requestMessage = "Hello";
const int requestsToSend = 10;
for(int requestNumber = 0; requestNumber < requestsToSend;requestNumber++)
{
Console.WriteLine("Sending Request {0}...", requestNumber);
requester.Send(requestMessage,Encoding.Unicode);
string reply = requester.Recv(Encoding.Unicode);
Console.WriteLine("Received Reply {0}: {1}", requestNumber, reply);
}
}
}
Console.ReadLine();
}
}
我遇到的问题是,一旦它到达下一行,程序就会停止并等待消息,而且它似乎永远不会收到它。
string reply = requester.Recv(Encoding.Unicode);
程序赶上了这条线。我想这可能与冲突的 tcp 地址有关?不太确定,因为我对套接字级编程不太熟悉。
关于为什么这不起作用的任何想法?我已经搜索了 ZeroMQ 文档,但到目前为止还没有找到任何东西。