Category Archives: Delphi

Delphi.RobustServer.Упрощаем routing запросов. Базовый класс TRP

Posted on 07.12.2018 by Stanislav_Panteleev

Дописал базовый класс TRP, от которого можно наследовать всю бизнес логику. Теперь можно обращаться, скажем по адресу Users/Create, сервер найдет класс TRPUsers и попытается найти у него метод Create. Реализация TRP включает в себя RTTI механизм. Чуть позже есть идея … Continue reading →

Posted in Delphi | Comments Off

Delphi.RobustServer.Обработка POST запросов для основных MIME

Posted on 02.12.2018 by Stanislav_Panteleev

Доработал обработку POST запросов для следующих MIME типов application/json application/x-www-form-urlencoded multipart/form-data Теперь сервер умеет работать с json, принимать файлы, пока ещё не оч. большие (poststream блоками читается в строку = оперативную память), поэтому по-хорошему, размер файлов надо ограничить, ну и … Continue reading →

Posted in Delphi | Comments Off

Delphi.RobustServer. Логгер на GUI

Posted on 18.11.2018 by Stanislav_Panteleev

Добавил логгер на GUI Механизм такой – при добавлении сообщения в лог, автоматически обновляется GUI. Сообщения идут в обратном порядке. Ключевым моментом является функция WaitAndCreateLogFileStream класса TLDSLogger. Сначала сообщения пишутся в файл, затем из файла в GUI. Всей многопоточной логикой заведует … Continue reading →

Posted in Delphi | Comments Off

Delphi.RobustServer.Открытие соединения с БД.Простой случай.

Posted on 18.11.2018 by Stanislav_Panteleev

Как и когда нужно создавать экземпляр соединения с бд в серверном приложении? Путем чтения книг, опыта и ошибок я понял, что под каждый запрос, создается поток, под каждый поток нужно создавать соединение отдельно, иначе начинается хаос… Но это в случае, если … Continue reading →

Posted in Delphi | Comments Off

Delphi.RobustServer. Загрузка файлов на сервер

Posted on 18.11.2018 by Stanislav_Panteleev

Сделал простую загрузку файлов на сервер, с возможностью создания уникального имени, если такое имя уже будет в директории сервера. Сама директория будет строиться как files/year/month/day Результат кода выглядит так Сам запрос идет через multipart следующим образом…

Posted in Delphi | Comments Off

Delphi.RobustServer. Совершенствуем CommandGet и тестовый класс TRPUsers

Posted on 18.11.2018 by Stanislav_Panteleev

Немного отрефакторил код OnCommandGet, получилось так, довольно коротко…

var
  r: IResponses;
begin
  r := TResponses.Create(ARequestInfo, AResponseInfo);
  try
    ProcessTests(ARequestInfo, AResponseInfo);
    ProcessUsers(ARequestInfo, AResponseInfo);
    AResponseInfo.ResponseNo := 404;
  except
    on E: Exception do
      r.Error(e.Message);
  end;
end;

var

r: IResponses;

begin

r := TResponses.Create(ARequestInfo, AResponseInfo);

try

ProcessTests(ARequestInfo, AResponseInfo);

ProcessUsers(ARequestInfo, AResponseInfo);

AResponseInfo.ResponseNo := 404;

except

on E: Exception do

r.Error(e.Message);

end;

Обработка запросов происходит в методах Process…, например ProcessUsers выглядит так

Posted in Delphi | Comments Off

Delphi.RobustServer.Обработка ошибок, интерфейсный класс TResponses и измерение оперативной памяти

Posted on 17.11.2018 by Stanislav_Panteleev

Сделал обработку ошибок следующим образом В модуле CommandGet сделал единый блок try / except

procedure TCommandGet.Execute(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo);
var
  json: ISuperObject;
  r: IResponses;
  d, a, b: Double;
begin
  r := TResponses.Create(ARequestInfo, AResponseInfo);
  try
    if ARequestInfo.URI = '/testConnection' then
    r.OK()
    else if ARequestInfo.URI = '/testException' then
    begin
      a := 1;
      b := 0;
      d := a / b;
    end
    else
      AResponseInfo.ResponseNo := 404;
  except
    on E: Exception do
      r.Error(e.Message);
  end;
end;

procedure TCommandGet.Execute(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo);

var

json: ISuperObject;

r: IResponses;

d, a, b: Double;

begin

r := TResponses.Create(ARequestInfo, AResponseInfo);

try

if ARequestInfo.URI = '/testConnection' then

r.OK()

else if ARequestInfo.URI = '/testException' then

begin

a := 1;

b := 0;

d := a / b;

end

else

AResponseInfo.ResponseNo := 404;

except

on E: Exception do

r.Error(e.Message);

end;

Теперь, если возникнет ошибка при обработке запроса, она не потеряется, а придет в понятном json формате, то есть вот так…. Кстати, здесь же можно посмотреть, … Continue reading →

Posted in Delphi | Comments Off

Delphi. Измерение оперативной памяти

Posted on 17.11.2018 by Stanislav_Panteleev

Модуль из проекта Вот эти 2 процедуры измеряют текущую память и пиковую

class function CurrentProcessMemoryKB: Extended; static;
class function CurrentProcessMemoryPeakKB: Extended; static;

1 2	class function CurrentProcessMemoryKB: Extended; static; class function CurrentProcessMemoryPeakKB: Extended; static;

Полный модуль

unit uRPMemory;

interface

uses
  System.SysUtils, System.Classes, IdContext, IdCustomHTTPServer;

