This is an automated email from the ASF dual-hosted git repository. ztelur pushed a commit to branch tmp/dubbo2http in repository https://gitbox.apache.org/repos/asf/dubbo-go-samples.git
commit 00519fa7319d36f92a90c101124da8b59b8e4ec4 Author: Randy <[email protected]> AuthorDate: Thu Dec 16 19:40:30 2021 +0800 update for test pixiu --- .run/generic-default-go-client.run.xml | 14 -------- generic/default/go-client/cmd/client.go | 60 ++------------------------------- 2 files changed, 3 insertions(+), 71 deletions(-) diff --git a/.run/generic-default-go-client.run.xml b/.run/generic-default-go-client.run.xml deleted file mode 100644 index 1d1006f..0000000 --- a/.run/generic-default-go-client.run.xml +++ /dev/null @@ -1,14 +0,0 @@ -<component name="ProjectRunConfigurationManager"> - <configuration default="false" name="generic-default-go-client" type="GoApplicationRunConfiguration" factoryName="Go Application" folderName="generic"> - <module name="dubbo-go-samples" /> - <working_directory value="$PROJECT_DIR$" /> - <envs> - <env name="DUBBO_GO_CONFIG_PATH" value="$PROJECT_DIR$/generic/default/go-client/conf/dubbogo.yml" /> - </envs> - <kind value="PACKAGE" /> - <package value="github.com/apache/dubbo-go-samples/generic/default/go-client/cmd" /> - <directory value="$PROJECT_DIR$/generic/default/go-client/cmd" /> - <filePath value="$PROJECT_DIR$/generic/default/go-client/cmd/client.go" /> - <method v="2" /> - </configuration> -</component> \ No newline at end of file diff --git a/generic/default/go-client/cmd/client.go b/generic/default/go-client/cmd/client.go index bbb14a3..ad36c2d 100644 --- a/generic/default/go-client/cmd/client.go +++ b/generic/default/go-client/cmd/client.go @@ -30,8 +30,6 @@ import ( "dubbo.apache.org/dubbo-go/v3/protocol/dubbo" hessian "github.com/apache/dubbo-go-hessian2" - - tpconst "github.com/dubbogo/triple/pkg/common/constant" ) import ( @@ -48,22 +46,6 @@ func main() { // generic invocation samples using hessian serialization on Dubbo protocol dubboRefConf := newRefConf("org.apache.dubbo.samples.UserProvider", dubbo.DUBBO) callGetUser(dubboRefConf) - //callGetOneUser(dubboRefConf) - callGetUsers(dubboRefConf) - callGetUsersMap(dubboRefConf) - callQueryUser(dubboRefConf) - callQueryUsers(dubboRefConf) - //callQueryAll(dubboRefConf) - - // generic invocation samples using hessian serialization on Triple protocol - tripleRefConf := newRefConf("org.apache.dubbo.samples.UserProviderTriple", tpconst.TRIPLE) - callGetUser(tripleRefConf) - //callGetOneUser(tripleRefConf) - callGetUsers(tripleRefConf) - callGetUsersMap(tripleRefConf) - callQueryUser(tripleRefConf) - callQueryUsers(tripleRefConf) - //callQueryAll(tripleRefConf) } @@ -80,38 +62,6 @@ func callGetUser(refConf config.ReferenceConfig) { } logger.Infof("GetUser1(userId string) res: %+v", resp) - resp, err = refConf.GetRPCService().(*generic.GenericService).Invoke( - context.TODO(), - "GetUser2", - []string{"java.lang.String", "java.lang.String"}, - []hessian.Object{"A003", "lily"}, - ) - if err != nil { - panic(err) - } - logger.Infof("GetUser2(userId string, name string) res: %+v", resp) - - resp, err = refConf.GetRPCService().(*generic.GenericService).Invoke( - context.TODO(), - "GetUser3", - []string{"int"}, - []hessian.Object{1}, - ) - if err != nil { - panic(err) - } - logger.Infof("GetUser3(userCode int) res: %+v", resp) - - resp, err = refConf.GetRPCService().(*generic.GenericService).Invoke( - context.TODO(), - "GetUser4", - []string{"int", "java.lang.String"}, - []hessian.Object{1, "zhangsan"}, - ) - if err != nil { - panic(err) - } - logger.Infof("GetUser4(userCode int, name string) res: %+v", resp) } // nolint @@ -236,21 +186,17 @@ func callQueryAll(refConf config.ReferenceConfig) { } func newRefConf(iface, protocol string) config.ReferenceConfig { - registryConfig := &config.RegistryConfig{ - Protocol: "zookeeper", - Address: "127.0.0.1:2181", - } refConf := config.ReferenceConfig{ - InterfaceName: iface, + InterfaceName: "org.apache.dubbo.samples.UserProvider", Cluster: "failover", RegistryIDs: []string{"zk"}, - Protocol: protocol, + Protocol: dubbo.DUBBO, Generic: "true", + URL: "dubbo://127.0.0.1:8888/org.apache.dubbo.samples.UserProvider", } rootConfig := config.NewRootConfigBuilder(). - AddRegistry("zk", registryConfig). Build() if err := config.Load(config.WithRootConfig(rootConfig)); err != nil { panic(err)
