(servicecomb-java-chassis) branch 2.9.x updated: [#4821] Fixed concurrent scenarios localContext empty problem (#4836) (#4846)

[youling1128]

This is an automated email from the ASF dual-hosted git repository.

youling1128 pushed a commit to branch 2.9.x
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git


The following commit(s) were added to refs/heads/2.9.x by this push:
     new 94946d134 [#4821] Fixed concurrent scenarios localContext empty 
problem (#4836) (#4846)
94946d134 is described below

commit 94946d13467168410f783545a6272a897e633d2d
Author: Alex <97039406+chengyoul...@users.noreply.github.com>
AuthorDate: Wed Jun 18 15:41:38 2025 +0800

    [#4821] Fixed concurrent scenarios localContext empty problem (#4836) 
(#4846)
---
 .../apache/servicecomb/loadbalance/LoadbalanceHandler.java  | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git 
a/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadbalanceHandler.java
 
b/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadbalanceHandler.java
index 4d8e943a8..97209486d 100644
--- 
a/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadbalanceHandler.java
+++ 
b/handlers/handler-loadbalance/src/main/java/org/apache/servicecomb/loadbalance/LoadbalanceHandler.java
@@ -89,7 +89,6 @@ public class LoadbalanceHandler implements Handler {
 
   private void preCheck() {
     // Old configurations check.Just print an error, because configurations 
may given in dynamic and fail on runtime.
-
     String policyName = DynamicPropertyFactory.getInstance()
         
.getStringProperty("servicecomb.loadbalance.NFLoadBalancerRuleClassName", null)
         .get();
@@ -115,8 +114,9 @@ public class LoadbalanceHandler implements Handler {
       response.handle(async);
     };
 
-    if (handleSuppliedEndpoint(invocation, asyncResp)) {
+    if (handleSuppliedEndpoint(invocation)) {
       invocation.addLocalContext(RetryContext.RETRY_LOAD_BALANCE, false);
+      invocation.next(asyncResp);
       return;
     }
     invocation.addLocalContext(RetryContext.RETRY_LOAD_BALANCE, true);
@@ -137,15 +137,13 @@ public class LoadbalanceHandler implements Handler {
 
   // user's can invoke a service by supplying target Endpoint.
   // in this case, we do not using load balancer, and no stats of server 
calculated, no retrying.
-  private boolean handleSuppliedEndpoint(Invocation invocation,
-      AsyncResponse asyncResp) throws Exception {
+  private boolean handleSuppliedEndpoint(Invocation invocation) throws 
Exception {
     if (invocation.getEndpoint() != null) {
-      invocation.next(asyncResp);
       return true;
     }
 
     if (supportDefinedEndpoint) {
-      return defineEndpointAndHandle(invocation, asyncResp);
+      return defineEndpointAndHandle(invocation);
     }
 
     return false;
@@ -162,7 +160,7 @@ public class LoadbalanceHandler implements Handler {
     return new Endpoint(transport, endpointUri);
   }
 
-  private boolean defineEndpointAndHandle(Invocation invocation, AsyncResponse 
asyncResp) throws Exception {
+  private boolean defineEndpointAndHandle(Invocation invocation) throws 
Exception {
     Object endpoint = invocation.getLocalContext(SERVICECOMB_SERVER_ENDPOINT);
     if (endpoint == null) {
       return false;
@@ -173,7 +171,6 @@ public class LoadbalanceHandler implements Handler {
     }
 
     invocation.setEndpoint((Endpoint) endpoint);
-    invocation.next(asyncResp);
     return true;
   }