diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/README.md b/1-basic/dubbo-samples-spring-boot-idl-diff-package/README.md new file mode 100644 index 0000000000..5ff484464a --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/README.md @@ -0,0 +1,58 @@ +# Dubbo Spring Boot Example using Triple and Protobuf with different package and java_package + +This example uses triple as the underlying RPC protocol and IDL to define services. It's highly recommend to use triple and IDL for cross-language communication scenarios. Please refer to [dubbo-samples-spring-boot](../dubbo-samples-spring-boot) for how to use pure Java interface to define services for triple protocol. + +This example define the Java package name separately from the service prefix, which is useful in some cross-language calling scenarios.And For instance, in the following IDL definition: + +1. The complete service name is `idl.Greeter`, which will be used during rpc calls and service discovery. +2. The Java package name is defined as `org.apache.dubbo.springboot.demo.idl.Greeter`, where the generated Java code will be placed. + +# How to run + +## Start Nacos +This example replies on Nacos as service discovery registry center, so you need to run the Nacos server first, there are two ways to do so: +1. [Download Nacos binary and start it directly](https://dubbo-next.staged.apache.org/zh-cn/overview/reference/integrations/nacos/#本地下载) +2. [Start Nacos using docker](https://dubbo-next.staged.apache.org/zh-cn/overview/reference/integrations/nacos/#docker) + +## Compile + +Step into 'dubbo-samples-spring-boot-idl-diff-package' directory, run the following command: + +```shell +$ mvn clean compile +``` + +## Start provider + +Enter provider directory: +```shell +$ cd dubbo-samples-spring-boot-idl-diff-package-provider +``` + +then, run the following command to start provider: +```shell +$ mvn compile exec:java -Dexec.mainClass="org.apache.dubbo.springboot.demo.provider.ProviderApplication" +``` + +Run the following command to see server works as expected: +```shell +curl \ + --header "Content-Type: application/json" \ + --data '{"name":"Dubbo"}' \ + http://localhost:50052/idl.Greeter/greet/ +``` + +## Start consumer + +Enter provider directory: +```shell +$ cd dubbo-samples-spring-boot-idl-diff-package-consumer +``` + +then, run the following command to start consumer: +```shell +$ mvn compile exec:java -Dexec.mainClass="org.apache.dubbo.springboot.demo.consumer.ConsumerApplication" +``` + + + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/DubboGreeterTriple.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/DubboGreeterTriple.java new file mode 100644 index 0000000000..e40fdeb281 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/DubboGreeterTriple.java @@ -0,0 +1,200 @@ +/* +* 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.springboot.demo.idl; + +import org.apache.dubbo.common.stream.StreamObserver; +import org.apache.dubbo.common.URL; +import org.apache.dubbo.rpc.Invoker; +import org.apache.dubbo.rpc.PathResolver; +import org.apache.dubbo.rpc.RpcException; +import org.apache.dubbo.rpc.ServerService; +import org.apache.dubbo.rpc.TriRpcStatus; +import org.apache.dubbo.rpc.model.MethodDescriptor; +import org.apache.dubbo.rpc.model.ServiceDescriptor; +import org.apache.dubbo.rpc.model.StubMethodDescriptor; +import org.apache.dubbo.rpc.model.StubServiceDescriptor; +import org.apache.dubbo.rpc.service.Destroyable; +import org.apache.dubbo.rpc.stub.BiStreamMethodHandler; +import org.apache.dubbo.rpc.stub.ServerStreamMethodHandler; +import org.apache.dubbo.rpc.stub.StubInvocationUtil; +import org.apache.dubbo.rpc.stub.StubInvoker; +import org.apache.dubbo.rpc.stub.StubMethodHandler; +import org.apache.dubbo.rpc.stub.StubSuppliers; +import org.apache.dubbo.rpc.stub.UnaryStubMethodHandler; + +import com.google.protobuf.Message; + +import java.util.HashMap; +import java.util.Map; +import java.util.function.BiConsumer; +import java.util.concurrent.CompletableFuture; + +public final class DubboGreeterTriple { + + public static final String SERVICE_NAME = Greeter.SERVICE_NAME; + + private static final StubServiceDescriptor serviceDescriptor = new StubServiceDescriptor(SERVICE_NAME,Greeter.class); + + static { + org.apache.dubbo.rpc.protocol.tri.service.SchemaDescriptorRegistry.addSchemaDescriptor(SERVICE_NAME,GreeterOuterClass.getDescriptor()); + StubSuppliers.addSupplier(SERVICE_NAME, DubboGreeterTriple::newStub); + StubSuppliers.addSupplier(Greeter.JAVA_SERVICE_NAME, DubboGreeterTriple::newStub); + StubSuppliers.addDescriptor(SERVICE_NAME, serviceDescriptor); + StubSuppliers.addDescriptor(Greeter.JAVA_SERVICE_NAME, serviceDescriptor); + } + + @SuppressWarnings("all") + public static Greeter newStub(Invoker invoker) { + return new GreeterStub((Invoker)invoker); + } + + private static final StubMethodDescriptor greetMethod = new StubMethodDescriptor("greet", + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.class, MethodDescriptor.RpcType.UNARY, + obj -> ((Message) obj).toByteArray(), obj -> ((Message) obj).toByteArray(), org.apache.dubbo.springboot.demo.idl.GreeterRequest::parseFrom, + org.apache.dubbo.springboot.demo.idl.GreeterReply::parseFrom); + + private static final StubMethodDescriptor greetAsyncMethod = new StubMethodDescriptor("greet", + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, java.util.concurrent.CompletableFuture.class, MethodDescriptor.RpcType.UNARY, + obj -> ((Message) obj).toByteArray(), obj -> ((Message) obj).toByteArray(), org.apache.dubbo.springboot.demo.idl.GreeterRequest::parseFrom, + org.apache.dubbo.springboot.demo.idl.GreeterReply::parseFrom); + + private static final StubMethodDescriptor greetProxyAsyncMethod = new StubMethodDescriptor("greetAsync", + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.class, MethodDescriptor.RpcType.UNARY, + obj -> ((Message) obj).toByteArray(), obj -> ((Message) obj).toByteArray(), org.apache.dubbo.springboot.demo.idl.GreeterRequest::parseFrom, + org.apache.dubbo.springboot.demo.idl.GreeterReply::parseFrom); + + + + + static{ + serviceDescriptor.addMethod(greetMethod); + serviceDescriptor.addMethod(greetProxyAsyncMethod); + } + + public static class GreeterStub implements Greeter, Destroyable { + private final Invoker invoker; + + public GreeterStub(Invoker invoker) { + this.invoker = invoker; + } + + @Override + public void $destroy() { + invoker.destroy(); + } + + @Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + return StubInvocationUtil.unaryCall(invoker, greetMethod, request); + } + + public CompletableFuture greetAsync(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + return StubInvocationUtil.unaryCall(invoker, greetAsyncMethod, request); + } + + public void greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request, StreamObserver responseObserver){ + StubInvocationUtil.unaryCall(invoker, greetMethod , request, responseObserver); + } + + + + } + + public static abstract class GreeterImplBase implements Greeter, ServerService { + + private BiConsumer> syncToAsync(java.util.function.Function syncFun) { + return new BiConsumer>() { + @Override + public void accept(T t, StreamObserver observer) { + try { + R ret = syncFun.apply(t); + observer.onNext(ret); + observer.onCompleted(); + } catch (Throwable e) { + observer.onError(e); + } + } + }; + } + + @Override + public CompletableFuture greetAsync(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + return CompletableFuture.completedFuture(greet(request)); + } + + /** + * This server stream type unary method is only used for generated stub to support async unary method. + * It will not be called if you are NOT using Dubbo3 generated triple stub and DO NOT implement this method. + */ + public void greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request, StreamObserver responseObserver){ + greetAsync(request).whenComplete((r, t) -> { + if (t != null) { + responseObserver.onError(t); + } else { + responseObserver.onNext(r); + responseObserver.onCompleted(); + } + }); + } + + @Override + public final Invoker getInvoker(URL url) { + PathResolver pathResolver = url.getOrDefaultFrameworkModel() + .getExtensionLoader(PathResolver.class) + .getDefaultExtension(); + Map> handlers = new HashMap<>(); + + pathResolver.addNativeStub( "/" + SERVICE_NAME + "/greet"); + pathResolver.addNativeStub( "/" + SERVICE_NAME + "/greetAsync"); + // for compatibility + pathResolver.addNativeStub( "/" + JAVA_SERVICE_NAME + "/greet"); + pathResolver.addNativeStub( "/" + JAVA_SERVICE_NAME + "/greetAsync"); + + + BiConsumer> greetFunc = this::greet; + handlers.put(greetMethod.getMethodName(), new UnaryStubMethodHandler<>(greetFunc)); + BiConsumer> greetAsyncFunc = syncToAsync(this::greet); + handlers.put(greetProxyAsyncMethod.getMethodName(), new UnaryStubMethodHandler<>(greetAsyncFunc)); + + + + + return new StubInvoker<>(this, url, Greeter.class, handlers); + } + + + @Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + throw unimplementedMethodException(greetMethod); + } + + + + + + @Override + public final ServiceDescriptor getServiceDescriptor() { + return serviceDescriptor; + } + private RpcException unimplementedMethodException(StubMethodDescriptor methodDescriptor) { + return TriRpcStatus.UNIMPLEMENTED.withDescription(String.format("Method %s is unimplemented", + "/" + serviceDescriptor.getInterfaceName() + "/" + methodDescriptor.getMethodName())).asException(); + } + } + +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/Greeter.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/Greeter.java new file mode 100644 index 0000000000..e5fdddd7c2 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/Greeter.java @@ -0,0 +1,43 @@ +/* +* 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.springboot.demo.idl; + +import org.apache.dubbo.common.stream.StreamObserver; +import com.google.protobuf.Message; + +import java.util.HashMap; +import java.util.Map; +import java.util.function.BiConsumer; +import java.util.concurrent.CompletableFuture; + +public interface Greeter extends org.apache.dubbo.rpc.model.DubboStub { + + String JAVA_SERVICE_NAME = "org.apache.dubbo.springboot.demo.idl.Greeter"; + String SERVICE_NAME = "idl.Greeter"; + org.apache.dubbo.springboot.demo.idl.GreeterReply greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request); + + CompletableFuture greetAsync(org.apache.dubbo.springboot.demo.idl.GreeterRequest request); + + + + + + + + +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterOuterClass.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterOuterClass.java new file mode 100644 index 0000000000..14d39dd215 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterOuterClass.java @@ -0,0 +1,61 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +public final class GreeterOuterClass { + private GreeterOuterClass() {} + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistryLite registry) { + } + + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistry registry) { + registerAllExtensions( + (com.google.protobuf.ExtensionRegistryLite) registry); + } + static final com.google.protobuf.Descriptors.Descriptor + internal_static_idl_GreeterRequest_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_idl_GreeterRequest_fieldAccessorTable; + static final com.google.protobuf.Descriptors.Descriptor + internal_static_idl_GreeterReply_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_idl_GreeterReply_fieldAccessorTable; + + public static com.google.protobuf.Descriptors.FileDescriptor + getDescriptor() { + return descriptor; + } + private static com.google.protobuf.Descriptors.FileDescriptor + descriptor; + static { + java.lang.String[] descriptorData = { + "\n\rgreeter.proto\022\003idl\"\036\n\016GreeterRequest\022\014" + + "\n\004name\030\001 \001(\t\"\037\n\014GreeterReply\022\017\n\007message\030" + + "\001 \001(\t2:\n\007Greeter\022/\n\005greet\022\023.idl.GreeterR" + + "equest\032\021.idl.GreeterReplyB(\n$org.apache." + + "dubbo.springboot.demo.idlP\001b\006proto3" + }; + descriptor = com.google.protobuf.Descriptors.FileDescriptor + .internalBuildGeneratedFileFrom(descriptorData, + new com.google.protobuf.Descriptors.FileDescriptor[] { + }); + internal_static_idl_GreeterRequest_descriptor = + getDescriptor().getMessageTypes().get(0); + internal_static_idl_GreeterRequest_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_idl_GreeterRequest_descriptor, + new java.lang.String[] { "Name", }); + internal_static_idl_GreeterReply_descriptor = + getDescriptor().getMessageTypes().get(1); + internal_static_idl_GreeterReply_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_idl_GreeterReply_descriptor, + new java.lang.String[] { "Message", }); + } + + // @@protoc_insertion_point(outer_class_scope) +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReply.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReply.java new file mode 100644 index 0000000000..cc0a8bdf2d --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReply.java @@ -0,0 +1,507 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +/** + * Protobuf type {@code idl.GreeterReply} + */ +public final class GreeterReply extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:idl.GreeterReply) + GreeterReplyOrBuilder { +private static final long serialVersionUID = 0L; + // Use GreeterReply.newBuilder() to construct. + private GreeterReply(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private GreeterReply() { + message_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new GreeterReply(); + } + + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterReply.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.Builder.class); + } + + public static final int MESSAGE_FIELD_NUMBER = 1; + @SuppressWarnings("serial") + private volatile java.lang.Object message_ = ""; + /** + * string message = 1; + * @return The message. + */ + @java.lang.Override + public java.lang.String getMessage() { + java.lang.Object ref = message_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + message_ = s; + return s; + } + } + /** + * string message = 1; + * @return The bytes for message. + */ + @java.lang.Override + public com.google.protobuf.ByteString + getMessageBytes() { + java.lang.Object ref = message_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + message_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(message_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, message_); + } + getUnknownFields().writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(message_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, message_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof org.apache.dubbo.springboot.demo.idl.GreeterReply)) { + return super.equals(obj); + } + org.apache.dubbo.springboot.demo.idl.GreeterReply other = (org.apache.dubbo.springboot.demo.idl.GreeterReply) obj; + + if (!getMessage() + .equals(other.getMessage())) return false; + if (!getUnknownFields().equals(other.getUnknownFields())) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + MESSAGE_FIELD_NUMBER; + hash = (53 * hash) + getMessage().hashCode(); + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(org.apache.dubbo.springboot.demo.idl.GreeterReply prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code idl.GreeterReply} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:idl.GreeterReply) + org.apache.dubbo.springboot.demo.idl.GreeterReplyOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterReply.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.Builder.class); + } + + // Construct using org.apache.dubbo.springboot.demo.idl.GreeterReply.newBuilder() + private Builder() { + + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + + } + @java.lang.Override + public Builder clear() { + super.clear(); + bitField0_ = 0; + message_ = ""; + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_descriptor; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply getDefaultInstanceForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterReply.getDefaultInstance(); + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply build() { + org.apache.dubbo.springboot.demo.idl.GreeterReply result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply buildPartial() { + org.apache.dubbo.springboot.demo.idl.GreeterReply result = new org.apache.dubbo.springboot.demo.idl.GreeterReply(this); + if (bitField0_ != 0) { buildPartial0(result); } + onBuilt(); + return result; + } + + private void buildPartial0(org.apache.dubbo.springboot.demo.idl.GreeterReply result) { + int from_bitField0_ = bitField0_; + if (((from_bitField0_ & 0x00000001) != 0)) { + result.message_ = message_; + } + } + + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.dubbo.springboot.demo.idl.GreeterReply) { + return mergeFrom((org.apache.dubbo.springboot.demo.idl.GreeterReply)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.dubbo.springboot.demo.idl.GreeterReply other) { + if (other == org.apache.dubbo.springboot.demo.idl.GreeterReply.getDefaultInstance()) return this; + if (!other.getMessage().isEmpty()) { + message_ = other.message_; + bitField0_ |= 0x00000001; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + message_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000001; + break; + } // case 10 + default: { + if (!super.parseUnknownField(input, extensionRegistry, tag)) { + done = true; // was an endgroup tag + } + break; + } // default: + } // switch (tag) + } // while (!done) + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.unwrapIOException(); + } finally { + onChanged(); + } // finally + return this; + } + private int bitField0_; + + private java.lang.Object message_ = ""; + /** + * string message = 1; + * @return The message. + */ + public java.lang.String getMessage() { + java.lang.Object ref = message_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + message_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string message = 1; + * @return The bytes for message. + */ + public com.google.protobuf.ByteString + getMessageBytes() { + java.lang.Object ref = message_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + message_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string message = 1; + * @param value The message to set. + * @return This builder for chaining. + */ + public Builder setMessage( + java.lang.String value) { + if (value == null) { throw new NullPointerException(); } + message_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + /** + * string message = 1; + * @return This builder for chaining. + */ + public Builder clearMessage() { + message_ = getDefaultInstance().getMessage(); + bitField0_ = (bitField0_ & ~0x00000001); + onChanged(); + return this; + } + /** + * string message = 1; + * @param value The bytes for message to set. + * @return This builder for chaining. + */ + public Builder setMessageBytes( + com.google.protobuf.ByteString value) { + if (value == null) { throw new NullPointerException(); } + checkByteStringIsUtf8(value); + message_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:idl.GreeterReply) + } + + // @@protoc_insertion_point(class_scope:idl.GreeterReply) + private static final org.apache.dubbo.springboot.demo.idl.GreeterReply DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new org.apache.dubbo.springboot.demo.idl.GreeterReply(); + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterReply getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public GreeterReply parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + Builder builder = newBuilder(); + try { + builder.mergeFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(builder.buildPartial()); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException(e) + .setUnfinishedMessage(builder.buildPartial()); + } + return builder.buildPartial(); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReplyOrBuilder.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReplyOrBuilder.java new file mode 100644 index 0000000000..d0e0ee803a --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReplyOrBuilder.java @@ -0,0 +1,21 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +public interface GreeterReplyOrBuilder extends + // @@protoc_insertion_point(interface_extends:idl.GreeterReply) + com.google.protobuf.MessageOrBuilder { + + /** + * string message = 1; + * @return The message. + */ + java.lang.String getMessage(); + /** + * string message = 1; + * @return The bytes for message. + */ + com.google.protobuf.ByteString + getMessageBytes(); +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequest.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequest.java new file mode 100644 index 0000000000..bb89150fc1 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequest.java @@ -0,0 +1,507 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +/** + * Protobuf type {@code idl.GreeterRequest} + */ +public final class GreeterRequest extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:idl.GreeterRequest) + GreeterRequestOrBuilder { +private static final long serialVersionUID = 0L; + // Use GreeterRequest.newBuilder() to construct. + private GreeterRequest(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private GreeterRequest() { + name_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new GreeterRequest(); + } + + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterRequest.Builder.class); + } + + public static final int NAME_FIELD_NUMBER = 1; + @SuppressWarnings("serial") + private volatile java.lang.Object name_ = ""; + /** + * string name = 1; + * @return The name. + */ + @java.lang.Override + public java.lang.String getName() { + java.lang.Object ref = name_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + name_ = s; + return s; + } + } + /** + * string name = 1; + * @return The bytes for name. + */ + @java.lang.Override + public com.google.protobuf.ByteString + getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(name_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, name_); + } + getUnknownFields().writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(name_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, name_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof org.apache.dubbo.springboot.demo.idl.GreeterRequest)) { + return super.equals(obj); + } + org.apache.dubbo.springboot.demo.idl.GreeterRequest other = (org.apache.dubbo.springboot.demo.idl.GreeterRequest) obj; + + if (!getName() + .equals(other.getName())) return false; + if (!getUnknownFields().equals(other.getUnknownFields())) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + NAME_FIELD_NUMBER; + hash = (53 * hash) + getName().hashCode(); + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(org.apache.dubbo.springboot.demo.idl.GreeterRequest prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code idl.GreeterRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:idl.GreeterRequest) + org.apache.dubbo.springboot.demo.idl.GreeterRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterRequest.Builder.class); + } + + // Construct using org.apache.dubbo.springboot.demo.idl.GreeterRequest.newBuilder() + private Builder() { + + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + + } + @java.lang.Override + public Builder clear() { + super.clear(); + bitField0_ = 0; + name_ = ""; + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_descriptor; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest getDefaultInstanceForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterRequest.getDefaultInstance(); + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest build() { + org.apache.dubbo.springboot.demo.idl.GreeterRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest buildPartial() { + org.apache.dubbo.springboot.demo.idl.GreeterRequest result = new org.apache.dubbo.springboot.demo.idl.GreeterRequest(this); + if (bitField0_ != 0) { buildPartial0(result); } + onBuilt(); + return result; + } + + private void buildPartial0(org.apache.dubbo.springboot.demo.idl.GreeterRequest result) { + int from_bitField0_ = bitField0_; + if (((from_bitField0_ & 0x00000001) != 0)) { + result.name_ = name_; + } + } + + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.dubbo.springboot.demo.idl.GreeterRequest) { + return mergeFrom((org.apache.dubbo.springboot.demo.idl.GreeterRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.dubbo.springboot.demo.idl.GreeterRequest other) { + if (other == org.apache.dubbo.springboot.demo.idl.GreeterRequest.getDefaultInstance()) return this; + if (!other.getName().isEmpty()) { + name_ = other.name_; + bitField0_ |= 0x00000001; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + name_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000001; + break; + } // case 10 + default: { + if (!super.parseUnknownField(input, extensionRegistry, tag)) { + done = true; // was an endgroup tag + } + break; + } // default: + } // switch (tag) + } // while (!done) + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.unwrapIOException(); + } finally { + onChanged(); + } // finally + return this; + } + private int bitField0_; + + private java.lang.Object name_ = ""; + /** + * string name = 1; + * @return The name. + */ + public java.lang.String getName() { + java.lang.Object ref = name_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + name_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string name = 1; + * @return The bytes for name. + */ + public com.google.protobuf.ByteString + getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string name = 1; + * @param value The name to set. + * @return This builder for chaining. + */ + public Builder setName( + java.lang.String value) { + if (value == null) { throw new NullPointerException(); } + name_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + /** + * string name = 1; + * @return This builder for chaining. + */ + public Builder clearName() { + name_ = getDefaultInstance().getName(); + bitField0_ = (bitField0_ & ~0x00000001); + onChanged(); + return this; + } + /** + * string name = 1; + * @param value The bytes for name to set. + * @return This builder for chaining. + */ + public Builder setNameBytes( + com.google.protobuf.ByteString value) { + if (value == null) { throw new NullPointerException(); } + checkByteStringIsUtf8(value); + name_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:idl.GreeterRequest) + } + + // @@protoc_insertion_point(class_scope:idl.GreeterRequest) + private static final org.apache.dubbo.springboot.demo.idl.GreeterRequest DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new org.apache.dubbo.springboot.demo.idl.GreeterRequest(); + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public GreeterRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + Builder builder = newBuilder(); + try { + builder.mergeFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(builder.buildPartial()); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException(e) + .setUnfinishedMessage(builder.buildPartial()); + } + return builder.buildPartial(); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequestOrBuilder.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequestOrBuilder.java new file mode 100644 index 0000000000..6bca5d24cd --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequestOrBuilder.java @@ -0,0 +1,21 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +public interface GreeterRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:idl.GreeterRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * string name = 1; + * @return The name. + */ + java.lang.String getName(); + /** + * string name = 1; + * @return The bytes for name. + */ + com.google.protobuf.ByteString + getNameBytes(); +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/pom.xml b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/pom.xml new file mode 100644 index 0000000000..dfea02b743 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/pom.xml @@ -0,0 +1,131 @@ + + + + dubbo-samples-spring-boot-idl-diff-package + org.apache.dubbo + 1.0-SNAPSHOT + ../pom.xml + + 4.0.0 + + dubbo-samples-spring-boot-idl-diff-package-consumer + + + + + org.apache.dubbo + dubbo-spring-boot-starter + + + org.apache.dubbo + dubbo-nacos-spring-boot-starter + + + + + org.springframework.boot + spring-boot-starter + + + + + com.google.protobuf + protobuf-java + ${protobuf-java.version} + + + com.google.protobuf + protobuf-java-util + ${protobuf-java.version} + + + + org.springframework.boot + spring-boot-starter-log4j2 + + + + org.springframework.boot + spring-boot-starter-test + test + + + + + + + kr.motd.maven + os-maven-plugin + 1.6.1 + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + org.xolstice.maven.plugins + protobuf-maven-plugin + 0.6.1 + + com.google.protobuf:protoc:${protoc.version}:exe:${os.detected.classifier} + build/generated/source/proto/main/java + + + dubbo + org.apache.dubbo + dubbo-compiler + ${dubbo.version} + org.apache.dubbo.gen.tri.Dubbo3TripleGenerator + + + + + + + compile + + + + + + + org.codehaus.mojo + build-helper-maven-plugin + 3.3.0 + + + generate-sources + + add-source + + + + build/generated/source/proto/main/java + + + + + + + + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/java/org/apache/dubbo/springboot/demo/consumer/ConsumerApplication.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/java/org/apache/dubbo/springboot/demo/consumer/ConsumerApplication.java new file mode 100644 index 0000000000..151ef54952 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/java/org/apache/dubbo/springboot/demo/consumer/ConsumerApplication.java @@ -0,0 +1,33 @@ +/* + * 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.springboot.demo.consumer; + +import org.apache.dubbo.common.constants.CommonConstants; +import org.apache.dubbo.config.spring.context.annotation.EnableDubbo; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +@EnableDubbo +public class ConsumerApplication { + + public static void main(String[] args) { + System.setProperty(CommonConstants.DubboProperty.DUBBO_PREFERRED_NETWORK_INTERFACE, "en0"); + SpringApplication.run(ConsumerApplication.class, args); + } +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/java/org/apache/dubbo/springboot/demo/consumer/Task.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/java/org/apache/dubbo/springboot/demo/consumer/Task.java new file mode 100644 index 0000000000..0859719c10 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/java/org/apache/dubbo/springboot/demo/consumer/Task.java @@ -0,0 +1,40 @@ +/* + * 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.springboot.demo.consumer; + +import java.util.Date; + +import org.apache.dubbo.config.annotation.DubboReference; +import org.apache.dubbo.springboot.demo.idl.Greeter; +import org.apache.dubbo.springboot.demo.idl.GreeterReply; +import org.apache.dubbo.springboot.demo.idl.GreeterRequest; +import org.apache.dubbo.springboot.demo.idl.Greeter; + +import org.springframework.boot.CommandLineRunner; +import org.springframework.stereotype.Component; + +@Component +public class Task implements CommandLineRunner { + @DubboReference + private Greeter greeter; + + @Override + public void run(String... args) throws Exception { + GreeterReply result = greeter.greet(GreeterRequest.newBuilder().setName("name").build()); + System.out.println("Received result ======> " + result.getMessage()); + } +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/proto/greeter.proto b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/proto/greeter.proto new file mode 100644 index 0000000000..2a82680ac4 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/proto/greeter.proto @@ -0,0 +1,21 @@ +syntax = "proto3"; + +option java_multiple_files = true; + +package idl; + +option java_package = "org.apache.dubbo.springboot.demo.idl"; + +message GreeterRequest { + string name = 1; +} + +message GreeterReply { + string message = 1; +} + +service Greeter{ + + rpc greet(GreeterRequest) returns (GreeterReply); + +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/resources/application.yml b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/resources/application.yml new file mode 100644 index 0000000000..9fa5bef5ea --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/resources/application.yml @@ -0,0 +1,25 @@ +# 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. + +dubbo: + application: + name: dubbo-springboot-demo-idl-diff-package-consumer + logger: slf4j + enable-file-cache: false + registry: + address: nacos://${nacos.address:127.0.0.1}:8848?username=nacos&password=nacos + register-mode: instance + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/resources/log4j2.xml b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/resources/log4j2.xml new file mode 100644 index 0000000000..01ab6d5bba --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-consumer/src/main/resources/log4j2.xml @@ -0,0 +1,34 @@ + + + + + + + + + + + + + + + + + + + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/DubboGreeterTriple.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/DubboGreeterTriple.java new file mode 100644 index 0000000000..e40fdeb281 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/DubboGreeterTriple.java @@ -0,0 +1,200 @@ +/* +* 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.springboot.demo.idl; + +import org.apache.dubbo.common.stream.StreamObserver; +import org.apache.dubbo.common.URL; +import org.apache.dubbo.rpc.Invoker; +import org.apache.dubbo.rpc.PathResolver; +import org.apache.dubbo.rpc.RpcException; +import org.apache.dubbo.rpc.ServerService; +import org.apache.dubbo.rpc.TriRpcStatus; +import org.apache.dubbo.rpc.model.MethodDescriptor; +import org.apache.dubbo.rpc.model.ServiceDescriptor; +import org.apache.dubbo.rpc.model.StubMethodDescriptor; +import org.apache.dubbo.rpc.model.StubServiceDescriptor; +import org.apache.dubbo.rpc.service.Destroyable; +import org.apache.dubbo.rpc.stub.BiStreamMethodHandler; +import org.apache.dubbo.rpc.stub.ServerStreamMethodHandler; +import org.apache.dubbo.rpc.stub.StubInvocationUtil; +import org.apache.dubbo.rpc.stub.StubInvoker; +import org.apache.dubbo.rpc.stub.StubMethodHandler; +import org.apache.dubbo.rpc.stub.StubSuppliers; +import org.apache.dubbo.rpc.stub.UnaryStubMethodHandler; + +import com.google.protobuf.Message; + +import java.util.HashMap; +import java.util.Map; +import java.util.function.BiConsumer; +import java.util.concurrent.CompletableFuture; + +public final class DubboGreeterTriple { + + public static final String SERVICE_NAME = Greeter.SERVICE_NAME; + + private static final StubServiceDescriptor serviceDescriptor = new StubServiceDescriptor(SERVICE_NAME,Greeter.class); + + static { + org.apache.dubbo.rpc.protocol.tri.service.SchemaDescriptorRegistry.addSchemaDescriptor(SERVICE_NAME,GreeterOuterClass.getDescriptor()); + StubSuppliers.addSupplier(SERVICE_NAME, DubboGreeterTriple::newStub); + StubSuppliers.addSupplier(Greeter.JAVA_SERVICE_NAME, DubboGreeterTriple::newStub); + StubSuppliers.addDescriptor(SERVICE_NAME, serviceDescriptor); + StubSuppliers.addDescriptor(Greeter.JAVA_SERVICE_NAME, serviceDescriptor); + } + + @SuppressWarnings("all") + public static Greeter newStub(Invoker invoker) { + return new GreeterStub((Invoker)invoker); + } + + private static final StubMethodDescriptor greetMethod = new StubMethodDescriptor("greet", + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.class, MethodDescriptor.RpcType.UNARY, + obj -> ((Message) obj).toByteArray(), obj -> ((Message) obj).toByteArray(), org.apache.dubbo.springboot.demo.idl.GreeterRequest::parseFrom, + org.apache.dubbo.springboot.demo.idl.GreeterReply::parseFrom); + + private static final StubMethodDescriptor greetAsyncMethod = new StubMethodDescriptor("greet", + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, java.util.concurrent.CompletableFuture.class, MethodDescriptor.RpcType.UNARY, + obj -> ((Message) obj).toByteArray(), obj -> ((Message) obj).toByteArray(), org.apache.dubbo.springboot.demo.idl.GreeterRequest::parseFrom, + org.apache.dubbo.springboot.demo.idl.GreeterReply::parseFrom); + + private static final StubMethodDescriptor greetProxyAsyncMethod = new StubMethodDescriptor("greetAsync", + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.class, MethodDescriptor.RpcType.UNARY, + obj -> ((Message) obj).toByteArray(), obj -> ((Message) obj).toByteArray(), org.apache.dubbo.springboot.demo.idl.GreeterRequest::parseFrom, + org.apache.dubbo.springboot.demo.idl.GreeterReply::parseFrom); + + + + + static{ + serviceDescriptor.addMethod(greetMethod); + serviceDescriptor.addMethod(greetProxyAsyncMethod); + } + + public static class GreeterStub implements Greeter, Destroyable { + private final Invoker invoker; + + public GreeterStub(Invoker invoker) { + this.invoker = invoker; + } + + @Override + public void $destroy() { + invoker.destroy(); + } + + @Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + return StubInvocationUtil.unaryCall(invoker, greetMethod, request); + } + + public CompletableFuture greetAsync(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + return StubInvocationUtil.unaryCall(invoker, greetAsyncMethod, request); + } + + public void greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request, StreamObserver responseObserver){ + StubInvocationUtil.unaryCall(invoker, greetMethod , request, responseObserver); + } + + + + } + + public static abstract class GreeterImplBase implements Greeter, ServerService { + + private BiConsumer> syncToAsync(java.util.function.Function syncFun) { + return new BiConsumer>() { + @Override + public void accept(T t, StreamObserver observer) { + try { + R ret = syncFun.apply(t); + observer.onNext(ret); + observer.onCompleted(); + } catch (Throwable e) { + observer.onError(e); + } + } + }; + } + + @Override + public CompletableFuture greetAsync(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + return CompletableFuture.completedFuture(greet(request)); + } + + /** + * This server stream type unary method is only used for generated stub to support async unary method. + * It will not be called if you are NOT using Dubbo3 generated triple stub and DO NOT implement this method. + */ + public void greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request, StreamObserver responseObserver){ + greetAsync(request).whenComplete((r, t) -> { + if (t != null) { + responseObserver.onError(t); + } else { + responseObserver.onNext(r); + responseObserver.onCompleted(); + } + }); + } + + @Override + public final Invoker getInvoker(URL url) { + PathResolver pathResolver = url.getOrDefaultFrameworkModel() + .getExtensionLoader(PathResolver.class) + .getDefaultExtension(); + Map> handlers = new HashMap<>(); + + pathResolver.addNativeStub( "/" + SERVICE_NAME + "/greet"); + pathResolver.addNativeStub( "/" + SERVICE_NAME + "/greetAsync"); + // for compatibility + pathResolver.addNativeStub( "/" + JAVA_SERVICE_NAME + "/greet"); + pathResolver.addNativeStub( "/" + JAVA_SERVICE_NAME + "/greetAsync"); + + + BiConsumer> greetFunc = this::greet; + handlers.put(greetMethod.getMethodName(), new UnaryStubMethodHandler<>(greetFunc)); + BiConsumer> greetAsyncFunc = syncToAsync(this::greet); + handlers.put(greetProxyAsyncMethod.getMethodName(), new UnaryStubMethodHandler<>(greetAsyncFunc)); + + + + + return new StubInvoker<>(this, url, Greeter.class, handlers); + } + + + @Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request){ + throw unimplementedMethodException(greetMethod); + } + + + + + + @Override + public final ServiceDescriptor getServiceDescriptor() { + return serviceDescriptor; + } + private RpcException unimplementedMethodException(StubMethodDescriptor methodDescriptor) { + return TriRpcStatus.UNIMPLEMENTED.withDescription(String.format("Method %s is unimplemented", + "/" + serviceDescriptor.getInterfaceName() + "/" + methodDescriptor.getMethodName())).asException(); + } + } + +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/Greeter.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/Greeter.java new file mode 100644 index 0000000000..e5fdddd7c2 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/Greeter.java @@ -0,0 +1,43 @@ +/* +* 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.springboot.demo.idl; + +import org.apache.dubbo.common.stream.StreamObserver; +import com.google.protobuf.Message; + +import java.util.HashMap; +import java.util.Map; +import java.util.function.BiConsumer; +import java.util.concurrent.CompletableFuture; + +public interface Greeter extends org.apache.dubbo.rpc.model.DubboStub { + + String JAVA_SERVICE_NAME = "org.apache.dubbo.springboot.demo.idl.Greeter"; + String SERVICE_NAME = "idl.Greeter"; + org.apache.dubbo.springboot.demo.idl.GreeterReply greet(org.apache.dubbo.springboot.demo.idl.GreeterRequest request); + + CompletableFuture greetAsync(org.apache.dubbo.springboot.demo.idl.GreeterRequest request); + + + + + + + + +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterOuterClass.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterOuterClass.java new file mode 100644 index 0000000000..14d39dd215 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterOuterClass.java @@ -0,0 +1,61 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +public final class GreeterOuterClass { + private GreeterOuterClass() {} + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistryLite registry) { + } + + public static void registerAllExtensions( + com.google.protobuf.ExtensionRegistry registry) { + registerAllExtensions( + (com.google.protobuf.ExtensionRegistryLite) registry); + } + static final com.google.protobuf.Descriptors.Descriptor + internal_static_idl_GreeterRequest_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_idl_GreeterRequest_fieldAccessorTable; + static final com.google.protobuf.Descriptors.Descriptor + internal_static_idl_GreeterReply_descriptor; + static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_idl_GreeterReply_fieldAccessorTable; + + public static com.google.protobuf.Descriptors.FileDescriptor + getDescriptor() { + return descriptor; + } + private static com.google.protobuf.Descriptors.FileDescriptor + descriptor; + static { + java.lang.String[] descriptorData = { + "\n\rgreeter.proto\022\003idl\"\036\n\016GreeterRequest\022\014" + + "\n\004name\030\001 \001(\t\"\037\n\014GreeterReply\022\017\n\007message\030" + + "\001 \001(\t2:\n\007Greeter\022/\n\005greet\022\023.idl.GreeterR" + + "equest\032\021.idl.GreeterReplyB(\n$org.apache." + + "dubbo.springboot.demo.idlP\001b\006proto3" + }; + descriptor = com.google.protobuf.Descriptors.FileDescriptor + .internalBuildGeneratedFileFrom(descriptorData, + new com.google.protobuf.Descriptors.FileDescriptor[] { + }); + internal_static_idl_GreeterRequest_descriptor = + getDescriptor().getMessageTypes().get(0); + internal_static_idl_GreeterRequest_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_idl_GreeterRequest_descriptor, + new java.lang.String[] { "Name", }); + internal_static_idl_GreeterReply_descriptor = + getDescriptor().getMessageTypes().get(1); + internal_static_idl_GreeterReply_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_idl_GreeterReply_descriptor, + new java.lang.String[] { "Message", }); + } + + // @@protoc_insertion_point(outer_class_scope) +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReply.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReply.java new file mode 100644 index 0000000000..cc0a8bdf2d --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReply.java @@ -0,0 +1,507 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +/** + * Protobuf type {@code idl.GreeterReply} + */ +public final class GreeterReply extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:idl.GreeterReply) + GreeterReplyOrBuilder { +private static final long serialVersionUID = 0L; + // Use GreeterReply.newBuilder() to construct. + private GreeterReply(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private GreeterReply() { + message_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new GreeterReply(); + } + + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterReply.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.Builder.class); + } + + public static final int MESSAGE_FIELD_NUMBER = 1; + @SuppressWarnings("serial") + private volatile java.lang.Object message_ = ""; + /** + * string message = 1; + * @return The message. + */ + @java.lang.Override + public java.lang.String getMessage() { + java.lang.Object ref = message_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + message_ = s; + return s; + } + } + /** + * string message = 1; + * @return The bytes for message. + */ + @java.lang.Override + public com.google.protobuf.ByteString + getMessageBytes() { + java.lang.Object ref = message_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + message_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(message_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, message_); + } + getUnknownFields().writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(message_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, message_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof org.apache.dubbo.springboot.demo.idl.GreeterReply)) { + return super.equals(obj); + } + org.apache.dubbo.springboot.demo.idl.GreeterReply other = (org.apache.dubbo.springboot.demo.idl.GreeterReply) obj; + + if (!getMessage() + .equals(other.getMessage())) return false; + if (!getUnknownFields().equals(other.getUnknownFields())) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + MESSAGE_FIELD_NUMBER; + hash = (53 * hash) + getMessage().hashCode(); + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterReply parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(org.apache.dubbo.springboot.demo.idl.GreeterReply prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code idl.GreeterReply} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:idl.GreeterReply) + org.apache.dubbo.springboot.demo.idl.GreeterReplyOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterReply.class, org.apache.dubbo.springboot.demo.idl.GreeterReply.Builder.class); + } + + // Construct using org.apache.dubbo.springboot.demo.idl.GreeterReply.newBuilder() + private Builder() { + + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + + } + @java.lang.Override + public Builder clear() { + super.clear(); + bitField0_ = 0; + message_ = ""; + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterReply_descriptor; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply getDefaultInstanceForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterReply.getDefaultInstance(); + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply build() { + org.apache.dubbo.springboot.demo.idl.GreeterReply result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply buildPartial() { + org.apache.dubbo.springboot.demo.idl.GreeterReply result = new org.apache.dubbo.springboot.demo.idl.GreeterReply(this); + if (bitField0_ != 0) { buildPartial0(result); } + onBuilt(); + return result; + } + + private void buildPartial0(org.apache.dubbo.springboot.demo.idl.GreeterReply result) { + int from_bitField0_ = bitField0_; + if (((from_bitField0_ & 0x00000001) != 0)) { + result.message_ = message_; + } + } + + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.dubbo.springboot.demo.idl.GreeterReply) { + return mergeFrom((org.apache.dubbo.springboot.demo.idl.GreeterReply)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.dubbo.springboot.demo.idl.GreeterReply other) { + if (other == org.apache.dubbo.springboot.demo.idl.GreeterReply.getDefaultInstance()) return this; + if (!other.getMessage().isEmpty()) { + message_ = other.message_; + bitField0_ |= 0x00000001; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + message_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000001; + break; + } // case 10 + default: { + if (!super.parseUnknownField(input, extensionRegistry, tag)) { + done = true; // was an endgroup tag + } + break; + } // default: + } // switch (tag) + } // while (!done) + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.unwrapIOException(); + } finally { + onChanged(); + } // finally + return this; + } + private int bitField0_; + + private java.lang.Object message_ = ""; + /** + * string message = 1; + * @return The message. + */ + public java.lang.String getMessage() { + java.lang.Object ref = message_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + message_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string message = 1; + * @return The bytes for message. + */ + public com.google.protobuf.ByteString + getMessageBytes() { + java.lang.Object ref = message_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + message_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string message = 1; + * @param value The message to set. + * @return This builder for chaining. + */ + public Builder setMessage( + java.lang.String value) { + if (value == null) { throw new NullPointerException(); } + message_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + /** + * string message = 1; + * @return This builder for chaining. + */ + public Builder clearMessage() { + message_ = getDefaultInstance().getMessage(); + bitField0_ = (bitField0_ & ~0x00000001); + onChanged(); + return this; + } + /** + * string message = 1; + * @param value The bytes for message to set. + * @return This builder for chaining. + */ + public Builder setMessageBytes( + com.google.protobuf.ByteString value) { + if (value == null) { throw new NullPointerException(); } + checkByteStringIsUtf8(value); + message_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:idl.GreeterReply) + } + + // @@protoc_insertion_point(class_scope:idl.GreeterReply) + private static final org.apache.dubbo.springboot.demo.idl.GreeterReply DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new org.apache.dubbo.springboot.demo.idl.GreeterReply(); + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterReply getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public GreeterReply parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + Builder builder = newBuilder(); + try { + builder.mergeFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(builder.buildPartial()); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException(e) + .setUnfinishedMessage(builder.buildPartial()); + } + return builder.buildPartial(); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterReply getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReplyOrBuilder.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReplyOrBuilder.java new file mode 100644 index 0000000000..d0e0ee803a --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterReplyOrBuilder.java @@ -0,0 +1,21 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +public interface GreeterReplyOrBuilder extends + // @@protoc_insertion_point(interface_extends:idl.GreeterReply) + com.google.protobuf.MessageOrBuilder { + + /** + * string message = 1; + * @return The message. + */ + java.lang.String getMessage(); + /** + * string message = 1; + * @return The bytes for message. + */ + com.google.protobuf.ByteString + getMessageBytes(); +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequest.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequest.java new file mode 100644 index 0000000000..bb89150fc1 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequest.java @@ -0,0 +1,507 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +/** + * Protobuf type {@code idl.GreeterRequest} + */ +public final class GreeterRequest extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:idl.GreeterRequest) + GreeterRequestOrBuilder { +private static final long serialVersionUID = 0L; + // Use GreeterRequest.newBuilder() to construct. + private GreeterRequest(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private GreeterRequest() { + name_ = ""; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance( + UnusedPrivateParameter unused) { + return new GreeterRequest(); + } + + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterRequest.Builder.class); + } + + public static final int NAME_FIELD_NUMBER = 1; + @SuppressWarnings("serial") + private volatile java.lang.Object name_ = ""; + /** + * string name = 1; + * @return The name. + */ + @java.lang.Override + public java.lang.String getName() { + java.lang.Object ref = name_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + name_ = s; + return s; + } + } + /** + * string name = 1; + * @return The bytes for name. + */ + @java.lang.Override + public com.google.protobuf.ByteString + getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(name_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 1, name_); + } + getUnknownFields().writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(name_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, name_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof org.apache.dubbo.springboot.demo.idl.GreeterRequest)) { + return super.equals(obj); + } + org.apache.dubbo.springboot.demo.idl.GreeterRequest other = (org.apache.dubbo.springboot.demo.idl.GreeterRequest) obj; + + if (!getName() + .equals(other.getName())) return false; + if (!getUnknownFields().equals(other.getUnknownFields())) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + NAME_FIELD_NUMBER; + hash = (53 * hash) + getName().hashCode(); + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + java.nio.ByteBuffer data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseDelimitedWithIOException(PARSER, input, extensionRegistry); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input); + } + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3 + .parseWithIOException(PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + public static Builder newBuilder(org.apache.dubbo.springboot.demo.idl.GreeterRequest prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE + ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code idl.GreeterRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder implements + // @@protoc_insertion_point(builder_implements:idl.GreeterRequest) + org.apache.dubbo.springboot.demo.idl.GreeterRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.dubbo.springboot.demo.idl.GreeterRequest.class, org.apache.dubbo.springboot.demo.idl.GreeterRequest.Builder.class); + } + + // Construct using org.apache.dubbo.springboot.demo.idl.GreeterRequest.newBuilder() + private Builder() { + + } + + private Builder( + com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + + } + @java.lang.Override + public Builder clear() { + super.clear(); + bitField0_ = 0; + name_ = ""; + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterOuterClass.internal_static_idl_GreeterRequest_descriptor; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest getDefaultInstanceForType() { + return org.apache.dubbo.springboot.demo.idl.GreeterRequest.getDefaultInstance(); + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest build() { + org.apache.dubbo.springboot.demo.idl.GreeterRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest buildPartial() { + org.apache.dubbo.springboot.demo.idl.GreeterRequest result = new org.apache.dubbo.springboot.demo.idl.GreeterRequest(this); + if (bitField0_ != 0) { buildPartial0(result); } + onBuilt(); + return result; + } + + private void buildPartial0(org.apache.dubbo.springboot.demo.idl.GreeterRequest result) { + int from_bitField0_ = bitField0_; + if (((from_bitField0_ & 0x00000001) != 0)) { + result.name_ = name_; + } + } + + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.dubbo.springboot.demo.idl.GreeterRequest) { + return mergeFrom((org.apache.dubbo.springboot.demo.idl.GreeterRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.dubbo.springboot.demo.idl.GreeterRequest other) { + if (other == org.apache.dubbo.springboot.demo.idl.GreeterRequest.getDefaultInstance()) return this; + if (!other.getName().isEmpty()) { + name_ = other.name_; + bitField0_ |= 0x00000001; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + name_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000001; + break; + } // case 10 + default: { + if (!super.parseUnknownField(input, extensionRegistry, tag)) { + done = true; // was an endgroup tag + } + break; + } // default: + } // switch (tag) + } // while (!done) + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.unwrapIOException(); + } finally { + onChanged(); + } // finally + return this; + } + private int bitField0_; + + private java.lang.Object name_ = ""; + /** + * string name = 1; + * @return The name. + */ + public java.lang.String getName() { + java.lang.Object ref = name_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + name_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * string name = 1; + * @return The bytes for name. + */ + public com.google.protobuf.ByteString + getNameBytes() { + java.lang.Object ref = name_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + name_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * string name = 1; + * @param value The name to set. + * @return This builder for chaining. + */ + public Builder setName( + java.lang.String value) { + if (value == null) { throw new NullPointerException(); } + name_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + /** + * string name = 1; + * @return This builder for chaining. + */ + public Builder clearName() { + name_ = getDefaultInstance().getName(); + bitField0_ = (bitField0_ & ~0x00000001); + onChanged(); + return this; + } + /** + * string name = 1; + * @param value The bytes for name to set. + * @return This builder for chaining. + */ + public Builder setNameBytes( + com.google.protobuf.ByteString value) { + if (value == null) { throw new NullPointerException(); } + checkByteStringIsUtf8(value); + name_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + @java.lang.Override + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + + // @@protoc_insertion_point(builder_scope:idl.GreeterRequest) + } + + // @@protoc_insertion_point(class_scope:idl.GreeterRequest) + private static final org.apache.dubbo.springboot.demo.idl.GreeterRequest DEFAULT_INSTANCE; + static { + DEFAULT_INSTANCE = new org.apache.dubbo.springboot.demo.idl.GreeterRequest(); + } + + public static org.apache.dubbo.springboot.demo.idl.GreeterRequest getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser + PARSER = new com.google.protobuf.AbstractParser() { + @java.lang.Override + public GreeterRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + Builder builder = newBuilder(); + try { + builder.mergeFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(builder.buildPartial()); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException(e) + .setUnfinishedMessage(builder.buildPartial()); + } + return builder.buildPartial(); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public org.apache.dubbo.springboot.demo.idl.GreeterRequest getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } + +} + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequestOrBuilder.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequestOrBuilder.java new file mode 100644 index 0000000000..6bca5d24cd --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/build/generated/source/proto/main/java/org/apache/dubbo/springboot/demo/idl/GreeterRequestOrBuilder.java @@ -0,0 +1,21 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: greeter.proto + +package org.apache.dubbo.springboot.demo.idl; + +public interface GreeterRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:idl.GreeterRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * string name = 1; + * @return The name. + */ + java.lang.String getName(); + /** + * string name = 1; + * @return The bytes for name. + */ + com.google.protobuf.ByteString + getNameBytes(); +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/pom.xml b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/pom.xml new file mode 100644 index 0000000000..7089254644 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/pom.xml @@ -0,0 +1,124 @@ + + + + dubbo-samples-spring-boot-idl-diff-package + org.apache.dubbo + 1.0-SNAPSHOT + ../pom.xml + + 4.0.0 + + dubbo-samples-spring-boot-idl-diff-package-provider + + + + + org.apache.dubbo + dubbo-spring-boot-starter + + + org.apache.dubbo + dubbo-nacos-spring-boot-starter + + + + + org.springframework.boot + spring-boot-starter + + + org.springframework.boot + spring-boot-starter-log4j2 + + + + + com.google.protobuf + protobuf-java + ${protobuf-java.version} + + + com.google.protobuf + protobuf-java-util + ${protobuf-java.version} + + + + + + + kr.motd.maven + os-maven-plugin + 1.6.1 + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + org.xolstice.maven.plugins + protobuf-maven-plugin + 0.6.1 + + com.google.protobuf:protoc:${protoc.version}:exe:${os.detected.classifier} + build/generated/source/proto/main/java + + + dubbo + org.apache.dubbo + dubbo-compiler + ${dubbo.version} + org.apache.dubbo.gen.tri.Dubbo3TripleGenerator + + + + + + + compile + + + + + + + org.codehaus.mojo + build-helper-maven-plugin + 3.3.0 + + + generate-sources + + add-source + + + + build/generated/source/proto/main/java + + + + + + + + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/java/org/apache/dubbo/springboot/demo/provider/ProviderApplication.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/java/org/apache/dubbo/springboot/demo/provider/ProviderApplication.java new file mode 100644 index 0000000000..279d4a9174 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/java/org/apache/dubbo/springboot/demo/provider/ProviderApplication.java @@ -0,0 +1,33 @@ +/* + * 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.springboot.demo.provider; + + +import org.apache.dubbo.common.constants.CommonConstants; +import org.apache.dubbo.config.spring.context.annotation.EnableDubbo; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +@EnableDubbo +public class ProviderApplication { + public static void main(String[] args) { + System.setProperty(CommonConstants.DubboProperty.DUBBO_PREFERRED_NETWORK_INTERFACE, "en0"); + SpringApplication.run(ProviderApplication.class, args); + } +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/java/org/apache/dubbo/springboot/demo/provider/dubbo/service/GreeterImpl.java b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/java/org/apache/dubbo/springboot/demo/provider/dubbo/service/GreeterImpl.java new file mode 100644 index 0000000000..1c0f8bd92f --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/java/org/apache/dubbo/springboot/demo/provider/dubbo/service/GreeterImpl.java @@ -0,0 +1,40 @@ +/* + * 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.springboot.demo.provider.dubbo.service; + +import org.apache.dubbo.springboot.demo.idl.DubboGreeterTriple.GreeterImplBase; +import org.apache.dubbo.springboot.demo.idl.GreeterReply; +import org.apache.dubbo.springboot.demo.idl.GreeterRequest; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import org.apache.dubbo.config.annotation.DubboService; + +@DubboService +public class GreeterImpl extends GreeterImplBase { + private static final Logger LOGGER = LoggerFactory.getLogger(GreeterImpl.class); + + @Override + public GreeterReply greet(GreeterRequest request) { + LOGGER.info("Server received greet request {}" , request); + return GreeterReply.newBuilder() + .setMessage("hello," + request.getName()) + .build(); + } + +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/proto/greeter.proto b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/proto/greeter.proto new file mode 100644 index 0000000000..2a82680ac4 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/proto/greeter.proto @@ -0,0 +1,21 @@ +syntax = "proto3"; + +option java_multiple_files = true; + +package idl; + +option java_package = "org.apache.dubbo.springboot.demo.idl"; + +message GreeterRequest { + string name = 1; +} + +message GreeterReply { + string message = 1; +} + +service Greeter{ + + rpc greet(GreeterRequest) returns (GreeterReply); + +} diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/resources/application.yml b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/resources/application.yml new file mode 100644 index 0000000000..6e27583373 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/resources/application.yml @@ -0,0 +1,28 @@ +# 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. + +dubbo: + application: + name: dubbo-springboot-demo-idl-diff-package-provider + logger: slf4j + enable-file-cache: false + metadata-type: remote + protocol: + name: tri + port: 50052 + registry: + address: nacos://${nacos.address:127.0.0.1}:8848?username=nacos&password=nacos + register-mode: instance diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/resources/log4j2.xml b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/resources/log4j2.xml new file mode 100644 index 0000000000..01ab6d5bba --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/dubbo-samples-spring-boot-idl-diff-package-provider/src/main/resources/log4j2.xml @@ -0,0 +1,34 @@ + + + + + + + + + + + + + + + + + + + diff --git a/1-basic/dubbo-samples-spring-boot-idl-diff-package/pom.xml b/1-basic/dubbo-samples-spring-boot-idl-diff-package/pom.xml new file mode 100644 index 0000000000..6aca60fcf3 --- /dev/null +++ b/1-basic/dubbo-samples-spring-boot-idl-diff-package/pom.xml @@ -0,0 +1,121 @@ + + + + + + org.apache + apache + 31 + + + 4.0.0 + + org.apache.dubbo + dubbo-samples-spring-boot-idl-diff-package + 1.0-SNAPSHOT + pom + + Dubbo Samples Spring Boot IDL Diff Package + Dubbo Samples Spring Boot IDL Diff Package + + + 17 + 17 + UTF-8 + + 3.3.4 + 3.2.3 + 3.19.6 + 3.22.3 + + + + dubbo-samples-spring-boot-idl-diff-package-provider + dubbo-samples-spring-boot-idl-diff-package-consumer + + + + + + org.springframework.boot + spring-boot-dependencies + ${spring-boot.version} + pom + import + + + org.springframework.boot + spring-boot-starter + ${spring-boot.version} + + + spring-boot-starter-logging + org.springframework.boot + + + + + org.apache.dubbo + dubbo-bom + ${dubbo.version} + pom + import + + + + + + + junit + junit + test + + + + + + + org.apache.maven.plugins + maven-compiler-plugin + + + -proc:none + + + + + + + + org.springframework.boot + spring-boot-maven-plugin + ${spring-boot.version} + + + + repackage + + + + + + + + diff --git a/1-basic/pom.xml b/1-basic/pom.xml index bd1e8debdd..0b70816a93 100644 --- a/1-basic/pom.xml +++ b/1-basic/pom.xml @@ -31,5 +31,6 @@ dubbo-samples-api-idl dubbo-samples-spring-boot dubbo-samples-spring-boot-idl + dubbo-samples-spring-boot-idl-diff-package