从rabbitMQ向PostgreSQL发送消息
RabbitMQ是一款开源的消息中间件，用于实现高效的消息传递。它基于AMQP协议，提供了可靠的消息传递机制，支持多种编程语言和平台。
- 概念：RabbitMQ是一个消息代理（Message Broker），通过在应用程序之间传递消息来实现解耦和异步通信。它采用生产者-消费者模式，应用程序可以将消息发布到一个或多个队列中，同时消费者可以订阅一个或多个队列来接收消息。
- 分类：RabbitMQ被归类为轻量级的、可扩展的消息中间件，主要特点包括可靠性、灵活性、多语言支持、易于使用等。
- 优势：
- 解耦和异步通信：RabbitMQ允许应用程序在不直接依赖彼此的情况下进行通信，实现了系统组件之间的解耦。
- 可靠性：RabbitMQ支持持久化消息、事务机制和消息确认机制，保证消息传递的可靠性。
- 灵活性：RabbitMQ提供了多种消息传递模式，包括点对点、发布-订阅、请求-响应等，可以根据应用需求选择合适的模式。
- 多语言支持：RabbitMQ支持多种编程语言，如Java、Python、.NET等，方便开发人员使用自己熟悉的语言进行消息传递。
- 易于使用：RabbitMQ提供了丰富的管理工具和监控功能，易于部署和管理。
- 应用场景：
- 异步处理：将耗时的任务放入消息队列中，由消费者异步处理，提高系统响应速度。
- 解耦和系统集成：不同系统之间通过消息队列进行通信，实现解耦和系统集成。
- 任务分发：将任务放入消息队列中，多个消费者并发处理，实现任务的分发和负载均衡。
- 日志处理：应用程序将日志消息发布到消息队列中，由消费者处理和存储，实现日志的集中管理。
- 推荐的腾讯云相关产品：
- 云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 云数据库 PostgreSQL：https://cloud.tencent.com/product/postgres
- 云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 云函数 SCF：https://cloud.tencent.com/product/scf
以上是关于从RabbitMQ向PostgreSQL发送消息的内容解答，希望能对您有所帮助。
相关·内容
1回答
我知道可以从PostgreSQL向RabbitMQ发送消息，但是否可以从RabbitMQ向PostgreSQL发送消息。 现在，我通过amqp插件向RabbitMQ提供了一些来自使用MQTT的树莓派的数据。 所以，是的，我想知道是否有可能在数据库中运行一个脚本或安装另一个插件，或者我是否需要这两者之间的一些东西来处理消息并转换它。 谢谢!
浏览 60提问于2019-03-11得票数 2
生产者发送消息rabbitmq，消费者从rabbitmq接收消息，然后消费者通过rabbitmq将消息发送回生产者。
有可能吗？
浏览 0提问于2013-01-30得票数 9
1回答
使用Erlang20.1安装并运行了RabbitMQ 3.5.7。我还在同一台服务器上运行了PostgreSQL 9.5。
在兔子中，我从这里安装了插件pgsql-listen-exchange：
根据rabbitmq-plugins list的说法，它是存在并运行的：
[E*] pgsql_listen_exchange 0.3.0-v3.5.x
我在兔子管理UI中创建了一个exchange和通道，将消息从PGSQL发送到：
当我从CLI登录到PGSQL并尝试发送NOTIFY消息时，它永远不会通过：
我错过了什么，我遵循了GIT页面上的说明
浏览 2提问于2017-12-19得票数 2
回答已采纳
我试图通过调用AWS函数将s3event消息发送到rabbitmq。我已经将SQS配置为我的死信队列(DLQ)。我知道，当lambda调用失败或超时或资源约束等情况发生时，该消息将发送给DLQ。我的问题是，我想在一定条件下从lambda函数内部向DLQ发送事件消息，比如如果rabbitmq关闭或其他我感兴趣的条件。有同样的可能性吗？我是应该抛出异常，还是有其他更好的方法向DLQ发送事件消息。
我使用java进行开发，并通过lambda函数连接到rabbitmq。
浏览 0提问于2018-03-21得票数 6
回答已采纳
我有一个模块化的微服务架构，在这里我使用带有RabbitMQ的Rebus作为消息总线。
一个容器正在运行RabbitMQ。其他容器正在运行通过Rebus/RabbitMQ相互通信的服务。
我希望我的解决方案能够对容器重新启动具有弹性，因此，例如，如果RabbitMQ容器重新启动，我希望其他服务不受此影响。我希望在RabbitMQ关闭时发送的消息会排队等待发送服务中的Rebus传递，并且在恢复RabbitMQ连接时传递这些消息。
要验证我是否运行了这个测试场景：
服务A通过Rebus和RabbitMQ向服务B发送消息。效果很好。
我停止了RabbitMQ容器。
服务A通过Rebus和
浏览 1提问于2020-07-31得票数 1
回答已采纳
我正在尝试在kubernetes集群中设置RabbitMQ任务队列，并且需要能够从kubernetes集群外部填充任务队列。我正在尝试使用nginx入口控制器来实现这一点。在尝试从集群外部声明队列或向现有队列发送消息时，我遇到了错误。从集群外部使用Ubuntu中的amqp-tools cli时，我得到一个错误： $ export BROKER_URL=amqp://<host-name>:80/rabbitmq
$ /usr/bin/amqp-declare-queue --url=$BROKER_URL -q foo -d
logging in to AMQP server:
浏览 80提问于2020-04-10得票数 1
回答已采纳
我用的是芹菜3.0.18和RabbitMQ 3.0.2。我使用celery.send_task向另一个应用程序发送了一个任务，我可以在日志中看到send_task调用，我可以看到离开worker实例的数据包，当我调用tcpflow -ce -i any port 5672时，我可以看到到达RabbitMQ实例的数据包，但是，只有第一条消息到达队列。它们都有相同的路由密钥，我尝试重新创建交换和绑定，甚至是一个新的RabbitMQ实例，但是似乎没有什么工作。过去这几个月都很正常，直到我们在AWS基础设施崩溃后不得不从头开始重建RabbitMQ。奇怪的是，我在其他应用程序上使用相同的设置，使用相同的
浏览 1提问于2013-12-20得票数 3
回答已采纳
我在C#中有两个windows服务。服务1将消息发布到RabbitMQ队列。服务2订阅RabbitMQ队列。服务2还连接到TCP服务器，并将它从RabbitMQ接收到的消息发送到该服务器。我的问题是，当使用此消息的服务2由于某种错误(主要是SocketException，如果它无法连接到服务器)而失败时，是否有办法停止服务1将消息发布到队列上。任何指针都会非常有用。如果还需要更多的信息，请告诉我。
提前谢谢。
浏览 2提问于2017-08-02得票数 0
在我们的项目中，我们使用rabbitmq作为消息传递。这主要用于审计日志记录。我们试图检查我们的应用程序是如何对某些失败场景做出反应的。例如，如果RabbitMQ关闭，使用者会不断尝试连接到rabbitmq，但失败。如果狂犬病发作了，消费者是否有办法停止尝试？类似地，在代理关闭时，发布者如何停止向队列发送消息？断路器是我们可以考虑的选择之一吗？
浏览 4提问于2017-02-22得票数 1
回答已采纳
1回答
在我的应用程序中，我允许用户发送消息和电子邮件。我想让他们能够安排发送--比如设置发送的时间和日期。
我已经发送了相当多的消息--我如何才能最好地构建它，使其具有可扩展性？我现在已经将它们存储在PostgreSQL中，但除了轮询之外，我没有其他方法来检查需要发送哪些内容。如果可能的话，我想避免轮询。
我目前在EC2上运行PHP、node.js、redis、PostgreSQL和RabbitMQ，所以它们的任何组合都是有利的。
浏览 1提问于2013-03-08得票数 0
我已经在视窗中安装了PostgreSQL服务器。我想在函数和触发器中向RabbitMQ发送消息。我该怎么做呢？我需要额外的通行费吗？
浏览 1提问于2021-12-03得票数 0
我正在尝试集成websocket聊天使用ERlang，牛仔，Websocket和gen_bunny。
我能够让他们独立工作。
浏览器->牛仔websocket聊天(作品) Erlang和RabbitMQ AMQP (作品)
在将它们集成在一起时，我能够将消息从浏览器传递给牛仔，并将其传递给RabbitMQ，然后再从RabbitMQ获取。
我甚至可以将消息回复给发送它的用户。但是，我希望将消息广播给所有已连接的用户。
根据我的理解，Erlang将为每个用户创建一个单独的进程。那么，在我从RabbitMQ得到响应后，如何将其广播给所有连接的用户？？
浏览 1提问于2013-05-01得票数 4
回答已采纳
1回答
所以我在一个节点上测试RabbitMQ。简单明了，
一个生产者向队列发送消息，
多个使用者从该队列中获取任务。
目前消费者每秒执行数千条消息，他们太快了，所以我需要他们放慢速度。由于网络的不可靠性质，管理客户端节流是不可能的。
总体来说，使用者不能从该队列中每秒接收10条以上的消息。
是否有一种方法可以配置RabbitMQ，以便队列每秒最多发送10条消息？
浏览 5提问于2017-12-15得票数 0
回答已采纳
我有一个rabbitmq侦听器作为单独的类和JSF2托管bean。
在我的bean中，我发送了一条消息，需要等待结果。我不能使用sendAndReceive...因为我将消息发送到一个队列，但是从另一个队列接收消息，所以我在发送之前分配了correlationId。
所以我需要异步等待，我需要等待，直到正确的消息到达监听器。如何在rmq中实现？
浏览 0提问于2015-05-09得票数 1
当我们在rabbitmq中使用持久队列和持久消息时，该消息是发送到本机操作系统的IOBuffer，还是写到磁盘immediately.Considering，即RabbitMQ运行在CentOS 6.3上
浏览 2提问于2014-07-01得票数 0
回答已采纳
1回答
我几乎是新手使用消息队列，而且我正在使用RabbitMQ (java)如何使用Rabbit发送SMTP消息？我从rabbitMQ 得到了一个git插件，但它显示“目前不支持从RabbitMQ发送外发电子邮件”是不是我错了，或者在RabbitMQ中发送电子邮件是不可能的？
谢谢
浏览 2提问于2015-02-24得票数 2
2回答
我对RabbitMQ和Apache相当陌生.消息被bing从接口(IMAP等)中取出并发送到队列中进行进一步处理。我很难找到一个解决方案，以避免在RabbitMQ关闭的情况下丢失消息。避免通过骆驼路由将消息发送到队列中的最佳解决方案是什么？
我使用Spring和camel版本2.25.1。
非常感谢。
浏览 4提问于2020-07-07得票数 0
回答已采纳
所以，伙计们，我使用的是RabbitMQ，当我每秒发送一次以上不同的信息时，我注意到有些没有到达。如果新消息仍然存在于队列中，是否有人知道RabbitMQ是否丢弃具有相同内容的新消息？
浏览 2提问于2022-04-20得票数 0
1回答
我使用Spring、Spring、STOMP作为我的应用程序，RabbitMQ作为代理。我需要记录通过RabbitMQ到Postgresql表的所有消息。我知道我可以在Spring中编写@MessageMapping并在那里登录，但我的问题是，一些客户端通过MQTT协议直接与RabbitMQ对话，而Spring还不支持它()。此外，浏览器客户端使用STOMP协议通过Spring与RabbitMQ进行通信。
RabbitMQ允许使用火龙带跟踪器跟踪所有消息。如何正确地从春季收听amq.rabbitmq.trace主题？还是我需要作为消费者编写单独的Java应用程序？
浏览 4提问于2015-05-21得票数 6
回答已采纳
在我的Django项目中，我实现了Celery，它使用RabbitMQ后端运行。 芹菜的作用： Celery将我的任务放入队列，然后在特定条件下运行它们。也就是说，我基本上只使用Celery python接口与RabbitMQ消息队列交互。 问题： 我只想将简单的字符串消息推送到RabbitMQ队列中，这应该由第三方应用程序使用。 我尝试过的： 有一种方法可以使用Pika library直接连接到RabbitMQ。然而，我会发现它有点笨拙-如果我已经Celery连接到RabbitMQ，为什么不使用它(如果可能的话)发送简单的消息到特定的队列，而是使用提到的Pika库打开另一个连接。 任何见解
浏览 12提问于2019-08-22得票数 2
回答已采纳
我希望实现至少一次对消息队列(ex: RabbitMQ)的传递，同时在数据库中提交事务(ex: PostgreSQL)。
流
启动数据库事务
从数据库中获取一些数据
将一些数据插入数据库
如果适用某些条件，则将消息发布到rabbitMQ
提交事务
如您所见，如果在步骤4之后、步骤5之前发生故障，我们已经发布了一条无效的消息。
即使我们重试整个过程，步骤4所需的条件也可能不再为真，因此先前发布的消息将更加无效。
解决这一问题的方法是使用CDC，但由于技术成本，目前已经无法选择。(我很想知道是否有任何廉价的配置CDC选项)
可能解决办法
创建一个events表并在其中插
浏览 7提问于2021-11-25得票数 0
在12.04上，当我在postgresql上执行apt-get install时(它已经安装了)，它会返回一个提到rabbitmq-server的错误。什么情况会导致这种类型的失败？
# apt-get install -y postgresql
Reading package lists... Done
Building dependency tree
Reading state information... Done
postgresql is already the newest version.
0 upgraded, 0 newly installed, 0 to re
浏览 0提问于2013-02-01得票数 0
我试图让RabbitMQ监视postgresql数据库，以便在更新数据库行时创建消息队列。最终的计划是将此消息队列作为作业输入到AWS EKS ()集群中。
我已经阅读过许多方法，但作为rabbitmq的新手，它们仍然令人困惑，而且许多方法似乎是在5年前编写的，因此我不确定它们是否仍能与postgres和RabbitMQ的当前版本一起工作。
我跟随安装了area51 51/Notific-兔子对接容器，它可以通过一个节点应用程序将两者连接起来，但是当我运行这个对接容器时，它立即停止了，似乎什么也没做。
还有，它使用go应用程序将两者连接起来，但我不想在码头容器的外面使用Go。
此外，还有，用于
浏览 7提问于2022-10-27得票数 0
回答已采纳
1回答
我尝试向rabbitmq-server发送消息：
send_message(Channel, Host, Password, Message) ->
amqp_channel:cast(Channel, #'basic.publish'{exchange = <<"">>},
routing_key = <<"test">>,
#amqp_msg{payload =
浏览 1提问于2011-06-29得票数 0
我正在尝试发布一条从PostgreSQL到RabbitMQ的消息(都运行在Docker上)
SELECT amqp.publish(1, 'amqp.direct', 'EMAIL', 'message');
但是它返回false和警告消息：
警告:代理1上的amqpmy_host_address:my_port登录失败
更新: RabbitMQ Docker容器日志中有错误：
未能协商连接参数:协商后的channel_max =0(无限制)高于最大值(2047年)
正确定义了amqp.broker表中的代理参数-主机、端口、虚拟
浏览 0提问于2019-02-14得票数 0
我使用RabbitMQ作为消息队列/消息总线进行评估，并一直在查看RabbitMQ页面上的示例。
我正在寻找一个没有包含在教程中的特定场景，我不确定是否以及如何通过RabbitMQ来实现。
安装程序
让我们假设我得到了一项服务，我们把它称为“采购订单”，而我不得不将其他服务称为“物流”和“会计”。
当订单被发送时，我想通过RabbitMQ作为消息发送它。
有2个“帐户”和3个“后勤”服务
怎样才能确保“帐户”和“后勤”只处理一次信息？如果我正确理解，使用pub/sub将导致消息被处理两次(帐户)或trice (物流)。
使用工作队列和prefetch=1，可以确保只有一个得
浏览 2提问于2015-11-29得票数 4
回答已采纳
1回答
我正在使用VueJS构建一个web应用程序。应用程序应该充当消息生成器，并向RabbitMQ发送消息。有关于如何实现组件的最佳实践吗？
编辑:我相信这是没有解决的，而且RabbitMQ允许使用RabbitMQ团队编写的插件来连接AMQP以外的协议，即MQTT和STOMP。
这些插件启用websocket传输协议，并使用这些消息传递协议启用操作。
来源：
浏览 0提问于2020-07-24得票数 2
回答已采纳
1回答
我正在设计一个基于RabbitMQ的消息处理系统，用于各种基于PHP的web应用程序。PHP守护进程将用于从队列中检索项并执行处理。
例如，通过电子邮件发送数百个接收者，消息队列将异步地发送到web应用程序。
我的问题是，在这种类型的系统中，最好的方法是
检测发送的电子邮件的进度(2/100)知道整个过程何时完成。当2已知时，在整个过程完成时向web应用程序发送一条消息？
对于1，我认为守护进程会向完成队列发送一条消息，但是条目2和3的代码将放在哪里？
希望这是合理的。
K
浏览 0提问于2010-02-25得票数 1
2回答
我使用rabbitMq、nodeJs(与socet.io、amqp模块)、ZF2进行开发聊天。
默认情况下，RabbitMq从帮助循环的队列中发送消息。
是否有RabbitMq向所有订阅者队列发送相同消息的机会？
例如:如果我为每个连接建立了它的队列，这是正确的，但是如果用户在他的浏览器上打开两个选项卡，那么就会生成2个队列。我觉得不太好。
我希望每个用户都有一个队列(如果我这样做了，那么第一个消息发送到第一个选项卡，第二个消息发送到第二个选项卡)
我的代码：
var exchange = connectionAmqp.exchange('chat', {type: '
浏览 12提问于2013-08-21得票数 0
我正在尝试用java开发一个聊天应用程序，并且已经部署了一个使用RabbitMQ和Comet的示例应用程序。我已经能够从绑定的RabbitMQ服务发送和接收消息。
当我尝试在没有要传递的挂起消息的情况下为消息池化队列时，就会出现问题。
我没有等待新的消息并保持连接打开，而是得到了504错误代码。
我认为这是由于Cloud Foundry的条件，即请求必须在30秒内响应。
因为我想保持连接打开，直到我有消息要传递给客户端，有没有什么方法可以克服这一点。
浏览 1提问于2012-07-11得票数 0
1回答
RabbitMQ是否支持在DB事务提交时发送接收到的消息确认的场景？
目前，我们在DB事务提交后发送ack。如果服务在两者之间失败，我们将获得数据复制-服务将再次获得相同的消息。
有没有解决这个问题的模式？
谢谢!
浏览 3提问于2010-03-02得票数 4
回答已采纳
如果消息是从不同的消息发送源(本例中为MassTransit客户端)发送的，那么RabbitMQ如何从RabbitMQ中提取消息？
这些消息共享相同的C#消息契约，并作为json进行序列化。
我收到的当前错误是masstransit解析错误..。
浏览 4提问于2015-02-12得票数 5
上下文：
假设我使用RabbitMQ执行以下操作：
将使用者连接到RabbitMQ中的队列RabbitMQ。
这个消费者可以是在noack模式下，也可以不是；没有区别。
如果不处于noack模式，则假设该使用者设置了basic.qos和channel.flow，使其能够接收消息；它的缓冲区没有满，并且能够使用。
将发布服务器连接到同一个RabbitMQ集群，并将强制消息(启用 )发布到Q。
在发布服务器中接收basic.ack。
问题：
当返回该basic.ack时，RabbitMQ是否保证将该消息发送到使用者的远程套接字？我知道它不能保证消息
浏览 1提问于2016-09-17得票数 1
回答已采纳
我们有一个带有websockets的JHipster微服务应用程序。目前，主要的微服务(带有前端)是通过websockets发送/接收消息的人，它依赖于RabbitMQ作为主题的中继。我们已经配置了Spring + RabbitMQ，如下文所述：
如果我还将这个其他微服务配置为中继到同一个RabbitMQ实例，那么我可以从架构中的其他微服务发送消息到主题吗？
编辑：
这里是Spring在RabbitMQ上中继的配置类。这是在主要的微服务中，其中有STOMP WebSockets和前端角度应用程序：
@Configuration
@EnableWebSocketMessageBroker
pub
浏览 1提问于2018-02-07得票数 0
2回答
我有一个客户端服务器应用程序，它使用rabbitmq。客户端连接到rabbitmq并向服务器发送消息。在某个时候，如果服务器决定这个客户机不应该连接到rabbitmq，我希望能够强制从rabbitmq边界断开客户端。请注意，在我的示例中，我不想向客户端发送断开连接的消息，而在服务器端，我只想强制将此客户端从rabbitmq断开。
找不到api来做这个。任何帮助都是徒劳无功。
浏览 3提问于2015-09-05得票数 1
回答已采纳
2回答
我尝试从Camel组件发送持久的消息到RabbitMQ。虽然默认选项为true，但我显式地设置了此选项：
.to(ExchangePattern.InOnly, "rabbitmq:demoExchange?queue=demoQueue" +
"&guaranteedDeliveries=true" +
"&mandatory=true" +
"&autoDelete=false" +
"&durable=true")
浏览 0提问于2019-09-05得票数 0
回答已采纳
如果我的问题很愚蠢，很抱歉，我是新来MassTransit的。 我的系统由一个服务器和多个客户端设备组成。我想从服务器向特定的客户端或一组客户端发送消息。据我所知，IBusControl.Publish将消息发送给所有订阅者，而IBusControl.Send将消息发送给唯一的订阅者。 如何使用MassTransit实现这一点？我的传输是RabbitMQ / Azure服务总线。 谢谢!
浏览 39提问于2019-03-13得票数 1
回答已采纳
1回答
在将消息从生产者发送到RabbitMQ broker以及从代理发送到生产者时，RabbitMQ使用哪些通信协议？我如何在它们之间切换？
浏览 4提问于2017-12-12得票数 0
回答已采纳
我正在研究WSO2 MI和RabbitMQ的集成，目标是创建一个具有以下步骤的系统: 1. MI接收来自客户端的请求并将消息发送到RabbitMQ 2. RabbitMQ将消息放入队列中，并由订阅者客户端进行处理。3.将来自处理服务的响应的消息放入response RabbitMQ队列。4. MI从响应队列接收消息并向客户端发送回复。
在wso2官方手册中有以下文档：
我假设这就是我所需要的，但不清楚这些代码到底应该如何执行。
假设我在MI中配置了一个到RabbitMQ的连接。
我到底如何使用文档中提到的这些synapse configurations来根据客户端的请求向rabbit发送消息
浏览 1提问于2020-04-14得票数 0
我是RabbitMQ的新手。我与PhantomJS一起工作，并使用JavaScript来做一些事情。现在，我需要将我的一些结果发送到RabbitMQ，以便使用另一个脚本读取它们。我是说，我想让PhantomJS和RabbitMQ沟通。发送一些消息和从队列中读取一些消息。这有可能吗？PhantomJS是否可以通过它与RabbitMQ通信？
浏览 1提问于2015-03-05得票数 2
回答已采纳
2回答
最近从之前的2.x升级到RabbitMQ版本3.2.0。目前使用的版本为0.9.13。以前，当发送“大”消息(20k-40k bytes...so，可能不是那么大)时，它会毫无问题地发送消息。现在，对于新的RabbitMQ服务器，消息不会发送，而是挂起在basic_publish上，也不会将消息发送到服务器；小消息似乎不是问题。
这造成了一些挫折，因为唯一改变的是有效地将服务器升级到较新的版本。我注意到，RabbitMQ在其站点上声明，现在默认设置了对frame_max大小的限制。我尝试更改/etc/rabbitmq/rabbit.config文件以消除frame_max：
[{rabbit,
浏览 1提问于2014-07-22得票数 0
回答已采纳
我试图构建一个具有多服务器消息交换的系统。
我有一台名叫主人的服务器，另一台叫奴隶的服务器。主从发送消息给从服务器，从服务器异步发送消息给主。
我在两台服务器上都有rabbitmq服务器，并在这两台服务器上使用联合插件来获取消息。因此，两台服务器上的发布者和消费者只与本地的rabbitmq服务器进行通信。并且服务器之间的所有消息交换都仅用rabbitmq完成。
效果很好。当两台服务器都联机时。
我的需求是，当服务器之间没有网络连接时，就应该容纳消息，直到连接恢复为止。而且，它的不工作与联邦插件。如果联邦连接没有活动，那么消息就不会存储在本地rabbitmq上。
我应该做些什么来建立一个模型，在
浏览 3提问于2015-09-22得票数 0
回答已采纳
是否可以在Amazon EC2 instance上设置RabbitMQ服务器，并使我办公室的一台计算机连接到此RabbitMQ服务器，并向它发送消息/从它接收消息？
流入/流出RabbitMQ EC2 instance的带宽/消息是否由Amazon收费
浏览 1提问于2011-07-22得票数 1
回答已采纳
我有一个spring boot应用程序，它充当生产者并通过RabbitMQ发送消息。如果代理关闭，是否有某种侦听器会检测代理何时再次启动，以便重试发送失败的消息？ 谢谢!
浏览 14提问于2020-09-01得票数 0
我最近开始使用spring webflux和Rabbitmq以及cassandra reactive存储库。我注意到的是，即使在cassandra中保存某些元素也无法成功保存该消息。我传播了在保存过程中抛出的异常，但即使消息是从队列中删除的。我想知道我应该怎么做才能让Rabbitmq知道这条消息应该被认为是失败的(我想拒绝消息以将其发送到死信队列)
@RabbitListener(queues = Constants.SOME_QUEUE, returnExceptions = "true")
public void receiveMessage(final List<I
浏览 0提问于2018-05-28得票数 0
我们正在开发一个监听或使用来自RabbitMQ队列的消息的服务。消息从Apache Nifi分派到消息队列(例如，队列名为“workitem”)。 现在，我希望看到一个使用Spring Integration的代码片段，用于侦听和处理从Apache Nifi发送到队列(RabbitMQ)中的消息。 谢谢!
浏览 29提问于2020-04-21得票数 0
回答已采纳
1回答
我使用以下策略在2个节点上设置了一个带有消息镜像的3节点RabbitMQ集群：
ha-mode: exactly
ha-params: 2
ha-sync-mode: automatic
我正在使用Spring Boot和Spring AMQP做一些性能测试。基本上，我让Apache向发布消息的控制器发送JMeter请求：
@RequestMapping(value = "/webhook", method = RequestMethod.POST)
public void webhook(@RequestBody(required = true) String webhook
浏览 9提问于2017-03-09得票数 1
回答已采纳
我有一个使用Hibernate和PostgreSQL的Spring应用程序。它还使用Spring AMQP (RabbitMQ)。
我正在使用Hibernate事务管理器，配置如下：
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager"
p:sessionFactory-ref="sessionFactory" p:dataSource-ref="dataSource&#
浏览 0提问于2012-06-28得票数 5
1回答
春集成与春云流
、、、、
我在写一个应用程序
轮询目录(流)
一旦该文件可用，它就会将其放入rabbitmq队列中。
Microservice侦听流RabbitMQ并处理文件(这是用Spring编写的)
现在，我不知道从Spring服务向RabbitMQ发送消息的最佳方法是什么。如何使用中的Spring云流将消息发布到RabbitMQ
浏览 0提问于2018-10-03得票数 3
回答已采纳
我在理解RabbitMQ中的路由时遇到了问题。考虑我有几个生产者(让他们称为客户端)，它们向队列产生消息。例如，客户端A、B和C向队列X1发送消息。
让消费者对所有消息进行响应，将响应发送回队列。例如，消费者从队列X1获取消息，执行某些操作，并向队列X1发送响应。
client A如何确定发送到它的X1消息在队列中的位置以及发送到客户端B或C的消息的位置
我不能为每个连接声明一个队列，因为需要大量的连接(~10^6)。所以我有麻烦了。有什么建议吗？谢谢。
浏览 1提问于2012-10-31得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
