Как создать rtmp server на delphi?

1
2
3
4
5
6
7
8
9

procedure TForm1.btnStartServerClick(Sender: TObject);
begin
  AdvTCPServer1.Active := False;
  AdvTCPServer1.Bindings.Clear;
  AdvTCPServer1.Bindings.Add;
  AdvTCPServer1.Bindings[0].Port := 1935; // RTMP port
  AdvTCPServer1.OnExecute := AdvTCPServer1Execute;
  AdvTCPServer1.Active := True;
end;

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

procedure TForm1.AdvTCPServer1Execute(AContext: TIdContext);
var
  Client: TAdvTCPClient;
begin
  Client := TAdvTCPClient.Create(nil);
  try
    Client.IOHandler := TIdIOHandlerStack.Create(Client);
    Client.IOHandler.InputBuffer.Clear;
    Client.IOHandler.WriteBufferOpen;
    Client.Connect(AContext.Binding.IP, AContext.Binding.Port);
    AdvTCPServer1Read(Client);
  finally
    Client.Free;
  end;
end;

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

procedure TForm1.AdvTCPServer1Read(Client: TAdvTCPClient);
var
  Message: TRTMPMessage;
begin
  Message := ReadRTMPMessage(Client);
  try
    // Обработка сообщения RTMP
  finally
    FreeRTMPMessage(Message);
  end;
end;

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

function TForm1.ReadRTMPMessage(Client: TAdvTCPClient): TRTMPMessage;
var
  Header: TRTMPHeader;
  Body: TMemoryStream;
begin
  Header := ReadRTMPHeader(Client);
  Body := TMemoryStream.Create;
  try
    Body.CopyFrom(Client.IOHandler, Header.Length);
    Result := TRTMPMessage.Create(Header, Body);
  except
    FreeAndNil(Body);
    raise;
  end;
end;

1
2
3
4
5
6
7

function TForm1.ReadRTMPHeader(Client: TAdvTCPClient): TRTMPHeader;
var
  RawHeader: array [0..15] of Byte;
  Timestamp: UInt32;
begin
  Client.IOHandler.ReadBytes(RawHeader, SizeOf(RawHeader));
  if (