fix(sentry): stop flushing metrics on every request

src/sentry/publish/sentry.php

@@ -56,6 +56,14 @@
     // @see: https://docs.sentry.io/platforms/php/guides/laravel/configuration/options/#enable_metrics
     'enable_metrics' => env('SENTRY_ENABLE_METRICS', false),
 
+    // Metrics are buffered in memory and are no longer flushed on every request
+    // or annotation call. They are reported when:
+    // - the SDK `metric_flush_threshold` is reached (automatic flush), or
+    // - the request runtime context ends (endContext flush), or
+    // - the periodic flush kicks in as a fallback (`metrics_interval`).
+    // Forcing a flush per request/call amplifies transport channel pressure and
+    // increases the risk of memory exhaustion under high traffic.
+
     // @see: https://docs.sentry.io/platforms/php/configuration/options/#before_send_metric
     // 'before_send_metric' => function (Sentry\Metrics\Types\Metric $metric): ?Sentry\Metrics\Types\Metric {
     //     return $metric;

src/sentry/src/Metrics/Aspect/CounterAspect.php

@@ -49,8 +49,6 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint): mixed
                 'class' => $proceedingJoinPoint->className,
                 'method' => $proceedingJoinPoint->methodName,
             ]);
-
-            metrics()->flush();
         }
 
         return $proceedingJoinPoint->process();

src/sentry/src/Metrics/Aspect/HistogramAspect.php

@@ -54,7 +54,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint): mixed
         ]);
 
         return tap($proceedingJoinPoint->process(), function () use ($timer) {
-            defer(fn () => $timer->end(true));
+            defer(fn () => $timer->end());
         });
     }
 

src/sentry/src/Metrics/Listener/RequestWatcher.php

@@ -62,7 +62,7 @@ public function process(object $event): void
                 ++$this->stats->response_count;
                 --$this->stats->connection_num;
 
-                $timer->end(true);
+                $timer->end();
 
                 unset($timer);
             });

tests/Sentry/Metrics/RequestWatcherTest.php

@@ -0,0 +1,75 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of friendsofhyperf/components.
+ *
+ * @link     https://github.com/friendsofhyperf/components
+ * @document https://github.com/friendsofhyperf/components/blob/main/README.md
+ * @contact  huangdijia@gmail.com
+ */
+
+namespace FriendsOfHyperf\Tests\Sentry\Metrics;
+
+use FriendsOfHyperf\Sentry\Feature;
+use FriendsOfHyperf\Sentry\Metrics\CoroutineServerStats;
+use FriendsOfHyperf\Sentry\Metrics\Listener\RequestWatcher;
+use Hyperf\HttpMessage\Server\Request;
+use Hyperf\HttpServer\Event\RequestReceived;
+use Mockery as m;
+
+function waitForCoroutine(int $cid): void
+{
+    if (\Swoole\Coroutine::getCid() === -1) {
+        return; // Top level: the created coroutine already finished synchronously.
+    }
+
+    while (\Swoole\Coroutine::exists($cid)) {
+        \Swoole\Coroutine::sleep(0.001);
+    }
+}
+
+test('process request received increments counters without throwing', function () {
+    $stats = new CoroutineServerStats();
+    $feature = m::mock(Feature::class);
+    $feature->shouldReceive('isMetricsEnabled')->andReturn(true);
+
+    $watcher = new RequestWatcher($stats, $feature);
+    $request = new Request('GET', 'http://127.0.0.1:9501/health');
+
+    $snapshot = null;
+    $cid = \Swoole\Coroutine::create(function () use ($watcher, $request, $stats, &$snapshot) {
+        $watcher->process(new RequestReceived($request, null));
+        $snapshot = [
+            'accept_count' => $stats->accept_count,
+            'request_count' => $stats->request_count,
+            'connection_num' => $stats->connection_num,
+        ];
+    });
+
+    waitForCoroutine($cid);
+
+    expect(\Swoole\Coroutine::exists($cid))->toBeFalse()
+        ->and($snapshot['accept_count'])->toBe(1)
+        ->and($snapshot['request_count'])->toBe(1)
+        ->and($snapshot['connection_num'])->toBe(1);
+});
+
+test('defer closes the request counters after the coroutine ends', function () {
+    $stats = new CoroutineServerStats();
+    $feature = m::mock(Feature::class);
+    $feature->shouldReceive('isMetricsEnabled')->andReturn(true);
+
+    $watcher = new RequestWatcher($stats, $feature);
+    $request = new Request('GET', 'http://127.0.0.1:9501/health');
+
+    $cid = \Swoole\Coroutine::create(function () use ($watcher, $request) {
+        $watcher->process(new RequestReceived($request, null));
+    });
+
+    waitForCoroutine($cid);
+
+    expect($stats->close_count)->toBe(1)
+        ->and($stats->response_count)->toBe(1)
+        ->and($stats->connection_num)->toBe(0);
+});