Загрузка srudp - Загрузка исходного кода srudp

srudp

Другие категории

1.0.0

Скачать

Безопасный надежный UDP

Этот репозиторий обеспечивает безопасный надежный поток данных , который работает как TCP.
Моя цель — позволить пользователям создавать P2P-соединения между клиентами в закрытом NAT.

Функции

Чистый Питон
Использование как обычный объект сокета
Протокол, аналогичный RUDP
Пробивка отверстий UDP
высокая производительность (4 Мбит/с Up&Down при 10 МБ)
ipv4/ipv6
необязательный асинхронный режим

Требование

Питон 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

Демо

Подготовьте два независимых компьютера.

 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 )

Сторона, отправляйте приветственные сообщения раз в 3 секунды.

 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 )

Другая сторона, получите сообщение и немедленно покажите.

использование asyncio

 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, который требует большого количества соединений, вам не нужно использовать асинхронный метод.

чтобы избежать неприятностей

Не думайте, что всегда удастся установить соединение . Web-RTC обнаруживает успех UDP-пробивания отверстий или использует альтернативный способ в случае неудачи, вам необходимо его реализовать.
UDP (и некоторые TCP) часто блокируются в общедоступных сетях, таких как бесплатный Wi-Fi в аэропортах, локальная локальная сеть университета и т. д. Кроме того, иногда блокируются некоторые маршрутизаторы и сетевые адаптеры.
Я разработал этот простой TCP-объект типа сокета . У него нет функции сигнализации и специализации по данным, потому что я буду использовать его как одну из низкоуровневых библиотек для P2P.

Примечание. Зачем это делать?

В наши дни ПК находится в локальной среде, защищенной NAT. Трудно передавать данные между двумя внешними устройствами. Чтобы решить эту проблему, соединение реализуется путем пробивки отверстий UDP без использования UPnP.

UDP — протокол сокетов с минимальным набором функций для подключения приложений. Таким образом, состояние соединения отсутствует, данные могут быть недоступны, подделать источник легко. Вот почему вы не можете заменить его TCP.

С помощью этой программы вы можете обращаться с ним так же, как с TCP, не беспокоясь о вышеупомянутых проблемах. Другими словами, он имеет состояние соединения, гарантирует доступность данных и его трудно подделать.