BullMQ

0 Artikel

JoyMini API — Praxis der unternehmensweiten NestJS-Backend-Architektur

Eine einheitliche Backend-Plattform, basierend auf NestJS + Prisma + PostgreSQL + Redis + BullMQ, die 200+ API-Endpunkte für 4 Frontend-Anwendungen bereitstellt.

**Projektbeispiele**

Optimierung der Übersetzungsparallelität: Leistungssprung von serieller zu paralleler Verarbeitung

Dieser Artikel analysiert den grundlegenden Leistungsengpass des Blog-Übersetzungssystems – die serielle Verarbeitung aufgrund von Worker concurrency=1. Durch Optimierungen wie die Erhöhung des Parallelitätsgrads und die Reduzierung interner Verzögerungen wird der Übersetzungsdurchsatz um etwa das 5-fache gesteigert.

**Schnittstellenverwaltung**

KI-Übersetzungsaufgaben-Überwachungsdashboard: Vollständige Implementierung mit 1309 Zeilen

Aufbau eines unternehmensweiten KI-Übersetzungsüberwachungszentrums – von Echtzeitüberwachung der BullMQ-Warteschlange, mehrdimensionaler Fortschrittsverfolgung bis hin zur Aufgabenverwaltung und Fehlerwarnungen

Frontend-Entwicklung

QueueMonitorService: BullMQ-Warteschlangen-Überwachungs-Dashboard

Der Warteschlangen-Überwachungsdienst der JoyMini API basiert auf dem BullMQ-Ereignissystem und erstellt ein Echtzeit-Dashboard zur Verfolgung des Warteschlangenstatus, des Job-Fortschritts, der Fehlerrate und der Verarbeitungsverzögerung. Er unterstützt die visuelle Betriebsführung im Verwaltungs-Backend.

**Schnittstellenverwaltung**

Media Processing Pipeline: Sharp-Bildkomprimierung + FFmpeg HLS-Videotranskodierung

Die Medienverarbeitungspipeline der JoyMini API basiert auf Sharp für die Generierung von Bildvarianten in mehreren Formaten und BlurHash-Kodierung sowie auf FFmpeg für die adaptive HLS-Videotranskodierung, alles asynchron gesteuert durch BullMQ.

**Schnittstellenverwaltung**

GroupService Gruppenkauf-System: Redis Optimistisches Sperren + BullMQ Abrechnungs-Warteschlange

JoyMinis Gruppenkauf-System basiert auf Redis optimistischem Sperren zur Verhinderung von Überverkäufen und einer BullMQ Abrechnungs-Warteschlange für die asynchrone Gewinnverteilung. Es deckt den vollständigen transaktionalen Ablauf von Gruppenerstellung, Beitritt, automatischer Gruppenbildung und Abrechnung ab.

**Schnittstellenverwaltung**

API-Datei-Upload-System — Cloudflare R2 S3 + BullMQ Medienverarbeitungspipeline

Das Datei-Upload-System der JoyMini API basiert auf Cloudflare R2 S3-Objektspeicher und der BullMQ- asynchronen Warteschlange und umfasst eine vollständige Medienverarbeitungspipeline für Bildkomprimierung (Sharp), Video-HLS-Transkodierung (FFmpeg) und BlurHash-Generierung.

**Schnittstellenverwaltung**

API Hintergrundaufgaben-System — BullMQ Queue-Architektur und Worker-Implementierung

Das JoyMini API basiert auf BullMQ (Redis-gesteuertes Queue-System) und umfasst eine Architektur mit 3 Queues und 4 Workern, einschließlich der vollständigen Implementierung einer Bildkomprimierungspipeline, Sharp-Komposition, Video-HLS-Transkodierung und Thumbnail-Extraktion.

**Schnittstellenverwaltung**

Avatar-Dienst, Zahlungsintegration und öffentlicher Cache-Interceptor

JoyMini API's automatischer Avatar-Generierungsdienst (Sharp-Komposition + BullMQ-Warteschlange), Xendit-Zahlungsintegration (mit verteilter Sperre für Kontenabstimmung) und Redis-basierter öffentlicher Cache-Interceptor.

**Schnittstellenverwaltung**