fix: triple reflection

pkg/common/service.go

@@ -30,6 +30,11 @@ type TripleGrpcService interface {
 	XXX_ServiceDesc() *grpc.ServiceDesc
 }
 
+// TripleGrpcReflectService is gRPC service, used to check impl
+type TripleGrpcReflectService interface {
+	SetGRPCServer(s *grpc.Server)
+}
+
 // TripleUnaryService is normal protocol service (except grpc service), should be implemented by users
 type TripleUnaryService interface {
 	InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error)

pkg/triple/dubbo3_server.go

@@ -34,7 +34,6 @@ import (
 	"github.com/dubbogo/grpc-go/encoding/msgpack"
 	"github.com/dubbogo/grpc-go/encoding/proto_wrapper_api"
 	"github.com/dubbogo/grpc-go/encoding/raw_proto"
-
 	perrors "github.com/pkg/errors"
 )
 
@@ -238,10 +237,13 @@ func (t *TripleServer) Start() {
 			desc := grpcService.XXX_ServiceDesc()
 			desc.ServiceName = key.(string)
 			grpcServer.RegisterService(desc, value)
-			return true
+		} else {
+			desc := createGrpcDesc(key.(string), value.(common.TripleUnaryService))
+			grpcServer.RegisterService(desc, value)
+		}
+		if key == "grpc.reflection.v1alpha.ServerReflection" {
+			grpcService.(common.TripleGrpcReflectService).SetGRPCServer(grpcServer)
 		}
-		desc := createGrpcDesc(key.(string), value.(common.TripleUnaryService))
-		grpcServer.RegisterService(desc, value)
 		return true
 	})
 
@@ -263,6 +265,9 @@ func (t *TripleServer) RefreshService() {
 			desc := createGrpcDesc(key.(string), value.(common.TripleUnaryService))
 			grpcServer.RegisterService(desc, value)
 		}
+		if key == "grpc.reflection.v1alpha.ServerReflection" {
+			grpcService.(common.TripleGrpcReflectService).SetGRPCServer(grpcServer)
+		}
 		return true
 	})
 	t.grpcServer.Stop()