org.zeromq.ZeroMQLibrary.zmq_msg_init_size()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-17 09:09:31 26 4

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

private zmq_msg_t newZmqMessage(byte[] msg) {
 zmq_msg_t message = new zmq_msg_t();
 if (msg.length == 0) {
  if (zmq.zmq_msg_init_size(message, new NativeLong(msg.length)) != 0) {
   raiseZMQException();
  }
 } else {
  Memory mem = new Memory(msg.length);
  mem.write(0, msg, 0, msg.length);
  if (zmq.zmq_msg_init_data(message, mem, new NativeLong(msg.length), messageDataBuffer, mem) == 0) {
   messageDataBuffer.add(mem);
  } else {
   raiseZMQException();
  }
 }
 return message;
}

26 4 0

• zeromq - ZeroMQ 用例是什么？

  你能举一些zeromq的例子吗？ 最佳答案 假设您想要某种公告板。您希望通过订阅公告板来只允许某些人看到它。 这可以使用 ZeroMQ 的发布者/订阅者模型来完成。 现在，假设您需要发送一些异步消息。

• zeromq - 了解 ZeroMQ

  因此，正如我在上一篇文章中所问的那样，我希望能够使用不同语言编写的程序或函数在它们之间进行通信。 我最近遇到了 zeromq，我试图弄清楚这是否可以帮助我，因为它提供了某种套接字。例如，zeromq

• zeromq - 请解释 Zeromq eventloop

  与通过 POLLIN 多路复用多个套接字有何不同？ while True: socks = dict(poller.poll()) if socks.get(control_recei

• zeromq - 在 ZeroMQ 中进行多部分或不进行多部分

  我正在设计一个与 ZeroMQ 对话的服务器应用程序。无需深入细节，服务器将存储和服务(来自查询请求)(eventid, eventstring)元组。 我的问题涉及有线协议(protocol)的设计

• zeromq - 哪种 ZeroMQ 模式最适合一对异步套接字？

  我有一个服务器(在 Amazon 上运行)和一个连接到它的客户端。建立连接后，客户端和服务器专门相互通信并发送消息。 例如 1. Client -> Server 2. Client -> Serve

• zeromq - 使用 ZeroMQ 的建议

  我正在开发一个新的客户端-服务器应用程序 (.Net)，并且到目前为止一直在使用 WCF，它非常适合应用程序的请求-响应方法。然而，我被要求用基于套接字的解决方案替换它，部分是为了支持非 .Net 客

• zeromq - 如何在 ZeroMQ 中使用单个端点执行多个发布者？

  我正在尝试做一个发布/订阅架构，其中多个发布者和多个订阅者存在于同一总线上。根据我在互联网上阅读的内容，只有一个套接字应该调用 bind()，而所有其他套接字(无论是 pub 还是 sub)都应该调用

• zeromq - Zeromq 是否保证发送方/接收方崩溃后的交付？

  使用zeromq，发送者发送10条消息后，发送者崩溃。 场景1:接收方正在一条一条地处理消息，花费了一些明显的时间成本，在这种情况下它还会收到 10 条消息吗？ 场景 2:另一种情况是，当接收器崩溃时

• zeromq - 有没有办法知道 ZeroMQ 消息来自哪里？

  我有一个 ZeroMQ 套接字，它正在从不同机器上的多个进程接收数据。在不改变数据内容的情况下，有没有办法识别数据的来源呢？具体来说，我想要发送者的 IP 地址(如果它来自 TCP 连接)。 最佳答案

• zeromq - ZeroMQ 的延迟/指标与其竞争对手的比较

  有人知道在哪里可以找到有关 ZeroMQ 延迟与 29 West LBM 等竞争对手的性能详细信息吗？ 看起来便宜得多，但我找不到任何指标来决定哪个更合适。 最佳答案 ZeroMQ 和 29West

• zeromq - 没有转发器的 zeroMQ 库中的消息广播

  有没有办法在不使用转发器概念的情况下使用 zeroMQ 库进行消息广播？ 最佳答案 是的，一个 PUB 套接字将广播到所有连接的 SUB 套接字。只有当您想要桥接不同的网络时才需要转发器(代理)，例如

• zeromq - 使用 zeromq 设计具有多个代理的发布订阅系统

  几天前我才开始使用zeromq。我的目标是设计一个具有多个代理(代理网络)的发布订阅系统。我已经阅读了 zeromq 指南的相关部分，并为简单的发布子系统编写了代码。如果有人可以帮助我解决以下问题:

• zeromq - 右 ZeroMQ 拓扑

  我需要编写一个订单管理器，将客户(股票、外汇等)订单发送到适当的交易所。客户想要发送订单，但对 FIX 或其他专有协议(protocol)一无所知，只知道发送订单的内部(规范化)格式。我有应用程序(服

• zeromq - zeromq 中的懒惰发布/订阅，仅获取最后一条消息

  我正在尝试从示例 wuclient/wuserver 在 zeromq 上实现一个惰性订阅者。 客户端比服务器慢得多，因此它必须只获取服务器最后发送的消息。 到目前为止，我发现这样做的唯一方法是连接/

• zeromq - 如果客户端断开连接，使用 ZeroMQ 向特定客户端和队列发送回复

  我是 ZeroMQ 的新手并试图找出设计问题。我的情况是我有一个或多个客户端向单个服务器发送请求。服务器将处理请求，做一些事情，并向客户端发送回复。有两个条件: 回复必须发送到发送请求的客户端。 如果

• zeromq - 是否可以从 ZeroMQ PUB 套接字获取过滤器列表？

  如 docs 中所述在 3.x 版本的 zeromq 中，PUB/SUB 场景中的消息正在被过滤 出版商侧(而不是在订阅者方面，这是微不足道的)。 对我来说，这听起来像是发布者必须持有所有连接的套接字

• zeromq - 为什么一些 ZeroMQ 模式被称为 "pirate"

  引自 ZeroMQ 指南 However, with a little extra work, this humble pattern becomes a good basis for real wo

• multithreading - ZeroMQ:如何处理 ZeroMQ 节点中与消息无关的异步事件？

  假设我有一个带有 ZeroMQ 接口(interface)的节点(进程、线程等)，比方说一个 REP 套接字。这意味着我有一个无限主循环，它在 zmq_recv 或 zmq_poll 函数中休眠。 现

• zeromq - grpc 和 Zeromq 比较

  我想以某种方式比较 grpc 与 Zeromq 及其模式的功能:并且我想创建一些比较(功能集) - 不知何故 - 0mq 是“更好”的套接字 - 但无论如何 - 如果我应用 0mq模式 - 我认为我得

• zeromq - ZeroMQ 内部是如何连接和绑定(bind)工作的

  我正在试验 ZeroMQ。我发现在 ZeroMQ 中非常有趣，connect 或 bind 先发生并不重要。我试着查看 ZeroMQ 的源代码，但它太大了，找不到任何东西。 代码如下。 # clien