This is an automated email from the ASF dual-hosted git repository. marsevilspirit pushed a commit to branch revert-860-fix_ploaris_limit in repository https://gitbox.apache.org/repos/asf/dubbo-go-samples.git
commit e87ed6498dd0cf9b4a374b9b7267929f8d228297 Author: marsevilspirit <[email protected]> AuthorDate: Mon Jun 30 19:27:45 2025 +0800 Revert "impl: delete all polaris related content (#860)" This reverts commit 2bae17fefea2a0baa8f94fcb89a3254f6a3776d4. --- README.md | 2 +- README_CN.md | 2 +- compatibility/polaris/limit/README-zh.md | 91 ++++++++++++++++ compatibility/polaris/limit/README.md | 91 ++++++++++++++++ compatibility/polaris/limit/go-client/cmd/main.go | 84 ++++++++++++++ .../polaris/limit/go-client/conf/dubbogo.yml | 24 ++++ .../polaris/limit/go-server/cmd/server.go | 111 +++++++++++++++++++ .../polaris/limit/go-server/conf/dubbogo.yml | 29 +++++ .../limit/images/dubbogo-ratelimit-rule.png | Bin 0 -> 113890 bytes compatibility/polaris/registry/README-zh.md | 62 +++++++++++ compatibility/polaris/registry/README.md | 61 +++++++++++ .../polaris/registry/go-client/cmd/main.go | 81 ++++++++++++++ .../polaris/registry/go-client/conf/dubbogo.yml | 24 ++++ .../polaris/registry/go-server/cmd/server.go | 110 +++++++++++++++++++ .../polaris/registry/go-server/conf/dubbogo.yml | 27 +++++ compatibility/polaris/router/README-zh.md | 121 +++++++++++++++++++++ compatibility/polaris/router/README.md | 121 +++++++++++++++++++++ compatibility/polaris/router/go-client/cmd/main.go | 81 ++++++++++++++ .../polaris/router/go-client/conf/dubbogo.yaml | 25 +++++ .../router/go-server/server-dev/cmd/server.go | 111 +++++++++++++++++++ .../router/go-server/server-dev/conf/dubbogo.yaml | 28 +++++ .../router/go-server/server-pre/cmd/server.go | 111 +++++++++++++++++++ .../router/go-server/server-pre/conf/dubbogo.yaml | 28 +++++ .../router/go-server/server-prod/cmd/server.go | 111 +++++++++++++++++++ .../router/go-server/server-prod/conf/dubbogo.yaml | 28 +++++ .../router/images/dubbogo-route-rule-dev.png | Bin 0 -> 103117 bytes .../router/images/dubbogo-route-rule-pre.png | Bin 0 -> 102704 bytes .../router/images/dubbogo-route-rule-prod.png | Bin 0 -> 97770 bytes .../rpc/triple/tests/integration/main_test.go | 1 + .../limit/tests/integration/limit_test.go} | 38 +++---- .../limit}/tests/integration/main_test.go | 48 +++++--- .../registry}/tests/integration/main_test.go | 48 +++++--- .../registry/tests/integration/registry_test.go} | 36 +++--- integrate_test/dockercompose/docker-compose.yml | 12 ++ start_integrate_test.sh | 4 + 35 files changed, 1670 insertions(+), 81 deletions(-) diff --git a/README.md b/README.md index 45fbfd17..2273f61a 100644 --- a/README.md +++ b/README.md @@ -22,7 +22,7 @@ * compatibility/metrics: How to collect Dubbo-go Prometheus metrics * compatibility/otel: How to use OpenTelemetry as Dubbo-go tracing tool * compatibility/proxyless: Proxyless service mesh example for deploying Dubbo-go services on Kubernetes -* compatibility/registry: How to use etcd/nacos/zookeeper as Dubbo-go registry +* compatibility/registry: How to use etcd/nacos/polaris/zookeeper as Dubbo-go registry * compatibility/rpc: Dubbo protocol communication examples * compatibility/rpc/dubbo: Dubbo-go 3.0 RPC example between Java and Go * compatibility/rpc/grpc: Dubbo-go RPC example based on gRPC diff --git a/README_CN.md b/README_CN.md index 919728bc..45c98d11 100644 --- a/README_CN.md +++ b/README_CN.md @@ -18,7 +18,7 @@ * compatibility/metrics：Prometheus 指标采集示例 * compatibility/otel：OpenTelemetry 链路追踪示例 * compatibility/proxyless：Kubernetes 下 proxyless 服务网格示例 -* compatibility/registry：多种注册中心（etcd/nacos/zookeeper）用法 +* compatibility/registry：多种注册中心（etcd/nacos/polaris/zookeeper）用法 * compatibility/rpc：Dubbo 协议通信示例 * compatibility/rpc/dubbo：Dubbo-go 3.0 Java/Go 跨语言 RPC 示例 * compatibility/rpc/grpc：基于 gRPC 的 Dubbo-go RPC 示例 diff --git a/compatibility/polaris/limit/README-zh.md b/compatibility/polaris/limit/README-zh.md new file mode 100644 index 00000000..ea1cec86 --- /dev/null +++ b/compatibility/polaris/limit/README-zh.md @@ -0,0 +1,91 @@ +# Dubbo Go & Polaris TpsLimiter Example + +[English](README.md) | 中文 + +## 使用服务限流功能 + +在 dubbogo 中快速体验北极星的服务限流能力 + +## 北极星服务端安装 + +[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/) + +[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/) + +## 如何使用 + +[北极星服务限流使用文档](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E8%AE%BF%E9%97%AE%E9%99%90%E6%B5%81) + +### dubbogo.yaml 配置文件 + +在使用 PolarisMesh 的服务限流能力时，需要先启用 PolarisMesh 在 dubbogo 中的注册发现功能。 + +```yaml +dubbo: + registries: + polarisMesh: + protocol: polaris + address: ${北极星服务端IP}:8091 + namespace: ${北极星命名空间信息} + token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数 + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test + tps.limiter: polaris-limit # 配置 tps.limiter 为 polaris-limiter 即可 + +``` + +注意：PolarisMesh 的服务限流能力是工作在 Provider 侧的。 + +### 如何配置服务限流参数 + +dubbogo 中的 PolarisMesh TpsLimiter 扩展点实现，能够根据用户配置的限流规则，自动的从当前 RPC 调用上下文以及请求信息中识别出需要参与限流的请求标签信息 + + + +- 请求匹配规则为 **请求参数(QUERY)** + - 标签来源: RPC 调用中方法的入参，即 Invoaction.Arguments() + - 标签键规则 + - 方法仅有一个入参: param.$.${fieldName}, **param.** 为固定前缀，后面的表达式为标准的 JSONPath expressions，[参考文档](https://goessner.net/articles/JsonPath/) + - 方法有多个参数: param[${index}].$.${fieldName}, **param[${index}].** 为固定前缀，${index} 代表是方法入参中的第几个参数，下标起始位置从 0 开始；后面的表达式为标准的 JSONPath expressions，[参考文档](https://goessner.net/articles/JsonPath/) +- 请求匹配规则为 **请求头(HEADER)**: + - 标签来源: RPC 调用的额外标签信息，即 Invoaction.Attachments() + +### 运行服务提供者 + +进入 go-server 的 cmd 目录，执行以下命令 + +``` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml" + go run . +``` + +当看到以下日志时即表示 server 端启动成功 + +```log +INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service: +``` + + +### 运行服务调用者 + +进入 go-client 的 cmd 目录，执行以下命令 + + +``` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" + go run . +``` + +当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用 + +```log +INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092 +0800 CST} +``` + +当看到以下日志时即表示在 PolarisMesh 针对 go-server 配置的限流策略已生效 + +```log +ERROR handler/rejected_execution_handler_only_log.go:73 The invocation was rejected +``` diff --git a/compatibility/polaris/limit/README.md b/compatibility/polaris/limit/README.md new file mode 100644 index 00000000..11c2bb89 --- /dev/null +++ b/compatibility/polaris/limit/README.md @@ -0,0 +1,91 @@ +# Dubbo Go & Polaris TpsLimiter Example + +English | [中文](README-zh.md) + +## Use the service current limit function + +Quickly experience Polaris' service current limiting capabilities in dubbogo + +## Polaris server installation + +[Polaris Server Standalone Version Installation Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/) + +[Polaris Server Cluster Version Installation Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/) + +## how to use + +[Polaris Service Current Limitation Documentation](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E8%AE%BF%E9%97%AE%E9%99%90%E6%B5%81) + +### dubbogo.yaml configuration file + +When using PolarisMesh's service current limiting capability, you need to enable PolarisMesh's registration discovery function in dubbogo firstly. + +````yaml +dubbo: + registries: + polarisMesh: + protocol: polaris + address: ${Polaris server IP}:8091 + namespace: ${Polaris namespace information} + token: ${Polaris resource authentication token} # If the Polaris server has enabled authentication for the client, you need to configure this parameter + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test + tps.limiter: polaris-limit # Configure tps.limiter as polaris-limiter + +```` + +Note: The service current limiting capability of PolarisMesh works on the Provider side. + +### How to configure service current limit parameters + +The implementation of the PolarisMesh TpsLimiter extension point in dubbogo can automatically identify the request tag information that needs to participate in current limiting from the current RPC call context and request information according to the current limiting rules configured by the user. + + + +- The request matching rule is **Request parameter(QUERY)** + - Tag source: the input parameter of the method in the RPC call, namely Invoaction.Arguments() + - Tag key rules + - The method has only one input parameter: param.$.${fieldName}, **param.** is a fixed prefix, the following expressions are standard JSONPath expressions, [reference document](https://goessner.net/ articles/JsonPath/) + - The method has multiple parameters: param[${index}].$.${fieldName}, **param[${index}].** is a fixed prefix, ${index} represents the first parameter in the method parameter Several parameters, the starting position of the subscript starts from 0; the following expressions are standard JSONPath expressions, [reference document](https://goessner.net/articles/JsonPath/) +- The request matching rule is **request header (HEADER)**: + - Tag source: Additional tag information for RPC calls, i.e. Invoaction.Attachments() + +### Running the service provider + +Enter the cmd directory of go-server and execute the following command + +```` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" + go run . +```` + +When you see the following log, it means that the server side started successfully + +````log +INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service: +```` + + +### Run the service caller + +Enter the cmd directory of go-client and execute the following command + + +```` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" + go run . +```` + +When you see the following log, it means that go-client successfully discovered go-server and made an RPC call + +````log +INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092 +0800 CST} +```` + +When you see the following log, it means that the current limiting policy configured for go-server in PolarisMesh has taken effect + +````log +ERROR handler/rejected_execution_handler_only_log.go:73 The invocation was rejected +```` \ No newline at end of file diff --git a/compatibility/polaris/limit/go-client/cmd/main.go b/compatibility/polaris/limit/go-client/cmd/main.go new file mode 100644 index 00000000..4acd43cb --- /dev/null +++ b/compatibility/polaris/limit/go-client/cmd/main.go @@ -0,0 +1,84 @@ +/* + * 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 main + +import ( + "context" + "errors" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +type UserProviderWithCustomGroupAndVersion struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type UserProvider struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +func main() { + var userProvider = &UserProvider{} + var userProviderWithCustomRegistryGroupAndVersion = &UserProviderWithCustomGroupAndVersion{} + config.SetConsumerService(userProvider) + config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion) + hessian.RegisterPOJO(&User{}) + err := config.Load() + if err != nil { + panic(err) + } + + logger.Infof("\n\n\nstart to test dubbo") + + var successCount, failCount int64 + for i := 0; i < 10; i++ { + time.Sleep(50 * time.Millisecond) + user, err := userProvider.GetUser(context.TODO(), &User{Name: "Alex03"}) + if err != nil { + failCount++ + logger.Infof("error: %v\n", err) + } else { + successCount++ + } + logger.Infof("response: %v\n", user) + } + logger.Infof("successCount=%v, failCount=%v\n", successCount, failCount) + + if failCount == 0 { + panic(errors.New("need failCount > 0")) + } +} diff --git a/compatibility/polaris/limit/go-client/conf/dubbogo.yml b/compatibility/polaris/limit/go-client/conf/dubbogo.yml new file mode 100644 index 00000000..294de217 --- /dev/null +++ b/compatibility/polaris/limit/go-client/conf/dubbogo.yml @@ -0,0 +1,24 @@ +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: pro # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + consumer: + references: + UserProvider: + protocol: dubbo + interface: org.apache.dubbo.UserProvider.Test + UserProviderWithCustomGroupAndVersion: + protocol: dubbo + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with server diff --git a/compatibility/polaris/limit/go-server/cmd/server.go b/compatibility/polaris/limit/go-server/cmd/server.go new file mode 100644 index 00000000..6272c16d --- /dev/null +++ b/compatibility/polaris/limit/go-server/cmd/server.go @@ -0,0 +1,111 @@ +/* + * 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 main + +import ( + "context" + "fmt" + "os" + "os/signal" + "syscall" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +var ( + survivalTimeout = int(3e9) +) + +func init() { + config.SetProviderService(&UserProvider{}) + config.SetProviderService(&UserProviderWithCustomGroupAndVersion{}) + // ------for hessian2------ + hessian.RegisterPOJO(&User{}) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +type UserProvider struct { +} + +func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +type UserProviderWithCustomGroupAndVersion struct { +} + +func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "Alex Stocks from UserProviderWithCustomGroupAndVersion", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to "conf/server.yml" before run +func main() { + if err := config.Load(); err != nil { + panic(err) + } + + initSignal() +} + +func initSignal() { + signals := make(chan os.Signal, 1) + // It is not possible to block SIGKILL or syscall.SIGSTOP + signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM) + for { + sig := <-signals + logger.Infof("get signal %s", sig.String()) + switch sig { + case syscall.SIGHUP: + // reload() + default: + time.AfterFunc(time.Duration(survivalTimeout), func() { + logger.Warnf("app exit now by force...") + os.Exit(1) + }) + + // The program exits normally or timeout forcibly exits. + fmt.Println("provider app exit now...") + return + } + } +} diff --git a/compatibility/polaris/limit/go-server/conf/dubbogo.yml b/compatibility/polaris/limit/go-server/conf/dubbogo.yml new file mode 100644 index 00000000..2aa7785d --- /dev/null +++ b/compatibility/polaris/limit/go-server/conf/dubbogo.yml @@ -0,0 +1,29 @@ +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: pro # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + protocols: + dubbo: + name: dubbo + port: 20000 + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test + tps.limiter: polaris-limit # the Limiter that judge if the TPS overs the threshold, such as method-service or default + UserProviderWithCustomGroupAndVersion: + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with client + group: myInterfaceGroup # dubbo interface group must be same with client + tps.limiter: polaris-limit # the Limiter that judge if the TPS overs the threshold, such as method-service or default diff --git a/compatibility/polaris/limit/images/dubbogo-ratelimit-rule.png b/compatibility/polaris/limit/images/dubbogo-ratelimit-rule.png new file mode 100644 index 00000000..efdd51ba Binary files /dev/null and b/compatibility/polaris/limit/images/dubbogo-ratelimit-rule.png differ diff --git a/compatibility/polaris/registry/README-zh.md b/compatibility/polaris/registry/README-zh.md new file mode 100644 index 00000000..a13c2aab --- /dev/null +++ b/compatibility/polaris/registry/README-zh.md @@ -0,0 +1,62 @@ +# Dubbo Go & Polaris Registry Example + +English | [中文](README-zh.md) + +## 使用服务注册发现功能 + +在 dubbogo 中快速体验北极星的服务注册以及服务发现能力 + +## 北极星服务端安装 + +[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/) + +[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/) + +## 如何使用 + +### dubbogo.yaml 配置文件 + +当前 PolarisMesh 已实现了 dubbogo 的注册发现扩展点，因此你只需要调整你的 dubbogo.yaml 文件中的 registries 配置项，新增 protocol 为 polaris 的注册中心配置即可，可以参考下面的样例。 + +```yaml +dubbo: + registries: + polarisMesh: + protocol: polaris + address: ${北极星服务端IP}:8091 + namespace: ${北极星命名空间信息} + token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数 +``` + +### 运行服务提供者 + +进入 go-server 的 cmd 目录，执行以下命令 + +``` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" + go run . +``` + +当看到以下日志时即表示 server 端启动成功 + +```log +INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service: +``` + + +### 运行服务调用者 + +进入 go-client 的 cmd 目录，执行以下命令 + + +``` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" + go run . +``` + +当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用 + +```log +INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092 +0800 CST} +``` + diff --git a/compatibility/polaris/registry/README.md b/compatibility/polaris/registry/README.md new file mode 100644 index 00000000..e6ea563f --- /dev/null +++ b/compatibility/polaris/registry/README.md @@ -0,0 +1,61 @@ +# Dubbo Go & Polaris Registry Example + +English | [中文](README-zh.md) + +## Using the service registration discovery function + +Quickly experience Polaris' service registration and service discovery capabilities in dubbogo + +## Polaris server installation + +[Polaris Server Standalone Version Installation Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/) + +[Polaris Server Cluster Version Installation Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/) + +## how to use + +### dubbogo.yaml configuration file + +Currently PolarisMesh has implemented the registration discovery extension point of dubbogo, so you only need to adjust the registries configuration item in your dubbogo.yaml file, and add the registry configuration of polaris as the protocol. You can refer to the following example. + +````yaml +dubbo: + registries: + polarisMesh: + protocol: polaris + address: ${Polaris server IP}:8091 + namespace: ${Polaris namespace information} + token: ${Polaris resource authentication token} # If the Polaris server has enabled authentication for the client, you need to configure this parameter +```` + +### Running the service provider + +Enter the cmd directory of go-server and execute the following command + +```` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" + go run . +```` + +When you see the following log, it means that the server side started successfully + +````log +INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service: +```` + + +### Run the service caller + +Enter the cmd directory of go-client and execute the following command + + +```` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" + go run . +```` + +When you see the following log, it means that go-client successfully discovered go-server and made an RPC call + +````log +INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092 +0800 CST} +```` \ No newline at end of file diff --git a/compatibility/polaris/registry/go-client/cmd/main.go b/compatibility/polaris/registry/go-client/cmd/main.go new file mode 100644 index 00000000..e685d8a4 --- /dev/null +++ b/compatibility/polaris/registry/go-client/cmd/main.go @@ -0,0 +1,81 @@ +/* + * 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 main + +import ( + "context" + "os" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +type UserProviderWithCustomGroupAndVersion struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type UserProvider struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +func main() { + var userProvider = &UserProvider{} + var userProviderWithCustomRegistryGroupAndVersion = &UserProviderWithCustomGroupAndVersion{} + config.SetConsumerService(userProvider) + config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion) + hessian.RegisterPOJO(&User{}) + err := config.Load() + if err != nil { + panic(err) + } + + logger.Infof("\n\n\nstart to test dubbo") + user, err := userProvider.GetUser(context.TODO(), &User{Name: "Alex001"}) + if err != nil { + logger.Errorf("error: %v\n", err) + os.Exit(1) + return + } + logger.Infof("response result: %v\n", user) + + user, err = userProviderWithCustomRegistryGroupAndVersion.GetUser(context.TODO(), &User{Name: "Alex001"}) + if err != nil { + logger.Errorf("error: %v\n", err) + os.Exit(1) + return + } + logger.Infof("response result: %v\n", user) +} diff --git a/compatibility/polaris/registry/go-client/conf/dubbogo.yml b/compatibility/polaris/registry/go-client/conf/dubbogo.yml new file mode 100644 index 00000000..068e6dd4 --- /dev/null +++ b/compatibility/polaris/registry/go-client/conf/dubbogo.yml @@ -0,0 +1,24 @@ +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: pro # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + consumer: + references: + UserProvider: + protocol: dubbo + interface: org.apache.dubbo.UserProvider.Test + UserProviderWithCustomGroupAndVersion: + protocol: dubbo + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with server \ No newline at end of file diff --git a/compatibility/polaris/registry/go-server/cmd/server.go b/compatibility/polaris/registry/go-server/cmd/server.go new file mode 100644 index 00000000..55988678 --- /dev/null +++ b/compatibility/polaris/registry/go-server/cmd/server.go @@ -0,0 +1,110 @@ +/* + * 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 main + +import ( + "context" + "fmt" + "os" + "os/signal" + "syscall" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +var ( + survivalTimeout = int(3e9) +) + +func init() { + config.SetProviderService(&UserProvider{}) + config.SetProviderService(&UserProviderWithCustomGroupAndVersion{}) + // ------for hessian2------ + hessian.RegisterPOJO(&User{}) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +type UserProvider struct { +} + +func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +type UserProviderWithCustomGroupAndVersion struct { +} + +func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "Alex Stocks from UserProviderWithCustomGroupAndVersion", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to "conf/server.yml" before run +func main() { + if err := config.Load(); err != nil { + panic(err) + } + + initSignal() +} + +func initSignal() { + signals := make(chan os.Signal, 1) + // It is not possible to block SIGKILL or syscall.SIGSTOP + signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM) + for { + sig := <-signals + logger.Infof("get signal %s", sig.String()) + switch sig { + case syscall.SIGHUP: + // reload() + default: + time.AfterFunc(time.Duration(survivalTimeout), func() { + logger.Warnf("app exit now by force...") + os.Exit(1) + }) + + // The program exits normally or timeout forcibly exits. + fmt.Println("provider app exit now...") + return + } + } +} diff --git a/compatibility/polaris/registry/go-server/conf/dubbogo.yml b/compatibility/polaris/registry/go-server/conf/dubbogo.yml new file mode 100644 index 00000000..0c0c7f70 --- /dev/null +++ b/compatibility/polaris/registry/go-server/conf/dubbogo.yml @@ -0,0 +1,27 @@ +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: pro # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + protocols: + dubbo: + name: dubbo + port: 20000 + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test + UserProviderWithCustomGroupAndVersion: + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with client + group: myInterfaceGroup # dubbo interface group must be same with client \ No newline at end of file diff --git a/compatibility/polaris/router/README-zh.md b/compatibility/polaris/router/README-zh.md new file mode 100644 index 00000000..be48668d --- /dev/null +++ b/compatibility/polaris/router/README-zh.md @@ -0,0 +1,121 @@ +# Dubbo Go & Polaris Router Example + +[English](README.md) | 中文 + +## 使用服务路由功能 + +在 dubbogo 中快速体验北极星的服务路由能力 + +## 北极星服务端安装 + +[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/) + +[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/) + +## 如何使用 + +[北极星服务路由使用文档](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E5%8A%A8%E6%80%81%E8%B7%AF%E7%94%B1) + +### dubbogo.yaml 配置文件 + +在使用 PolarisMesh 的服务路由能力时，需要先启用 PolarisMesh 在 dubbogo 中的注册发现功能。 + +```yaml +dubbo: + registries: + polarisMesh: + protocol: polaris + address: ${北极星服务端IP}:8091 + namespace: ${北极星命名空间信息} + token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数 + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test +``` + +### 如何配置服务路由参数 + +dubbogo 中的 PolarisMesh PriorityRouter 扩展点实现，能够根据用户配置的服务路由规则，自动的从当前 RPC 调用上下文以及请求信息中识别出需要参与服务路由的请求标签信息 + + + + + +- 请求匹配规则为 **请求参数(QUERY)** + - 标签来源: RPC 调用中方法的入参，即 Invoaction.Arguments() + - 标签键规则 + - 方法仅有一个入参: param.$.${fieldName}, **param.** 为固定前缀，后面的表达式为标准的 JSONPath expressions，[参考文档](https://goessner.net/articles/JsonPath/) + - 方法有多个参数: param[${index}].$.${fieldName}, **param[${index}].** 为固定前缀，${index} 代表是方法入参中的第几个参数，下标起始位置从 0 开始；后面的表达式为标准的 JSONPath expressions，[参考文档](https://goessner.net/articles/JsonPath/) +- 请求匹配规则为 **请求头(HEADER)**: + - 标签来源: RPC 调用的额外标签信息，即 Invoaction.Attachments() + +### 运行服务提供者 + +分别进入 server-prod、server-pre、server-dev 的 cmd 目录，执行以下命令 + +``` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml" + go run . +``` + +当看到以下日志时即表示 server 端启动成功 + +```log +INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service: +``` + + +### 运行服务调用者 + +进入 go-client 的 cmd 目录，执行以下命令 + + +``` +export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" +export uid=user-1 +go run . +``` + +当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用 + +```log +INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092 +0800 CST} +``` + +分别执行以下命令 + +```bash +export uid= +go run . + +export uid=user-1 +go run . + +export uid=user-2 +``` + +当看到以下日志时即表示在 PolarisMesh 配置的路由策略已生效 + +```log +# export uid= +2022-11-26T13:39:31.637+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:31.637 +0800 CST} +2022-11-26T13:39:31.842+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:31.841 +0800 CST} +2022-11-26T13:39:32.043+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:32.043 +0800 CST} +2022-11-26T13:39:32.247+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:32.247 +0800 CST} +2022-11-26T13:39:32.452+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:32.452 +0800 CST} + +# export uid=user-1 +2022-11-26T13:39:51.053+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.053 +0800 CST} +2022-11-26T13:39:51.257+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.257 +0800 CST} +2022-11-26T13:39:51.459+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.459 +0800 CST} +2022-11-26T13:39:51.662+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.662 +0800 CST} +2022-11-26T13:39:51.866+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.866 +0800 CST} + +# export uid=user-2 +2022-11-26T13:42:39.351+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.351 +0800 CST} +2022-11-26T13:42:39.555+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.555 +0800 CST} +2022-11-26T13:42:39.760+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.76 +0800 CST} +2022-11-26T13:42:39.962+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.961 +0800 CST} +2022-11-26T13:42:40.165+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:40.165 +0800 CST} +``` diff --git a/compatibility/polaris/router/README.md b/compatibility/polaris/router/README.md new file mode 100644 index 00000000..a80804d8 --- /dev/null +++ b/compatibility/polaris/router/README.md @@ -0,0 +1,121 @@ +# Dubbo Go & Polaris Router Example + +English | [中文](README-zh.md) + +## Using the service routing function + +Quickly experience Polaris' service routing capabilities in dubbogo + +## Polaris server installation + +[Polaris Server Standalone Version Installation Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/) + +[Polaris Server Cluster Version Installation Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/) + +## how to use + +[Polaris Service Routing Usage Document](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E5%8A%A8%E6%80%81%E8%B7%AF%E7%94%B1) + +### dubbogo.yaml configuration file + +When using PolarisMesh's service route capability, you need to enable PolarisMesh's registration discovery function in dubbogo firstly. + +````yaml +dubbo: + registries: + polarisMesh: + protocol: polaris + address: ${Polaris server IP}:8091 + namespace: ${Polaris namespace information} + token: ${Polaris resource authentication token} # If the Polaris server has enabled authentication for the client, you need to configure this parameter + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test +```` + +### How to configure service routing parameters + +The implementation of the PolarisMesh PriorityRouter extension point in dubbogo can automatically identify the request label information that needs to participate in service routing from the current RPC call context and request information according to the service route rules configured by the user. + + + + + +- The request matching rule is **Request parameter(QUERY)** + - Tag source: the input parameter of the method in the RPC call, namely Invoaction.Arguments() + - Tag key rules + - The method has only one input parameter: param.$.${fieldName}, **param.** is a fixed prefix, the following expressions are standard JSONPath expressions, [reference document](https://goessner.net/ articles/JsonPath/) + - The method has multiple parameters: param[${index}].$.${fieldName}, **param[${index}].** is a fixed prefix, ${index} represents the first parameter in the method parameter Several parameters, the starting position of the subscript starts from 0; the following expressions are standard JSONPath expressions, [reference document](https://goessner.net/articles/JsonPath/) +- The request matching rule is **request header (HEADER)**: + - Tag source: Additional tag information for RPC calls, i.e. Invoaction.Attachments() + +### Running the service provider + +Enter the cmd directory of server-prod, server-pre, and server-dev respectively, and execute the following commands + +```` + export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml" + go run . +```` + +When you see the following log, it means that the server side started successfully + +````log +INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service: +```` + + +### Running the service caller + +Enter the cmd directory of go-client and execute the following command + + +```` +export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml" +export uid=user-1 +go run . +```` + +When you see the following log, it means that go-client successfully discovered go-server and made an RPC call + +````log +INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092 +0800 CST} +```` + +Execute the following commands respectively + +```bash +export uid= +go run . + +export uid=user-1 +go run . + +export uid=user-2 +```` + +When you see the following log, it means that the routing policy configured in PolarisMesh has taken effect + +```log +# export uid= +2022-11-26T13:39:31.637+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:31.637 +0800 CST} +2022-11-26T13:39:31.842+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:31.841 +0800 CST} +2022-11-26T13:39:32.043+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:32.043 +0800 CST} +2022-11-26T13:39:32.247+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:32.247 +0800 CST} +2022-11-26T13:39:32.452+0800 INFO cmd/main.go:78 response: &{A001 [Prod] Alex Stocks 18 2022-11-26 13:39:32.452 +0800 CST} + +# export uid=user-1 +2022-11-26T13:39:51.053+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.053 +0800 CST} +2022-11-26T13:39:51.257+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.257 +0800 CST} +2022-11-26T13:39:51.459+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.459 +0800 CST} +2022-11-26T13:39:51.662+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.662 +0800 CST} +2022-11-26T13:39:51.866+0800 INFO cmd/main.go:78 response: &{A001 [Pre] Alex Stocks 18 2022-11-26 13:39:51.866 +0800 CST} + +# export uid=user-2 +2022-11-26T13:42:39.351+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.351 +0800 CST} +2022-11-26T13:42:39.555+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.555 +0800 CST} +2022-11-26T13:42:39.760+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.76 +0800 CST} +2022-11-26T13:42:39.962+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:39.961 +0800 CST} +2022-11-26T13:42:40.165+0800 INFO cmd/main.go:78 response: &{A001 [Dev] Alex Stocks 18 2022-11-26 13:42:40.165 +0800 CST} +``` diff --git a/compatibility/polaris/router/go-client/cmd/main.go b/compatibility/polaris/router/go-client/cmd/main.go new file mode 100644 index 00000000..1e4f6b53 --- /dev/null +++ b/compatibility/polaris/router/go-client/cmd/main.go @@ -0,0 +1,81 @@ +/* + * 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 main + +import ( + "context" + "os" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/common/constant" + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +type UserProviderWithCustomGroupAndVersion struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type UserProvider struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +func main() { + var userProvider = &UserProvider{} + var userProviderWithCustomRegistryGroupAndVersion = &UserProviderWithCustomGroupAndVersion{} + config.SetConsumerService(userProvider) + config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion) + hessian.RegisterPOJO(&User{}) + err := config.Load() + if err != nil { + panic(err) + } + + logger.Infof("\n\n\nstart to test dubbo") + + uid := os.Getenv("uid") + atta := make(map[string]interface{}) + atta["uid"] = uid + reqContext := context.WithValue(context.Background(), constant.DubboCtxKey("attachment"), atta) + + for i := 0; i < 5; i++ { + time.Sleep(200 * time.Millisecond) + user, err := userProvider.GetUser(reqContext, &User{Name: "Alex001"}) + if err != nil { + panic(err) + } + logger.Infof("response: %v\n", user) + } +} diff --git a/compatibility/polaris/router/go-client/conf/dubbogo.yaml b/compatibility/polaris/router/go-client/conf/dubbogo.yaml new file mode 100644 index 00000000..b41630c6 --- /dev/null +++ b/compatibility/polaris/router/go-client/conf/dubbogo.yaml @@ -0,0 +1,25 @@ + +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: pro # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + consumer: + references: + UserProvider: + protocol: dubbo + interface: org.apache.dubbo.UserProvider.Test + UserProviderWithCustomGroupAndVersion: + protocol: dubbo + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with server diff --git a/compatibility/polaris/router/go-server/server-dev/cmd/server.go b/compatibility/polaris/router/go-server/server-dev/cmd/server.go new file mode 100644 index 00000000..71eab8ac --- /dev/null +++ b/compatibility/polaris/router/go-server/server-dev/cmd/server.go @@ -0,0 +1,111 @@ +/* + * 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 main + +import ( + "context" + "fmt" + "os" + "os/signal" + "syscall" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +var ( + survivalTimeout = int(3e9) +) + +func init() { + config.SetProviderService(&UserProvider{}) + config.SetProviderService(&UserProviderWithCustomGroupAndVersion{}) + // ------for hessian2------ + hessian.RegisterPOJO(&User{}) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +type UserProvider struct { +} + +func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "[Dev] Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +type UserProviderWithCustomGroupAndVersion struct { +} + +func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "[Dev] Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to "conf/server.yml" before run +func main() { + if err := config.Load(); err != nil { + panic(err) + } + + initSignal() +} + +func initSignal() { + signals := make(chan os.Signal, 1) + // It is not possible to block SIGKILL or syscall.SIGSTOP + signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM) + for { + sig := <-signals + logger.Infof("get signal %s", sig.String()) + switch sig { + case syscall.SIGHUP: + // reload() + default: + time.AfterFunc(time.Duration(survivalTimeout), func() { + logger.Warnf("app exit now by force...") + os.Exit(1) + }) + + // The program exits normally or timeout forcibly exits. + fmt.Println("provider app exit now...") + return + } + } +} diff --git a/compatibility/polaris/router/go-server/server-dev/conf/dubbogo.yaml b/compatibility/polaris/router/go-server/server-dev/conf/dubbogo.yaml new file mode 100644 index 00000000..557ea4c4 --- /dev/null +++ b/compatibility/polaris/router/go-server/server-dev/conf/dubbogo.yaml @@ -0,0 +1,28 @@ +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: dev # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + protocols: + dubbo: + name: dubbo + port: 20000 + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test + tps.limiter: polaris-limit # the Limiter that judge if the TPS overs the threshold, such as method-service or default + UserProviderWithCustomGroupAndVersion: + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with client + group: myInterfaceGroup # dubbo interface group must be same with client diff --git a/compatibility/polaris/router/go-server/server-pre/cmd/server.go b/compatibility/polaris/router/go-server/server-pre/cmd/server.go new file mode 100644 index 00000000..46ef833e --- /dev/null +++ b/compatibility/polaris/router/go-server/server-pre/cmd/server.go @@ -0,0 +1,111 @@ +/* + * 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 main + +import ( + "context" + "fmt" + "os" + "os/signal" + "syscall" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +var ( + survivalTimeout = int(3e9) +) + +func init() { + config.SetProviderService(&UserProvider{}) + config.SetProviderService(&UserProviderWithCustomGroupAndVersion{}) + // ------for hessian2------ + hessian.RegisterPOJO(&User{}) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +type UserProvider struct { +} + +func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "[Pre] Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +type UserProviderWithCustomGroupAndVersion struct { +} + +func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "[Pre] Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to "conf/server.yml" before run +func main() { + if err := config.Load(); err != nil { + panic(err) + } + + initSignal() +} + +func initSignal() { + signals := make(chan os.Signal, 1) + // It is not possible to block SIGKILL or syscall.SIGSTOP + signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM) + for { + sig := <-signals + logger.Infof("get signal %s", sig.String()) + switch sig { + case syscall.SIGHUP: + // reload() + default: + time.AfterFunc(time.Duration(survivalTimeout), func() { + logger.Warnf("app exit now by force...") + os.Exit(1) + }) + + // The program exits normally or timeout forcibly exits. + fmt.Println("provider app exit now...") + return + } + } +} diff --git a/compatibility/polaris/router/go-server/server-pre/conf/dubbogo.yaml b/compatibility/polaris/router/go-server/server-pre/conf/dubbogo.yaml new file mode 100644 index 00000000..1ef24dfc --- /dev/null +++ b/compatibility/polaris/router/go-server/server-pre/conf/dubbogo.yaml @@ -0,0 +1,28 @@ +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: pre # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + protocols: + dubbo: + name: dubbo + port: 21000 + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test + tps.limiter: polaris-limit # the Limiter that judge if the TPS overs the threshold, such as method-service or default + UserProviderWithCustomGroupAndVersion: + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with client + group: myInterfaceGroup # dubbo interface group must be same with client diff --git a/compatibility/polaris/router/go-server/server-prod/cmd/server.go b/compatibility/polaris/router/go-server/server-prod/cmd/server.go new file mode 100644 index 00000000..56dc89a0 --- /dev/null +++ b/compatibility/polaris/router/go-server/server-prod/cmd/server.go @@ -0,0 +1,111 @@ +/* + * 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 main + +import ( + "context" + "fmt" + "os" + "os/signal" + "syscall" + "time" +) + +import ( + "dubbo.apache.org/dubbo-go/v3/config" + _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy" + _ "dubbo.apache.org/dubbo-go/v3/imports" + + hessian "github.com/apache/dubbo-go-hessian2" + + "github.com/dubbogo/gost/log/logger" +) + +var ( + survivalTimeout = int(3e9) +) + +func init() { + config.SetProviderService(&UserProvider{}) + config.SetProviderService(&UserProviderWithCustomGroupAndVersion{}) + // ------for hessian2------ + hessian.RegisterPOJO(&User{}) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +type UserProvider struct { +} + +func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "[Prod] Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +type UserProviderWithCustomGroupAndVersion struct { +} + +func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context, req *User) (*User, error) { + logger.Infof("req:%#v", req) + rsp := User{"A001", "[Prod] Alex Stocks", 18, time.Now()} + logger.Infof("rsp:%#v", rsp) + return &rsp, nil +} + +// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to "conf/server.yml" before run +func main() { + if err := config.Load(); err != nil { + panic(err) + } + + initSignal() +} + +func initSignal() { + signals := make(chan os.Signal, 1) + // It is not possible to block SIGKILL or syscall.SIGSTOP + signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM) + for { + sig := <-signals + logger.Infof("get signal %s", sig.String()) + switch sig { + case syscall.SIGHUP: + // reload() + default: + time.AfterFunc(time.Duration(survivalTimeout), func() { + logger.Warnf("app exit now by force...") + os.Exit(1) + }) + + // The program exits normally or timeout forcibly exits. + fmt.Println("provider app exit now...") + return + } + } +} diff --git a/compatibility/polaris/router/go-server/server-prod/conf/dubbogo.yaml b/compatibility/polaris/router/go-server/server-prod/conf/dubbogo.yaml new file mode 100644 index 00000000..cd623867 --- /dev/null +++ b/compatibility/polaris/router/go-server/server-prod/conf/dubbogo.yaml @@ -0,0 +1,28 @@ +dubbo: + application: + name: myApp # metadata: application=myApp; name=myApp + module: opensource #metadata: module=opensource + group: myAppGroup # no metadata record + organization: dubbo # metadata: organization=dubbo + owner: laurence # metadata: owner=laurence + version: myversion # metadata: app.version=myversion + environment: prod # metadata: environment=pro + registries: + polarisMesh: + protocol: polaris + address: 127.0.0.1:8091 + namespace: dubbogo + registry-type: interface + protocols: + dubbo: + name: dubbo + port: 22000 + provider: + services: + UserProvider: + interface: org.apache.dubbo.UserProvider.Test + tps.limiter: polaris-limit # the Limiter that judge if the TPS overs the threshold, such as method-service or default + UserProviderWithCustomGroupAndVersion: + interface: org.apache.dubbo.UserProvider.Test2 + version: myInterfaceVersion # dubbo interface version must be same with client + group: myInterfaceGroup # dubbo interface group must be same with client diff --git a/compatibility/polaris/router/images/dubbogo-route-rule-dev.png b/compatibility/polaris/router/images/dubbogo-route-rule-dev.png new file mode 100644 index 00000000..b61ed0eb Binary files /dev/null and b/compatibility/polaris/router/images/dubbogo-route-rule-dev.png differ diff --git a/compatibility/polaris/router/images/dubbogo-route-rule-pre.png b/compatibility/polaris/router/images/dubbogo-route-rule-pre.png new file mode 100644 index 00000000..61eb8977 Binary files /dev/null and b/compatibility/polaris/router/images/dubbogo-route-rule-pre.png differ diff --git a/compatibility/polaris/router/images/dubbogo-route-rule-prod.png b/compatibility/polaris/router/images/dubbogo-route-rule-prod.png new file mode 100644 index 00000000..0fd28f07 Binary files /dev/null and b/compatibility/polaris/router/images/dubbogo-route-rule-prod.png differ diff --git a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go b/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go index 0ca9cbc4..818b0e6b 100644 --- a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go +++ b/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go @@ -48,4 +48,5 @@ func TestMain(m *testing.M) { panic(err) } os.Exit(m.Run()) + } diff --git a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go b/integrate_test/compatibility/polaris/limit/tests/integration/limit_test.go similarity index 55% copy from integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go copy to integrate_test/compatibility/polaris/limit/tests/integration/limit_test.go index 0ca9cbc4..7c68bd8f 100644 --- a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go +++ b/integrate_test/compatibility/polaris/limit/tests/integration/limit_test.go @@ -18,34 +18,28 @@ package integration import ( - "os" + "context" "testing" + "time" ) import ( - "dubbo.apache.org/dubbo-go/v3/config" - _ "dubbo.apache.org/dubbo-go/v3/imports" + "github.com/stretchr/testify/assert" ) -import ( - "github.com/apache/dubbo-go-samples/compatibility/api" -) - -var greeterProvider = new(api.GreeterClientImpl) +func TestPolarisLimit(t *testing.T) { -func TestMain(m *testing.M) { - config.SetConsumerService(greeterProvider) - rootConfig := config.NewRootConfigBuilder(). - SetConsumer(config.NewConsumerConfigBuilder(). - AddReference("GreeterClientImpl", config.NewReferenceConfigBuilder(). - SetProtocol("tri"). - Build()). - Build()). - AddRegistry("zkRegistryKey", config.NewRegistryConfigWithProtocolDefaultPort("zookeeper")). - Build() - - if err := config.Load(config.WithRootConfig(rootConfig)); err != nil { - panic(err) + var successCount, failCount int64 + for i := 0; i < 10; i++ { + time.Sleep(50 * time.Millisecond) + _, err := userProvider.GetUser(context.TODO(), &User{Name: "Alex03"}) + if err != nil { + failCount++ + } else { + successCount++ + } } - os.Exit(m.Run()) + //current limiting effect + assert.Equal(t, true, failCount > 0) + } diff --git a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go b/integrate_test/compatibility/polaris/limit/tests/integration/main_test.go similarity index 56% copy from integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go copy to integrate_test/compatibility/polaris/limit/tests/integration/main_test.go index 0ca9cbc4..5db1c648 100644 --- a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go +++ b/integrate_test/compatibility/polaris/limit/tests/integration/main_test.go @@ -18,34 +18,48 @@ package integration import ( - "os" + "context" "testing" + "time" ) import ( "dubbo.apache.org/dubbo-go/v3/config" _ "dubbo.apache.org/dubbo-go/v3/imports" -) -import ( - "github.com/apache/dubbo-go-samples/compatibility/api" + hessian "github.com/apache/dubbo-go-hessian2" ) -var greeterProvider = new(api.GreeterClientImpl) +type UserProviderWithCustomGroupAndVersion struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type UserProvider struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +var userProvider = &UserProvider{} +var userProviderWithCustomRegistryGroupAndVersion = &UserProviderWithCustomGroupAndVersion{} func TestMain(m *testing.M) { - config.SetConsumerService(greeterProvider) - rootConfig := config.NewRootConfigBuilder(). - SetConsumer(config.NewConsumerConfigBuilder(). - AddReference("GreeterClientImpl", config.NewReferenceConfigBuilder(). - SetProtocol("tri"). - Build()). - Build()). - AddRegistry("zkRegistryKey", config.NewRegistryConfigWithProtocolDefaultPort("zookeeper")). - Build() - - if err := config.Load(config.WithRootConfig(rootConfig)); err != nil { + + config.SetConsumerService(userProvider) + config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion) + hessian.RegisterPOJO(&User{}) + err := config.Load() + if err != nil { panic(err) } - os.Exit(m.Run()) + } diff --git a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go b/integrate_test/compatibility/polaris/registry/tests/integration/main_test.go similarity index 56% copy from integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go copy to integrate_test/compatibility/polaris/registry/tests/integration/main_test.go index 0ca9cbc4..5db1c648 100644 --- a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go +++ b/integrate_test/compatibility/polaris/registry/tests/integration/main_test.go @@ -18,34 +18,48 @@ package integration import ( - "os" + "context" "testing" + "time" ) import ( "dubbo.apache.org/dubbo-go/v3/config" _ "dubbo.apache.org/dubbo-go/v3/imports" -) -import ( - "github.com/apache/dubbo-go-samples/compatibility/api" + hessian "github.com/apache/dubbo-go-hessian2" ) -var greeterProvider = new(api.GreeterClientImpl) +type UserProviderWithCustomGroupAndVersion struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type UserProvider struct { + GetUser func(ctx context.Context, req *User) (rsp *User, err error) +} + +type User struct { + ID string + Name string + Age int32 + Time time.Time +} + +func (u *User) JavaClassName() string { + return "org.apache.dubbo.User" +} + +var userProvider = &UserProvider{} +var userProviderWithCustomRegistryGroupAndVersion = &UserProviderWithCustomGroupAndVersion{} func TestMain(m *testing.M) { - config.SetConsumerService(greeterProvider) - rootConfig := config.NewRootConfigBuilder(). - SetConsumer(config.NewConsumerConfigBuilder(). - AddReference("GreeterClientImpl", config.NewReferenceConfigBuilder(). - SetProtocol("tri"). - Build()). - Build()). - AddRegistry("zkRegistryKey", config.NewRegistryConfigWithProtocolDefaultPort("zookeeper")). - Build() - - if err := config.Load(config.WithRootConfig(rootConfig)); err != nil { + + config.SetConsumerService(userProvider) + config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion) + hessian.RegisterPOJO(&User{}) + err := config.Load() + if err != nil { panic(err) } - os.Exit(m.Run()) + } diff --git a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go b/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go similarity index 54% copy from integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go copy to integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go index 0ca9cbc4..76251f2c 100644 --- a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go +++ b/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go @@ -18,34 +18,24 @@ package integration import ( - "os" + "context" "testing" ) import ( - "dubbo.apache.org/dubbo-go/v3/config" - _ "dubbo.apache.org/dubbo-go/v3/imports" + "github.com/stretchr/testify/assert" ) -import ( - "github.com/apache/dubbo-go-samples/compatibility/api" -) - -var greeterProvider = new(api.GreeterClientImpl) - -func TestMain(m *testing.M) { - config.SetConsumerService(greeterProvider) - rootConfig := config.NewRootConfigBuilder(). - SetConsumer(config.NewConsumerConfigBuilder(). - AddReference("GreeterClientImpl", config.NewReferenceConfigBuilder(). - SetProtocol("tri"). - Build()). - Build()). - AddRegistry("zkRegistryKey", config.NewRegistryConfigWithProtocolDefaultPort("zookeeper")). - Build() +func TestPolarisRegistry(t *testing.T) { + user, err := userProvider.GetUser(context.TODO(), &User{Name: "Alex001"}) + assert.Nil(t, err) + assert.NotNil(t, user) + assert.Equal(t, user.ID, "A001") + assert.Equal(t, user.Name, "Alex Stocks") + assert.Equal(t, user.Age, 18) - if err := config.Load(config.WithRootConfig(rootConfig)); err != nil { - panic(err) - } - os.Exit(m.Run()) + user, err = userProviderWithCustomRegistryGroupAndVersion.GetUser(context.TODO(), &User{Name: "Alex001"}) + assert.Nil(t, err) + assert.Equal(t, user.Name, "Alex Stocks from UserProviderWithCustomGroupAndVersion") + assert.Equal(t, user.Age, 18) } diff --git a/integrate_test/dockercompose/docker-compose.yml b/integrate_test/dockercompose/docker-compose.yml index e9153023..11bbf48d 100644 --- a/integrate_test/dockercompose/docker-compose.yml +++ b/integrate_test/dockercompose/docker-compose.yml @@ -20,6 +20,18 @@ services: test: "curl --fail http://127.0.0.1:8848/nacos/v1/console/health/liveness || exit 1" interval: 5s + polaris: + image: polarismesh/polaris-standalone:latest + container_name: polaris-standalone + privileged: true + ports: + - "8090:8090" + - "8091:8091" + - "8093:8093" + healthcheck: + test: "curl --fail http://127.0.0.1:8090 || exit 1" + interval: 5s + etcd: image: "quay.io/coreos/etcd:v3.4.28" container_name: etcd diff --git a/start_integrate_test.sh b/start_integrate_test.sh index b5201565..49b2f46b 100755 --- a/start_integrate_test.sh +++ b/start_integrate_test.sh @@ -94,6 +94,10 @@ array+=("rpc/multi-protocols") # async array+=("compatibility/async") +# polaris +array+=("compatibility/polaris/registry") +array+=("compatibility/polaris/limit") + # error array+=("error")
