问题描述
我正在尝试使用pysctp
套接字实现基于SCTP和基于异步的客户端。理想情况下,我想做类似的事情:
async def sctp_client():
sock = sctp.sctpsocket_udp(socket.AF_INET)
reader,writer = await asyncio.open_connection(sock=sock)
writer.write(b'some data',ppid=5)
await writer.drain()
data = await reader.read(100)
print(f'Received: {data.decode()}')
writer.close()
await writer.wait_closed()
实际上,有两个问题:
- 是否可以将“运输工厂”传递给
open_connection
或loop.create_connection
? 我希望流包含的传输对象使用sctp_recv
而不是recv
和sctp_send
而不是send
。显然,最简单的方法是从原始传输类派生,但是我找不到一种很好的pythonic方法来实现它。 - 是否可以从
StreamWriter
获取自定义open_connection
?显然,我可以从原始文件中创建自己的文件,可以在原始文件中添加方法,也可以只访问内部运输,但这些选择非常难看。我能想到的第二个最佳方法就是使用open_connection
实现自己的loop.create_connection
。
非常感谢!
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)