如何为多个不同侦听器设置 Service Weaver

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《如何为多个不同侦听器设置 Service Weaver》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

我一直在使用 Service Weaver，它已经发布了一段时间，并且很好奇我们应该如何使用它设置多个侦听器。我的意图是，当我们部署应用程序时，web 的处理程序和 api 的处理程序单独运行（作为示例）。我的代码目前如下：

package main

import (
    "context"
    "log"
    "sync"

    "github.com/ServiceWeaver/weaver"
    "github.com/labstack/echo/v4"
    "github.com/labstack/echo/v4/middleware"
)

type Server struct {
    weaver.Implements[weaver.Main]
    apiServer weaver.Ref[APIServer]
    webServer weaver.Ref[WebServer]
}

type APIServer interface {
    Serve(context.Context) error
}

type apiServer struct {
    weaver.Implements[APIServer]
    api weaver.Listener
}

func (a apiServer) Serve(ctx context.Context) error {
    logger := a.Logger(ctx)
    e := echo.New()
    e.Listener = a.api

    e.Use(middleware.RequestID())

    e.Use(middleware.RequestLoggerWithConfig(middleware.RequestLoggerConfig{
        LogStatus: true,
        LogURI:    true,
        LogValuesFunc: func(c echo.Context, v middleware.RequestLoggerValues) error {
            logger.Info("Request", "id", v.RequestID, "uri", v.URI, "status", v.Status, "size", v.ResponseSize)
            return nil
        },
    }))

    return e.Start("")
}

type WebServer interface {
    Serve(context.Context) error
}

type webServer struct {
    weaver.Implements[WebServer]
    web weaver.Listener
}

func (w webServer) Serve(ctx context.Context) error {
    logger := w.Logger(ctx)
    e := echo.New()
    e.Listener = w.web

    e.Use(middleware.RequestID())

    e.Use(middleware.RequestLoggerWithConfig(middleware.RequestLoggerConfig{
        LogStatus: true,
        LogURI:    true,
        LogValuesFunc: func(c echo.Context, v middleware.RequestLoggerValues) error {
            logger.Info("Request", "id", v.RequestID, "uri", v.URI, "status", v.Status, "size", v.ResponseSize)
            return nil
        },
    }))

    return e.Start("")
}

func main() {
    if err := weaver.Run(context.Background(), serve); err != nil {
        log.Fatal(err)
    }
}

func serve(ctx context.Context, server *Server) error {
    wg := sync.WaitGroup{}
    wg.Add(2)

    go func() {
        defer wg.Done()
        server.apiServer.Get().Serve(context.Background())
    }()

    go func() {
        defer wg.Done()
        server.webServer.Get().Serve(context.Background())
    }()

    wg.Wait()

    return nil
}

基本上，我只是设置两个 Echo 服务器，每个组件一个。

对于它的价值，这是我的配置：

[serviceweaver]
binary = "./platform"

[multi]
listeners.api = { address = "localhost:12345" }
listeners.web = { address = "localhost:54321" }

[single]
listeners.api = { address = "localhost:12345" }
listeners.web = { address = "localhost:54321" }

当我在单个进程中运行它时，一切似乎都按预期进行。我看到网络请求的日志条目，表明一切正常。当我在部署模式下运行它时（即，实际上执行多进程魔法），我只能发出 1-2 个请求，然后才能看到如下所示的日志条目，然后响应不会经常起作用：

2023/09/14 21:35:51 http: proxy error: context canceled

看起来我做错了什么，但似乎这是一个会以某种方式支持的用例，所以我想知道是否有适当的方法来解决这个问题。

谢谢！

正确答案

tl;dr Service Weaver 当前没有从非主要组件运行 HTTP 服务器的好方法。我建议您将两个侦听器移至 Server 结构，并在 Serve 函数内运行两个 HTTP 服务器。 HTTP 服务器可以调用其他组件上的方法。

type Server struct {
    weaver.Implements[weaver.Main]
    api weaver.Listener
    web weaver.Listener
}

详细信息

weaver multi 部署程序将每个组件复制两次，每个副本都在自己的操作系统进程中运行。考虑当 APIServer 组件请求端口 12345 上的网络侦听器时会发生什么。 APIServer 组件的两个副本不能同时侦听端口 12345；只有一个操作系统进程可以侦听该端口。为了解决这个问题，两个副本分别侦听随机选择的端口，例如 8000 和 9000。然后 weaver multi 部署程序在端口 12345 上运行 HTTP 代理，将请求转发到端口 8000 和 9000。

在您的应用程序中，主 Server 组件被复制两次，并且 Serve 函数运行两次，每个副本运行一次。在 Serve 内部，当您调用 apiServer.Get().Serve(context.Background()) 时，会随机选择 APIServer 的副本来执行 Serve 方法。如果幸运的话，这两个方法调用被发送到两个不同的副本，那么一切都应该顺利运行。但是，如果两个方法调用都发送到同一个副本，则 APIServer 的一个副本正在运行 HTTP 服务器，而另一个则没有。

在这种情况下，代理会将所有请求的一半转发到正在运行的 HTTP 服务器，并将另一半请求转发到未侦听的侦听器。这会导致您看到代理错误。

最后请注意，当您使用 go run 或 weaver single deploy 运行应用程序时，一切正常，因为没有代理，并且组件不会被复制。

今天关于《如何为多个不同侦听器设置 Service Weaver》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！