我一直在玩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
}
基本上,我只是设置了两个回声服务器,一个为每个组件。
为了它的价值,这是我的配置:
[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" }
当我在单个进程中运行它时,一切似乎都按预期工作。我看到了Web请求的日志条目,表明一切正常。当我在部署模式下运行它时(即,实际上执行多进程魔术),我只能发出1-2个请求,然后才能看到如下日志条目,然后响应通常不起作用:
2023/09/14 21:35:51 http: proxy error: context canceled
看起来我做错了什么,但这似乎是一个用例,将以某种方式得到支持,所以我想知道是否有一个适当的方法来解决这个问题。
谢谢你,谢谢
1条答案
按热度按时间pcrecxhr1#
tl;drService Weaver目前还没有一个很好的方法来从非主组件运行HTTP服务器。我建议您将两个侦听器都移动到
Server
结构体中,并在serve
函数中运行两个HTTP服务器。HTTP服务器可以调用其他组件上的方法。详情
weaver multi
部署器将每个组件复制两次,每个副本都在自己的操作系统进程中运行。考虑一下当APIServer
组件在端口12345上请求网络侦听器时会发生什么。APIServer
组件的两个副本不能同时侦听端口12345;只有一个OS进程可以在端口上侦听。为了解决这个问题,两个副本分别监听一个随机选择的端口,比如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
运行应用程序时,事情是正常的,因为没有代理,而且组件没有被复制。