C/C++编程：[zmq.error.ZMQError: Operation cannot be accomplished in current state]

约定不等于承诺〃 2022-11-09 03:59 125阅读 0赞

# 1. 摘要 #

一个项目中，由于Python中某些module对python3和python2的支持不同，必须将一部分代码运行在python2.7环境中，另一部分代码运行在python3.5环境中

*  deuces：只支持python2
 *  tensorflow：只支持python3

那这两部分代码如何进行数据传输呢？

*  用message queue
 *  于是选择了轻量级的ZMQ（它对python2和python3都支持的很好）

ZMQ的入门也很简单。但在写稍微复杂一点的通信过程时，就经常遇到下面这个报错：

zmq.error.ZMQError: Operation cannot be accomplished in current state

这个报错也很简单，打了很多log也无法看出具体问题所在。

这就是背景，下面详细讲解如何重现与解决这个问题。

# 2. ZMQ介绍 #

从\[1\]中可知，ZMQ是一个简单好用的传输层，像框架一样的一个 socket library，他使得 Socket 编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。ZMQ 的明确目标是“成为标准网络协议栈的一部分，之后进入 Linux 内核。

与 RabbitMQ 相比，ZMQ 并不像是一个传统意义上的消息队列服务器，事实上，它也根本不是一个服务器，它更像是一个底层的网络通讯库，在 Socket API 之上做了一层封装，将网络通讯、进程通讯和线程通讯抽象为统一的 API 接口。

ZMQ的编程示例可参考示例。

# 3. 导致错误的由来 #

下面我们写一个能重新该问题的简单程序：

服务端程序如下，它主要在一个死循环中不断接受信息，并根据信息内容，做出相应的回复/或不回复。

import zmq
    
    # server
    context = zmq.Context()
    socket = context.socket(zmq.REP)
    socket.bind('tcp://127.0.0.1:5555')
    while True:
        msg = socket.recv()
        print('get msg={0}'.format(msg))
        if msg == 'test':
            socket.send_string('done')
            print('reply done')
        else:
            print('reply nothing')

客户端程序如下，它不断向服务端程序发送消息

import zmq
    
    # client
    context = zmq.Context()
    socket = context.socket(zmq.REQ)
    socket.connect('tcp://127.0.0.1:5555')
    socket.send('test')
    socket.send('test1')
    socket.send('test2')
    print msg

先运行服务端程序，在运行客户端程序，能看到两个程序都有报错：

zmq.error.ZMQError: Operation cannot be accomplished in current state

这是怎么回事呢？

# 4. 错误的原因 #

通过报错打印的trace看到，在客户端程序中，报错相关信息为：

Traceback (most recent call last):
      File "zmq_client.py", line 8, in <module>
        socket.send('test1')

可见，在报错前，已经成功通过socket.send(‘test’)将信息送出。

在服务端程序中，报错时的打印内容为：

get msg=b’test’  
reply nothing  
Traceback (most recent call last):  
File “zmq\_server.py”, line 9, in  
msg = socket.recv()

可见，在报错前，已经成功收到了’test’信息。

所以，问题并不是trace打印出来的recv()和send()使用错误。而是\[3\]中提到的编程模式问题。

回到程序中，我们可以看到，这里使用的zmq模式为zmq.REP。在这种模式下，我们的程序必须要遵守recv()和send()配对使用的编程模式。

也就是说，在服务程序中，必须要有完整的recv()和send()成对出现。同理，在客户端程序中，send()后，也要有recv()。

# 5. 如何修复错误 #

**只要recv()和send()配对使用，就能解决这个问题。**

修复后的服务端程序：

import zmq
    
    
    # server
    context = zmq.Context()
    socket = context.socket(zmq.REP)
    socket.bind('tcp://127.0.0.1:5555')
    while True:
        msg = socket.recv()
        print('get msg={0}'.format(msg))
        if msg == 'test':
            socket.send_string('done')
            print('reply done')
        else:
            socket.send_string('nothing')# fixing for recv-send pair
            print('reply nothing')

修复后的客户端程序：

import zmq
    
    # client
    context = zmq.Context()
    socket = context.socket(zmq.REQ)
    socket.connect('tcp://127.0.0.1:5555')
    socket.send('test')
    socket.recv()# fixing for recv-send pair
    
    socket.send('test1')
    socket.recv()# fixing for recv-send pair
    
    socket.send('test2')
    socket.recv()# fixing for recv-send pair

程序中加了注释的地方，就是改动/增加的代码fixing