amqp相关内容

如何使用 python 在 RabbitMQ 交换中列出或发现队列?

我需要一个 python 客户端，它可以在重新启动的 RabbitMQ 服务器交换上发现队列，然后启动一个客户端以恢复使用每个队列中的消息.如何从一些 RabbitMQ 兼容的 python api/library 中发现队列? 解决方案 据我所知，没有任何方法可以做到这一点.这与 Python 无关，而是因为 AMQP 没有定义任何队列发现方法. 无论如何，在 AMQP 中，声明队 ..
发布时间：2021-11-27 11:44:56 Python

Objective-C RabbitMQ 客户端不向队列发布消息

我正在尝试使用 RabbitMQ for iOS 制作消息传递应用程序.我将这个包装类用于目标 c，以及 RabbitMQ-C 客户端库. https://github.com/profmaad/librabbitmq-objc 交换、队列和队列绑定一切正常，但我的代码没有将消息发布到 RabbitMQ 服务器.请帮帮我，有什么问题吗? 这是我的代码: NSError *er ..
发布时间：2021-11-27 11:44:38 移动开发

消息、队列和交换的限制是什么?

允许的消息类型有哪些(字符串、字节、整数等)? 消息的最大大小是多少? 队列和交换的最大数量是多少? 解决方案 理论上任何东西都可以作为消息存储/发送.您实际上不想在队列中存储任何内容.如果队列大部分时间都是空的，则系统的工作效率最高.您可以使用两个先决条件将任何您想要的内容发送到队列: 您发送的内容可以与字节串相互转换 消费者确切地知道它得到了什么以及如何将其转换为原始对 ..
发布时间：2021-11-27 11:44:19 其他开发

面向服务的架构 - AMQP 或 HTTP

一点背景. 非常大的单体 Django 应用程序.所有组件都使用相同的数据库.我们需要将服务分开，以便我们可以独立升级系统的某些部分而不影响其余部分. 我们使用 RabbitMQ 作为 Celery 的代理. 现在我们有两个选择: 使用 REST 接口的 HTTP 服务. 通过 AMQP 的 JSONRPC 到事件循环服务 我的团队倾向于使用 HTTP，因为这是他们 ..
发布时间：2021-11-27 11:44:00 其他开发

RabbitMQ/AMQP:单个队列，同一消息的多个消费者?

我刚刚开始使用 RabbitMQ 和 AMQP. 我有一个消息队列 我有多个消费者，我想用相同的消息做不同的事情. 大多数 RabbitMQ 文档似乎都集中在轮询机制上，即单个消息由单个消费者消费，负载分布在每个消费者之间.这确实是我亲眼所见的行为. 一个例子:生产者有一个队列，每 2 秒发送一次消息: var amqp = require('amqp');var conne ..
发布时间：2021-11-27 11:43:44 其他开发

微服务、amqp 和服务注册/发现

我正在研究微服务架构，实际上我在想一些事情. 我非常同意使用(返回)服务发现来使请求能够在基于 REST 的微服务上进行.我需要知道发出请求的服务(或至少是服务器集群的前端)在哪里.因此，在这种情况下能够发现 ip:port 是有意义的. 但我想知道在处理 AMQP(仅基于，没有 HTTP 可能调用)时使用服务注册/发现的目的是什么? 我的意思是，使用 AMQP 就像“我需要那个 ..
发布时间：2021-11-17 02:47:33 其他开发

使用 http api 发布到默认的 rabbitmq 交换

所以我使用rabbitmqs http api 在rabbit 中做一些非常基本的动作.它在大多数情况下都很好用，但我在弄清楚如何使用它向默认的 rabbitmq 交换发布消息时遇到了问题.此交换始终存在，无法删除，并且绑定到每个队列，其路由键等于队列名称. 我的问题是这个队列没有名字，或者更确切地说，它的名字是一个空字符串“".我必须用来通过 HTTP api 发布此消息的 URL 包含交 ..
发布时间：2021-11-15 02:10:27 其他开发

无法按优先级顺序获取消息 Spring camel rabbitmq

我是spring camel rabbitmq的初学者. 我可以通过在生产者端的交换头中设置消息头中的消息优先级，如下所示: exchange.getOut().setHeader("rabbitmq.PRIORITY", 1); 但是在使用消息时，它们并没有按优先级顺序排列.帮助！！ 我可以在 rabbitmq 的 Web 界面中看到，优先级标头已适当设置 解决方案 解决 ..
发布时间：2021-11-11 23:15:55 其他开发