type
  TRPMemory = class(TDataModule)
  private
        { Private declarations }
    class function CurrentProcessMemoryKB: Extended; static;
    class function CurrentProcessMemoryPeakKB: Extended; static;
  public
    { Public declarations }
    class procedure GetMemory(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo); static;
  end;

implementation

uses
  Winapi.PsAPI, Winapi.Windows, Math;
{%CLASSGROUP 'Vcl.Controls.TControl'}

{$R *.dfm}

class function TRPMemory.CurrentProcessMemoryKB: Extended;
var
  MemCounters: TProcessMemoryCounters;
begin
  MemCounters.cb := SizeOf(MemCounters);
  if GetProcessMemoryInfo(GetCurrentProcess, @MemCounters, SizeOf(MemCounters)) then
    Result := trunc(MemCounters.WorkingSetSize / 1024)
  else
    RaiseLastOSError;
end;

class function TRPMemory.CurrentProcessMemoryPeakKB: Extended;
var
  MemCounters: TProcessMemoryCounters;
begin
  MemCounters.cb := SizeOf(MemCounters);
  if GetProcessMemoryInfo(GetCurrentProcess, @MemCounters, SizeOf(MemCounters)) then
    Result := trunc(MemCounters.PeakWorkingSetSize / 1024)
  else
    RaiseLastOSError;
end;

class procedure TRPMemory.GetMemory(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo);
var
  curr, peak: Extended;
begin
  curr := Math.RoundTo(CurrentProcessMemoryKB / 1024, -2);
  peak := Math.RoundTo(CurrentProcessMemoryPeakKB / 1024, -2);

  AResponseInfo.ResponseNo := 200;
  AResponseInfo.ContentType := 'application/json';
  AResponseInfo.CacheControl := 'no-cache';
  AResponseInfo.CustomHeaders.Add('Access-Control-Allow-Origin: *');
  AResponseInfo.ContentText := curr.ToString + ' / ' + peak.ToString + '   (MB)';
  AResponseInfo.WriteContent;
end;

end.

unit uRPMemory;

interface

uses

System.SysUtils, System.Classes, IdContext, IdCustomHTTPServer;

type

TRPMemory = class(TDataModule)

private

{ Private declarations }

class function CurrentProcessMemoryKB: Extended; static;

class function CurrentProcessMemoryPeakKB: Extended; static;

public

{ Public declarations }

class procedure GetMemory(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo); static;

end;

implementation

uses

Winapi.PsAPI, Winapi.Windows, Math;

{%CLASSGROUP 'Vcl.Controls.TControl'}

{$R *.dfm}

class function TRPMemory.CurrentProcessMemoryKB: Extended;

var

MemCounters: TProcessMemoryCounters;

begin

MemCounters.cb := SizeOf(MemCounters);

if GetProcessMemoryInfo(GetCurrentProcess, @MemCounters, SizeOf(MemCounters)) then

Result := trunc(MemCounters.WorkingSetSize / 1024)

else

RaiseLastOSError;

end;

class function TRPMemory.CurrentProcessMemoryPeakKB: Extended;

var

MemCounters: TProcessMemoryCounters;

begin

MemCounters.cb := SizeOf(MemCounters);

if GetProcessMemoryInfo(GetCurrentProcess, @MemCounters, SizeOf(MemCounters)) then

Result := trunc(MemCounters.PeakWorkingSetSize / 1024)

else

RaiseLastOSError;

end;

class procedure TRPMemory.GetMemory(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo);

var

curr, peak: Extended;

begin

curr := Math.RoundTo(CurrentProcessMemoryKB / 1024, -2);

peak := Math.RoundTo(CurrentProcessMemoryPeakKB / 1024, -2);

AResponseInfo.ResponseNo := 200;

AResponseInfo.ContentType := 'application/json';

AResponseInfo.CacheControl := 'no-cache';

AResponseInfo.CustomHeaders.Add('Access-Control-Allow-Origin: *');

AResponseInfo.ContentText := curr.ToString + ' / ' + peak.ToString + ' (MB)';

AResponseInfo.WriteContent;

end;

end.

Posted in Delphi | Comments Off

Delphi.RobustServer – первые шаги

Posted on 17.11.2018 by Stanislav_Panteleev

Github Первые несколько шагов. Текущую версию я делаю Visual Components Library App. Потом можно будет перевернуть это приложение в сервис, при желании. Архитектура следующая

Posted in Delphi | Comments Off

Delphi. RobustServer. Пишем мощный и надежный сервер на Indy

Posted on 11.11.2018 by Stanislav_Panteleev

На мой взгляд, более менее универсальная архитектура приложения выглядит так… В этом и последующем постах будем писать мощный и надежный сервер. Это будет шаблон для будущих проектов. Стэк технологий у нас будет следующий Delphi Seattle MySQL FireDAC SuperObject … Ближайшие … Continue reading →

Posted in Delphi | Comments Off

Category Archives: Delphi

Delphi.RobustServer.Упрощаем routing запросов. Базовый класс TRP

Delphi.RobustServer.Обработка POST запросов для основных MIME

Delphi.RobustServer. Логгер на GUI

Delphi.RobustServer.Открытие соединения с БД.Простой случай.

Delphi.RobustServer. Загрузка файлов на сервер

Delphi.RobustServer. Совершенствуем CommandGet и тестовый класс TRPUsers

Delphi.RobustServer.Обработка ошибок, интерфейсный класс TResponses и измерение оперативной памяти

Delphi. Измерение оперативной памяти

Delphi.RobustServer – первые шаги

Delphi. RobustServer. Пишем мощный и надежный сервер на Indy

MY PROJECTS

Recent Posts

Categories