Jak používat Async DICOM JSON serializace v ASP.NET Core Web APIs
Tento tutoriál ukazuje, jak používat async DICOM JSON serializace v ASP.NET Core web APIs. Asynk operace jsou nezbytné pro vysoce výkonné webové aplikace, aby se zabránilo blokování vlákniny a udržet odpovědnost pod zatížením.
Proč používat Async serializace?
Skládací kapacita:- Neblokování I/O umožňuje zpracování více souběžných požadavků.
• Odpovědnost *- Webový server zůstává při zpracování velkých souborů odpovědný.
• Účinnost zdrojů *:- Hrozby jsou uvolněny, zatímco čekají na operace I/O.
Předpoklady: Příprava životního prostředí
- Nastavení Visual Studio nebo jakéhokoli kompatibilního .NET IDE.
- Vytvořte nový projekt ASP.NET Core Web API zaměřený na .NET 8.
- Instalace aplikace Aspose.Medical z programu NuGet Package Manager.
Krok za krokem průvodce Async DICOM JSON serializace
Krok 1: Instalace Aspose.Medical
Přidejte do svého projektu knihovnu Aspose.Medicine pomocí aplikace NuGet.
Install-Package Aspose.MedicalKrok 2: Vložte potřebné názevové prostory
Přidejte odkazy na požadované názevové prostory ve vašem ovladači.
using Aspose.Medical.Dicom;
using Aspose.Medical.Dicom.Serialization;
using Microsoft.AspNetCore.Mvc;Krok 3: Vytvoření Async Deserialization Endpoint
Vytvořte koncový bod, který deserializuje JSON z požadovaného orgánu.
[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");
}Krok 4: Vytvoření Async serializace Endpoint
Vytvořte koncový bod, který serializuje DICOM na JSON v odpovědi.
[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);
}Krok 5: Zrušení tokenů
Pass zrušení tokenů pro správné zpracování žádosti o zrušení.
[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();
}Využití ASP.NET Core Controller
Zde je kompletní ovladač provádějící async DICOM JSON operace:
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}");
}
}
}Konfigurace požadavků na velikost limitů
Pro velké soubory DICOM nastavte požadavky na 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();Příklad zpracování toku
Zpracování souborů DICOM bez načítání do paměti:
[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
);
}Nejlepší postupy řešení chyb
Provádění komplexní chybové manipulace:
[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 });
}
}Další nejlepší postupy
Použití prohlášení pro proudy
Vždy používejte správné rozložení:
using (FileStream fs = System.IO.File.OpenRead(filepath))
{
// Process stream
}Konfigurace Timeout
Nastavení vhodných časů pro dlouhé operace:
builder.WebHost.ConfigureKestrel(options =>
{
options.Limits.RequestHeadersTimeout = TimeSpan.FromMinutes(2);
options.Limits.KeepAliveTimeout = TimeSpan.FromMinutes(5);
});Další informace
- Async metody zlepšují skalovatelnost, ale nemusí nutně urychlit individuální požadavky.
- Použijte tokeny pro zrušení, abyste řádně zvládli klientské rozhraní.
- Monitorování používání paměti při zpracování velkých souborů DICOM.
závěr
Tento tutoriál ukázal, jak implementovat async DICOM JSON serializace v ASP.NET Core web APIs pomocí Aspose.Medical. Asynk operace jsou nezbytné pro budování skalovatelné zdravotní péče API, které zpracovávají velké lékařské snímky data efektivně.