apache#4

Author: panxiaojun233

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2FrameListener.java

@@ -65,9 +65,13 @@ public int onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int
         int processed = data.readableBytes() + padding;
         if (endOfStream) {
             Invocation invocation = buildInvocation(request.getHeaders(), request.getData());
+            final String path = request.getHeaders().path().toString();
+            String[] parts = path.split("/");
+            // todo parts illegal service not found
+            String serviceName = parts[1];
             // TODO add version/group support
             //TODO add method not found / service not found err
-            Result result = serviceContainer.resolve("io.grpc.examples.helloworld.IGreeter").invoke(invocation);
+            Result result = serviceContainer.resolve(serviceName).invoke(invocation);
             CompletionStage<Object> future = result.thenApply(Function.identity());
 
             future.whenComplete((appResult, t) -> {
@@ -103,9 +107,11 @@ private Invocation buildInvocation(Http2Headers http2Headers, ByteBuf data) {
         RpcInvocation inv = new RpcInvocation();
         final String path = http2Headers.path().toString();
         String[] parts = path.split("/");
-        // todo
-        String serviceName = "io.grpc.examples.helloworld.IGreeter";
-        String methodName = "sayHello";
+        // todo parts illegal service not found
+        String serviceName = parts[1];
+        String originalMethodName = parts[2];
+        String methodName = originalMethodName.substring(0,1).toLowerCase().concat(originalMethodName.substring(1));
+
         ServiceRepository repo = ApplicationModel.getServiceRepository();
         MethodDescriptor methodDescriptor = repo.lookupMethod(serviceName, methodName);
         Object obj = Marshaller.marshaller.unmarshaller(methodDescriptor.getParameterClasses()[0], data);