[#4873] Support for SSE interface RPC calls

.github/workflows/maven.yml

@@ -36,7 +36,7 @@ jobs:
     - name: Set up jdk
       uses: actions/setup-java@v3
       with:
-        java-version: '21'
+        java-version: '17'
         distribution: 'temurin'
     - name: Set up Maven
       uses: stCarolas/[email protected]

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/AbstractRestInvocation.java

@@ -351,7 +351,7 @@ protected void onExecuteHttpServerFiltersFinish(Response response, Throwable e)
 
     if (!(response.getResult() instanceof ServerWebSocket)) {
       try {
-        responseEx.flushBuffer();
+        responseEx.endResponse();
       } catch (Throwable flushException) {
         LOGGER.error("Failed to flush rest response, operation:{}, request uri:{}",
             getMicroserviceQualifiedName(), requestEx.getRequestURI(), flushException);

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/RestProducerInvocationFlow.java

@@ -53,24 +53,24 @@ protected Invocation sendCreateInvocationException(Throwable throwable) {
           requestEx.getRequestURI(), e);
     }
 
-    flushResponse("UNKNOWN_OPERATION");
+    endResponse("UNKNOWN_OPERATION");
     return null;
   }
 
   @Override
   protected void sendResponse(Invocation invocation, Response response) {
     if (isDownloadFileResponseType(invocation, response)) {
       responseEx.sendPart(PartUtils.getSinglePart(null, response.getResult()))
-          .whenComplete((r, e) -> flushResponse(invocation.getMicroserviceQualifiedName()));
+          .whenComplete((r, e) -> endResponse(invocation.getMicroserviceQualifiedName()));
       return;
     }
 
-    flushResponse(invocation.getMicroserviceQualifiedName());
+    endResponse(invocation.getMicroserviceQualifiedName());
   }
 
-  private void flushResponse(String operationName) {
+  private void endResponse(String operationName) {
     try {
-      responseEx.flushBuffer();
+      responseEx.endResponse();
     } catch (Throwable flushException) {
       LOGGER.error("Failed to flush rest response, operation:{}, request uri:{}",
           operationName, requestEx.getRequestURI(), flushException);