add update dart_hybrid implementation

Author: iapicca

frameworks/Dart/dart3/dart_aot/bin/server.dart

@@ -85,7 +85,7 @@ void _startServer(List<String> args) async {
   server
     ..defaultResponseHeaders.clear()
     /// Sets [HttpServer]'s [serverHeader].
-    ..serverHeader = 'dart'
+    ..serverHeader = 'dart_aot'
     /// Handles [HttpRequest]'s from [HttpServer].
     ..listen(_handleRequest);
 }

frameworks/Dart/dart3/dart_hybrid/Dockerfile

@@ -0,0 +1,15 @@
+
+FROM dart:3.11.0 AS build
+WORKDIR /app
+
+COPY pubspec.yaml .
+COPY dart_hybrid/bin/ bin/
+
+RUN dart compile exe bin/server.dart -o server
+
+FROM scratch
+COPY --from=build /runtime/ /
+COPY --from=build /app/server /bin/server
+
+EXPOSE 8080
+ENTRYPOINT ["server"]

frameworks/Dart/dart3/dart_hybrid/bin/server.dart

@@ -0,0 +1,108 @@
+import 'dart:convert';
+import 'dart:io';
+import 'dart:isolate';
+
+void main() {
+  /// Retrieve the maximum number of isolates from the environment variables.
+  final maxIsolatesFromEnvironment = Platform.environment['MAX_ISOLATES'];
+  if (maxIsolatesFromEnvironment == null) {
+    throw Exception('MAX_ISOLATES environment variable is not set.');
+  }
+
+  /// Parse the isolate count; ensures we have a valid integer for scaling.
+  final maxIsolates = int.tryParse(maxIsolatesFromEnvironment);
+  if (maxIsolates == null) {
+    throw Exception('MAX_ISOLATES must be a valid integer.');
+  }
+
+  /// Retrieve the file system path for the Unix Domain Socket.
+  final socketPath = Platform.environment['SOCKET_PATH'];
+  if (socketPath == null) {
+    throw Exception('SOCKET_PATH environment variable is not set.');
+  }
+
+  /// Define the network address as a Unix Domain Socket (UDS).
+  /// This is often faster than TCP for local inter-process communication.
+  final address = InternetAddress(socketPath, type: InternetAddressType.unix);
+
+  /// Create an [Isolate] containing an [HttpServer]
+  /// for each processor after the first
+  for (int i = 1; i < maxIsolates; i++) {
+    Isolate.spawn<InternetAddress>(_startServer, address);
+  }
+
+  /// Create a [HttpServer] for the first processor
+  _startServer(address);
+}
+
+/// Initializes and binds the [HttpServer] to the provided [address].
+///
+/// Setting [shared] to true allows multiple isolates to bind to the same
+/// address/port, enabling automatic load balancing by the OS kernel.
+void _startServer(InternetAddress address) async {
+  final server = await HttpServer.bind(address, 0, shared: true);
+
+  server
+    ..defaultResponseHeaders.clear()
+    /// Sets [HttpServer]'s [serverHeader].
+    ..serverHeader = 'dart_hybrid'
+    /// Handles [HttpRequest]'s from [HttpServer].
+    ..listen(_handleRequest);
+}
+
+/// Dispatches requests to specific handlers.
+void _handleRequest(HttpRequest request) {
+  switch (request.uri.path) {
+    case '/json':
+      _jsonTest(request);
+      break;
+    case '/plaintext':
+      _plaintextTest(request);
+      break;
+    default:
+      _sendResponse(request, HttpStatus.notFound);
+  }
+}
+
+/// Completes the given [request] by writing the [bytes] with the given
+/// [statusCode] and [type].
+void _sendResponse(
+  HttpRequest request,
+  int statusCode, {
+  ContentType? type,
+  List<int> bytes = const [],
+}) => request.response
+  ..statusCode = statusCode
+  ..headers.contentType = type
+  ..headers.date = DateTime.now()
+  ..contentLength = bytes.length
+  ..add(bytes)
+  ..close();
+
+/// Completes the given [request] by writing the [response] as JSON.
+void _sendJson(HttpRequest request, Object response) => _sendResponse(
+  request,
+  HttpStatus.ok,
+  type: ContentType.json,
+  bytes: JsonUtf8Encoder().convert(response),
+);
+
+/// Completes the given [request] by writing the [response] as plain text.
+void _sendText(HttpRequest request, String response) => _sendResponse(
+  request,
+  HttpStatus.ok,
+  type: ContentType.text,
+  bytes: utf8.encode(response),
+);
+
+/// Responds with the JSON test to the [request].
+void _jsonTest(HttpRequest request) => _sendJson(
+  request,
+  const {'message': 'Hello, World!'},
+);
+
+/// Responds with the plaintext test to the [request].
+void _plaintextTest(HttpRequest request) => _sendText(
+  request,
+  'Hello, World!',
+);

frameworks/Dart/dart3/dart_hybrid/docker-compose.yml

@@ -0,0 +1,58 @@
+x-dart-template: &dart-base
+  build:
+    context: .
+    dockerfile: ./dart-hybrid/Dockerfile
+  network_mode: host
+  restart: always
+  volumes:
+    - socket-data:/var/run/dart-sockets
+
+services:
+  traefik:
+    image: traefik:latest
+    network_mode: host
+    cpuset: "0-15"
+    volumes:
+      - ./traefik.yaml:/etc/traefik/traefik.yaml:ro
+      - socket-data:/var/run/dart-sockets
+
+  dart-1:
+    <<: *dart-base
+    cpuset: "16-23"
+    environment:
+      - SOCKET_PATH=/var/run/dart-sockets/dart-1.sock
+      - MAX_ISOLATES=8
+
+  dart-2:
+    <<: *dart-base
+    cpuset: "24-31"
+    environment:
+      - SOCKET_PATH=/var/run/dart-sockets/dart-2.sock
+      - MAX_ISOLATES=8
+
+  dart-3:
+    <<: *dart-base
+    cpuset: "32-39"
+    environment:
+      - SOCKET_PATH=/var/run/dart-sockets/dart-3.sock
+      - MAX_ISOLATES=8
+
+  dart-4:
+    <<: *dart-base
+    cpuset: "40-47"
+    environment:
+      - SOCKET_PATH=/var/run/dart-sockets/dart-4.sock
+      - MAX_ISOLATES=8
+
+  dart-5:
+    <<: *dart-base
+    cpuset: "48-55"
+    environment:
+      - SOCKET_PATH=/var/run/dart-sockets/dart-5.sock
+      - MAX_ISOLATES=8
+
+volumes:
+  socket-data:
+    driver_opts:
+      type: tmpfs
+      device: tmpfs

frameworks/Dart/dart3/dart_native/bin/server.dart

@@ -33,7 +33,7 @@ void _startServer(List<String> args) async {
   server
     ..defaultResponseHeaders.clear()
     /// Sets [HttpServer]'s [serverHeader].
-    ..serverHeader = 'dart'
+    ..serverHeader = 'dart_native'
     /// Handles [HttpRequest]'s from [HttpServer].
     ..listen(_handleRequest);
 }