时间戳

首页 > 解决方案 > 如何在 pysctp 库中使用 sctpsocket_udp 类

python - 如何在 pysctp 库中使用 sctpsocket_udp 类

问题描述

我正在尝试使用 pysctp 库设置一个基本的 SCTP 客户端/服务器示例。我想使用sctp.sctpsocket_udp该类，因为根据相关的文档字符串：

一个 UDP 样式的 SCTP 套接字可以通过一个套接字保存多个关联。

...这是我需要的功能。这是我到目前为止所拥有的：

server_sock = sctp.sctpsocket_udp(socket.AF_INET)
server_sock.bind((str(ip_address), port))
server_sock.listen(16)
server_sock.settimeout(1)

while not done:
    time.sleep(3)
    fromaddr, flags, msg, notif = server_sock.sctp_recv(3*1024*1024)

为了简洁起见，我当然省略了诸如导入之类的内容。最重要的是，当执行此操作时，我收到以下错误：

BlockingIOError: [Errno 11] 资源暂时不可用

相应的堆栈跟踪表明问题是在底层调用上出现的_sctp.sctp_recv_msg(...)

strace 的输出显示如下：

1032 socket(PF_INET, SOCK_SEQPACKET|SOCK_CLOEXEC, IPPROTO_SCTP) = 3
1033 getsockopt(3, 0x84 /* SOL_??? */, 2, "\n\0\377\377\10\0`\352", [8]) = 0
1034 getsockopt(3, 0x84 /* SOL_??? */, 11, "\0\0\0\0\0\0\0\0\0\0", [10]) = 0
1035 bind(3, {sa_family=AF_INET, sin_port=htons(9000), in_addr=inet_addr("127.0.0.1")}, 16) = 0
1036 listen(3, 16)                           = 0
1037 ioctl(3, FIONBIO, [1])                  = 0
1038 mmap(NULL, 3149824, PROT_READ|PROT_WRITE, MAP_PRIVATE|MAP_ANONYMOUS, -1, 0) = 0x7fd621646000
1039 recvmsg(3, 0x7ffe1a59ba40, 0)           = -1 EAGAIN (Resource temporarily unavailable)

我试图重新启动我的计算机，以防有一些资源挂起，但这没有任何帮助。

标签： pythonpython-3.7sctp

解决方案

想通了这个问题。

在后台，我也尝试过的调用socket.settimeout(1)或类似调用socket.setblocking(False)会导致底层套接字设置为非阻塞。这成为一个问题的原因是，虽然大多数套接字操作（例如，socket.recvmsg您在sctp.sctpsocket_udp对象上调用的普通操作都被委托给 pythonsocket对象，但sctp_*调用不会，它们是通过_sctp.cpysctp 的 C 扩展组件处理的。什么这意味着，当你做一些导致底层套接字非阻塞的事情时，例如socket.settimeout(1)，然后使用其中一个sctp_*函数，而不是超时然后得到一个socket.timeout异常，你最终会进入底层 C 扩展的这一部分：

size = sctp_recvmsg(...)
if(size < 0){
    free(msg);
    PyErr_SetFromErrno(PyExc_IOError);
    return ret;
}

因此，得到上面引用的 BlockingIOError。解决方案是使用非阻塞模式而不是打扰超时，然后捕获BlockingIOError而不是 socket.timeout检查errno异常的属性以确保它EAGAIN因此指示此时没有可用数据，所以睡眠或其他东西然后再试一次。

推荐阅读