我们需要在RabbitMQ和MQSeries之间传输消息。
为此，我们使用下面的配置。
<int:channel id="channelRmqMQ"></int:channel>
<int-amqp:inbound-channel-adapter channel="channelRmqMQ"
queue-names=" QUEUE_OUT "
connecti
浏览 22提问于2020-03-11得票数 1
回答已采纳
我在将消息发布到RabbitMQ时遇到问题。我们的应用程序必须工作在事务层。 但是，我不明白有一种情况:如果我首先启动事务并提交它，那么接下来的所有消息都不会发布到RabbitMQ。 $connection = new \AMQPConnection([
'host' => 'rabbitmq',
'port' => 5672,
'login' => 'guest',
'password' => 'guest&#
浏览 8提问于2019-09-22得票数 0
1回答
我正在开发一个模块，该模块消耗一些HTTP资源，编写一个postgres，最后将消息推到消息总线( message，RabbitMQ)。
我想知道如何处理模块内的事务:如何封装我的postgres操作和对RabbitMQ的推送(即，如果消息不能推送到RabbitMQ，我的DB操作应该被回滚)？
谢谢。
浏览 0提问于2016-06-02得票数 1
回答已采纳
我有一个在RabbitMQ中使用AMQP创建消息的ruby脚本。
# above code sets up config for connecting to RabbitMQ via APMQ
AMQP.start(:host => 'localhost') do
amq = MQ.new
amq.queue('initiate', :durable => true).publish(message_id, :persistent => true)
AMQP.stop{ EM.stop }
end
如果重新启动RabbitMQ服务器
浏览 15提问于2011-03-17得票数 4
回答已采纳
我有一个使用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
3回答
我有一个RabbitMQ消息结构，其中消息A应该生成许多消息，我们称之为B和C。工作进程接收消息A，然后处理它并生成消息B和C。
假定的工作流流程如下：
接收带有A的消息ack=False
启动事务
运行一些代码
生成消息B
生成消息C
发送ack以获取消息A
完成交易
在任何情况下，工作进程都会在消息A的处理过程中死亡，或者当is尚未完成事务时，我希望RabbitMQ将消息A视为未传递的，并重新对其进行排队。
如果相关的话，RabbitMQ在高度可用的配置中运行。
为什么问题是试图清除RabbitMQ文档，并指出：
此外，即使事务只涉及单个队列，Rabb
浏览 6提问于2016-06-07得票数 1
我的spring引导应用程序的功能是:侦听rabbitmq队列上的消息，在onMessage中进行一些处理，然后将消息发布到另一个rabbitmq队列上。我们用的是春兔(1.7.2)。我们已经使用SimpleMessageListenerContainer配置了侦听器。
我的问题是，我能用他的相同的渠道发表我正在阅读他的信息。Spring-兔子提供对侦听器使用的通道的访问吗？这样同一个频道就可以被重用来发布了？
谢谢你，斯米塔
浏览 2提问于2018-07-18得票数 1
回答已采纳
2回答
以下属性之间的主要区别是什么：
1)spring.rabbitmq.listener.direct.prefetch= #单次请求处理的消息数。它应该大于或等于事务大小(如果使用)。
2)spring.rabbitmq.listener.simple.prefetch= #单次请求处理的消息数。它应该大于或等于事务大小(如果使用)。
浏览 2提问于2018-09-21得票数 1
我有一个使用以下依赖项的示例应用程序：
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-amqp</artifactId>
<version>1.4.5.RELEASE</version>
</dependency>
我有一个兔子发送者，配置如下：
<!-- Create rabbitMQ connection factory -->
<rabbi
浏览 2提问于2016-05-31得票数 0
当我们在rabbitmq中使用持久队列和持久消息时，该消息是发送到本机操作系统的IOBuffer，还是写到磁盘immediately.Considering，即RabbitMQ运行在CentOS 6.3上
浏览 2提问于2014-07-01得票数 0
回答已采纳
2回答
为了简化我的问题，我
具有@Transactionnal方法的App1 createUser():
在数据库中插入新用户
在RabbitMQ中添加异步消息，以便用户接收通知邮件
(可能会增加一些代码，但不多)
App2与RabbitMQ消息使用者
实时地使用邮件队列上的消息。
读取数据库中的邮件数据
寄出邮件
问题是，有时，App2试图在事务提交到App1之前使用RabbitMQ消息。这意味着App2无法读取数据库中的邮件数据，因为用户尚未创建。
一些解决方案可能是：
在READ_UNCOMMITED上使用App2隔离级别
在RabbitMQ消息
浏览 1提问于2013-07-02得票数 10
2回答
我对RabbitMQ和Apache相当陌生.消息被bing从接口(IMAP等)中取出并发送到队列中进行进一步处理。我很难找到一个解决方案，以避免在RabbitMQ关闭的情况下丢失消息。避免通过骆驼路由将消息发送到队列中的最佳解决方案是什么？
我使用Spring和camel版本2.25.1。
非常感谢。
浏览 4提问于2020-07-07得票数 0
回答已采纳
1回答
我们计划在消息传递服务中使用RabbitMq，我们将把所有消息请求发布到一个RabbitMq持久队列中。
对于.Net客户端，我们决定使用EasyNetQ，因此问题是在发布消息时如何处理RabbitMq服务器？
我们是否应该捕获异常并将消息保存到数据库中，并使用计划作业重新发布？
我们应该用断路器吗？
不然还能怎么样？我想听听你的经历。
浏览 0提问于2016-12-19得票数 1
回答已采纳
1回答
我正在尝试实现以下场景并使用JMS。使用DefaultMessageListenerContainer接收消息
场景-我有一个发布者发布消息到一个RabbitMQ交换和一个侦听器侦听一个RMQ队列来接收消息。如果在侦听器上处理接收到的消息时出现异常，则该消息或一组消息应该回滚并放入同一个队列中。
我使用属性"session = true“通过本地事务实现上述场景。但是，当出现异常时，我的消息并没有回滚回原来的队列。如果我漏掉了什么能帮上忙吗。
Spring配置如下。
<bean id="rmqConnectionFactory" class="com.ra
浏览 5提问于2017-03-22得票数 1
1回答
RabbitMQ与应用解耦
、、、、
我需要设置RabbitMQ，试图使用异步消息重新设计我们的体系结构。
现有应用程序流：
JEE应用程序(通过浏览器)创建一个新线程。
这个线程创建一个新的OS进程来调用Perl脚本来进行一些处理。
Perl脚本将其输出写入文件中，然后控件返回到线程。
然后，线程读取输出文件并将结果加载到数据库。
控件传递给servlet，servlet将结果显示给UI。
所有这些都是同步和耗时的，我们需要将其转换为异步消息传递通信。
现在，我计划将其分解为以下不同的组件，但不确定这是否适用于RabbitMQ：
应用程序分解：
JEE应用程序，它是RabbitMQ的生产者
将
浏览 2提问于2016-09-02得票数 1
回答已采纳
1回答
当消息监听器容器上的channelTransacted = true时，acknowledgeMode.AUTO和acknowledgeMode.MANUAL有什么区别？
我知道，当我想在channelTransacted=false中使用acknowledgeMode.MANUAL时，侦听器必须通过调用Channel.basicAck()来确认消息。当监听器容器的channelTransacted = true时，是否没有必要使用acknowledgeMode.MANUAL？因为当我将acknowledgeMode.MANUAL和channelTransacted=true与调用Channe
浏览 9提问于2018-02-19得票数 0
回答已采纳
1回答
我刚刚安装了RabbitMQ，我正在与logstash一起使用它。我一直在发送信息，但我丢失了很多数据。我不知道该怎么解决这个问题。我在rabbitMQ中使用默认配置。
这些是logstash中的输出和logstash中的输入：
output {
rabbitmq {
host => "IPHOST"
exchange => "logstash-rabbitmq"
exchange_type => "direct"
key => "logstash-key"
浏览 1提问于2015-12-02得票数 0
回答已采纳
我向RabbitMQ队列发送消息，但是消费者什么也没收到。
channel.assertQueue(config.amqp.queue
显示
{ queue: 'tasks', messageCount: 0, consumerCount: 1 }
消费者什么也没表现出来。管理面板不显示任何内容。如何确认消息已经发送到RabbitMQ队列？我以const ok = await channel.assertQueue(config.amqp.queue，{channel.assertQueue: true })的方式发送；
我通过以下方式发送：
await channel.s
浏览 0提问于2019-11-19得票数 2
当我的消息没有被传递到RabbitMQ服务器时，我正在使用hystrix来处理错误场景。当RabbitMQ服务器关闭时(当AMQPException被抛出时)，我的回退就会被调用。如果代理无法接受/路由消息，则会调用returnCallback/returnConfirm(带有nack)。
我所理解的是，RabbitTemplate回拨/回拨将在与Hystrix线程不同的线程中执行。
是否有可能在这些场景中抛出异常，从而执行Hystrix回退？
我已经提到了这些Q：
任何用于处理此场景的指针都是非常感谢的。
浏览 5提问于2016-09-14得票数 3
回答已采纳
我有一个系统，它使用mongoDB作为持久性，使用RabbitMQ作为消息代理。我面临一个挑战，我只想为发布失败场景实现RabbitMQ。我不确定这是否可能，因为我也有使用相同mongoDB持久性的使用者，所以当我编写一个代码，涵盖RabbitMQ发布失败场景的事务性发件箱时，发布的消息会在mongoDB commitTransaction之前到达消费者，因此由于延迟，我的使用者无法在mongoDB中找到消息。
我的代码如下所示；
1-开始会话事务
2-使用会话插入文档(因此在我调用commit之前它不会持久)
3-发布rabbitMQ
4-如果成功，commitTransaction
5-如
浏览 28提问于2021-08-30得票数 1
回答已采纳
rabbitmq服务器或集群重启后，所有队列都恢复了所有消息，即使消息已经确认(从rabbitmq服务器启动时开始)，并重新处理所有消息。
队列详细信息
根据我的理解，在消息参数中将persistenet设置为false，如果代理重新启动，消息将不会继续存在。此外，我还将队列的durabele设置为false。
我是否遗漏了任何其他设置？
浏览 1提问于2018-07-10得票数 0
现在，如果可以用RabbitMQ和来实现这个想法，我想：
一个队列，具有1条消息的容量。
使用者将请求这个消息，如果它存在于队列中，它将被传递给他们，如果没有，他们会得到一个null或一个错误。
此消息(如果存在于队列中)将不会被删除，因为已经下载，只有当生产者将另一条新消息放入队列时才会删除。
诚挚的问候!
浏览 2提问于2017-12-14得票数 1
我使用的是RabbitMQ 3.6.5
我有镜像设置，一切都很好。我有一个关于法定人数的问题。
发布者是否确认消息被写入镜像或仅写入主服务器？
谢谢
浏览 5提问于2017-03-10得票数 0
回答已采纳
我创建了一个SpringBoot/Spring AMQP项目，其中我在RabbitMQ队列上配置了一个侦听器。问:有没有办法把消息留在队列中？让我解释一下:我消费了消息并做了一些事情(例如在数据库上保存)，如果出现问题，我希望能够重新消费消息。
提前感谢
浏览 2提问于2021-01-22得票数 0
2回答
MassTransit事务性发布
、、、、
我不知道如何使用MassTransit 3.1.2和RabbitMQ 3.6.0发布消息事务。我有一个基本的场景，我将一些东西保存到数据库中，然后我想要发布一个事件。在我完成消息已经发送的范围之前，包装它的System.Transactions.TransactionScope是不起作用的：
using (var scope = new TransactionScope(TransactionScopeOption.Required))
{
// Save to database here.
bus.Publish(new EntityCreatedEvent());
浏览 1提问于2016-02-11得票数 3
我有两个函数，每个函数都在创建特定于一个事务的日志；它是一个多线程应用程序，因此对于已完成的事务，func1的函数条目可以是随机的，但是对于单个事务，它只能通过func1、func2和func3订单进行。
func1(transactionId) {
log("%d Now in func1", transactionId);
}
func2(transactionId) {
log("%d Now in func2", transactionId);
}
func3(transactionId) {
log("%d N
浏览 0提问于2015-09-27得票数 0
我已经通过MassTransit (使用RabbitMQ)实现了一个竞争的消费者模式，作为处理单个命令的结果，需要发布另外三个命令。我想在“全有或全无”(事务型)发布中这样做，其中"all“将确保三个消息成功地发送到RabbitMQ，或者”none“，其中我的3个事件都不会发送到RabbitMQ，即使发布失败的第三个也是如此。
到目前为止，我只是简单地调用message.Respond(new MyNewCommandHere(){...})，但是我没有在那里或IServiceBus实例上看到批量接口。
所以..。有没有可能以某种方式进行批量发布，或者其他一些推荐的方式来实现这种事务性
浏览 0提问于2013-11-15得票数 1
我写了一个Java应用程序，它将消息发送到RabbitMQ。然后，Flume从RabbitMQ队列中提取消息。我感兴趣的是，除了flume之外，没有人从队列中提取消息。
我的应用程序使用Spring AMQP Java插件。
问题是：
使用下面的代码，消息进入RabbitMQ队列，并永远保持“未知”。据我所知，RabbitMQ正在等待来自MessageListener的确认，但MessageListener永远不会确认。有谁知道怎么修复它吗？
代码：
public class MyAmqpConfiguration {
@Autowired
ConnectionFactory
浏览 3提问于2012-08-14得票数 4
1回答
使用wso2ei-6.4.0，我发现可以通过定义入站端点或定义消息库来使用消息传递消息(RabbitMQ)。
所需的功能是有保证的传递和消息排序。如果我们使用建议的，我们就失去了消息顺序(因为失败的消息存储在队列的开头)。
我的想法是利用JMS事务。我是否可以将JMS事务与JMS消息存储库一起使用，或者我是否需要定义一个JMS入站端点？
浏览 0提问于2019-03-01得票数 1
1回答
春云流中的事务处理
、、、、
Problem：我试图逐行读取一个大文件，并将消息放入RabbitMQ中。我想在文件末尾提交rabbitMQ。如果文件中的任何记录都是错误的，那么我希望撤销发布到队列中的消息。
技术：Spring引导，Spring云流，RabbitMQ
你能帮我实现这个过渡吗。我知道如何使用spring云流读取文件并发布到队列中。
编辑：
@Transactional
public void sendToQueue(List<Data> dataList) {
for(Data data:dataList)
{
this.output.send
浏览 1提问于2018-05-16得票数 1
回答已采纳
1回答
我对Mule ESB非常陌生。
我已经创建了一个具有多个队列的流(我正在使用RabbitMQ)。流程类似于将一些消息放入第一个队列中，然后由第二个队列读取，然后再读取第三个队列，等等。
注意：--我正在使用JMeter并发发送消息。
假设在将所有消息从第二个队列放入第三个队列之前，我的rabbitmq服务器已经停止。现在，在这种情况下，我想恢复我的消息。此外，我应该能够知道哪些消息已被放入第三队列中，哪些消息仍在保留。
我可能没有以优雅或可理解的方式提出我的问题，但我希望你理解我想要实现的目标。
浏览 3提问于2014-03-11得票数 0
1回答
XA事务和消息总线
、、、
在我们的新项目中，我们希望实现涉及jpa (mysql)和消息总线(rabbitmq)的事务。
我们开始使用mysql和rabbitmq构建使用spring数据的基础设施(通过spring模块)。由于rabbitMq不是XA事务性的，所以我们将neo4j chainedTransactionManager配置为我们的主要transactionManager。这个管理器使用jpa txManager和rabbitTransactionManager作为参数。
现在，我确实能够用@Transacitonal对服务进行注释，并在其中同时使用jpa和兔子。如果我在服务中抛出一个异常，那么所有的操作都不
浏览 1提问于2013-12-12得票数 5
我希望实现至少一次对消息队列(ex: RabbitMQ)的传递，同时在数据库中提交事务(ex: PostgreSQL)。
流
启动数据库事务
从数据库中获取一些数据
将一些数据插入数据库
如果适用某些条件，则将消息发布到rabbitMQ
提交事务
如您所见，如果在步骤4之后、步骤5之前发生故障，我们已经发布了一条无效的消息。
即使我们重试整个过程，步骤4所需的条件也可能不再为真，因此先前发布的消息将更加无效。
解决这一问题的方法是使用CDC，但由于技术成本，目前已经无法选择。(我很想知道是否有任何廉价的配置CDC选项)
可能解决办法
创建一个events表并在其中插
浏览 7提问于2021-11-25得票数 0
我计划在我的项目中使用。是否可以使用Publisher确认(又名Publisher Acknowledgements)，即注册中描述的确认回调？或者是否有其他可能从RabbitMQ接收到来自客户端的消息？
浏览 4提问于2017-04-05得票数 2
回答已采纳
我想知道使用java API处理通信错误(例如，RabbitMQ崩溃或网络问题)的最好方法是什么。
我们使用Channel.basicPublish(...)方法，并希望保证发送给代理的每条消息都能送达。
更具体地说，在Java client publish API中(在消息被发送到总线之前)是否有一种机制来确保消息将被传递(或者在总线发送IOException时调用回调)，或者我们必须实现这个过程吗？
你会怎么做呢？
浏览 0提问于2010-10-12得票数 2
回答已采纳
1回答
我使用python脚本(3.5.2)和RabbitMQ工作队列来处理数据。有一个队列，其中充满了外部系统的用户请求。这些用户请求将由我的python脚本处理，每个用户请求都会产生几条输出消息。我使用acknoledge功能来确保传入的消息只有在处理之后才会被删除。这确保了如果工作人员偶尔死亡，消息将被重新分配。但是，如果工作线程在发送消息过程中死亡，则此用户请求的一些消息可能已经发送到队列，而其他消息将不会发送。有没有办法自动发送多条消息，即发送所有消息或不发送消息？
浏览 0提问于2016-12-09得票数 0
当我的事务标记为回滚时，我不希望SimpleMessageListenerContainer继续使用这些消息。
我没有在配置文件中添加listener-container并试图重新抛出AmqpRejectAndDontRequeueException。它不起作用。这是我的代码库：
@Transactional
public class MySecondService {
@Resource
private MySecondRepository mySecondRepository;
@Transactional(propagation = Propagation.
浏览 2提问于2016-10-18得票数 0
回答已采纳
1回答
在我以前的工作中，我使用了AMQP的好处，但我没有参与rabbitMQ子项目开发。在我目前的工作中，我想负责集成一个AMQP实现(可能是rabbitMQ)。这里的问题是我必须说服我的老板使用AMQP。
我正在阅读"RabbitMQ in Action“，Videla先生写道，AMQP可以改进任何系统，但我不知道如何改进我的项目。我们只使用两个服务器在中间调用API，所以我们现在没有可伸缩性问题。我们处理的是真正的资金流，这意味着任何操作都需要成功的确认，也就是说，我不能把任务排在队列中，“忘记”它。在这种情况下，AMQP能带来什么好处？
当你不需要很难扩展的时候，你能提供几个关于相对较
浏览 2提问于2013-02-13得票数 7
1回答
我是一个使用CDI和EJB的新手，我刚刚创建了一个jboss web应用程序。不过，除此之外，我还想让这个应用程序处理rabbitmq消息。在处理这些时，我想做一些持久化工作，但是，因为我一直在侦听来自以@Startup注释启动的应用程序范围的bean的rabbitmq消息，所以我无法在这种范围内提交任何事务，也就是说，当我离开应用程序范围时，我将从该范围实例化的每个bean都将是应用程序范围的。当我尝试执行em.getTransaction()和em.commit()时，代码崩溃了，报告我不能在JTA事务下调用getTransaction()，当我使用用户事务时，每个操作似乎都放在同一个事务
浏览 0提问于2013-03-16得票数 0
回答已采纳
代码的背景：
为了复制生产场景，我创建了一个虚拟应用程序，它基本上可以在事务中保存DB中的某些内容，并且在相同的方法中，它publishEvent和publishEvent向rabbitMQ发送一条消息。
类和用法
事务从此方法开始。：
@Override
@Transactional
public EmpDTO createEmployeeInTrans(EmpDTO empDto) {
return createEmployee(empDto);
}
此方法保存数据库中的记录，并触发publishEvent。
@Override
public
浏览 0提问于2021-03-13得票数 0
回答已采纳
我们的需求非常简单。向订阅主题的用户发送消息。我们需要我们的消息传递系统能够支持数百万个主题，甚至是几乎实时的任何给定主题的数百万订阅者。我们的应用程序是用Java构建的。
我们几乎决定选择RabbitMQ，因为它的社区支持、文档和功能(可能它可以提供我们需要的一切)。但我非常倾向于使用Redis，因为它看起来很有前途，而且很轻量级。老实说，我对Redis作为一个消息系统的理解有限，但是看着越来越多的公司使用它作为队列(使用Ruby Resque)，我想知道Java中是否有像Resque这样的产品，以及使用Redis作为MQ而不是RabbitMQ有什么优点或缺点。
浏览 0提问于2011-09-12得票数 11
回答已采纳
我认为发布者确认模式和事务处理都要求代理确认接收消息，那么为什么发布者确认模式被认为是比事务吞吐量更轻的操作呢？
我认为事务具有同步样式，而publisher确认模式具有异步样式，但我错了，存在具有同步样式的publisher确认模式。
那么，发布者确认模式与RabbitMQ中的事务有什么区别，以及为什么Publisher确认模式提供了更好的吞吐量性能？
浏览 3提问于2019-10-07得票数 0
回答已采纳
我正在使用RabbitMq和Masstransit来扩展分布式体系结构中的消息，我真的想测量消息机制对应用程序正在处理的操作的延迟的影响吗？谢谢
浏览 3提问于2022-06-23得票数 0
回答已采纳
1回答
我对RabbitMQ有一个时间问题。我有一个通知类，我试图将它从运行在tomcat下的web服务保存到数据库中，然后将该实体id排队到RabbitMQ，以供消费者获取。
问题是在事务完成之前消息被排队，这样消费者就找不到记录了。
我尝试通过Propagation.REQUIRES_NEW为保存部分创建一个单独的事务，但是我得到了一个Hibernate异常，如下所示：
org.hibernate.HibernateException:非法尝试将代理与两个开放会话关联
是否有一种人们通常用来解决这个问题的模式？
任何帮助都是非常感谢的。
浏览 0提问于2015-05-18得票数 4
回答已采纳
我们有以下使用.NET RabbitMQ库的场景：
工作线程从队列中提取“请求”消息，并将它们分派到多个工作线程上进行处理。完成后，每个工作线程将发送另一条消息。
我的问题是，为了获得最好的吞吐量和稳定性，人们向发送者推荐了什么“模式”？例如：
1)可由具有单个连接和锁的所有工作线程访问的单个“IModel”实例(使用“锁”来同步对publisher的访问)
2)一个单独的'publisher‘实例，它由具有单个连接的所有工作线程访问，并为每个发送请求创建一个新的IModel。
还是别的什么？
浏览 3提问于2012-02-21得票数 5
回答已采纳
我正在尝试构建集成流，这将防止消息在传递给AMQP (rabbitMQ)时丢失。在代理停止的情况下，我看到一些意想不到的行为：
失败的邮件正在保存到消息存储区，但保存时间不长。这个流程并不是等待代理的可用性，它从消息存储中提取消息，即使代理仍然被停止以防止重新启动rabbitmq，消息存储中的记录(如果仍然存在)也不会被传递到队列中。
请帮我调查一下。代码示例：
@Bean
public MessageChannel messageStoreBackedChannel() {
return new QueueChannel(
new MessageGroupQ
浏览 2提问于2021-04-01得票数 1
回答已采纳
我正在研究简单的Wso2 RabbitMQ集成。我的入站端点使用该消息并将其发送到序列。然后序列存储消息。另一个正在记录错误的故障序列。我正在尝试从序列中再次发送队列上的消息。
SalesOrderQueueInboundEP
<?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint name="SalesOrderQueueInboundEP" onError="SalesOrderQueueErrorSeq" protocol="rabbitmq&
浏览 3提问于2020-11-08得票数 0
回答已采纳
1回答
在服务中保存一个域对象时，使用保存该域时的flush: true，在我必须使用该对象之前，不会保存该对象。
Domain domain = new Domain(property: something.toString()).save(failOnError: true, flush: true)
我不确定如何在我正在使用的两个服务中强制刷新hibernate会话。
对于某些上下文，我对一个API服务进行API调用，该API服务转到另一个服务，在那里我保存了域，然后返回到API服务，然后向RabbitMQ队列添加一个字符串，然后向用户返回200OK。但是，因为域不会保存在第二个服务中，所以当项
浏览 9提问于2015-11-24得票数 0
1回答
我有一个泽西应用程序，在这个应用程序中，我使用spring库向rabbitMQ交换发布消息。我在兔模板中使用CachingConnectionFactory，最初通道事务被设置为false。我注意到有些消息实际上并没有发布到交换中，所以我将通道事务处理的值更改为true。
在这样做时，我的发布功能开始使用500 5ms (它是5 5ms，而通道事务是假的)。这里是不是有什么东西我错过了，因为500毫秒太多了。
作为另一种选择，我尝试将publisherConfirms设置为true并添加了一个ConfirmCallback。我还没有对此进行基准测试，但想知道与通道事务相比，这是否具有更好的性能
浏览 4提问于2018-01-04得票数 3
1回答
我已经实现了Redis，在某些端点上的一些更新中，我需要连接到某个RabbitMQ服务器或RESTful服务器。这些消息将帮助事件进一步展开。我的问题是，在这种情况下，我如何处理网络异常？
例如，如果任务A被更新，我首先在数据库中更新任务的状态(例如mongodb)，然后在某个RabbitMQ服务器上提交一条消息，以通知另一个微服务上的另一个消费者。或者我可能需要在Redis服务器上更新一些计数器。
* API REQUEST - update Task A
*serving request:
* update Task A on DB
* send message to RabbitMQ a
浏览 2提问于2020-08-25得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
