所以目前我正在与RabbitMQ和Golang合作。我在RabbitMQ主页上开始了教程，并创建了队列和交换。但是我找不到任何教程来解释如何在Golang中实现Exchange头。
浏览 3提问于2021-04-21得票数 1
回答已采纳
我正在编写一个简单的聊天应用程序，使用在Go中实现的gRPC服务器。type Server struct {}
conn := &Connection{ id: p
浏览 4提问于2022-11-17得票数 0
我正在使用Kubernetes golang operator sdk实现一个管理RabbitMQ队列的操作符。我想知道k8s是否有办法在我的自定义资源上强制特定规范字段的不变性。我有以下golang结构，它表示一个rabbitMQ队列和一些参数，以便将其绑定到rabbitMQ交换： VHost string `jsonSecretConfig map[string]string `json:"secretConfig"`我之所以想要不
浏览 49提问于2019-06-25得票数 3
回答已采纳
在golang中，调用C库的方式与PHP / Python / Java等其他大型机动态语言中使用的方法不同，因为Golang有不同的多任务处理机制，而不是基于OS线程，因此，如我所理解，调用c函数可能导致上下文切换或线程切换在我的项目中，我尝试使用Golang中的Judy (作为队列工作人员)来做一些简单但数量大的与dict相关的计算，比如"select distinct"，所以
使用这种c(相对较高的密度计算)并尽可能减少引入的性能开销的最佳实践是什么
浏览 7提问于2013-12-27得票数 1
回答已采纳
特别是，我在C++中有一些阻塞队列，我想等到它们中的任何一个都有我可以弹出的项。Golang是否实现了一些我可以在自己的C++代码中实现的更优雅的机制？
浏览 0提问于2016-05-04得票数 8
2回答
我正在研究纯在Golang的后端架构。我有一个API，用于将文件上传到golang服务器，然后将文件传输到云存储(从golang服务器本身)。End User -> Golang Server ->[Concurrency/Parallelism] -> Cloud Storage
一旦用户完成上传并将文件传输到云将文件处理程序插入队列中，另一个进程将读取该队列并将文件传输到云存储(多个生产者-单一消费者模型)。正如注释中指出的，
浏览 7提问于2015-12-13得票数 2
回答已采纳
由于golang在单独的goroutines中处理传入的请求，因此我不清楚哪些类型的任务应该被消息队列(例如NSQ使用者)延迟处理，哪些任务应该在http请求goroutine中处理。
浏览 2提问于2015-04-17得票数 2
回答已采纳
2回答
我使用Go包github.com/golang/protobuf/proto，在这里我需要将Protobuff加入到存储队列中。但是，根据库文档，Enqueue函数只将消息作为字符串。visibilityTimeout time.Duration, timeToLive time.Duration) (*EnqueueMessageResponse, error)*
有没有办法将原型字节数组排队到Azure存储队列
浏览 2提问于2021-06-02得票数 0
，它将消息写入发送缓冲区队列并立即返回。但是，写入内部缓冲区队列并不能保证消息传递成功。我们如何确保在这里成功地传递信息？word := range []string{"Welcome", "to", "the",
"Confluent", "Kafka", "Golang
浏览 15提问于2022-07-20得票数 1
我有一个lambda函数，它响应调用它的两个不同的SQS队列(第二个是一个后退队列)，因此我想动态地确定消息来自哪个队列，这样一旦消息被处理，我就可以删除它。我能够创建从两个队列触发lambda的EventSourceMapping，但是我看不到如何干净地检索执行DeleteMessage调用所需的QueueURL。我正在使用AWS Golang SDK。避免这种情况的唯一方法(我能想到的)是将两个队列URL作为环境变量传递，并使用EventSourceArn中的队列名
浏览 15提问于2021-08-12得票数 1
回答已采纳
我正试着用来测试我的golang /http服务器。当我使用2048个虚拟用户访问我的aws服务器时，k6抛出“由对等方重置连接”。在互联网上的调查中，我发现可能是积压队列的问题。修改为1024之后，当我运行我的主go程序时： "fmt" "net/http" "golang.orghttp.ListenAndSer
浏览 0提问于2019-01-20得票数 0
回答已采纳
我的期望是，如果一条消息在一次订阅中重新发送超过5次，该消息将自动从订阅队列中删除。但是它并没有发生，消息仍然在队列中无限循环。当我打印属性deliveryAttempt时，值始终为空。我使用的是golang，google pubsub版本1.3.1
浏览 18提问于2020-05-09得票数 0
使用案例:逐个读取百万级数据，并将其发送到优先级队列。我只想要前5个计算出的元素，所以我只想要一个大小为5的堆/优先级队列。我指的是
我如何才能做到这一点？
浏览 15提问于2018-03-02得票数 5
回答已采纳
我无法让appengine任务队列接受我抛出的任何上下文： "context" "google.golang.org
浏览 1提问于2019-05-22得票数 3
目前，对于每个触发器，我们都连接到队列，并在延迟(Golang)上关闭连接。如果是，有哪些可供选择的方案？
浏览 1提问于2021-02-19得票数 1
回答已采纳
我负责维护一个用Golang编写的生产软件，它使用RabbitMq作为消息队列。
每个发布者或使用者都有自己的连接，以及各自的通道，它们在一个无限循环中工作，并且永不消亡。所有队列都是持久的，autoDelete、exclusive和noWait都设置为false。基本假设是，队列中的每条消息都将被传递给一个并且只有一个使用者，因此每条消息都将
浏览 0提问于2018-01-23得票数 2
我在我的程序中使用。在重新初始化之前，我应该如何确保用于消费和/或生产的通道仍在工作？bunny_client = Bunny.new({....})来启动客户端，并且 # re-initialize the client
浏览 1提问于2013-06-14得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
对象存储
云直播活动推荐
腾讯云开发者
