您好，登录后才能下订单哦！
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
这篇“Golang基于泛化调用与Nacos实现Dubbo代理的方法是什么”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“Golang基于泛化调用与Nacos实现Dubbo代理的方法是什么”文章吧。
由于是通用的 dubbo 代理，因此肯定需要使用泛化调用。而我们使用的注册中心是 nacos，因此也需要使用 nacos-sdk 来获取 provider 的实例信息。
│
├── dubbo/
│ ├─ generic.go # 泛化调用 dubbo 接口
│ ├─ models.go # 数据模型
│ └─ nacos.go # 获取 nacos 元信息
├── web/
│ └─ server.go # 对外 http 接口
│
├── main.go # main 入口函数
└── go.mod # 模块描述文件
module dubbo-proxy go 1.20 require ( dubbo.apache.org/dubbo-go/v3 v3.0.5 github.com/apache/dubbo-go-hessian2 v1.12.0 github.com/gin-gonic/gin v1.9.0 github.com/nacos-group/nacos-sdk-go/v2 v2.1.2 )
dubbo/models.go:
type DataResult struct {
Env string `json:"env,omitempty"` // 当前调用环境
Code string `json:"code,omitempty"` // 返回结果码
Data any `json:"data,omitempty"` // 返回结果
Message string `json:"message,omitempty"` // 返回消息
}根据环境创建 nacos client
func buildClient(env string, serverCfgs []constant.ServerConfig) naming_client.INamingClient {
client, _ := clients.NewNamingClient(
vo.NacosClientParam{
ClientConfig: constant.NewClientConfig(
constant.WithNamespaceId(env),
constant.WithNotLoadCacheAtStart(true),
),
ServerConfigs: serverCfgs,
},
)
return client
}获取服务实例
func SelectInstance(env, servName string) (string, bool) {
cli, ok := cliMap[env]
if !ok {
return "client not found from " + env, false
}
instances, e := cli.SelectInstances(vo.SelectInstancesParam{
ServiceName: fmt.Sprintf("providers:%s:1.0.0:", servName),
HealthyOnly: true,
})
if e != nil {
return "instance not found, " + e.Error(), false
}
if len(instances) <= 0 {
return "instance not found", false
}
return fmt.Sprintf("dubbo://%s:%d", instances[0].Ip, instances[0].Port), true
}完整代码
dubbo/nacos.go:
package dubbo
import (
"fmt"
"github.com/nacos-group/nacos-sdk-go/v2/clients"
"github.com/nacos-group/nacos-sdk-go/v2/clients/naming_client"
"github.com/nacos-group/nacos-sdk-go/v2/common/constant"
"github.com/nacos-group/nacos-sdk-go/v2/vo"
)
var cliMap = make(map[string]naming_client.INamingClient)
func init() {
serverCfgs := []constant.ServerConfig{
*constant.NewServerConfig("127.0.0.1", 6801, constant.WithContextPath("/nacos")),
}
cliMap["local"] = buildClient("local", serverCfgs)
cliMap["dev"] = buildClient("develop", serverCfgs)
cliMap["test"] = buildClient("test", serverCfgs)
}
func buildClient(env string, serverCfgs []constant.ServerConfig) naming_client.INamingClient {
client, _ := clients.NewNamingClient(
vo.NacosClientParam{
ClientConfig: constant.NewClientConfig(
constant.WithNamespaceId(env),
constant.WithNotLoadCacheAtStart(true),
),
ServerConfigs: serverCfgs,
},
)
return client
}
func SelectInstance(env, servName string) (string, bool) {
cli, ok := cliMap[env]
if !ok {
return "client not found from " + env, false
}
instances, e := cli.SelectInstances(vo.SelectInstancesParam{
ServiceName: fmt.Sprintf("providers:%s:1.0.0:", servName),
HealthyOnly: true,
})
if e != nil {
return "instance not found, " + e.Error(), false
}
if len(instances) <= 0 {
return "instance not found", false
}
return fmt.Sprintf("dubbo://%s:%d", instances[0].Ip, instances[0].Port), true
}dubbo root 配置
var dubboRoot = cfg.NewRootConfigBuilder().SetProtocols(map[string]*cfg.ProtocolConfig{
dubbo.DUBBO: {
Params: map[string]interface{}{
"getty-session-param": map[string]interface{}{
"max-msg-len": 1024000,
},
},
},
}).Build()泛化调用
func GenericInvoke(iName, method, env string, req []byte) DataResult {
instance, ok := SelectInstance(env, iName)
if !ok {
return DataResult{
Code: "ERROR",
Message: instance,
}
}
cfg.Load(cfg.WithRootConfig(dubboRoot))
refConf := cfg.ReferenceConfig{
InterfaceName: iName,
Cluster: "failover",
Protocol: dubbo.DUBBO,
Generic: "true",
Version: "1.0.0",
URL: instance,
}
refConf.Init(dubboRoot)
refConf.GenericLoad("dubbo-proxy")
var args = utils.Unmarshal(req, &map[string]hessian.Object{})
raw, err := refConf.GetRPCService().(*generic.GenericService).Invoke(context.Background(), method, nil, []hessian.Object{args})
if err != nil {
panic(err)
}
rawResult := raw.(map[interface{}]interface{})
result := DataResult{
Code: rawResult["code"].(string),
Message: rawResult["message"].(string),
Data: utils.ConvertAs(rawResult["data"], map[string]interface{}{}),
}
return result
}注意25-30行要根据业务自身的返回数据格式包装结果：
/*
这个例子的 dubbo 调用都会返回通过的结构：
{
"code": "",
"message": "",
"data": // 真正的调用结果
}
*/
rawResult := raw.(map[interface{}]interface{})
result := DataResult{
Code: rawResult["code"].(string),
Message: rawResult["message"].(string),
Data: rawResult["data"],
}完整代码
dubbo/generic.go:
package dubbo
import (
"context"
"dubbo-proxy/utils"
cfg "dubbo.apache.org/dubbo-go/v3/config"
"dubbo.apache.org/dubbo-go/v3/config/generic"
_ "dubbo.apache.org/dubbo-go/v3/imports"
"dubbo.apache.org/dubbo-go/v3/protocol/dubbo"
hessian "github.com/apache/dubbo-go-hessian2"
)
var dubboRoot = cfg.NewRootConfigBuilder().SetProtocols(map[string]*cfg.ProtocolConfig{
dubbo.DUBBO: {
Params: map[string]interface{}{
"getty-session-param": map[string]interface{}{
"max-msg-len": 1024000,
},
},
},
}).Build()
func GenericInvoke(iName, method, env string, req []byte) DataResult {
instance, ok := SelectInstance(env, iName)
if !ok {
return DataResult{
Code: "ERROR",
Message: instance,
}
}
cfg.Load(cfg.WithRootConfig(dubboRoot))
refConf := cfg.ReferenceConfig{
InterfaceName: iName,
Cluster: "failover",
Protocol: dubbo.DUBBO,
Generic: "true",
Version: "1.0.0",
URL: instance,
}
refConf.Init(dubboRoot)
refConf.GenericLoad("dubbo-proxy")
var args = utils.Unmarshal(req, &map[string]hessian.Object{})
raw, err := refConf.GetRPCService().(*generic.GenericService).Invoke(context.Background(), method, nil, []hessian.Object{args})
if err != nil {
panic(err)
}
rawResult := raw.(map[interface{}]interface{})
result := DataResult{
Code: rawResult["code"].(string),
Message: rawResult["message"].(string),
Data: utils.ConvertAs(rawResult["data"], map[string]interface{}{}),
}
return result
}dubbo/generic.go:
package web
import (
"dubbo-proxy/dubbo"
"github.com/gin-gonic/gin"
"net/http"
)
func Run() {
router := gin.Default()
router.POST("/:intf/:method", func(c *gin.Context) {
intf := c.Param("intf")
method := c.Param("method")
env := c.Query("env")
data, err := c.GetRawData()
if err != nil {
panic(err)
}
res := dubbo.GenericInvoke(intf, method, env, data)
res.Env = env
c.JSON(http.StatusOK, res)
})
panic(router.Run(":7788"))
}main.go:
package main
import "dubbo-proxy/web"
func main() {
web.Run()
}
以上就是关于“Golang基于泛化调用与Nacos实现Dubbo代理的方法是什么”这篇文章的内容，相信大家都有了一定的了解，希望小编分享的内容对大家有帮助，若想了解更多相关的知识内容，请关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。