srudpダウンロード - srudpソースコードのダウンロード

srudp

その他のカテゴリー

1.0.0

ダウンロード

安全で信頼性の高い UDP

このリポジトリは、TCP のように動作するSecure Reliable Data Streamを提供します。
私の目的は、ユーザーがクローズド NAT でクライアント間で P2P 接続を作成できるようにすることです。

特徴

ピュアパイソン
通常のソケットオブジェクトと同様の使用法
RUDPに似たプロトコル
UDPホールパンチング
高性能 (10mb の場合、上り/下り 4Mbps/s)
ipv4/ipv6
オプションの非同期

要件

Python 3.6+
要件.txt

インストール

ユーザー向けのチュートリアル「私の条件では動作しません」

pip3 install --user srudp

テスト

 git clone https://github.com/namuyan/srudp
cd srudp
pip3 install --user -r requirements.txt
python3 -m mypy --config-file=mypy.ini srudp
python3 -m unittest discover

デモ

独立したPCを2台用意します。

 from srudp import SecureReliableSocket
from time import sleep , time
 
sock = SecureReliableSocket ()
sock . connect (( "<remote host 1>" , 12345 ))
 
while not sock . is_closed :
    sock . sendall ( b'hello ' + str ( time ()). encode ())
    sleep ( 3 )
print ( "closed" , sock )

A側、3秒に1回helloメッセージを送信します。

 from srudp import SecureReliableSocket
from time import time
 
sock = SecureReliableSocket ()
sock . connect (( "<remote host 2>" , 12345 ))
 
while not sock . is_closed :
    data = sock . recv ( 1024 )
    if not data :
        break
    print ( time (), data )
print ( "closed" , sock )

別の面では、メッセージを受信してすぐに表示します。

非同期の使用法

 from srudp import SecureReliableSocket
import asyncio

# Get a reference to the current event loop
loop = asyncio . get_event_loop ()

# create a socket
sock = SecureReliableSocket ()

# connect() on another thread because block event loop
address = ( "example.com" , 3000 )
await loop . run_in_executor ( None , sock . connect , ( address ,))

# Register the open socket to wait for data
reader , writer = await asyncio . open_connection ( sock = sock )

# read
data = await reader . read ( 1024 )

# write
writer . write ( b"hello" )
writer . write ( b"world" )
await writer . drain ()

# close
writer . close ()

通常の TCP ソケットと同じように実行できます。ただし、大量の接続を必要とする HTTP プロトコルなど、意図しない場合は、async メソッドを使用する必要はありません。

トラブルを避けるために

接続の確立が常に成功するとは限りません。 Web-RTC は UDP ホールパンチの成功を検出するか、失敗した場合に別の方法を使用するように実装する必要があります。
UDP (および一部の TCP) は、空港の無料 Wi-Fi や大学のローカル LAN などのパブリックネットワークでブロックされることがよくあります。さらに、一部のルーターやネットワークアダプターもブロックすることがあります。
私はこの単純な TCP のようなソケットオブジェクトを設計しました。 P2P用の低層ライブラリの1つとして使用するため、シグナリング機能はなく、データの特化もしていません。