当前位置：首页 > news >正文

TMultiPartFormData

news 2026/5/12 7:26:23

TMultiPartFormData

unit form.data;
//cxg 2025
interfaceusescore.firedac, core.global, core.firedacpool, core.router, core.log, core.json,core.datasetHelp, core.encoding,DB, Classes, SysUtils, System.Net.Mime, Net.CrossHttpParams;typeTFormDataService = recordprocedure DownloadFile(const ARequest: THttpRequest;const AResponse: THttpResponse);procedure UploadFile(const ARequest: THttpRequest;const AResponse: THttpResponse);procedure Select(const ARequest: THttpRequest;const AResponse: THttpResponse);end;implementationfunction DownloadPath: string;
beginResult := ExtractFilePath(ParamStr(0)) + 'download' + PathDelim;
end;procedure TFormDataService.DownloadFile(const ARequest: THttpRequest;const AResponse: THttpResponse);
varLRequestData: THttpMultiPartFormData;LResponseData: TMultiPartFormData;
beginLResponseData := TMultiPartFormData.Create;trytryTRequestFunc.UnMarshal(ARequest, LRequestData);LResponseData.AddField('success', 'true');LResponseData.AddField('message', '下载成功');LResponseData.AddField('filename', LRequestData.Fields['filename'].AsString);LResponseData.AddFile('file', DownloadPath + LRequestData.Fields['filename'].AsString);TResponseFunc.Send(AResponse, LResponseData);excepton E: Exception dobeginLResponseData.AddField('success', 'false');LResponseData.AddField('message', E.Message);TResponseFunc.Send(AResponse, LResponseData);WriteLog('TFormDataService.DownloadFile()' + E.Message);end;end;finallyLRequestData.Free;end;
end;function UploadPath: string;
beginResult := ExtractFilePath(ParamStr(0)) + 'upload' + PathDelim;
end;procedure TFormDataService.Select(const ARequest: THttpRequest;const AResponse: THttpResponse);
var LDB: TDB;LPool: TDBPool;LRequestData: THttpMultiPartFormData;LResponseData: TMultiPartFormData;i: Integer;LStream: TStream;
beginLResponseData := TMultiPartFormData.Create;trytryTRequestFunc.UnMarshal(ARequest, LRequestData);LPool := GetDBPool(LRequestData.Fields['dbid'].AsString);LDB := LPool.Lock;for i := 0 to LRequestData.Fields['count'].AsString.ToInteger - 1 dobeginLStream := LDB.select3(LRequestData.Fields['sql' + i.ToString].AsString);LStream.Position := 0;LResponseData.AddStream(TConst.Data + i.ToString, LStream);LStream.Free;end;LResponseData.AddField(TConst.Success, 'true');TResponseFunc.Send(AResponse, LResponseData);excepton E: Exception dobeginLResponseData.AddField(TConst.Success, 'false');LResponseData.AddField('message', E.Message);TResponseFunc.Send(AResponse, LResponseData);WriteLog('TFormDataService.Select()' + E.Message);end;end;finallyLPool.Unlock(LDB);LRequestData.Free;end;
end;procedure TFormDataService.UploadFile(const ARequest: THttpRequest;const AResponse: THttpResponse);
varLRequestData: THttpMultiPartFormData;LResponseData: TMultiPartFormData;LMemoryStream: TMemoryStream;
beginLResponseData := TMultiPartFormData.Create;LMemoryStream := TMemoryStream.Create;trytryTRequestFunc.UnMarshal(ARequest, LRequestData);LMemoryStream.CopyFrom(LRequestData.Fields['file'].Value);LMemoryStream.SaveToFile(UploadPath + LRequestData.Fields['filename'].AsString);LResponseData.AddField('success', 'true');LResponseData.AddField('message', '上传成功');TResponseFunc.Send(AResponse, LResponseData);excepton E: Exception dobeginLResponseData.AddField('success', 'false');LResponseData.AddField('message', E.Message);TResponseFunc.Send(AResponse, LResponseData);WriteLog('TFormDataService.DownloadFile()' + E.Message);end;end;finallyLRequestData.Free;end;
end;varFormDataService: TFormDataService;initialization//multipart/form-data apiTRouter.Add('/formdata/downloadfile', FormDataService.DownloadFile);TRouter.Add('/formdata/uploadfile', FormDataService.UploadFile);TRouter.Add('/formdata/select', FormDataService.Select);end.

unit server.api;// cxg 2025
interfaceuses Net.CrossHttpParams,Net.Mime, IdHTTP, System.Net.HttpClientComponent, Net.HttpClient,IniFiles, SysUtils, Classes;varurl: string;typeTHttpClient = TNetHTTPClient;TRpc = record // remote-procedure-call（multipart/form-data）class function UploadFile(const AData: TMultipartFormData): Boolean; static;class function DownloadFile(const AData: TMultipartFormData): THttpMultiPartFormData; static;end;implementationfunction Newhttp: THttpClient;
beginResult := THttpClient.Create(nil);Result.HandleRedirects := True;
end;{ TRpc }class function TRpc.DownloadFile(const AData: TMultipartFormData): THttpMultiPartFormData;
varLHttp: THttpClient;LResponseStream: TMemoryStream;LBoundary: string;
beginif AData = nil thenExit;LHttp := THttpClient.Create(nil);LResponseStream := TMemoryStream.Create;Result := THttpMultiPartFormData.Create;tryLHttp.CustomHeaders['Boundary'] := AData.Boundary;LBoundary := LHttp.Post(url + '/formdata/downloadfile', AData.Stream,LResponseStream).HeaderValue['Boundary'];Result.InitWithBoundary(LBoundary);LResponseStream.Position := 0;Result.Decode(LResponseStream);finallyLHttp.Free;LResponseStream.Free;end;
end;class function TRpc.UploadFile(const AData: TMultipartFormData): Boolean;
varLHttp: THttpClient;LResponseStream: TMemoryStream;LPart: THttpMultiPartFormData;LBoundary: string;
beginif AData = nil thenExit;LHttp := THttpClient.Create(nil);LResponseStream := TMemoryStream.Create;LPart := THttpMultiPartFormData.Create;tryLHttp.CustomHeaders['Boundary'] := AData.Boundary;LBoundary := LHttp.Post(url + '/formdata/uploadfile', AData.Stream,LResponseStream).HeaderValue['Boundary'];LPart.InitWithBoundary(LBoundary);LResponseStream.Position := 0;LPart.Decode(LResponseStream);Result := LPart.Fields['success'].AsString = 'true';finallyLHttp.Free;LResponseStream.Free;LPart.Free;end;
end;procedure ReadConf;
varLIni: TIniFile;
beginLIni := TIniFile.Create(ExtractFilePath(ParamStr(0)) + 'client.ini');url := LIni.ReadString('config', 'url', '');LIni.Free;
end;initializationReadConf;end.