amqp 第7页 - IT屋-程序员软件开发技术分享社区

如何在Python中使用amqp将消息发送到Azure事件中心

任何人都知道如何使用python中的amqp向Azure事件中心发送消息吗?我需要使用分区键(而不是分区ID)发送消息.非常感谢. 解决方案根据此处. 希望有帮助. ..

qpid-proton-0.17.0的链接错误

构建qpid-proton-0.17.0程序时，出现此链接错误: 对质子:: event_loop :: inject(std :: function)的未定义引用这是我的建造方式: g ++ -std = c ++ 14 myprog.cpp -o myprog -lqpid-质子-cpp -lboost_system -lcrypto -lssl 我想念图书馆 ..

发布时间：2021-04-03 20:05:00 amqp qpid 其他开发

配置RabbitMQ将旧的待处理消息替换为新的消息

是否可以通过一种方式配置RabbitMQ交换或队列，以使任何时候都最多有一条带有给定路由密钥的消息挂起?如果收到新消息，则旧消息将被丢弃，新消息将进入队列. 如果该选项不可用，那么在应用程序级别实现此目的的最佳方法是什么?IE.当应用程序收到消息时，如何检查是否还有待处理的消息? 解决方案您需要安装Last Value Cache并启用它.您的交易所将是"x-lvc"类型，它继承自 ..

发布时间：2021-04-03 20:04:57 rabbitmq amqp 其他开发

谁能告诉我python中的pika和kombu消息传递库有什么区别?

我想在我的应用程序中使用消息传递库与Rabbitmq进行交互.谁能解释一下pika和kombu库之间的区别? 解决方案 Kombu和pika是两个不同的python库，它们在根本上具有相同的用途:将消息发布到消息代理和从消息代理使用消息. Kombu具有比pika更高的抽象级别.Pika仅支持AMQP 0.9.1协议，而Kombu可以支持其他传输(例如Redis).一般而言，Komb ..

发布时间：2021-04-03 20:04:54 python-2.7 rabbitmq amqp pika kombu 其他开发

如何从Java程序创建对ibm mq amqp主题的持久订阅?

我们通过提供 clientId 和订户名称，使用 createDurableSubscriber 以编程方式创建了IBM MQ AMQP主题的订户. 我们启动了程序，因此它订阅了TOPIC并停止了该程序.然后将msg发送到主题，然后再次启动接收器程序，但是我们无法接收已发送的msg，并释放消息(如果持久订阅则不会发生此消息). 使用mqsc命令连接订户时，我们可以看到amqp主题及其持 ..

发布时间：2021-04-03 20:04:50 java ibm-mq publish-subscribe amqp jms-topic Java开发

RabbitMQ中消息，队列和交换的限制是什么?

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

发布时间：2021-04-03 20:04:47 rabbitmq message-queue message amqp rabbitmq-exchange 其他开发

为什么以及何时应该使用异步消息传递(如JMS或AMQP)?

从概念上讲，什么时候应该使用异步消息传递?又为什么呢?我们不能将消息内容存储到某些数据库存储中，并且为了执行这些消息而迅速地运行计划的作业吗? 例如，使用JMS或AMQP为系统开发带来了真正的优势?有没有一种方法可以简化此设计并获得相同的结果? 解决方案很快，是的，如果速度和其他资源(例如，CPU/RAM)适合您的需要，则可以改用DB.作为任何专业的解决方案，JMS都可以最大程度地 ..

发布时间：2021-02-12 19:13:37 asynchronous jms amqp 其他开发

SpringJMS-如何断开MessageListenerContainer的连接

我想断开队列的DefaultMessageListenerContainer.我正在使用dmlc.stop()，dmlc.shutdown().在连接时，有5个使用者线程已连接到队列.当我尝试断开连接时，有4个使用方断开连接，但仍有1个使用方保持连接状态. (请参阅线程末尾的屏幕截图.) 环境 1.带有AMQP的ActiveMQ 2.带有ApacheQpid的SpringJMS 问题 ..

发布时间：2021-02-12 19:12:58 spring jms activemq amqp spring-jms 其他开发

无法按优先顺序获取消息Spring骆驼rabbitmq

我是使用spring camel rabbitmq的初学者. 我可以通过在生产者端交换出报头中设置消息优先级来设置消息优先级，就像这样: exchange.getOut().setHeader("rabbitmq.PRIORITY", 1); 但是在使用消息时，它们不会按优先级顺序出现.帮助！！！我可以在rabbitmq的Web界面中看到适当设置的优先级标头解决方案 ..

发布时间：2020-08-24 02:12:34 spring rabbitmq apache-camel amqp 其他开发

AMQP连接已被对等方重置，但已连接芹菜

我有一个烧瓶应用程序，使用Celery和RabbitMQ作为代理. 我已按照此“>中的说明进行操作开始. 我有两台机器. 运行RabbitMQ的机器A发送要由机器B上的芹菜消耗的任务. 我的经纪人网址和后端结果网址相同:amqp://remote:***@12.345.678.999:5672/remote_host. 两台机器上都具有flask应用程序的副本.已配置 ..

