amqp 相关问题

AMQP是一种开放式消息传递标准。它为高性能企业消息传递定义了线级协议和语义框架。如果您正在使用特定代理(例如:[rabbitmq]),则AMQP标记可能是多余的。 AMQP不应与Apache [ActiveMQ]混淆

如何从RabbitMQ中删除队列绑定?

我正在使用RabbitMQ按主题将消息路由到感兴趣的订阅者。每个订阅者都有一个队列,我将队列绑定到他们感兴趣的主题。我想允许用户...

回答 3 投票 8

获取rabbitmq中的路由/绑定密钥

我有两个队列,两个绑定/路由键,我想根据路由/绑定密钥在消费者中写一个条件语句,如何获取它们的值? var amqp = require('amqplib / ...

回答 1 投票 0

芹菜可以在运行时刷新amqp连接参数吗?

我正在尝试用云AMQP建立芹菜经纪人。由于云AMQP服务只提供Java SDK,所以我用Python重写了加密代码,连接工作正常。但是,有......

回答 1 投票 0

无法打开绑定到应用程序标头x-match表达式的接收器

我正在使用rhea(https://github.com/amqp/rhea),一个node.js库来开发AMQP 1.0客户端。我正在尝试使用x-match调整https://github.com/amqp/rhea/tree/master/examples/selector示例...

回答 1 投票 1

如何在ActiveMQ中使用AMQP python客户端

我使用amqp客户端连接ActiveMQ代理。 import amqp USER =“guest”PASSWORD =“guest”HOST ='localhost'PORT ='5672'host = HOST +“:”+ PORT conn = amqp.connection.Connection(host = host,...

回答 2 投票 1

ASP.NET CORE Web API与RabbitMQ(AMPQ)中的微服务通信

我正在尝试使用asp .net核心Web API实现微服务,并对RabbitMQ进行研发以与每个Web服务进行通信。关于我的项目,它是一个学习管理系统。当老师......

回答 1 投票 0

通过URL连接到RabbitMQ

我正在尝试连接到隐藏在nginx代理后面的rabbitmq。它被声明为:location ^〜/ rabbitmq / {proxy_pass http://127.0.0.1:5672/;问题是,我发现......

回答 1 投票 0

RabbitMQ消息的大小和类型

RabbitMQ队列中可以存储哪些消息?只有字符串?或者我可以选择我想要存储的类型:int,binary,string等?一条消息的最大大小是多少?有多少队列或交换......

回答 3 投票 88

使用AMQP可以实现路由方案,但不能使用JMS API

我在面对JMS vs RabbitMQ AMQP时遇到了很大麻烦,需要你的帮助。所以我的问题是 - 是否有一些场景可以使用AMQP 0.9.1协议解决但不能用JMS解决?一世'...

回答 1 投票 1

异步处理消息时的BasicAck

我正在尝试设置RabbitMQ消息队列,以便我可以发送消息以启动长时间运行的进程,并且还能够发送消息以在需要时取消长时间运行的进程。所以我 ...

回答 2 投票 3

我需要在我的单元Test中模拟一个RabbitMQ

我在我的项目中使用RabbitMQ。我在我的消费者中有rabbitMQ的客户端部分的代码,并且连接需要tls1.1来连接真实的MQ。我想在我的JUnit中测试这段代码......

回答 3 投票 8

从rabbitMQ发送消息到PostgreSQL

我知道可以将消息从PostgreSQL发送到RabbitMQ,但是可以将消息从RabbitMQ发送到PostgreSQL。现在我正在通过amqp插件为RabbitMQ提供一些...

回答 1 投票 1

Rabbitmq - php amqp破坏了管道错误

我正在处理一个巨大的xml文档(其中包含大约一百万个条目),然后使用rabbitmq将格式化版本导入数据库。每次发布约200,000个条目后......

回答 3 投票 3

使用RabbitTemplate发布消息时出现java.lang.IllegalArgumentException

我尝试使用RabbitTemplate在队列上发布消息(使用Spring Boot),我得到了这条消息。我已经尝试过寻找解决方案。引起:java.lang.IllegalArgumentException:...

回答 1 投票 0

如何使用rhea在amqp中实现天蓝色服务总线的重新传递延迟

我在nodejs应用程序中使用rhea使用AMQP在Azure Service Bus上发送消息。我的问题如下:有时消息处理尝试可能会失败,因为......

回答 1 投票 0

从客户端检查RabbitMQ队列大小

有谁知道是否有办法从客户端应用程序检查RabbitMQ队列中的消息数量?我正在使用.NET客户端库。

回答 9 投票 41

使用Spring,ActiveMQ和Qpid进行集成测试

在项目中,我必须用Qpid替换ActiveMQ客户端,但保留activeMQ代理。由于这种变化,许多测试都失败了,尤其是集成测试。在我使用vm连接之前,...

回答 1 投票 0

我们是否需要重新考虑微服务

我们基于微服务架构创建了我们的应用程序,包含大约30个微服务。几乎所有的服务间通信都是同步的,它们直接相互通信。现在......

回答 1 投票 1

如何使用ssl连接连接节点的amqplib?

我正在尝试连接我的RabbitMQ服务器,该服务器被强制使用SSL,并受到用户和密码的保护。以前,我成功地从C#,PHP和Python应用程序连接到此服务器。 ...

回答 2 投票 2

Golang中的JSON RPC与AMQP

我使用“github.com/streadway/amqp”通过队列(RabbitMQ)进行异步处理请求。我使用“github.com/gorilla/rpc”来注册我的服务而没有解决方法,但我必须使用丑陋的解决方案......

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.