This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go-samples.git
The following commit(s) were added to refs/heads/main by this push:
new c8e372da feat: migrate registry/polaris (#1017)
c8e372da is described below
commit c8e372da2ee3cf763d3b9bf2360c012519e4a3e8
Author: zbchi <[email protected]>
AuthorDate: Thu Jan 15 09:36:53 2026 +0800
feat: migrate registry/polaris (#1017)
* feat: migrate registry/polaris
* update readme
* rm old sample
* rm old integrate test
* add link
---
README.md | 1 -
README_CN.md | 1 -
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 ---
.../polaris}/tests/integration/main_test.go | 55 +++--
.../polaris}/tests/integration/registry_test.go | 22 +-
registry/README.md | 1 +
registry/polaris/README.md | 22 ++
registry/polaris/README_zh.md | 23 +++
registry/polaris/go-client/cmd/client.go | 69 +++++++
registry/polaris/go-server/cmd/server.go | 79 +++++++
registry/polaris/proto/greet.pb.go | 230 +++++++++++++++++++++
.../polaris/proto/greet.proto | 41 ++--
registry/polaris/proto/greet.triple.go | 122 +++++++++++
start_integrate_test.sh | 2 +-
19 files changed, 604 insertions(+), 429 deletions(-)
diff --git a/README.md b/README.md
index 292e5f35..6aa6d90c 100644
--- a/README.md
+++ b/README.md
@@ -53,7 +53,6 @@ A collection of runnable Dubbo-go examples covering
configuration, registries, o
* `compatibility/generic`: Generic invocation example.
* `compatibility/polaris`: Dubbo-go integrate with polaris samples.
* `compatibility/polaris/limit`: Quickly experience Polaris' service
current limiting capabilities in dubbogo
- * `compatibility/polaris/registry`: Quickly experience Polaris' service
registration and service discovery capabilities in dubbogo
* `compatibility/polaris/router`: Quickly experience Polaris' service
routing capabilities in dubbogo
* `compatibility/rpc`: Dubbo protocol communication examples.
* `compatibility/rpc/dubbo`: Dubbo-go 3.0 RPC example between Java and Go.
diff --git a/README_CN.md b/README_CN.md
index 510f0d66..eab49017 100644
--- a/README_CN.md
+++ b/README_CN.md
@@ -53,7 +53,6 @@
* `compatibility/generic`：泛化调用示例。
* `compatibility/polaris`: Dubbo-go 与 polaris 集成示例.
* `compatibility/polaris/limit`: 在 dubbogo 中快速体验北极星的服务限流能力
- * `compatibility/polaris/registry`: 在 dubbogo 中快速体验北极星的服务注册以及服务发现能力
* `compatibility/polaris/router`: 在 dubbogo 中快速体验北极星的服务路由能力
* `compatibility/rpc`：Dubbo 协议通信示例。
* `compatibility/rpc/dubbo`：Dubbo-go 3.0 下 Java 与 Go 的 RPC 示例。
diff --git a/compatibility/polaris/registry/README-zh.md
b/compatibility/polaris/registry/README-zh.md
deleted file mode 100644
index a13c2aab..00000000
--- a/compatibility/polaris/registry/README-zh.md
+++ /dev/null
@@ -1,62 +0,0 @@
-# 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
deleted file mode 100644
index e6ea563f..00000000
--- a/compatibility/polaris/registry/README.md
+++ /dev/null
@@ -1,61 +0,0 @@
-# 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
deleted file mode 100644
index e685d8a4..00000000
--- a/compatibility/polaris/registry/go-client/cmd/main.go
+++ /dev/null
@@ -1,81 +0,0 @@
-/*
- * 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
deleted file mode 100644
index 068e6dd4..00000000
--- a/compatibility/polaris/registry/go-client/conf/dubbogo.yml
+++ /dev/null
@@ -1,24 +0,0 @@
-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
deleted file mode 100644
index 55988678..00000000
--- a/compatibility/polaris/registry/go-server/cmd/server.go
+++ /dev/null
@@ -1,110 +0,0 @@
-/*
- * 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
deleted file mode 100644
index 0c0c7f70..00000000
--- a/compatibility/polaris/registry/go-server/conf/dubbogo.yml
+++ /dev/null
@@ -1,27 +0,0 @@
-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/integrate_test/compatibility/polaris/registry/tests/integration/main_test.go
b/integrate_test/registry/polaris/tests/integration/main_test.go
similarity index 55%
rename from
integrate_test/compatibility/polaris/registry/tests/integration/main_test.go
rename to integrate_test/registry/polaris/tests/integration/main_test.go
index 5db1c648..7455ae54 100644
---
a/integrate_test/compatibility/polaris/registry/tests/integration/main_test.go
+++ b/integrate_test/registry/polaris/tests/integration/main_test.go
@@ -18,48 +18,45 @@
package integration
import (
- "context"
+ "os"
"testing"
- "time"
)
import (
- "dubbo.apache.org/dubbo-go/v3/config"
+ "dubbo.apache.org/dubbo-go/v3"
_ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
+ "dubbo.apache.org/dubbo-go/v3/registry"
)
-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"
-}
+import (
+ greet "github.com/apache/dubbo-go-samples/registry/polaris/proto"
+)
-var userProvider = &UserProvider{}
-var userProviderWithCustomRegistryGroupAndVersion =
&UserProviderWithCustomGroupAndVersion{}
+var greetService greet.GreetService
func TestMain(m *testing.M) {
+ ins, err := dubbo.NewInstance(
+ dubbo.WithName("dubbo_registry_polaris_client"),
+ dubbo.WithRegistry(
+ registry.WithPolaris(),
+ registry.WithAddress("127.0.0.1:8091"),
+ registry.WithNamespace("dubbogo"),
+ registry.WithRegisterInterface(),
+ ),
+ )
+ if err != nil {
+ panic(err)
+ }
+ // configure the params that only client layer cares
+ cli, err := ins.NewClient()
+ if err != nil {
+ panic(err)
+ }
- config.SetConsumerService(userProvider)
- config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion)
- hessian.RegisterPOJO(&User{})
- err := config.Load()
+ greetService, err = greet.NewGreetService(cli)
if err != nil {
panic(err)
}
+ os.Exit(m.Run())
}
diff --git
a/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
b/integrate_test/registry/polaris/tests/integration/registry_test.go
similarity index 68%
copy from
integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
copy to integrate_test/registry/polaris/tests/integration/registry_test.go
index 76251f2c..eb996de1 100644
---
a/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
+++ b/integrate_test/registry/polaris/tests/integration/registry_test.go
@@ -26,16 +26,20 @@ import (
"github.com/stretchr/testify/assert"
)
+import (
+ greet "github.com/apache/dubbo-go-samples/registry/polaris/proto"
+)
+
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)
+ req := &greet.GreetRequest{
+ Name: "Dubbo",
+ }
+
+ ctx := context.Background()
+
+ reply, err := greetService.Greet(ctx, req)
- 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)
+ assert.NotNil(t, reply)
+ assert.Equal(t, "Dubbo", reply.Greeting)
}
diff --git a/registry/README.md b/registry/README.md
index 4bebd01f..814d2a41 100644
--- a/registry/README.md
+++ b/registry/README.md
@@ -5,5 +5,6 @@ This directory contains a series of examples showing dubbo-go's
service discover
* [Zookeeper as registry](./zookeeper)
* [Nacos as registry](./nacos)
* [Etcd as registry](./etcd)
+* [Polaris as registry](./polaris)
[Service Discovery]:
https://dubbo-next.staged.apache.org/zh-cn/overview/mannual/golang-sdk/tutorial/service-discovery
\ No newline at end of file
diff --git a/registry/polaris/README.md b/registry/polaris/README.md
new file mode 100644
index 00000000..da90ec66
--- /dev/null
+++ b/registry/polaris/README.md
@@ -0,0 +1,22 @@
+# Polaris as registry
+
+[English](README.md) | [中文](README_zh.md)
+
+This example shows dubbo-go's service discovery feature with Polaris as
registry.
+
+## How to run
+
+### Start Polaris server
+Follow this instruction to [install and start Polaris
server](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/).
+
+### Run server
+```shell
+$ go run ./go-server/cmd/server.go
+```
+
+Open Polaris console, check service successfully registered into Polaris.
+
+### Run client
+```shell
+$ go run ./go-client/cmd/client.go
+```
diff --git a/registry/polaris/README_zh.md b/registry/polaris/README_zh.md
new file mode 100644
index 00000000..7e8d52e8
--- /dev/null
+++ b/registry/polaris/README_zh.md
@@ -0,0 +1,23 @@
+# 使用 Polaris 作为注册中心
+
+[English](README.md) | [中文](README_zh.md)
+
+本示例展示 dubbo-go 使用 Polaris 作为注册中心的服务发现功能。
+
+## 如何运行
+
+### 启动 Polaris 服务器
+按照[安装文档](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 服务器。
+
+### 运行服务端
+```shell
+$ go run ./go-server/cmd/server.go
+```
+
+打开 Polaris 控制台，检查服务是否成功注册到 Polaris。
+
+### 运行客户端
+```shell
+$ go run ./go-client/cmd/client.go
+```
+
diff --git a/registry/polaris/go-client/cmd/client.go
b/registry/polaris/go-client/cmd/client.go
new file mode 100644
index 00000000..7b0aab4a
--- /dev/null
+++ b/registry/polaris/go-client/cmd/client.go
@@ -0,0 +1,69 @@
+/*
+ * 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"
+)
+
+import (
+ "dubbo.apache.org/dubbo-go/v3"
+ _ "dubbo.apache.org/dubbo-go/v3/imports"
+ "dubbo.apache.org/dubbo-go/v3/registry"
+
+ "github.com/dubbogo/gost/log/logger"
+)
+
+import (
+ greet "github.com/apache/dubbo-go-samples/registry/polaris/proto"
+)
+
+func main() {
+ ins, err := dubbo.NewInstance(
+ dubbo.WithName("dubbo_registry_polaris_client"),
+ dubbo.WithRegistry(
+ registry.WithPolaris(),
+ registry.WithAddress("127.0.0.1:8091"),
+ registry.WithNamespace("dubbogo"),
+ registry.WithRegisterInterface(),
+ ),
+ )
+ if err != nil {
+ logger.Errorf("new dubbo instance failed: %v", err)
+ panic(err)
+ }
+ // configure the params that only client layer cares
+ cli, err := ins.NewClient()
+ if err != nil {
+ logger.Errorf("new client failed: %v", err)
+ panic(err)
+ }
+
+ svc, err := greet.NewGreetService(cli)
+ if err != nil {
+ logger.Errorf("create greet service failed: %v", err)
+ panic(err)
+ }
+
+ resp, err := svc.Greet(context.Background(), &greet.GreetRequest{Name:
"hello world"})
+ if err != nil {
+ logger.Error(err)
+ }
+ logger.Infof("Greet response: %s", resp)
+ select {}
+}
diff --git a/registry/polaris/go-server/cmd/server.go
b/registry/polaris/go-server/cmd/server.go
new file mode 100644
index 00000000..a1744ea5
--- /dev/null
+++ b/registry/polaris/go-server/cmd/server.go
@@ -0,0 +1,79 @@
+/*
+ * 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"
+)
+
+import (
+ "dubbo.apache.org/dubbo-go/v3"
+ _ "dubbo.apache.org/dubbo-go/v3/imports"
+ "dubbo.apache.org/dubbo-go/v3/protocol"
+ "dubbo.apache.org/dubbo-go/v3/registry"
+
+ "github.com/dubbogo/gost/log/logger"
+)
+
+import (
+ greet "github.com/apache/dubbo-go-samples/registry/polaris/proto"
+)
+
+type GreetTripleServer struct {
+}
+
+func (srv *GreetTripleServer) Greet(ctx context.Context, req
*greet.GreetRequest) (*greet.GreetResponse, error) {
+ resp := &greet.GreetResponse{Greeting: req.Name}
+ return resp, nil
+}
+
+func main() {
+ polarisAddr := "127.0.0.1:8091"
+
+ ins, err := dubbo.NewInstance(
+ dubbo.WithName("dubbo_registry_polaris_server"),
+ dubbo.WithRegistry(
+ registry.WithPolaris(),
+ registry.WithAddress(polarisAddr),
+ registry.WithNamespace("dubbogo"),
+ registry.WithRegisterInterface(),
+ ),
+ dubbo.WithProtocol(
+ protocol.WithTriple(),
+ protocol.WithPort(20000),
+ ),
+ )
+ if err != nil {
+ logger.Errorf("new dubbo instance failed: %v", err)
+ panic(err)
+ }
+ srv, err := ins.NewServer()
+ if err != nil {
+ logger.Errorf("new server failed: %v", err)
+ panic(err)
+ }
+ if err := greet.RegisterGreetServiceHandler(srv, &GreetTripleServer{});
err != nil {
+ logger.Errorf("register greet handler failed: %v", err)
+ panic(err)
+ }
+
+ if err := srv.Serve(); err != nil {
+ logger.Errorf("server serve failed: %v", err)
+ panic(err)
+ }
+}
diff --git a/registry/polaris/proto/greet.pb.go
b/registry/polaris/proto/greet.pb.go
new file mode 100644
index 00000000..acdcfa29
--- /dev/null
+++ b/registry/polaris/proto/greet.pb.go
@@ -0,0 +1,230 @@
+//
+// 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.
+
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// protoc-gen-go v1.31.0
+// protoc v3.21.12
+// source: proto/greet.proto
+
+package greet
+
+import (
+ protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+ protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+ reflect "reflect"
+ sync "sync"
+)
+
+const (
+ // Verify that this generated code is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+ // Verify that runtime/protoimpl is sufficiently up-to-date.
+ _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+type GreetRequest struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
+ Name string `protobuf:"bytes,1,opt,name=name,proto3"
json:"name,omitempty"`
+}
+
+func (x *GreetRequest) Reset() {
+ *x = GreetRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_proto_greet_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
+}
+
+func (x *GreetRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GreetRequest) ProtoMessage() {}
+
+func (x *GreetRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_proto_greet_proto_msgTypes[0]
+ if protoimpl.UnsafeEnabled && x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GreetRequest.ProtoReflect.Descriptor instead.
+func (*GreetRequest) Descriptor() ([]byte, []int) {
+ return file_proto_greet_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *GreetRequest) GetName() string {
+ if x != nil {
+ return x.Name
+ }
+ return ""
+}
+
+type GreetResponse struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
+ Greeting string `protobuf:"bytes,1,opt,name=greeting,proto3"
json:"greeting,omitempty"`
+}
+
+func (x *GreetResponse) Reset() {
+ *x = GreetResponse{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_proto_greet_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
+}
+
+func (x *GreetResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GreetResponse) ProtoMessage() {}
+
+func (x *GreetResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_proto_greet_proto_msgTypes[1]
+ if protoimpl.UnsafeEnabled && x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use GreetResponse.ProtoReflect.Descriptor instead.
+func (*GreetResponse) Descriptor() ([]byte, []int) {
+ return file_proto_greet_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *GreetResponse) GetGreeting() string {
+ if x != nil {
+ return x.Greeting
+ }
+ return ""
+}
+
+var File_proto_greet_proto protoreflect.FileDescriptor
+
+var file_proto_greet_proto_rawDesc = []byte{
+ 0x0a, 0x11, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x65,
0x74, 0x2e, 0x70, 0x72,
+ 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x67, 0x72, 0x65, 0x65, 0x74, 0x22, 0x22,
0x0a, 0x0c, 0x47, 0x72,
+ 0x65, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12,
0x0a, 0x04, 0x6e, 0x61,
+ 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61,
0x6d, 0x65, 0x22, 0x2b,
+ 0x0a, 0x0d, 0x47, 0x72, 0x65, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x12,
+ 0x1a, 0x0a, 0x08, 0x67, 0x72, 0x65, 0x65, 0x74, 0x69, 0x6e, 0x67, 0x18,
0x01, 0x20, 0x01, 0x28,
+ 0x09, 0x52, 0x08, 0x67, 0x72, 0x65, 0x65, 0x74, 0x69, 0x6e, 0x67, 0x32,
0x44, 0x0a, 0x0c, 0x47,
+ 0x72, 0x65, 0x65, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12,
0x34, 0x0a, 0x05, 0x47,
+ 0x72, 0x65, 0x65, 0x74, 0x12, 0x13, 0x2e, 0x67, 0x72, 0x65, 0x65, 0x74,
0x2e, 0x47, 0x72, 0x65,
+ 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x14, 0x2e,
0x67, 0x72, 0x65, 0x65,
+ 0x74, 0x2e, 0x47, 0x72, 0x65, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x22,
+ 0x00, 0x42, 0x41, 0x5a, 0x3f, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e,
0x63, 0x6f, 0x6d, 0x2f,
+ 0x61, 0x70, 0x61, 0x63, 0x68, 0x65, 0x2f, 0x64, 0x75, 0x62, 0x62, 0x6f,
0x2d, 0x67, 0x6f, 0x2d,
+ 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x73, 0x2f, 0x72, 0x65, 0x67, 0x69,
0x73, 0x74, 0x72, 0x79,
+ 0x2f, 0x70, 0x6f, 0x6c, 0x61, 0x72, 0x69, 0x73, 0x2f, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x3b, 0x67,
+ 0x72, 0x65, 0x65, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+ file_proto_greet_proto_rawDescOnce sync.Once
+ file_proto_greet_proto_rawDescData = file_proto_greet_proto_rawDesc
+)
+
+func file_proto_greet_proto_rawDescGZIP() []byte {
+ file_proto_greet_proto_rawDescOnce.Do(func() {
+ file_proto_greet_proto_rawDescData =
protoimpl.X.CompressGZIP(file_proto_greet_proto_rawDescData)
+ })
+ return file_proto_greet_proto_rawDescData
+}
+
+var file_proto_greet_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
+var file_proto_greet_proto_goTypes = []interface{}{
+ (*GreetRequest)(nil), // 0: greet.GreetRequest
+ (*GreetResponse)(nil), // 1: greet.GreetResponse
+}
+var file_proto_greet_proto_depIdxs = []int32{
+ 0, // 0: greet.GreetService.Greet:input_type -> greet.GreetRequest
+ 1, // 1: greet.GreetService.Greet:output_type -> greet.GreetResponse
+ 1, // [1:2] is the sub-list for method output_type
+ 0, // [0:1] is the sub-list for method input_type
+ 0, // [0:0] is the sub-list for extension type_name
+ 0, // [0:0] is the sub-list for extension extendee
+ 0, // [0:0] is the sub-list for field type_name
+}
+
+func init() { file_proto_greet_proto_init() }
+func file_proto_greet_proto_init() {
+ if File_proto_greet_proto != nil {
+ return
+ }
+ if !protoimpl.UnsafeEnabled {
+ file_proto_greet_proto_msgTypes[0].Exporter = func(v
interface{}, i int) interface{} {
+ switch v := v.(*GreetRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_proto_greet_proto_msgTypes[1].Exporter = func(v
interface{}, i int) interface{} {
+ switch v := v.(*GreetResponse); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ }
+ type x struct{}
+ out := protoimpl.TypeBuilder{
+ File: protoimpl.DescBuilder{
+ GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+ RawDescriptor: file_proto_greet_proto_rawDesc,
+ NumEnums: 0,
+ NumMessages: 2,
+ NumExtensions: 0,
+ NumServices: 1,
+ },
+ GoTypes: file_proto_greet_proto_goTypes,
+ DependencyIndexes: file_proto_greet_proto_depIdxs,
+ MessageInfos: file_proto_greet_proto_msgTypes,
+ }.Build()
+ File_proto_greet_proto = out.File
+ file_proto_greet_proto_rawDesc = nil
+ file_proto_greet_proto_goTypes = nil
+ file_proto_greet_proto_depIdxs = nil
+}
diff --git
a/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
b/registry/polaris/proto/greet.proto
similarity index 56%
rename from
integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
rename to registry/polaris/proto/greet.proto
index 76251f2c..54142160 100644
---
a/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
+++ b/registry/polaris/proto/greet.proto
@@ -15,27 +15,22 @@
* limitations under the License.
*/
-package integration
-
-import (
- "context"
- "testing"
-)
-
-import (
- "github.com/stretchr/testify/assert"
-)
-
-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)
-
- 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)
+syntax = "proto3";
+
+package greet;
+
+option go_package =
"github.com/apache/dubbo-go-samples/registry/polaris/proto;greet";
+
+message GreetRequest {
+ string name = 1;
+}
+
+message GreetResponse {
+ string greeting = 1;
}
+
+service GreetService {
+ rpc Greet(GreetRequest) returns (GreetResponse) {}
+}
+
+
diff --git a/registry/polaris/proto/greet.triple.go
b/registry/polaris/proto/greet.triple.go
new file mode 100644
index 00000000..1df73466
--- /dev/null
+++ b/registry/polaris/proto/greet.triple.go
@@ -0,0 +1,122 @@
+// Code generated by protoc-gen-triple. DO NOT EDIT.
+//
+// Source: proto/greet.proto
+package greet
+
+import (
+ "context"
+)
+
+import (
+ "dubbo.apache.org/dubbo-go/v3"
+ "dubbo.apache.org/dubbo-go/v3/client"
+ "dubbo.apache.org/dubbo-go/v3/common"
+ "dubbo.apache.org/dubbo-go/v3/common/constant"
+ "dubbo.apache.org/dubbo-go/v3/protocol/triple/triple_protocol"
+ "dubbo.apache.org/dubbo-go/v3/server"
+)
+
+// This is a compile-time assertion to ensure that this generated file and the
Triple package
+// are compatible. If you get a compiler error that this constant is not
defined, this code was
+// generated with a version of Triple newer than the one compiled into your
binary. You can fix the
+// problem by either regenerating this code with an older version of Triple or
updating the Triple
+// version compiled into your binary.
+const _ = triple_protocol.IsAtLeastVersion0_1_0
+
+const (
+ // GreetServiceName is the fully-qualified name of the GreetService
service.
+ GreetServiceName = "greet.GreetService"
+)
+
+// These constants are the fully-qualified names of the RPCs defined in this
package. They're
+// exposed at runtime as procedure and as the final two segments of the HTTP
route.
+//
+// Note that these are different from the fully-qualified method names used by
+// google.golang.org/protobuf/reflect/protoreflect. To convert from these
constants to
+// reflection-formatted method names, remove the leading slash and convert the
remaining slash to a
+// period.
+const (
+ // GreetServiceGreetProcedure is the fully-qualified name of the
GreetService's Greet RPC.
+ GreetServiceGreetProcedure = "/greet.GreetService/Greet"
+)
+
+var (
+ _ GreetService = (*GreetServiceImpl)(nil)
+)
+
+// GreetService is a client for the greet.GreetService service.
+type GreetService interface {
+ Greet(ctx context.Context, req *GreetRequest, opts
...client.CallOption) (*GreetResponse, error)
+}
+
+// NewGreetService constructs a client for the greet.GreetService service.
+func NewGreetService(cli *client.Client, opts ...client.ReferenceOption)
(GreetService, error) {
+ conn, err := cli.DialWithInfo("greet.GreetService",
&GreetService_ClientInfo, opts...)
+ if err != nil {
+ return nil, err
+ }
+ return &GreetServiceImpl{
+ conn: conn,
+ }, nil
+}
+
+func SetConsumerGreetService(srv common.RPCService) {
+ dubbo.SetConsumerServiceWithInfo(srv, &GreetService_ClientInfo)
+}
+
+// GreetServiceImpl implements GreetService.
+type GreetServiceImpl struct {
+ conn *client.Connection
+}
+
+func (c *GreetServiceImpl) Greet(ctx context.Context, req *GreetRequest, opts
...client.CallOption) (*GreetResponse, error) {
+ resp := new(GreetResponse)
+ if err := c.conn.CallUnary(ctx, []interface{}{req}, resp, "Greet",
opts...); err != nil {
+ return nil, err
+ }
+ return resp, nil
+}
+
+var GreetService_ClientInfo = client.ClientInfo{
+ InterfaceName: "greet.GreetService",
+ MethodNames: []string{"Greet"},
+ ConnectionInjectFunc: func(dubboCliRaw interface{}, conn
*client.Connection) {
+ dubboCli := dubboCliRaw.(*GreetServiceImpl)
+ dubboCli.conn = conn
+ },
+}
+
+// GreetServiceHandler is an implementation of the greet.GreetService service.
+type GreetServiceHandler interface {
+ Greet(context.Context, *GreetRequest) (*GreetResponse, error)
+}
+
+func RegisterGreetServiceHandler(srv *server.Server, hdlr GreetServiceHandler,
opts ...server.ServiceOption) error {
+ return srv.Register(hdlr, &GreetService_ServiceInfo, opts...)
+}
+
+func SetProviderGreetService(srv common.RPCService) {
+ dubbo.SetProviderServiceWithInfo(srv, &GreetService_ServiceInfo)
+}
+
+var GreetService_ServiceInfo = server.ServiceInfo{
+ InterfaceName: "greet.GreetService",
+ ServiceType: (*GreetServiceHandler)(nil),
+ Methods: []server.MethodInfo{
+ {
+ Name: "Greet",
+ Type: constant.CallUnary,
+ ReqInitFunc: func() interface{} {
+ return new(GreetRequest)
+ },
+ MethodFunc: func(ctx context.Context, args
[]interface{}, handler interface{}) (interface{}, error) {
+ req := args[0].(*GreetRequest)
+ res, err :=
handler.(GreetServiceHandler).Greet(ctx, req)
+ if err != nil {
+ return nil, err
+ }
+ return triple_protocol.NewResponse(res), nil
+ },
+ },
+ },
+}
diff --git a/start_integrate_test.sh b/start_integrate_test.sh
index 511d4981..f5227e97 100755
--- a/start_integrate_test.sh
+++ b/start_integrate_test.sh
@@ -36,6 +36,7 @@ array+=("filter/custom")
# registry
array+=("registry/zookeeper")
array+=("registry/nacos")
+array+=("registry/polaris")
array+=("generic")
@@ -74,7 +75,6 @@ array+=("tls")
array+=("async")
# polaris
-array+=("compatibility/polaris/registry")
array+=("compatibility/polaris/limit")
# error
