netmq

2热度

1回答

什么是NetMQ API在自定义缓冲区中接收以避免在每个帧/消息上创建新的字节数组？

我有以下代码： while (!isCancellationRequested) { byte[] frameBytes = socket.ReceiveFrameBytes(); MyData data = new MyData(); data.Deserialize(frameBytes); // send the data somewhere som

0热度

1回答

IQbservable <>需要组装已经在项目

使用面向.NET 4.5的项目，我有一段代码，这是否 public static IObservable<string> Receive(SubscriberSocket subp) { return Observable .Create<string>(o => Observable.Using<string, SubscriberSocket>(() =>

1热度

1回答

netMQ或者zeroMQ如何决定发送

其客户端的代码是在这里： using (var server = new ResponseSocket()) { server.Bind("tcp://*:5555"); while (true) { var message = server.ReceiveFrameString(); Con

0热度

1回答

如何确定客户端套接字的连接状态？

我正在使用NetMQ套接字来执行客户端 - 服务器通信。我有一台监听端口5555和一台客户端的服务器，即.bind() -s。这里是我的代码示例： using (NetMQContext ctx = NetMQContext.Create()) { using (var client = ctx.CreateRequestSocket()) {

0热度

2回答

如何同步客户端的发送帧和接收帧？

如果我发送请求（帧）B并接收响应，同时我已经在等待前一个请求（A）的响应，那么B任务中接收到的响应实际上是A请求的响应： request A sent request B sent request B processed (quick) response B sent response B received (*) ... request A processed (slow) res

1热度

1回答

REQ/REP模式中的ZeroMQ FiniteStateMachineException

我有两个简单的组件，它们应该使用REQ/REP ZeroMQ模式相互通信。服务器（REP插座）使用pyzmq用Python实现： import zmq def launch_server(): print "Launching server" with zmq.Context.instance() as ctx: socket = ctx.socket(zmq

0热度

1回答

NetMQ接收/响应循环不工作

我拿了https://netmq.readthedocs.io/上的一个简单的接收/请求套接字示例，并希望使它在无限循环中与parametrizedThread一起工作。代码工作正常几圈后，它抛出非阻塞套接字操作无法立即完成了什么，我得到了上面应该在第一循环结束后立即发生而不是随机的。这里有什么问题？这听起来像是必须刷新才能再次获得干净的连接（不确定）。 class Program {

1热度

1回答

有没有办法将TCP keepalive用作事件？

由于我使用TCP进行连接，我不知道是否可以使用保持活动信号作为我的应用程序的通知源。即我想在客户端和服务器端检测断开状态（对于给定的套接字）。可能吗？如果是 - 如何做？到目前为止，我找到了设置保持活动时间间隔和Monitor方法的选项，但我没有看到如何通知它的方法。在服务器端，我想知道哪个客户端死了当然。

0热度

2回答

如何在ZeroMQ或NetMQ中从路由器套接字发送和接收数据？

我有一个经销商< - >路由器设置在NetMQ v4我可以在任何方向异步发送和接收消息，没有问题。我现在要正式到这一点抽象，其中服务器（路由器）监听任何进入的消息，但它也需要按需广播消息到任何连接的客户端（经销商）的。我试图避免使用Pub < - >子套接字，因为我需要订户也发送消息到服务器。我试图实现的最接近的模式是WebSocket客户端 - 服务器通信。听取客户端的消息的第一部分是在像

1热度

2回答

netMQ 4.0多线程

我有一些基于netMQ 4.0的多线程服务器的问题。我试图使用http://zguide.zeromq.org/cs:mtserver，但netMQ 4.0上没有上下文。我想： for (var i = 0; i < workerCount; ++i) { new Thread(() => Worker(connStr.Value)).Start(); } //... pri