在Python的nanomsg PUSH/PULL模式中设置套接字超时遇阻

你遇到的这个问题我之前也踩过坑——核心原因是超时参数的传递类型完全错误。nanomsg的NN_RCVTIMEO和NN_SNDTIMEO选项要求传入的是整数类型的毫秒值，但你用create_string_buffer(b'500')把字符串转成字节缓冲区传进去，这就导致nanomsg内部无法解析出有效的超时时间，自然会保持无限超时的默认行为。

至于为什么getsockopt能返回你设置的值？那是因为它只是原样返回了你写入的字节内容，但nanomsg根本没把这个字符串当成有效的超时参数来处理。

修正方案 #

你需要用ctypes的整数类型（比如c_int）来包装超时值，并且确保传递的是这个整数的内存地址和正确的大小（如果你的nn_wrapper封装遵循标准nanomsg的API签名的话）。

下面是修正后的完整代码：

import ctypes
import time
import nn_wrapper

# 确认nanomsg常量值是否和你的版本匹配，通常这些值是通用的
NN_RCVTIMEO = 5 
NN_SNDTIMEO = 4 
NN_SOL_SOCKET = 0 
AF_SP = 1
PULL = 1
PUSH = 0

# 设置超时为500毫秒，用c_int包装整数类型的超时值
timeout_ms = 500
timeout = ctypes.c_int(timeout_ms)

# 处理PULL套接字（接收端）
socket_in = nn_wrapper.nn_socket(AF_SP, PULL)
# 传递超时值的指针和大小给setsockopt
success = nn_wrapper.nn_setsockopt(
    socket_in, 
    NN_SOL_SOCKET, 
    NN_RCVTIMEO, 
    ctypes.byref(timeout), 
    ctypes.sizeof(timeout)
)
nn_wrapper.nn_bind(socket_in, 'tcp://127.0.0.1:64411')
time.sleep(0.2)
print("设置接收超时成功?", success)

# 处理PUSH套接字（发送端）
socket_out = nn_wrapper.nn_socket(AF_SP, PUSH)
success = nn_wrapper.nn_setsockopt(
    socket_out, 
    NN_SOL_SOCKET, 
    NN_SNDTIMEO, 
    ctypes.byref(timeout), 
    ctypes.sizeof(timeout)
)
nn_wrapper.nn_connect(socket_out, 'tcp://127.0.0.1:64400')
time.sleep(0.2)
print("设置发送超时成功?", success)

# 发送消息，根据封装逻辑处理超时（标准nanomsg会返回-1并设置errno）
try:
    send_result = nn_wrapper.nn_send(socket_out, b'HELLO', 0)
    if send_result == -1:
        print("发送超时或失败")
except Exception as e:
    print("发送超时:", e)

# 接收消息，同样处理超时情况
try:
    bytes_received, message = nn_wrapper.nn_recv(socket_in, 0)
    if bytes_received == -1:
        print("接收超时或失败")
    else:
        print("收到消息:", message)
except Exception as e:
    print("接收超时:", e)

# 清理套接字资源
nn_wrapper.nn_close(socket_in)
nn_wrapper.nn_close(socket_out)

额外注意事项 #

• 如果你封装的nn_setsockopt已经自动处理了参数大小（比如内部默认按4字节整数处理），那可能只需要把timeout换成c_int实例，但最好还是明确传递大小，避免版本兼容问题。
• 标准nanomsg的nn_send和nn_recv在超时会返回-1，同时设置errno为ETIMEDOUT，所以你可能需要在封装里处理错误码，或者在调用后检查返回值。
• 确认AF_SP、PUSH、PULL这些常量值和你的nanomsg版本一致，不同版本可能有细微差异，不确定的话可以查nanomsg的头文件。

内容的提问来源于stack exchange，提问作者teafellow