在 nanomsg python 中设置套接字超时

Question

我在 PUSH/PULL 架构中的 nanomsg python 上正确设置超时时遇到问题。我使用设置套接字选项函数并传入一个 ctype 对象。两个set_sock_optionsreturn都成功了。我错过了什么吗？

套接字可以接收和发送，但超时无限。当我使用 get_sock_option 时，它 return 是我刚刚设置的值，所以我的输入似乎有某种效果。

NN_RCVTIMEO = 5
NN_SNDTIMEO = 4
NN_SOL_SOCKET = 0

message = ""

timeout = ctypes.create_string_buffer(b'500');

#Bind input socket
socket_in = nn_wrapper.nn_socket(AF_SP, PULL)
sucess = nn_wrapper.nn_setsockopt(socket_in, NN_SOL_SOCKET, NN_RCVTIMEO, timeout)
nn_wrapper.nn_bind(socket_in, 'tcp://127.0.0.1:64411')
time.sleep(0.2)

print("SUCESS?" + str(sucess))


#Send inquiry
socket_out = nn_wrapper.nn_socket(AF_SP, PUSH)
sucess = nn_wrapper.nn_setsockopt(socket_out, NN_SOL_SOCKET, NN_SNDTIMEO, timeout)
nn_wrapper.nn_connect(socket_out, 'tcp://127.0.0.1:64400')
time.sleep(0.2)

print("SUCESS?" + str(sucess))

nn_wrapper.nn_send(socket_out, b'HELLO',0)

#Received...
bytes, message = nn_wrapper.nn_recv(socket_in, 0)

nn_wrapper.nn_close(socket_in)
nn_wrapper.nn_close(socket_out)

Answer 1

看起来在使用通过引用接收参数（在本例中为整数）的 C 函数包装器时，您必须使用 'struct' 模块。这是如何使用整数值 500 作为 nn_setsockopt() 函数的参数：

from struct import Struct
from nanomsg import wrapper as nn_wrapper
from nanomsg import Socket, PULL, PUSH, AF_SP
import ctypes

NN_RCVTIMEO = 5
NN_SOL_SOCKET = 0

INT_PACKER = Struct(str('i'))
timeout = (ctypes.c_ubyte * INT_PACKER.size)()
INT_PACKER.pack_into(timeout, 0, 500)

socket_in = nn_wrapper.nn_socket(AF_SP, PULL)
nn_wrapper.nn_bind(socket_in, 'tcp:///127.0.0.1:60000')
nn_wrapper.nn_setsockopt(socket_in, NN_SOL_SOCKET, NN_RCVTIMEO, timeout)

Answer 2

聚会迟到了，希望能帮助下一个人...

库的编写者已经想到了这些问题，并为socket对象提供了set_int_optionpython

这对我有用：

import nanomsg


class ManagementClient:
    def __init__(self, endpoint):
        self._client_socket = nanomsg.Socket(nanomsg.REQ)
        self._client_socket.set_int_option(nanomsg.SOL_SOCKET, nanomsg.RCVTIMEO, 5 * 1000)
        self._client_socket.connect("tcp://" + endpoint)

在 nanomsg python 中设置套接字超时

Setting up socket timeout in nanomsg python

python-2.7

ctypes

nanomsg