php小编小新在这里为大家介绍如何使用Service Weaver来设置多个不同侦听器的问题。Service Weaver是一个功能强大的工具，它允许开发人员创建和管理多个服务。通过设置不同的侦听器，我们可以实现对不同的服务进行监控和管理。在本文中，我们将详细讨论如何使用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 设置多个不同侦听器的问题的详细内容，更多请关注每日运维网(www.mryunwei.com)其它相关文章！
