Создание P2P-сети на Delphi: Implementing a Peer Class

Delphi , Интернет и Сети , TCP/IP

В данной статье мы рассмотрим, как создать класс, который будет представлять собой узел (peer) в P2P-сети с использованием Object Pascal (Delphi) и компонентов Indy. Мы будем следовать обсуждению на форуме, где пользователь Gustavo 'Gus' Carreno ищет советы о том, как создать такой класс.

Контекст: Пользователь Gus хочет создать класс, который будет представлять собой peer в P2P-сети, подобно TIdTCPServer или TIdTCPClient. Он не уверен, стоит ли унаследовать TIdTCPServer и добавить методы для клиентской стороны P2P или же лучше унаследовать от другого класса, о котором он не знает. Он также упоминает, что в P2P-контексте нужны флаги, чтобы отличать UP (инициированные) и DOWN (полученные) соединения, чего нет в текущей реализации TCP-сервера.

Решение:

Для создания класса, представляющего собой peer в P2P-сети, мы можем использовать существующие компоненты Indy и добавить необходимые методы и свойства. Ниже приведены шаги, которые помогут вам создать такой класс:

1. Выбор базового компонента: Как отметил Remy Lebeau, для создания P2P-класса нам понадобится компонент, который может обрабатывать tanto inbound (полученные) quanto outbound (инициированные) соединения. TIdTCPServer подходит для inbound-соединений, а TIdTCPClient - для outbound-соединений. Однако, поскольку в P2P-сетях узлы могут инициировать и получать соединения, нам нужен компонент, который может делать и то, и другое. TIdTCPServer не подходит, так как он может обрабатывать только одно соединение одновременно. TIdSimpleServer также не подходит, так как он не поддерживает multiple connections.

В этом случае мы можем использовать TIdTCPServer в качестве базового класса и добавить методы для изначально клиентских (outbound) соединений. Для этого нам понадобится унаследовать TIdTCPServer и добавить необходимые методы и свойства.

1. Создание списка соединений: Для хранения tanto inbound quanto outbound-соединений нам понадобится список. Indy уже имеет несколько вариантов thread-safe list, которые мы можем использовать, например, TIdThreadSafeList или TIdSyncList.

В нашем классе мы можем создать два списка: один для inbound-соединений и один для outbound-соединений. Каждый список будет содержать экземпляры TIdTCPConnection, которые мы можем получить из TIdTCPServer. Мы также можем добавить свойство, которое будет возвращать объединенный список всех соединений.

type
  TIdPeer = class(TIdTCPServer)
  private
    FInboundConnections: TIdThreadSafeList<TIdTCPConnection>;
    FOutboundConnections: TIdThreadSafeList<TIdTCPConnection>;
  public
    property InboundConnections: TIdThreadSafeList<TIdTCPConnection> read FInboundConnections;
    property OutboundConnections: TIdThreadSafeList<TIdTCPConnection> read FOutboundConnections;
    property AllConnections: TIdThreadSafeList<TIdTCPConnection> read GetAllConnections;
    procedure ConnectToPeer(const PeerAddress: TIdTCPEndPoint);
  end;

1. Добавление методов для изначально клиентских (outbound) соединений: Чтобы инициировать соединение с другим peer, мы можем добавить метод ConnectToPeer, который будет принимать адрес peer в виде TIdTCPEndPoint и создавать новое TIdTCPConnection-соединение с этим адресом. Мы также можем добавить флаг, чтобы отличать outbound-соединения от inbound-соединений.

procedure TIdPeer.ConnectToPeer(const PeerAddress: TIdTCPEndPoint);
begin
  with TIdTCPConnection.Create(nil) do
  try
    FreeOnTerminate := True;
    IOHandler := IdTCPClient.IOHandler;
    IOHandler.Connect(PeerAddress);
    FOutboundConnections.Add(Self);
    OnConnect(Self);
  except
    on E: Exception do
      LogError(E.ClassName, E.Message, [PeerAddress]);
  end;
end;

1. Обработка inbound-соединений: Для обработки inbound-соединений мы можем переопределить метод Execute в TIdTCPServer, чтобы добавлять новые соединения в список inbound-соединений.

procedure TIdPeer.Execute;
begin
  inherited;
  if (Active) and (not Terminated) then
  begin
    with TIdTCPConnection.Create(nil) do
    try
      FreeOnTerminate := True;
      IOHandler := IdTCPClient.IOHandler;
      IOHandler.ReadTimeout := ReadTimeout;
      IOHandler.WriteTimeout := WriteTimeout;
      IOHandler.Connect(Socket, Address, Port);
      FInboundConnections.Add(Self);
      OnConnect(Self);
    except
      on E: Exception do
      begin
        LogError(E.ClassName, E.Message, [Socket.Binding.Socket]);
        Free;
      end;
    end;
  end;
end;

1. Добавление других методов и свойств: В зависимости от требований вашего приложения, вы можете добавить другие методы и свойства, например, для отправки и получения данных, управления соединениями и т.д.

Альтернативное решение:

В качестве альтернативы мы можем использовать TIdStackComponent в качестве базового класса, так как он может обрабатывать tanto inbound quanto outbound-соединения. TIdStackComponent уже имеет список соединений, который мы можем использовать для хранения tanto inbound quanto outbound-соединений. Однако, в этом случае мы должны добавить методы и свойства для управления соединениями и другими аспектами P2P-сети.

Заключение:

В этой статье мы рассмотрели, как создать класс, представляющий собой peer в P2P-сети с использованием Object Pascal (Delphi) и компонентов Indy. Мы использовали TIdTCPServer в качестве базового класса и добавили необходимые методы и свойства для управления tanto inbound quanto outbound-соединениями. Мы также рассмотрели альтернативное решение, основанное на TIdStackComponent. Выбор между этими двумя подходами зависит от конкретных требований вашего приложения.

Создано по материалам из источника по ссылке.

В контексте обсуждения на форуме пользователь Gustavo 'Gus' Carreno ищет советы о том, как создать класс, представляющий собой peer в P2P-сети с использованием Object Pascal (Delphi) и компонентов Indy, и не уверен, стоит ли унаследовать TIdTCPServer и до

Комментарии и вопросы

Получайте свежие новости и обновления по Object Pascal, Delphi и Lazarus прямо в свой смартфон. Подпишитесь на наш Telegram-канал delphi_kansoftware и будьте в курсе последних тенденций в разработке под Linux, Windows, Android и iOS

:: Главная :: TCP/IP ::