1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:
43:
44:
45:
46:
47:
48:
49:
50:
51:
52:
53:
54:
55:
56:
57:
58:
59:
60:
61:
62:
63:
64:
65:
66:
67:
68:
69:
70:
71:
72:
73:
74:
75:
76:
77:
78:
79:
80:
81:
82:

unit UClient;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, StdCtrls, NarsesBFPA, UProtocol;

type
  TfrmClient = class(TForm)
    OpenDialog: TOpenDialog;
    BtnSend: TButton;
    NBFPAClient: TNBFPAClient;
    procedure FormShow(Sender: TObject);
    procedure FormClose(Sender: TObject; var Action: TCloseAction);
    procedure BtnSendClick(Sender: TObject);
    procedure NBFPAClientRequestData(Sender: TObject; PA: TProtocolAdapter);
    procedure FormCreate(Sender: TObject);
  private
    FOutStream: TFileStream;
  public
    { Public-Deklarationen }
  end;

var
  frmClient: TfrmClient;

implementation

{$R *.dfm}

procedure TfrmClient.FormCreate(Sender: TObject);
begin
  FOutStream := NIL;
end;

procedure TfrmClient.FormShow(Sender: TObject);
begin
  NBFPAClient.SessionName := DateTimeToStr(Now);
  NBFPAClient.Connect;
end;

procedure TfrmClient.BtnSendClick(Sender: TObject);
begin
  if OpenDialog.Execute then begin
    BtnSend.Enabled := FALSE;
    FOutStream := TFileStream.Create(OpenDialog.FileName,
                                     fmOpenRead or fmShareDenyWrite);
    NBFPAClient.Send;
  end;
end;

procedure TfrmClient.NBFPAClientRequestData(Sender: TObject; PA: TProtocolAdapter);
  const
    CHUNK_SIZE = 2048;
  var
    Remaining: Integer;
    Cmd: TCmdSeq;
begin
  if Assigned(FOutStream) then begin
    Remaining := FOutStream.Size -FOutStream.Position;
    if (Remaining > CHUNK_SIZE) then
      Remaining := CHUNK_SIZE;
    Cmd := TCmdSeq.Create(CMD_CHUNK);
    Cmd.Add(FOutStream,Remaining);
    NBFPAClient.SendAndFree(Cmd);
    if (FOutStream.Position = FOutStream.Size) then begin
      FreeAndNil(FOutStream);
      Cmd := TCmdSeq.Create(CMD_STOP);
      NBFPAClient.SendAndFree(Cmd);
      BtnSend.Enabled := TRUE;
    end;
  end;
end;

procedure TfrmClient.FormClose(Sender: TObject; var Action: TCloseAction);
begin
  FreeAndNil(FOutStream);
  NBFPAClient.Disconnect;
end;

end.					

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:
43:
44:
45:
46:
47:
48:
49:
50:
51:
52:
53:
54:
55:
56:
57:
58:
59:
60:
61:
62:
63:
64:
65:
66:
67:
68:
69:
70:

unit UServer;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, StdCtrls, NarsesBFPA, UProtocol;

type
  TfrmServer = class(TForm)
    NBFPAServer: TNBFPAServer;
    ListBox: TListBox;
    procedure NBFPAServerConnectionsChange(Sender: TObject);
    procedure FormShow(Sender: TObject);
    procedure FormClose(Sender: TObject; var Action: TCloseAction);
    procedure NBFPAServerClientExecute(Sender: TObject;
      PA: TProtocolAdapter);
  private
    { Private-Deklarationen }
  public
    { Public-Deklarationen }
  end;

var
  frmServer: TfrmServer;

implementation

{$R *.dfm}

procedure TfrmServer.NBFPAServerConnectionsChange(Sender: TObject);
begin
  ListBox.Items.Assign(NBFPAServer.Connections);
end;

procedure TfrmServer.FormShow(Sender: TObject);
begin
  NBFPAServer.Open;
end;

procedure TfrmServer.NBFPAServerClientExecute(Sender: TObject; PA: TProtocolAdapter);
begin
  case PA.CurrentToken of
    CMD_CHUNK: // Dateistück eingetroffen
      begin
        if (PA.RefObject = NIL) then begin // Datei schon angelegt?
          PA.RefObject := TFileStream.Create(
                            ExtractFilePath(Application.ExeName)+
                              IntToStr(frmServer.Tag)+'.txt',
                            fmCreate);
          PA.OwnsRefObject := TRUE; // beim Freigeben des PAs den FileStream auch
          frmServer.Tag := frmServer.Tag +1; // Dateizähler erhöhen
        end;
        TFileStream(PA.RefObject).Write(PA.Inbound.Data[1]^, // Daten
                                        PA.Inbound.FrameSize[1]); // Menge
      end;
    CMD_STOP: // Dateitransfer beendet
      begin
        TFileStream(PA.RefObject).Free;
        PA.RefObject := NIL; // Referenz entfernen
      end;
  end;
end;

procedure TfrmServer.FormClose(Sender: TObject; var Action: TCloseAction);
begin
  NBFPAServer.Close;
end;

end.