我正在尝试使用NetMQ实现在两个应用程序之间传递的简单消息(稍微更详细地描述了我想要实现的内容).
经过一些试验和错误后,我发现在Connect / Bind调用之后我不能立即发送或接收消息,因为它们是非阻塞的,即使尚未建立连接也会实际返回.
现在我用Thread.Sleep()解决了这个问题,但这对它有不好的品味,对于生产系统来说绝对不行.
经过一些试验和错误后,我发现在Connect / Bind调用之后我不能立即发送或接收消息,因为它们是非阻塞的,即使尚未建立连接也会实际返回.
现在我用Thread.Sleep()解决了这个问题,但这对它有不好的品味,对于生产系统来说绝对不行.
所以问题是,如何在NetMQ / ZeroMQ中做到这一点?
客户端示例:
using (NetMQContext ctx = NetMQContext.Create()) { using (var client = ctx.CreatePushSocket()) { client.Connect("tcp://127.0.0.1:5555"); Thread.Sleep(100); // wait for connection for (int i = 0; i < 5; i++) { client.Send("test " + i,true); } } } }
服务器示例:
using (NetMQContext ctx = NetMQContext.Create()) { using (var server = ctx.CreatePullSocket()) { server.Bind("tcp://127.0.0.1:5555"); Thread.Sleep(100); // wait for connection while (true) { var str = server.ReceiveString(); Console.Out.WriteLine(str); Thread.Sleep(60*1000); // do msg processing } } }
我想要实现的目标的描述:
客户端 – 将消息发送到单个服务器.当服务器不可用时,客户端不应阻止并且不应丢弃消息.客户端可以随时离线/在线.
服务器 – 从单个客户端接收消息.服务器将阻塞,直到收到消息.服务器需要对消息进行冗长的处理,并且在处理时不应丢失任何其他消息.服务器可以随时离线/在线.
解决方法
原文地址:https://www.jb51.cc/csharp/97560.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。