ftr: triple multi params support

go.mod

@@ -12,7 +12,7 @@ require (
 	github.com/creasty/defaults v1.5.1
 	github.com/dubbogo/go-zookeeper v1.0.3
 	github.com/dubbogo/gost v1.11.14
-	github.com/dubbogo/triple v1.0.1
+	github.com/dubbogo/triple v1.0.2
 	github.com/emicklei/go-restful/v3 v3.4.0
 	github.com/frankban/quicktest v1.4.1 // indirect
 	github.com/fsnotify/fsnotify v1.4.9

go.sum

@@ -133,8 +133,8 @@ github.com/dubbogo/gost v1.11.14/go.mod h1:vIcP9rqz2KsXHPjsAwIUtfJIJjppQLQDcYaZT
 github.com/dubbogo/jsonparser v1.0.1/go.mod h1:tYAtpctvSP/tWw4MeelsowSPgXQRVHHWbqL6ynps8jU=
 github.com/dubbogo/net v0.0.3 h1:2k53mh+1U8h1gFjJ8ykzyP4wNdAdgjc5moD+xVHI/AE=
 github.com/dubbogo/net v0.0.3/go.mod h1:B6/ka3g8VzcyrmdCH4VkHP1K0aHeI37FmclS+TCwIBU=
-github.com/dubbogo/triple v1.0.1 h1:fdBkXTR0I4UBBCDcN+k22uJWU338ZK5mvOPpIBIL5h8=
-github.com/dubbogo/triple v1.0.1/go.mod h1:O6vQD2XLCWugzAk0P27HTW4+Uhkd8sjaQn0BZijdGzU=
+github.com/dubbogo/triple v1.0.2 h1:+QKw6XbTyHP4yqUQ4gXRvV1FbhJZ7ldl9WrN0AjmCPM=
+github.com/dubbogo/triple v1.0.2/go.mod h1:O6vQD2XLCWugzAk0P27HTW4+Uhkd8sjaQn0BZijdGzU=
 github.com/dustin/go-humanize v0.0.0-20171111073723-bb3d318650d4/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
 github.com/dustin/go-humanize v1.0.0 h1:VSnTsYCnlFHaM2/igO1h6X3HA71jcobQuxemgkq4zYo=
 github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=

protocol/dubbo3/dubbo3_protocol.go

@@ -99,18 +99,18 @@ func (dp *DubboProtocol) Export(invoker protocol.Invoker) protocol.Exporter {
 		valueOf := reflect.ValueOf(service)
 		typeOf := valueOf.Type()
 		numField := valueOf.NumMethod()
-		tripleService := &Dubbo3HessianService{proxyImpl: invoker}
+		tripleService := &UnaryService{proxyImpl: invoker}
 		for i := 0; i < numField; i++ {
 			ft := typeOf.Method(i)
 			if ft.Name == "Reference" {
 				continue
 			}
-			// num out is checked in common/rpc_service.go
-			if ft.Type.NumIn() != 3 {
-				panic(fmt.Sprintf("function %s input params num = %d not supported, which should be 2", ft.Name, ft.Type.NumIn()-1))
+			// get all method params type
+			typs := make([]reflect.Type, 0)
+			for j := 2; j < ft.Type.NumIn(); j++ {
+				typs = append(typs, ft.Type.In(j))
 			}
-			typ := ft.Type.In(2)
-			tripleService.setReqParamsInterface(ft.Name, typ)
+			tripleService.setReqParamsTypes(ft.Name, typs)
 		}
 		service = tripleService
 		triSerializationType = tripleConstant.CodecType(serializationType)
@@ -164,25 +164,29 @@ type Dubbo3GrpcService interface {
 	ServiceDesc() *grpc.ServiceDesc
 }
 
-type Dubbo3HessianService struct {
+type UnaryService struct {
 	proxyImpl  protocol.Invoker
 	reqTypeMap sync.Map
 }
 
-func (d *Dubbo3HessianService) setReqParamsInterface(methodName string, typ reflect.Type) {
+func (d *UnaryService) setReqParamsTypes(methodName string, typ []reflect.Type) {
 	d.reqTypeMap.Store(methodName, typ)
 }
 
-func (d *Dubbo3HessianService) GetReqParamsInteface(methodName string) (interface{}, bool) {
+func (d *UnaryService) GetReqParamsInterfaces(methodName string) ([]interface{}, bool) {
 	val, ok := d.reqTypeMap.Load(methodName)
 	if !ok {
 		return nil, false
 	}
-	typ := val.(reflect.Type)
-	return reflect.New(typ).Interface(), true
+	typs := val.([]reflect.Type)
+	reqParamsInterfaces := make([]interface{}, 0, len(typs))
+	for _, typ := range typs {
+		reqParamsInterfaces = append(reqParamsInterfaces, reflect.New(typ).Interface())
+	}
+	return reqParamsInterfaces, true
 }
 
-func (d *Dubbo3HessianService) InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error) {
+func (d *UnaryService) InvokeWithArgs(ctx context.Context, methodName string, arguments []interface{}) (interface{}, error) {
 	res := d.proxyImpl.Invoke(ctx, invocation.NewRPCInvocation(methodName, arguments, nil))
 	return res.Result(), res.Error()
 }

protocol/dubbo3/dubbo3_protocol_test.go

@@ -18,11 +18,14 @@
 package dubbo3
 
 import (
+	"context"
+	"reflect"
 	"testing"
 	"time"
 )
 
 import (
+	hessian "github.com/apache/dubbo-go-hessian2"
 	"github.com/stretchr/testify/assert"
 )
 
@@ -85,3 +88,63 @@ func TestDubboProtocolRefer(t *testing.T) {
 	invokersLen = len(proto.(*DubboProtocol).Invokers())
 	assert.Equal(t, 0, invokersLen)
 }
+
+type MockUser struct {
+	Name string
+}
+
+func (m *MockUser) JavaClassName() string {
+	return "mockuser"
+}
+
+type MockService struct {
+}
+
+func (m *MockService) GetUser(ctx context.Context, user, user2 *MockUser) (*MockUser, error) {
+	return user, nil
+}
+
+func TestDubbo3UnaryService_GetReqParamsInterfaces(t *testing.T) {
+	hessian.RegisterPOJO(&MockUser{})
+	srv := UnaryService{}
+	valueOf := reflect.ValueOf(&MockService{})
+	typeOf := valueOf.Type()
+	numField := valueOf.NumMethod()
+	for i := 0; i < numField; i++ {
+		ft := typeOf.Method(i)
+		// num in/out is checked in common/rpc_service.go
+		typs := make([]reflect.Type, 0)
+		for j := 2; j < ft.Type.NumIn(); j++ {
+			typs = append(typs, ft.Type.In(j))
+		}
+		srv.setReqParamsTypes("GetUser", typs)
+	}
+	paramsInterfaces, ok := srv.GetReqParamsInterfaces("GetUser")
+	assert.True(t, ok)
+	enc := hessian.NewEncoder()
+	err := enc.Encode(&MockUser{
+		Name: "laurence",
+	})
+	assert.Nil(t, err)
+	data := enc.Buffer()
+	decoder := hessian.NewDecoder(data)
+	val, err := decoder.Decode()
+	assert.Nil(t, err)
+	assert.Equal(t, 2, len(paramsInterfaces))
+	subTest(t, val, paramsInterfaces)
+	args := make([]interface{}, 0, 1)
+	for _, v := range paramsInterfaces {
+		tempParamObj := reflect.ValueOf(v).Elem().Interface()
+		args = append(args, tempParamObj)
+	}
+	assert.Equal(t, "laurence", args[0].(*MockUser).Name)
+	assert.Equal(t, "laurence", args[1].(*MockUser).Name)
+}
+
+func subTest(t *testing.T, val, paramsInterfaces interface{}) {
+	list := paramsInterfaces.([]interface{})
+	for k, _ := range list {
+		err := hessian.ReflectResponse(val, list[k])
+		assert.Nil(t, err)
+	}
+}