Kuinka käyttää Async DICOM JSON Seriointi ASP.NET Core Web API: ssä
Tämä opetusohjelma osoittaa, miten käytetään async DICOM JSON -seriointia ASP.NET Core -verkkopalveluissa. Asynk-toiminnot ovat välttämättömiä korkean läpimurron verkkosovelluksille, jotta vältetään kiintolevyn estäminen ja ylläpidetään reaktiivisuutta kuormituksen alla.
Miksi käytetään Async Serializationia?
Luotettavuus:- I/O:n estäminen mahdollistaa kilpailukykyisempien pyyntöjen käsittelyn.
- Vastattomuus on seuraava:- Web-palvelin pysyy reaktiivisena suurien tiedostojen käsittelyn aikana.
• Resurssitehokkuus:- Uhka vapautuu odottamalla I/O-operaatioita.
Edellytykset: Ympäristön valmistelu
- Aseta Visual Studio tai yhteensopiva .NET IDE.
- Luo uusi ASP.NET Core Web API -hanke, joka on kohdistettu .NET 8:een.
- Asenna Aspose.Medical NuGet Package Managerista.
Askel askeleelta Async DICOM JSON Seriointi
Vaihe 1: Asenna Aspose.Medical
Lisää Aspose.Medical -kirjasto projektillesi NuGetin avulla.
Install-Package Aspose.MedicalVaihe 2: Sisällytä tarvittavat nimet
Lisää viittauksia tarvittaviin nimipaikkoihin ohjaimessa.
using Aspose.Medical.Dicom;
using Aspose.Medical.Dicom.Serialization;
using Microsoft.AspNetCore.Mvc;Vaihe 3: Async Deserialization Endpointin luominen
Luo loppupiste, joka deserialisoi JSONia pyyntölaitokselta.
[HttpPost("import")]
public async Task<IActionResult> ImportDicomJson()
{
Dataset? dataset = await DicomJsonSerializer.DeserializeAsync(Request.Body);
if (dataset == null)
return BadRequest("Invalid DICOM JSON");
return Ok("DICOM data imported successfully");
}Vaihe 4: Async Serialization Endpointin luominen
Luo loppupiste, joka serialisoi DICOMin JSONiin vastauksessa.
[HttpGet("export/{filename}")]
public async Task ExportDicomJson(string filename)
{
DicomFile dcm = DicomFile.Open($"storage/{filename}");
Response.ContentType = "application/json";
await DicomJsonSerializer.SerializeAsync(Response.Body, dcm.Dataset);
}Vaihe 5: Käsittele peruutus tokenit
Siirry peruutus tokenit asianmukaiseen pyyntöperuutuksen käsittelyyn.
[HttpPost("process")]
public async Task<IActionResult> ProcessDicomAsync(CancellationToken cancellationToken)
{
Dataset? dataset = await DicomJsonSerializer.DeserializeAsync(
Request.Body,
cancellationToken
);
if (cancellationToken.IsCancellationRequested)
return StatusCode(499, "Client Closed Request");
// Process dataset...
return Ok();
}Täydellinen ASP.NET Core Controller esimerkki
Tässä on täydellinen ohjain, joka toteuttaa async DICOM JSON -toimintoja:
using Aspose.Medical.Dicom;
using Aspose.Medical.Dicom.Serialization;
using Microsoft.AspNetCore.Mvc;
namespace DicomApi.Controllers;
[ApiController]
[Route("api/[controller]")]
public class DicomController : ControllerBase
{
private readonly string _storagePath = "dicom_storage";
public DicomController()
{
Directory.CreateDirectory(_storagePath);
}
/// <summary>
/// Import DICOM JSON and save as DICOM file
/// </summary>
[HttpPost("import")]
public async Task<IActionResult> ImportDicomJson(CancellationToken cancellationToken)
{
try
{
Dataset? dataset = await DicomJsonSerializer.DeserializeAsync(
Request.Body,
cancellationToken
);
if (dataset == null)
return BadRequest("Failed to deserialize DICOM JSON");
// Generate unique filename
string filename = $"{Guid.NewGuid()}.dcm";
string filepath = Path.Combine(_storagePath, filename);
// Save as DICOM file
DicomFile dcm = new DicomFile(dataset);
dcm.Save(filepath);
return Ok(new { message = "DICOM imported successfully", filename });
}
catch (OperationCanceledException)
{
return StatusCode(499, "Request cancelled");
}
catch (Exception ex)
{
return BadRequest($"Import failed: {ex.Message}");
}
}
/// <summary>
/// Export DICOM file as JSON stream
/// </summary>
[HttpGet("export/{filename}")]
public async Task ExportDicomJson(string filename, CancellationToken cancellationToken)
{
string filepath = Path.Combine(_storagePath, filename);
if (!System.IO.File.Exists(filepath))
{
Response.StatusCode = 404;
await Response.WriteAsync("File not found");
return;
}
try
{
DicomFile dcm = DicomFile.Open(filepath);
Response.ContentType = "application/json";
Response.Headers["Content-Disposition"] = $"attachment; filename=\"{filename}.json\"";
await DicomJsonSerializer.SerializeAsync(
Response.Body,
dcm.Dataset,
writeIndented: true
);
}
catch (OperationCanceledException)
{
// Client disconnected
}
catch (Exception ex)
{
Response.StatusCode = 500;
await Response.WriteAsync($"Export failed: {ex.Message}");
}
}
/// <summary>
/// Convert uploaded DICOM file to JSON
/// </summary>
[HttpPost("convert")]
[RequestSizeLimit(100_000_000)] // 100MB limit
public async Task ConvertDicomToJson(IFormFile file, CancellationToken cancellationToken)
{
if (file == null || file.Length == 0)
{
Response.StatusCode = 400;
await Response.WriteAsync("No file uploaded");
return;
}
try
{
// Save uploaded file temporarily
string tempPath = Path.GetTempFileName();
using (var stream = System.IO.File.Create(tempPath))
{
await file.CopyToAsync(stream, cancellationToken);
}
// Load and convert
DicomFile dcm = DicomFile.Open(tempPath);
Response.ContentType = "application/json";
await DicomJsonSerializer.SerializeAsync(
Response.Body,
dcm.Dataset,
writeIndented: true
);
// Cleanup temp file
System.IO.File.Delete(tempPath);
}
catch (OperationCanceledException)
{
// Client disconnected
}
catch (Exception ex)
{
Response.StatusCode = 500;
await Response.WriteAsync($"Conversion failed: {ex.Message}");
}
}
}Pyynnön koon rajoittaminen
Suuriin DICOM-tiedostoihin asettaa pyyntörajat Program.cs:
var builder = WebApplication.CreateBuilder(args);
// Configure Kestrel for large uploads
builder.WebHost.ConfigureKestrel(options =>
{
options.Limits.MaxRequestBodySize = 500_000_000; // 500MB
});
// Configure form options
builder.Services.Configure<FormOptions>(options =>
{
options.MultipartBodyLengthLimit = 500_000_000;
});
var app = builder.Build();Liikenneprosessin esimerkki
Käsittele DICOM-tiedostoja lataamatta kokonaan muistiin:
[HttpPost("stream-process")]
public async Task StreamProcessDicom(CancellationToken cancellationToken)
{
// Read JSON from request body stream
using var reader = new StreamReader(Request.Body);
string json = await reader.ReadToEndAsync(cancellationToken);
// Deserialize
Dataset? dataset = DicomJsonSerializer.Deserialize(json);
if (dataset == null)
{
Response.StatusCode = 400;
await Response.WriteAsync("Invalid JSON");
return;
}
// Process and stream response
Response.ContentType = "application/json";
await DicomJsonSerializer.SerializeAsync(
Response.Body,
dataset,
writeIndented: true
);
}Virheiden käsittely parhaat käytännöt
Täydellinen virheiden käsittely:
[HttpPost("safe-import")]
public async Task<IActionResult> SafeImportDicomJson(CancellationToken cancellationToken)
{
try
{
Dataset? dataset = await DicomJsonSerializer.DeserializeAsync(
Request.Body,
cancellationToken
);
if (dataset == null)
return BadRequest(new { error = "Invalid DICOM JSON format" });
// Process dataset...
return Ok(new { success = true });
}
catch (OperationCanceledException)
{
return StatusCode(499, new { error = "Request cancelled by client" });
}
catch (JsonException ex)
{
return BadRequest(new { error = "JSON parsing error", details = ex.Message });
}
catch (OutOfMemoryException)
{
return StatusCode(507, new { error = "File too large to process" });
}
catch (Exception ex)
{
return StatusCode(500, new { error = "Internal server error", details = ex.Message });
}
}Lisää parhaita käytäntöjä
Käyttämällä ilmoituksia virtauksille
Käytä aina asianmukaisia laitteita:
using (FileStream fs = System.IO.File.OpenRead(filepath))
{
// Process stream
}Timeout -asetukset
Määritä sopivat aikataulut pitkille toiminnoille:
builder.WebHost.ConfigureKestrel(options =>
{
options.Limits.RequestHeadersTimeout = TimeSpan.FromMinutes(2);
options.Limits.KeepAliveTimeout = TimeSpan.FromMinutes(5);
});Lisätietoja
- Async-menetelmät parantavat skalatiivisuutta, mutta eivät välttämättä nopeuta yksittäisiä pyyntöjä.
- Käytä peruutus tokenejä asiakkaan yhteyksien käsittelyyn oikein.
- Seuraa muistin käyttöä suurien DICOM-tiedostojen käsittelyssä.
johtopäätöksiä
Tämä opetusohjelma on osoittanut, miten async DICOM JSON-seriointi voidaan toteuttaa ASP.NET Core -verkkopalveluissa käyttämällä Aspose.Medical. Asyncin toiminnot ovat välttämättömiä laajennettavien terveydenhuollon APIs:ien rakentamiseen, jotka käsittelevät suuria lääketieteellisiä kuvatietoja tehokkaasti.