org.zeromq.ZeroMQLibrary类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(125)

本文整理了Java中org.zeromq.ZeroMQLibrary类的一些代码示例，展示了ZeroMQLibrary类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZeroMQLibrary类的具体详情如下：
包路径：org.zeromq.ZeroMQLibrary
类名称：ZeroMQLibrary

ZeroMQLibrary介绍

暂无

代码示例

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

public void bind(String addr) {
 zmq.zmq_bind(ptr, addr);
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding

public void close() {
 zmq.zmq_close(ptr);
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding

public void connect(String addr) {
 zmq.zmq_connect(ptr, addr);
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding_2.10

private void raiseZMQException() {
 int errno = zmq.zmq_errno();
 String reason = zmq.zmq_strerror(errno);
 throw new ZMQException(reason, errno);
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding

public byte[] recv(int flags) {
 zmq_msg_t message = newZmqMessage();
 if (zmq.zmq_recv(ptr, message, flags) != 0) {
  if (zmq.zmq_errno() == ZeroMQ$.MODULE$.EAGAIN()) {
   if (zmq.zmq_msg_close(message) != 0) {
    raiseZMQException();
   } else {
    return null;
   }
  } else {
   zmq.zmq_msg_close(message);
   raiseZMQException();
  }
 }
 Pointer data = zmq.zmq_msg_data(message);
 int length = zmq.zmq_msg_size(message);
 byte[] dataByteArray = data.getByteArray(0, length);
 if (zmq.zmq_msg_close(message) != 0) {
  raiseZMQException();
 }
 return dataByteArray;
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding

public boolean send(byte[] msg, int flags) {
 zmq_msg_t message = newZmqMessage(msg);
 if (zmq.zmq_send(ptr, message, flags) != 0) { // problem sending
  if (zmq.zmq_errno() == ZeroMQ$.MODULE$.EAGAIN()) {
   if (zmq.zmq_msg_close(message) != 0) {
    raiseZMQException();
   } else {
    return false;
   }
  } else {
   zmq.zmq_msg_close(message);
   raiseZMQException();
   return false;
  }
 }
 if (zmq.zmq_msg_close(message) != 0) {
  raiseZMQException();
 }
 return true;
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding

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;
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

private long getLongSockopt(int option) {
 Memory value = new Memory(Long.SIZE / 8);
 LongByReference length = new LongByReference(Long.SIZE / 8);
 zmq.zmq_getsockopt(ptr, option, value, length);
 return value.getLong(0);
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding

private zmq_msg_t newZmqMessage() {
 zmq_msg_t message = new zmq_msg_t();
 if (zmq.zmq_msg_init(message) != 0)
  raiseZMQException();
 return message;
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

protected Context (int ioThreads) {
  ptr = zmq.zmq_init(ioThreads);
 }
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

public byte[] recv(int flags) {
 zmq_msg_t message = newZmqMessage();
 if (zmq.zmq_recv(ptr, message, flags) != 0) {
  if (zmq.zmq_errno() == ZeroMQ$.MODULE$.EAGAIN()) {
   if (zmq.zmq_msg_close(message) != 0) {
    raiseZMQException();
   } else {
    return null;
   }
  } else {
   zmq.zmq_msg_close(message);
   raiseZMQException();
  }
 }
 Pointer data = zmq.zmq_msg_data(message);
 int length = zmq.zmq_msg_size(message);
 byte[] dataByteArray = data.getByteArray(0, length);
 if (zmq.zmq_msg_close(message) != 0) {
  raiseZMQException();
 }
 return dataByteArray;
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding

public boolean send(byte[] msg, int flags) {
 zmq_msg_t message = newZmqMessage(msg);
 if (zmq.zmq_send(ptr, message, flags) != 0) { // problem sending
  if (zmq.zmq_errno() == ZeroMQ$.MODULE$.EAGAIN()) {
   if (zmq.zmq_msg_close(message) != 0) {
    raiseZMQException();
   } else {
    return false;
   }
  } else {
   zmq.zmq_msg_close(message);
   raiseZMQException();
   return false;
  }
 }
 if (zmq.zmq_msg_close(message) != 0) {
  raiseZMQException();
 }
 return true;
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

private void raiseZMQException() {
 int errno = zmq.zmq_errno();
 String reason = zmq.zmq_strerror(errno);
 throw new ZMQException(reason, errno);
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding_2.10

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;
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding

private long getLongSockopt(int option) {
 Memory value = new Memory(Long.SIZE / 8);
 LongByReference length = new LongByReference(Long.SIZE / 8);
 zmq.zmq_getsockopt(ptr, option, value, length);
 return value.getLong(0);
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding

private zmq_msg_t newZmqMessage() {
 zmq_msg_t message = new zmq_msg_t();
 if (zmq.zmq_msg_init(message) != 0)
  raiseZMQException();
 return message;
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding_2.10

protected Context (int ioThreads) {
  ptr = zmq.zmq_init(ioThreads);
 }
}

代码示例来源：origin: org.zeromq/zeromq-scala-binding_2.10

public byte[] recv(int flags) {
 zmq_msg_t message = newZmqMessage();
 if (zmq.zmq_recv(ptr, message, flags) != 0) {
  if (zmq.zmq_errno() == ZeroMQ$.MODULE$.EAGAIN()) {
   if (zmq.zmq_msg_close(message) != 0) {
    raiseZMQException();
   } else {
    return null;
   }
  } else {
   zmq.zmq_msg_close(message);
   raiseZMQException();
  }
 }
 Pointer data = zmq.zmq_msg_data(message);
 int length = zmq.zmq_msg_size(message);
 byte[] dataByteArray = data.getByteArray(0, length);
 if (zmq.zmq_msg_close(message) != 0) {
  raiseZMQException();
 }
 return dataByteArray;
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding_2.10

public boolean send(byte[] msg, int flags) {
 zmq_msg_t message = newZmqMessage(msg);
 if (zmq.zmq_send(ptr, message, flags) != 0) { // problem sending
  if (zmq.zmq_errno() == ZeroMQ$.MODULE$.EAGAIN()) {
   if (zmq.zmq_msg_close(message) != 0) {
    raiseZMQException();
   } else {
    return false;
   }
  } else {
   zmq.zmq_msg_close(message);
   raiseZMQException();
   return false;
  }
 }
 if (zmq.zmq_msg_close(message) != 0) {
  raiseZMQException();
 }
 return true;
}

代码示例来源：origin: org.spark-project.zeromq/zeromq-scala-binding

private void raiseZMQException() {
 int errno = zmq.zmq_errno();
 String reason = zmq.zmq_strerror(errno);
 throw new ZMQException(reason, errno);
}

内容来源于网络，如有侵权，请联系作者删除！

ZeroMQLibrary

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com