发布时间：2020-08-24 02:12:29 python flask rabbitmq celery amqp Python

AMQP(rabbitmq)识别错误消息的来源

在rabbitmq中识别(坏)AMQP消息来源的最佳方法是什么? 该方案是多个客户端将消息发布到服务器，如果成功，则会将消息发布到扇出交换机(供发布/订阅使用). 客户端也是该队列的订阅者，并且没有自己的应答队列. 如果服务器认为邮件无效，则会对其进行处理并丢弃. 我们还需要另外两件事: 发布一条消息，客户端或监视系统可能会使用该消息说“停止向我发送垃圾" 记录有关错误消 ..

发布时间：2020-08-24 02:12:23 rabbitmq amqp 其他开发

我正在遵循Stock Trading示例的说明，该示例概述了如何在spring-amqp中使用请求/答复消息传递:我已经调整了示例说明，以创建一个客户端，该客户端应使用convertSendAndReceive而不是convertAndSend等待回复: https://gist.github.com/pulkitsinghal/5774487 现在，即使将答复放入responseQueue ..

发布时间：2020-08-24 02:12:20 java rabbitmq amqp spring-amqp spring-rabbit Java开发

安装RabbitMQ PHP:致命错误:找不到类'AMQPConnection'

我已经在服务器上安装了RabbitMQ，并且一切正常.我已经尝试过使用Java客户端发送和接收排队的消息，并且一切顺利. 现在，我需要安装PHP RabbitMQ客户端，因为我想将Java程序与PHP网页进行通信，但是这次我并不那么幸运. 我已经按照此安装的官方网页中的步骤进行操作，具体是这些步骤: # Download the rabbitmq-c library hg clo ..

发布时间：2020-08-24 02:11:13 php rabbitmq amqp PHP

RabbitMQ获取消息发送确认

当我发送到队列时，是否可以在RabbitMQ中获取确认消息? 谢谢！解决方案您可能要使用基本发布 ..

发布时间：2020-08-24 02:11:11 java spring rabbitmq amqp Java开发

具有多个客户端的AMQ地址到多播队列

我的查询是针对产品Red Hat AMQ 7.X(我使用的是7.2)，该产品基于Apache ActiveMQ Artemis和一个使用AMQP协议连接到队列的.Net客户端. Artemis的文章讨论了单播(点对点)，多播(发布-订阅)以及以下寻址方式的组合:它没有详细说明两个使用者在一个地址下连接到同一多播队列的情况.我们的要求是具有pub-sub通讯模型，发布者发布到多播地址. ..

发布时间：2020-08-24 02:10:08 amqp activemq-artemis jboss-amq 其他开发

AMQP(RabbitMQ)无法反序列化对象ClassNotFoundException

我想在Java SpringBoot中实现RabbitMq(AMQP)消息传递，但是当我收到消息时，它说messaGE无法反序列化，因为即使我没有找到我应该接收的对象的类，将该类包含在类路径中. RabbitMqListener.java: @EnableRabbit @Component public class RabbitMqListener { Logger logge ..

发布时间：2020-08-24 02:09:02 java serialization rabbitmq classnotfoundexception amqp Java开发

如果连接空闲/长时间不使用，则停止channel.basic_consume

我有一个用例，我想得到一个pika使用者(pika.BlockingConnection)的最后一个空闲时间(最后一个消息处理时间). 用例: 如果最后处理时间大于阈值时间(例如:1小时).我想让消费者退出还是可以使用回调方法来决定我需要做什么?就像向用户发送通知一样. 有没有办法做到这一点? 解决方案 pika支持您可以在每个消息接收的末尾添加此回调，保留对其的引用，然后在每个 ..

发布时间：2020-08-24 02:08:58 python rabbitmq amqp pika Python

RabbitMQ固定答复和使用者配置

我的目标是实现以下目标:php代码将请求发送到队列-Java代码从代码读取-java代码将答复发送到固定答复队列-php代码读取答复.我已经设置了以下测试(生产者现在是在Java中): POJO: public class PojoListener { public String handleMessage(String foo) { System.out.println(" ..

发布时间：2020-08-24 02:08:54 java rabbitmq amqp spring-amqp spring-rabbit Java开发

如何在JavaScript中将Promise添加到事件处理程序

现在，我想将 amqp 包装为Promise Sender.prototype.createConnection_ = function () { var deferred = Q.defer(); this.con_ = amqp.createConnection( this.connectOpt_, this.implementOpt_ ); deferred.resolve( this.co ..

发布时间：2020-08-24 02:08:51 javascript node.js promise amqp q 前端开发

在AMQP 0.9(rabbitmq)中，app_id和cluster_id字段是什么

我正在尝试了解AMQP消息中的app_id和cluster_id字段. 我什至尝试阅读如下定义的AMQP规范: https://www.rabbitmq.com/specification.html 和 http://www.amqp.org/resources/download 但是尚不清楚app_id和cluster_id字段是什么. 同样在AMQP 1.0中还不清楚(默认情况下 ..

发布时间：2020-08-24 02:08:47 rabbitmq amqp 其他开发

amqp相关内容