我在我的应用程序中执行以下操作：
>从经纪人处获得1条消息(手动确认)
>做一些处理
>在数据库和代理上启动事务
>在数据库中插入一些记录并发布一些消息
经纪人(不同的队列)
>提交数据库和代理
>您在步骤1中从经纪人处获得的确认消息.
经纪人的所有操作都是通过单一渠道完成的.这是准备代码：
Connection brokerConnection = factory.newConnection();
Channel channel = brokerConnection.createChannel();
channel.basicQos(1);
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume("receive-queue", false, consumer);
以下是我的代码.我已经删除了try,catch部分以使其清楚.我将所有例外记录到文件中.
步骤1：
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
Request request = (Request) SerializationUtils.deserialize(delivery.getBody());
第2,3,4,5步：
dbConnection.setAutoCommit(false);
channel.txSelect();
stmt = dbConnection.prepareStatement(query);
/* set paramteres */
stmt.executeUpdate();
channel.basicPublish(/* exchange name */, "KEY", MessageProperties.PERSISTENT_BASIC, /* result */ result);
dbConnection.commit();
channel.txCommit();
dbConnection.setAutoCommit(true);
第6步：
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
在一次迭代之后,我可以在数据库和代理中看到记录(意味着它在第5步之前正常工作).问题是在步骤6之后未删除接收队列上的消息,并且管理插件显示一条未确认的消息.此外,我在日志文件中看不到任何异常.有人可以帮忙吗？
[UPDATE1]
现在我创建一个用于发布的频道和另一个用于接收的频道.现在正在运作.那么如何使用单一渠道进行接收和发布(使用交易)？我之前使用过单个频道进行接收和发布,但没有交易.
[UPDATE2]
我在事务中移动了第6步,它现在正在运行.
dbConnection.setAutoCommit(false);
channel.txSelect();
stmt = dbConnection.prepareStatement(query);
/* set paramteres */
stmt.executeUpdate();
channel.basicPublish(/* exchange name */, "KEY", MessageProperties.PERSISTENT_BASIC, /* result */ result);
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
dbConnection.commit();
channel.txCommit();
dbConnection.setAutoCommit(true);
我有点困惑.我只是希望发布部分在内部事务中.
解决方法:
您已将频道置于事务模式 – 而ack是事务性事物.所以你需要在一个单独的非交易渠道上消费和确认,或者只是接受你的ack需要在tx.commit之前.
标签：java,rabbitmq,amqp 来源： https://codeday.me/bug/20190825/1720099.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。