jjzjj

microservices

全部标签

go - 一元与流基准

我开始使用一些GRPC和Golang微服务应用程序。在阅读了GRPC文档后,我有些不清楚:WhentouseUnaryandwhentouseStreaming?我的意思是,例如,我正在构建一个微服务,它将解析XLS并将JSON返回到stub。我将使用第三方库为我解析它。所以,我的工作是接收xls,调用lib并将其转发。很简单。我能达到的最佳实践/表现是什么?使用流逐行发送()或一次发送整个解析的json? 最佳答案 发送一元几乎总是更快。使用流式传输大文件。 关于go-一元与流基准,我

go - 一元与流基准

我开始使用一些GRPC和Golang微服务应用程序。在阅读了GRPC文档后,我有些不清楚:WhentouseUnaryandwhentouseStreaming?我的意思是,例如,我正在构建一个微服务,它将解析XLS并将JSON返回到stub。我将使用第三方库为我解析它。所以,我的工作是接收xls,调用lib并将其转发。很简单。我能达到的最佳实践/表现是什么?使用流逐行发送()或一次发送整个解析的json? 最佳答案 发送一元几乎总是更快。使用流式传输大文件。 关于go-一元与流基准,我

go - 如何使用 Golang 设计多文件处理器?

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭5年前。Improvethisquestion我正在尝试弄清楚如何设计一种可以处理多种文件格式的服务,例如使用微服务:我有一个客户使用文件格式A,另一个使用格式B,另一个使用格式C。在为每个客户处理特定格式后,我需要将这种格式转换为通用格式,并插入数据库。我尝试的第一件事是为每个客户设计一个服务,但他们都需要知道基本格式,如果需要更新此基本格式,我需要更新所有服务。我正在尝试分离服务处理器,并在一个地方转换为基本格式。如果我的客户服务知道基本格式,如

go - 如何使用 Golang 设计多文件处理器?

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭5年前。Improvethisquestion我正在尝试弄清楚如何设计一种可以处理多种文件格式的服务,例如使用微服务:我有一个客户使用文件格式A,另一个使用格式B,另一个使用格式C。在为每个客户处理特定格式后,我需要将这种格式转换为通用格式,并插入数据库。我尝试的第一件事是为每个客户设计一个服务,但他们都需要知道基本格式,如果需要更新此基本格式,我需要更新所有服务。我正在尝试分离服务处理器,并在一个地方转换为基本格式。如果我的客户服务知道基本格式,如

csv - 从 go-kit golang 中的 API 请求解析 CSV 文件

我正在尝试构建一项服务,该服务从POST请求中获取用户输入的文件,然后迭代CSV并将其传递到我的数据库中。我在传递文件和阅读文件时遇到问题。以下是我的代码。端点.gotypeCSVRequeststruct{Fileio.Reader}funcMakeCSVEndpoint(svcService)endpoint.Endpoint{returnfunc(ctxcontext.Context,requestinterface{})(interface{},error){req:=request.(CSVRequest)data,err:=svc.ReadCSV(req.File)ifer

csv - 从 go-kit golang 中的 API 请求解析 CSV 文件

我正在尝试构建一项服务,该服务从POST请求中获取用户输入的文件,然后迭代CSV并将其传递到我的数据库中。我在传递文件和阅读文件时遇到问题。以下是我的代码。端点.gotypeCSVRequeststruct{Fileio.Reader}funcMakeCSVEndpoint(svcService)endpoint.Endpoint{returnfunc(ctxcontext.Context,requestinterface{})(interface{},error){req:=request.(CSVRequest)data,err:=svc.ReadCSV(req.File)ifer

go - 使用 Go Micro 从一个经纪人消费并生产到另一个经纪人

我正在尝试使用GoMicro框架编写一个微服务,该框架将从RabbitMQ代理消费并写入另一个。GoMicro有一个RabbitMQ插件,但似乎如果想使用GoMicro抽象(例如micro.RegisterSubscriber),就必须依赖许多内部的全局状态图书馆。我最终使用micro.RegisterSubscriber设置了一个消费者,然后手动创建一个单独的代理,注意不要使用任何内部全局状态(例如默认交换),然后调用broker.Publish在消费者函数中,这意味着我必须在发送消息之前手动编码消息。GoMicro不支持这种模式吗?有没有更好的方法来做这样的事情?我应该提到,在这种

go - 使用 Go Micro 从一个经纪人消费并生产到另一个经纪人

我正在尝试使用GoMicro框架编写一个微服务,该框架将从RabbitMQ代理消费并写入另一个。GoMicro有一个RabbitMQ插件,但似乎如果想使用GoMicro抽象(例如micro.RegisterSubscriber),就必须依赖许多内部的全局状态图书馆。我最终使用micro.RegisterSubscriber设置了一个消费者,然后手动创建一个单独的代理,注意不要使用任何内部全局状态(例如默认交换),然后调用broker.Publish在消费者函数中,这意味着我必须在发送消息之前手动编码消息。GoMicro不支持这种模式吗?有没有更好的方法来做这样的事情?我应该提到,在这种

docker - 如何为微服务应用程序配置 docker 公开端口?

请问,学习过go-micro,知道微服务客户端不需要知道微服务部署在哪个ip和端口。服务自己运行时,端口是随机设置的,服务由其服务名称定位,如go.micro.api.user。服务端运行如下:userService:=micro.NewService(micro.Name("go.micro.api.user"))userService.Init()user.RegisterUserHandler(userService.Server(),new(User),api.WithEndpoint(&api.Endpoint{Name:"User.GetToken",Path:[]stri

docker - 如何为微服务应用程序配置 docker 公开端口?

请问,学习过go-micro,知道微服务客户端不需要知道微服务部署在哪个ip和端口。服务自己运行时,端口是随机设置的,服务由其服务名称定位,如go.micro.api.user。服务端运行如下:userService:=micro.NewService(micro.Name("go.micro.api.user"))userService.Init()user.RegisterUserHandler(userService.Server(),new(User),api.WithEndpoint(&api.Endpoint{Name:"User.GetToken",Path:[]stri