如何使用 AMQP 协议连接到 Nginx 反向代理后面的 RabbitMQ

我有一个用 C# 构建的客户端应用程序，它使用 AMQP 与 RabbitMQ 通信，但由于消息代理被移到 Nginx 反向代理后面，它停止工作.我如何配置 Nginx 以使用 AMQP，如果不可能，我有哪些替代方案? 解决方案 Nginx 可以配置为负载平衡 TCP 和 UDP，因此您可以配置 nginx 进行 tcp 负载平衡，并以类似于代理 HTTP 的方式使用它.此处链接到文档:h ..
发布时间：2021-07-02 18:42:05 其他开发

使用brew在Mac上安装amqp

我想用pecl为我的mac sierra安装 amqp . 我用brew安装php，并用 pecl install amqp 收到错误:使用pkg-config检查amqp ...配置:错误:找不到librabbitmq 我在brew中安装了 librabbitmq-c 软件包，但仍然收到此错误.我认为某种程度上它与pkg-config不同步. 有人知道在这里做什么吗? 解 ..
发布时间：2021-05-14 19:14:00 PHP

tls:使用streadway/amqp为RabbitMQ启用tls时握手失败

我正在尝试使用streadway/amqp在Go中使用 amqps://连接到RabbitMQ.我可以成功连接 amqp://.启用TLS并使用 amqps://时，出现以下错误: panic:远程错误:tls:握手失败 RabbitMQ在docker中运行时具有以下环境变量和设置: 环境:RABBITMQ_SSL_CACERTFILE:/ca_certificate.pemRABBIT ..
发布时间：2021-05-11 19:57:12 其他开发

amqp协议对等

我尝试使用amqpnetlite来对等发送消息.我使用以下代码: amqpnetlite点对点.我的问题是:我应该使用amqp经纪人吗?这里是确切的代码: 字符串地址="amqp://guest:guest@127.0.0.1:5672";Uri addressUri =新的Uri(地址);ContainerHost主机=新的ContainerHost(新的Uri [] {addressUri} ..
发布时间：2021-04-03 20:05:25 C#/.NET

芹菜消耗send_task响应

在Django应用程序中，我需要调用在Windows服务器上运行并在其中使用django应用程序在linux服务器上运行的外部应用程序的外部Rabbitmq. 我目前能够通过使用芹菜 send_task 将任务添加到队列中: app.send_task('任务'，kwargs = self.get_input()，queue = Queue('queue_async'，持久= False ..
发布时间：2021-04-03 20:05:22 其他开发

将无代理的AMQP写入MQTT适配器

我想实现一个从amqp到mqtt的适配器，该适配器将接收amqp消息，获取其有效负载并将其作为mqtt消息发布到我的mqtt代理.因此，适配器必须能够 在端口上听 确认连接请求 接收amqp消息 确认他们 使用mqtt发布 在我的生态系统中，我想为传入消息提供不同的协议，但是我只想运行一个mqtt代理.我想避免其他经纪人.我在这里 amqp"1.0允许无代理点对点通信".我想这 ..
发布时间：2021-04-03 20:05:19 Java开发

如何使用SOCKS代理或Java中的任何其他代理通过SSL创建与AMQP队列的连接

使用SOCKS代理或任何其他代理，对于无法直接访问Internet或防火墙禁止amqps连接端口的环境，有什么方法可以使用org.apache.qpid.jms.JmsConnectionFactory通过SSL连接到amqp队列. 我已经尝试在可以使用Internet的环境中使用org.apache.qpid.jms.JmsConnectionFactory通过SSL连接到amqp队列.它 ..
发布时间：2021-04-03 20:05:16 Java开发

主题交易所是唯一支持通配符的交易所吗?

在试图理解直接交换，扇出交换和主题交换之间的区别时，我想确认主题交换的优点是生产者推送到交换并指定了完全特定的路由键，并且队列可以绑定到多个通过通配符路由密钥.例如话题推到... $ channel-> basic_publish($ msg，'logs-exchange'，'error.critical.ram') 并且将向呼叫团队发送所有严重错误的消息的队列将绑定为... $ ch ..
发布时间：2021-04-03 20:05:06 其他开发