rabbitmq 相关问题

RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。

RabbitMQ在spring(不是spring boot)中的自动线不工作。

我想把rabbitmq整合到我的spring应用程序中。所以,我在我的pom.xml中添加了以下几行内容。 org.springframework.amqp ...

回答 1 投票 0

Socket.io与Rabbitmq进行一对一聊天。

我在用Socket.io和RabbitMQ构建一个一对一的聊天 我的实现做一对一的聊天是可以的,但是我不知道实现是否正确。 roomID是 ...

回答 1 投票 1

RabbitMQ或Kafka消息队列是1:1消息系统吗?

正如答案中提到的,消息队列是一个单向管道:一个进程向队列写入数据,另一个进程按顺序读取数据 SysV消息队列就是一个例子 所以,我的理解是,......

回答 1 投票 0

RabbitTemplate在使用旧版Spring的遗留项目中无法获得自动布线。

我试图在我的旧项目中实现rabbitmq,使用普通的spring开发。我试图使用@Autowire RabbitTemplate rabbitTemplate; public void send(){ rabbitTemplate......。

回答 1 投票 0

如何用python pika的自签名证书发布msg到rabbitmq服务器?

参数 = pika.URLParameters('amqps:/) : @ ') connection = pika.BlockingConnection(parameters) channel = connection.channel() 我得到的是:ssl......。

回答 1 投票 0

RabbitMQ conf文件位置

我把rabbitmq.conf文件放在哪里,如何让rabbitmq服务器知道?所有的文档和我能找到的东西都只说明了这个文件最初是不存在的,而且这个例子......。

回答 1 投票 0

有没有办法在RabbitMQ中把队列显式地绑定到默认的交易所?

我犯了一个错误:现在两个队列中的两个队列都被显式地绑定到了某个交易所,我可以为每个队列编辑。其中一个队列必须绑定到默认的交换。现在当我试图改变...

回答 1 投票 0

将 Postman 请求转换为 RabbitMQ

我有一个POST请求,我在Postman中使用它来更改设备的状态,当我直接通过Postman执行请求时,它似乎可以工作,但我一直无法使它与RabbitMQ一起工作。...

回答 1 投票 0

C# RabbitMQ客户端线程安全

ConnectionFactory factory = new ConnectionFactory {HostName = "localhost"}; using (IConnection connection = factory.CreateConnection()) using (IModel channel = connection.CreateModel()) { channel...。

回答 1 投票 12

RabbitMQ + .NET C#。消息发布+消费的性能低下且变化多端

我正在尝试使用RabbitMQ + .NET C#来提高发布和消费消息的性能。我在下面定义了一个相对 "大 "的 xml 文件(作为嵌入式资源)。

回答 1 投票 0

当使用Lenses MQTT源连接器和汇合的kafka时,消息流断断续续。

我正在尝试使用Lenses MQTT源连接器[https:/docs.l lenses.ioconnectorssourcemqtt.html]与confluent kafka v5.4。以下是我的MQTT源连接器属性文件:连接器......。

回答 1 投票 1

Django电子商务项目作为初学者rabbitmq安装问题在windows 10上。

请帮忙,但要简单,因为我是初学者。Django电子商务项目,在windows 10上安装了Erlang 64位和rabbitmq,但当我尝试在bycharm终端上用:apt-...

回答 1 投票 0

Spring AMQP RabbitListener调整自动重连配置。

我试图更好地理解RabbitListener的行为,当broker宕机时& 当它被恢复时。我已在本地主机:6672 的 docker 容器中设置了一个 rabbit,并创建了一个 ...

回答 1 投票 0

为什么要在 RabbitMQ 中声明 Exchange?

我正在用RabbitMQ做一个项目。我的代码如下。Producer: public static void Main() { var factory = new ConnectionFactory() { HostName = "localhost" }; using (var connection = ...

回答 1 投票 5

Rabbit MQ 错误:无法在节点“rabbit@USERNAME”上执行操作

错误:无法在节点“rabbit@YASHODIP-PC”上执行操作。请参阅下面的诊断信息和建议。 最常见的原因是: 目标节点无法访问(例如 du...

回答 3 投票 0

setConfirmCallback vs setReturnCallback

为什么setReturnCallback执行在setConfirmCallback之前,理想情况下setConfirmCallback回调方法应该执行在返回回调之前。

回答 1 投票 0

RabbitMQ客户端如何判断何时失去与服务器的连接?

如果我连接到RabbitMQ,并使用EventingBasicConsumer监听事件,我如何判断我是否已与服务器断开连接?我知道有一个Shutdown事件,但它没有发射......

回答 2 投票 10

没有消费者RabbitMQ

我有一个没有定义消费者和每条消息TTL的队列。当最大TTL消息在头部,而它的TTL还没有过期时,会发生什么?其他消息的TTL已经过期,但会不会 ...

回答 1 投票 0

延迟优先级 Rabbitmq

我正面临这样一种情况,即队列中的每条消息都应在延迟后被消耗,而延迟是可以使用 RabbitMQ 中的 TTL 和死信交换实现的,但当最大 TTL 将在队首时,比......

回答 1 投票 0

Pika: 如何从回调函数中获取返回值?

我的程序中有一个回调函数 我需要检查successfailure. 我怎样才能做到这一点呢?在我下面的例子中,failail_code去了哪里?我的代码: def mq_callback(job_id, ch, method, ...)

回答 1 投票 0

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