reliable_udp

Protocolo UDP confiável (ALPHA).

Nota: Esta não é uma implementação de https://en.wikipedia.org/wiki/Reliable_User_Datagram_Protocol

É suporte:

• Limitação constante de largura de banda por conexão.
• lógica ping/pong para ter certeza de que a conexão ainda está ativa
• reconhecimento de pacote de dados (confirmação de entrega)
• reiteração de pacotes de dados quando o reconhecimento não é recebido após algum tempo
• limitação de tentativas de envio de dados. Ele pode encerrar a conexão quando houver muitos pacotes perdidos.
• envio assíncrono de pacotes UDP simples (1024 bytes) sem qualquer reconhecimento
• enviando pacotes de dados como mensagens. Portanto, o destinatário será demitido quando receber a mensagem completamente
• limitação por enviar pacotes que estão aguardando confirmação de entrega
• prioridade interna de tráfego (QoS). (como exemplos: ping tem prioridade em tempo real, confirmação de entrega tem alta prioridade, pacotes de dados têm baixa prioridade)
• envio sincronizado/assíncrono de dados. Envio síncrono retorna controle de fluxo quando todos os pacotes com dados são enviados (eles não podem ser confirmados)

Roteiro:

• largura de banda flexível para conexão. Deve considerar a largura de banda completa do canal UDP.
• usando STUN para fazer furos UDP (https://en.wikipedia.org/wiki/UDP_hole_punching)

Opções de aplicação rudp:

ps A opção comentada está desabilitada, mas pode ser habilitada no futuro.

    % { workers_for_each_port, 1 }, %% Workers for parallel process packets for each port
    { listener_options, [] }, %% Socket listener options. See http://erlang.org/doc/man/gen_udp.html#open-2
    { connection_timeout, 10000 }, %% Connection timeout, ms
    { ping_interval, 5000 }, %% Timeout to check good connection, ms
    { ping_packet_count, 4 }, %% Number of ping packets are sent before disconnection
    { delivery_timeout, 10000 }, %% Delivery timeout to check status of delivery of packet, ms
    { bandwith_max, 100000 }, %% Max bandwith of sender for one connection, bytes/second
    { bandwith_min, 100 }, %% Min bandwith of sender for one connection, bytes/second
    %%{ bandwith_step, 100 }, %% Bandwith step for one lost packet
    { max_attempts_to_send_packet, 500000 }, %% Max attempts to send packet when it can't get delivery confirmation
    %{ bandwith_step_increase, 10000 }, %% Step to increase bandwith, bytes
    %{ bandwith_check_interval, 5000 }, %% Interval to check right bandwith.
    %{ bandwith_step_decrease, 100 }, %% Step to decrease bandwith, bytes
    { send_buffer_size, 10 }, %% Number of packets inside send buffer. Sender will be stoped if this buffer is big.
    { udp_packet_size, 1024 } %% Max udp packet size, bytes
  ]}

Uso:

Todas as funções básicas descritas no módulo gen_rudp:

  start_listener - start listener for port
  stop_listener - stop listener for port.
  connect -- connect to other host by port
  close -- close connection
  accept - start accept connection
  is_alive -- check is socket alive
  is_connected - check is socket connected to other host.
  controlling_process -- change controlling process for socket
  async_send_binary -- sends message asynchronously
  sync_send_binary -- sends message synchronously. This function will retunr ok only after full packet will be sended (delivery not confirmed)
  send_udp -- sends simple UDP message without confirmation of delivery. The maximu side for message is 1024 bytes.

Mensagens geradas pelo rudp:

• { rudp_connected, Socket, Address, Port} - fez conexão de endereço e porta
• { rudp_closed, Socket, Reason } – conexão fechada com Reason
• { rudp_received, Socket, Binary } – binário recebido