草庐IT

消息中间件

全部标签

go - 将一个客户端的消息反射(reflect)到 Websocket (golang) 上的另一个客户端

我在后端使用websockets时遇到问题。我必须用golang和旧开发人员使用websocket重写一些旧的,同时一个客户端跟踪另一个客户端的位置。两个客户端都使用给定的url连接websocket"\(URLConstants.webSocketURL)?token=\(token)&jobId=\(jobId)"所以我认为两个客户端都使用她/他自己的token连接websocket,我需要将用户的消息反射(reflect)给其他用户。我可以用给定的url打开两个套接字。这是我第一次使用websocket,所以我不确定我问的问题是否正确。 最佳答案

go - 在 Gorilla mux 处理后运行中间件

我正在尝试使用Golang中间件在处理GorillaMux路由后运行,以便更改每个请求的响应。代码示例见下文。目前它返回“之前运行,运行测试”,目标是使用runsafter中间件返回“之前运行,运行测试,之后运行”。GorillaMux可以实现这样的功能吗?packagemainimport("fmt""github.com/gorilla/mux""net/http")funcrunsbefore(hhttp.Handler)http.Handler{fn:=func(whttp.ResponseWriter,r*http.Request){w.Write([]byte("runbe

go - 带有两个外键的中间模型 : file structure?

目标是创建一个中间模型(user_product),它有两个外键:user和product。我们能否通过外部文件(以某种方式)中的用户和产品结构来实现这一点,或者我们必须将它们与UserProduct放在同一个文件中,就像在文档中一样?此时,将它们放在外部并在UserProduct中导入它们,当然会抛出导入循环错误。结构:app/models/product.gouser.gouser_product.go问题是,如果我使用import"github.com/somehow/somehow/models"在user_product中导入product.go,显然它还导入了user_pr

Golang 请求中间件库?

我正在为我的路由设置的复用器使用gorilla复用器。是否有任何开源库可以提供某种请求中间件?router.HandleFunc("/products",GetProducts).Methods("GET")所以目前我有GetProducts函数,它将返回产品等。但这是我正在构建的RESTapi,所以我必须处理加载用户、验证请求的“apitoken”等事情。我不想对每个方法都这样做,所以我希望我有一些请求中间件,当我可以在执行之前/之后执行此操作时,以及添加诸如User之类的东西,权限每个中间件函数中的上下文。 最佳答案 您可以使用

Goroutines 和消息去重

所以我有一些事件队列和几个goroutine,它们在无限循环中从相应的队列中获取事件,处理它们,然后将结果发送到channel中。不同的队列可能会给你相同的事件,所以我需要确保每个事件都被发送到channel一次,并且该消息在另一个队列中的任何出现都将被忽略。我认为这更像是一个架构问题,但我不知道如何正确处理。我当前代码的简化版本如下。获取和处理传入事件的Goroutine看起来有点像这样:func(q*Queue)ProcessEvents(handlerHandler){lastEvent=0for{events=getEvents(lastEvent)for_,e:=rangee

json - 作为发送到 Amazon SNS 的嵌套信息的一部分,在消息响应中获取多个反斜杠 - 我是否遗漏了什么?

我在下面编写的用于将信息发送到AmazonSNS的golang客户端脚本收到以下消息响应:消息响应:{\"recipient\":\"test20@test.com\",\"template\":\"welcome_email_v1\",\"type\":\"email\",\"source\":\"noreply@sender.co\",\"user\":{\"first_name\":\"\\\"tester\\\"\",\"last_name\":\"\\\"M\\\"\"}}"我不太确定作为first_name和last_name的嵌套user散列的一部分的多个反斜杠是否作为以

go - 将变量从中间件传递到结束函数

我正在使用中间件(CheckToken)来检查JWT并获取自定义声明(Id)(它将是我数据库中用户的ID)但是我需要将它传递给campaign.Attack(这样我就可以知道谁是进行“攻击”的用户),但我无法找到一种方法来做到这一点。我试图将它作为参数传递给token.go中的next(w,req,claim.id)但我需要触摸http.HandlerFunc函数,所以这不是一个有效的选项。关于如何将claim.id从CheckToken传递到campaign.Attack()有什么想法吗?谢谢*****main.go*****funcmain(){router:=mux.NewRou

go - 我有一个在 Kubernetes 上运行的 Golang 应用程序,但是当 pod 死亡时根本没有错误消息。我应该怎么办?

如题。当我运行kubectllogsmy-go-app-deployment-1967699436-yxxn7或kubectllogsmy-go-app-deployment-1967699436-yxxn7-p时,根本没有错误日志打印出来。我该怎么办?是什么导致Golangpod崩溃? 最佳答案 首先,您应该检查pod以了解它死亡的原因以及它是否重新启动。kubectldescribepodmy-go-app-deployment-1967699436-yxxn7在Containers->yourcontainer->LastSt

go - 当我传递中间件配置时,如何允许 Buffalo (gobuffalo) 中间件使用 skip() 方法?

我正在尝试创建一个接受正在运行的配置的自定义Buffalo(gobuffalo)中间件。问题是我无法通过此错误跳过中间件功能:actions/app.go:63:22:不能在app.Middleware.Skip的参数中使用myMiddlewareFunc(类型func(myConfig)buffalo.MiddlewareFunc)作为类型buffalo.MiddlewareFunc到目前为止我得到的代码是:packageactionsimport("github.com/gobuffalo/buffalo""github.com/gobuffalo/buffalo/middlewa

go - emersion/go-imap - 将消息标记为可见

我正在尝试使用此IMAP协议(protocol)实现将消息标记为可见,但它没有按预期工作。我有一个打印看不见的消息的功能,我的意图是到最后,它将每条消息标记为已看到。packagemainimport("emailmonitor/util""fmt")funcmain(){serverGmail:=util.NewServerGmail()serverGmail.Connect()serverGmail.Login()serverGmail.ListUnseenMessages()}//-----------------------------------------packageut