ZMQ高水位标记已在3.x.x上弃用

Question

使用jzmq包装器：

scala>导入org.zeromq.ZMQ导入org.zeromq.ZMQ

scala> val context = ZMQ.context(1)
context: org.zeromq.ZMQ.Context = org.zeromq.ZMQ$Context@56d58984
scala> val socket = context.socket(ZMQ.REP)
socket: org.zeromq.ZMQ.Socket = org.zeromq.ZMQ$Socket@2a5a0f9
scala> socket.getHWM()
res6: Long = -1
scala> socket.setHWM(200)
scala> socket.getHWM()
res8: Long = -1

这似乎在版本3:中得到了缓解

https://github.com/zeromq/jzmq/blob/750f2eecaa4c71adf86c156fab5840a2f614d4ea/src/org/zeromq/ZMQ.java#L895-900

有人知道为什么吗？使用jzqm+zmq3设置HWM的替代方案是什么？

Answer 1

看看：http://zeromq.org/docs:3-1-升级

在zeromq3.2中，HWM被划分为发送和接收高水位标记：ZMQ_SNDHWM和ZMQ_RCVHWM。

您在jzmq中查找的函数有：

long    getRcvHWM()
long    getSndHWM()
void    setRcvHWM(long rcvHWM)
void    setSndHWM(long sndHWM) 

Answer 2

CZMQ绑定模拟旧的HWM选项，其他绑定也可以这样做。