Support more content types for Triple protocol

dubbo-dependencies-bom/pom.xml

@@ -207,6 +207,8 @@
     <palantirJavaFormat.version>2.38.0</palantirJavaFormat.version>
     <revision>3.3.0-beta.2-SNAPSHOT</revision>
     <open_feign_version>3.1.5</open_feign_version>
+    <jakarta.xml.bind-api.version>4.0.1</jakarta.xml.bind-api.version>
+    <jaxb-runtime.version>2.3.3-b02</jaxb-runtime.version>
   </properties>
 
   <dependencyManagement>
@@ -1073,6 +1075,16 @@
         <artifactId>spring-cloud-openfeign-core</artifactId>
         <version>${open_feign_version}</version>
       </dependency>
+      <dependency>
+        <groupId>jakarta.xml.bind</groupId>
+        <artifactId>jakarta.xml.bind-api</artifactId>
+        <version>${jakarta.xml.bind-api.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.glassfish.jaxb</groupId>
+        <artifactId>jaxb-runtime</artifactId>
+        <version>${jaxb-runtime.version}</version>
+      </dependency>
     </dependencies>
   </dependencyManagement>
 

dubbo-remoting/dubbo-remoting-http12/pom.xml

@@ -60,5 +60,14 @@
       <artifactId>netty-codec-http2</artifactId>
     </dependency>
 
+    <dependency>
+      <groupId>javax.xml.bind</groupId>
+      <artifactId>jaxb-api</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.glassfish.jaxb</groupId>
+      <artifactId>jaxb-runtime</artifactId>
+    </dependency>
   </dependencies>
 </project>

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/AbstractServerHttpChannelObserver.java

@@ -32,18 +32,18 @@ public abstract class AbstractServerHttpChannelObserver implements CustomizableH
 
     private boolean headerSent;
 
-    private HttpMessageCodec httpMessageCodec;
+    private HttpMessageCodec responseEncoder;
 
     public AbstractServerHttpChannelObserver(HttpChannel httpChannel) {
         this.httpChannel = httpChannel;
     }
 
-    public void setHttpMessageCodec(HttpMessageCodec httpMessageCodec) {
-        this.httpMessageCodec = httpMessageCodec;
+    public void setResponseEncoder(HttpMessageCodec responseEncoder) {
+        this.responseEncoder = responseEncoder;
     }
 
-    protected HttpMessageCodec getHttpMessageCodec() {
-        return httpMessageCodec;
+    public HttpMessageCodec getResponseEncoder() {
+        return responseEncoder;
     }
 
     @Override
@@ -77,7 +77,7 @@ public void onNext(Object data) {
             }
             HttpOutputMessage outputMessage = encodeHttpOutputMessage(data);
             preOutputMessage(outputMessage);
-            this.httpMessageCodec.encode(outputMessage.getBody(), data);
+            this.responseEncoder.encode(outputMessage.getBody(), data);
             getHttpChannel().writeMessage(outputMessage);
             postOutputMessage(outputMessage);
         } catch (Throwable e) {
@@ -114,7 +114,7 @@ public void onError(Throwable throwable) {
             errorResponse.setMessage(throwable.getMessage());
             this.errorResponseCustomizer.accept(errorResponse, throwable);
             HttpOutputMessage httpOutputMessage = encodeHttpOutputMessage(errorResponse);
-            this.httpMessageCodec.encode(httpOutputMessage.getBody(), errorResponse);
+            this.responseEncoder.encode(httpOutputMessage.getBody(), errorResponse);
             getHttpChannel().writeMessage(httpOutputMessage);
         } catch (Throwable ex) {
             throwable = new EncodeException(ex);
@@ -140,7 +140,7 @@ private void doSendHeaders(String statusCode) {
                 .headers()
                 .set(
                         HttpHeaderNames.CONTENT_TYPE.getName(),
-                        httpMessageCodec.contentType().getName());
+                        responseEncoder.mediaType().getName());
         this.headersCustomizer.accept(httpMetadata.headers());
         getHttpChannel().writeHeader(httpMetadata);
         this.headerSent = true;

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/HttpHeaderNames.java

@@ -25,7 +25,9 @@ public enum HttpHeaderNames {
 
     TRANSFER_ENCODING("transfer-encoding"),
 
-    TE("te");
+    TE("te"),
+
+    ACCEPT("accept");
 
     private final String name;
 

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/HttpHeaders.java

@@ -212,6 +212,14 @@ public Map<String, String> toSingleValueMap() {
         return result;
     }
 
+    public String getContentType() {
+        return getFirst(HttpHeaderNames.CONTENT_TYPE.getName());
+    }
+
+    public String getAccept() {
+        return getFirst(HttpHeaderNames.ACCEPT.getName());
+    }
+
     @Override
     public boolean equals(Object other) {
         return (this == other || this.targetMap.equals(other));

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/CodecSupportStrategy.java

@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.dubbo.remoting.http12.message;
+
+public interface CodecSupportStrategy {
+
+    boolean supportDecode(String mediaType);
+
+    boolean supportEncode(String mediaType);
+
+    MediaType contentType();
+}

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/HttpMessageCodec.java

@@ -46,10 +46,5 @@ default Object[] decode(InputStream inputStream, Class<?>[] targetTypes) throws
         };
     }
 
-    MediaType contentType();
-
-    default boolean support(String contentType) {
-        MediaType mediaType = this.contentType();
-        return mediaType.getName().startsWith(contentType);
-    }
+    MediaType mediaType();
 }

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/HttpMessageCodecFactory.java

@@ -27,12 +27,7 @@
 @SPI(scope = ExtensionScope.FRAMEWORK)
 public interface HttpMessageCodecFactory {
 
-    HttpMessageCodec createCodec(URL url, FrameworkModel frameworkModel);
+    HttpMessageCodec createCodec(URL url, FrameworkModel frameworkModel, String mediaType);
 
-    MediaType contentType();
-
-    default boolean support(String contentType) {
-        MediaType mediaType = this.contentType();
-        return mediaType.getName().startsWith(contentType);
-    }
+    CodecSupportStrategy codecSupport();
 }

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/MediaType.java

@@ -28,6 +28,15 @@ public class MediaType {
 
     public static final MediaType TEXT_EVENT_STREAM_VALUE = new MediaType("text", "event-stream");
 
+    public static final MediaType MULTIPART_FORM_DATA = new MediaType("multipart", "form-data");
+
+    public static final MediaType APPLICATION_X_WWW_FROM_URLENCODED =
+            new MediaType("application", "x-www-form-urlencoded");
+
+    public static final MediaType APPLICATION_XML = new MediaType("application", "xml");
+
+    public static final MediaType TEXT_PLAIN = new MediaType("text", "plain");
+
     private final String name;
 
     private final String type;

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/codec/CodecUtils.java

@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.dubbo.remoting.http12.message.codec;
+
+import org.apache.dubbo.common.URL;
+import org.apache.dubbo.remoting.http12.HttpHeaders;
+import org.apache.dubbo.remoting.http12.message.HttpMessageCodec;
+import org.apache.dubbo.remoting.http12.message.HttpMessageCodecFactory;
+import org.apache.dubbo.rpc.model.FrameworkModel;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+public class CodecUtils {
+
+    public static HttpMessageCodec determineHttpMessageCodec(
+            FrameworkModel frameworkModel, HttpHeaders headers, URL url, boolean decode) {
+        String mediaType = headers.getContentType();
+        // encode
+        if (!decode && headers.getAccept() != null) {
+            mediaType = headers.getAccept();
+        }
+        HttpMessageCodecFactory factory = determineHttpMessageCodecFactory(frameworkModel, mediaType, decode);
+        if (factory != null) {
+            return factory.createCodec(url, frameworkModel, mediaType);
+        }
+        return null;
+    }
+
+    public static HttpMessageCodecFactory determineHttpMessageCodecFactory(
+            FrameworkModel frameworkModel, String mediaType, boolean decode) {
+        frameworkModel.getExtensionLoader(HttpMessageCodecFactory.class).getSupportedExtensions();
+        for (HttpMessageCodecFactory httpMessageCodecFactory :
+                frameworkModel.getExtensionLoader(HttpMessageCodecFactory.class).getActivateExtensions()) {
+            if (decode) {
+                if (httpMessageCodecFactory.codecSupport().supportDecode(mediaType)) {
+                    return httpMessageCodecFactory;
+                }
+            } else {
+                // encode
+                if (httpMessageCodecFactory.codecSupport().supportEncode(mediaType)) {
+                    return httpMessageCodecFactory;
+                }
+            }
+        }
+        return null;
+    }
+
+    public static ByteArrayOutputStream toByteArrayStream(InputStream in) throws IOException {
+        ByteArrayOutputStream result = new ByteArrayOutputStream();
+        byte[] buffer = new byte[1024];
+        int length;
+        while ((length = in.read(buffer)) != -1) {
+            result.write(buffer, 0, length);
+        }
+        return result;
+    }
+}

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/codec/DefaultSupportStrategy.java

@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.dubbo.remoting.http12.message.codec;
+
+import org.apache.dubbo.remoting.http12.message.CodecSupportStrategy;
+import org.apache.dubbo.remoting.http12.message.MediaType;
+
+public class DefaultSupportStrategy implements CodecSupportStrategy {
+    private final MediaType mediaType;
+
+    public DefaultSupportStrategy(MediaType mediaType) {
+        this.mediaType = mediaType;
+    }
+
+    public boolean supportDecode(String mediaType) {
+        return mediaType != null && mediaType.startsWith(this.mediaType.getName());
+    }
+
+    public boolean supportEncode(String mediaType) {
+        return mediaType != null && (mediaType.contains(this.mediaType.getName()));
+    }
+
+    @Override
+    public MediaType contentType() {
+        return mediaType;
+    }
+}

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/JsonCodec.java → dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/codec/JsonCodec.java

@@ -14,12 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.dubbo.remoting.http12.message;
+package org.apache.dubbo.remoting.http12.message.codec;
 
 import org.apache.dubbo.common.extension.Activate;
 import org.apache.dubbo.common.utils.JsonUtils;
 import org.apache.dubbo.remoting.http12.exception.DecodeException;
 import org.apache.dubbo.remoting.http12.exception.EncodeException;
+import org.apache.dubbo.remoting.http12.message.HttpMessageCodec;
+import org.apache.dubbo.remoting.http12.message.MediaType;
 
 import java.io.InputStream;
 import java.io.OutputStream;
@@ -35,10 +37,8 @@
 @Activate
 public class JsonCodec implements HttpMessageCodec {
 
-    public static final HttpMessageCodec INSTANCE = new JsonCodec();
-
     @Override
-    public MediaType contentType() {
+    public MediaType mediaType() {
         return MediaType.APPLICATION_JSON_VALUE;
     }
 

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/JsonCodecFactory.java → dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/codec/JsonCodecFactory.java

@@ -14,10 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.dubbo.remoting.http12.message;
+package org.apache.dubbo.remoting.http12.message.codec;
 
 import org.apache.dubbo.common.URL;
 import org.apache.dubbo.common.extension.Activate;
+import org.apache.dubbo.remoting.http12.message.CodecSupportStrategy;
+import org.apache.dubbo.remoting.http12.message.HttpMessageCodec;
+import org.apache.dubbo.remoting.http12.message.HttpMessageCodecFactory;
+import org.apache.dubbo.remoting.http12.message.MediaType;
 import org.apache.dubbo.rpc.model.FrameworkModel;
 
 @Activate
@@ -26,12 +30,12 @@ public class JsonCodecFactory implements HttpMessageCodecFactory {
     public static final String NAME = "json";
 
     @Override
-    public HttpMessageCodec createCodec(URL url, FrameworkModel frameworkModel) {
+    public HttpMessageCodec createCodec(URL url, FrameworkModel frameworkModel, String mediaType) {
         return new JsonCodec();
     }
 
     @Override
-    public MediaType contentType() {
-        return MediaType.APPLICATION_JSON_VALUE;
+    public CodecSupportStrategy codecSupport() {
+        return new DefaultSupportStrategy(MediaType.APPLICATION_JSON_VALUE);
     }
 }

dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/JsonPbCodec.java → dubbo-remoting/dubbo-remoting-http12/src/main/java/org/apache/dubbo/remoting/http12/message/codec/JsonPbCodec.java

@@ -14,13 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.dubbo.remoting.http12.message;
+package org.apache.dubbo.remoting.http12.message.codec;
 
 import org.apache.dubbo.common.extension.Activate;
-import org.apache.dubbo.common.utils.ClassUtils;
 import org.apache.dubbo.common.utils.MethodUtils;
 import org.apache.dubbo.remoting.http12.exception.DecodeException;
 import org.apache.dubbo.remoting.http12.exception.EncodeException;
+import org.apache.dubbo.remoting.http12.message.HttpMessageCodec;
+import org.apache.dubbo.remoting.http12.message.MediaType;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -40,15 +41,8 @@ public void setJsonCodec(HttpMessageCodec jsonCodec) {
     }
 
     @Override
-    public MediaType contentType() {
-        return jsonCodec.contentType();
-    }
-
-    @Override
-    public boolean support(String contentType) {
-        return HttpMessageCodec.super.support(contentType)
-                && ClassUtils.isPresent(
-                        "com.google.protobuf.Message", getClass().getClassLoader());
+    public MediaType mediaType() {
+        return jsonCodec.mediaType();
     }
 
     @Override