现在想实现一个功能，后台新增商品的同时，把新增商品的信息同步至索引库。
但是如果把发送消息的代码加到新增商品的方法里，因为最后一句是resalut ok()，所以会导致还未提交事务，就先发送了消息，此时发送的消息是空。导致报空指针错误。我把新增方法和发消息的代码装在一个新的方法里。但并未解决问题。
请问，怎么写才能做到先提交事务，再发送消息(activeMQ)
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
2条回答 默认 最新
浮生-半日 2018-11-29 13:06关注把发消息的部分抽出成方法,然后在该方法中先调用新增保存方法,在获取消息的参数来发消息
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏举报 分享
- 2018-11-29 09:30回答 2 已采纳 把发消息的部分抽出成方法,然后在该方法中先调用新增保存方法,在获取消息的参数来发消息
- 2017-10-22 08:15回答 1 已采纳 1、返回的ackknowldge 取决于服务器session的设置。默认是Session.AUTO_ACKNOWLEDGE，客户端recevie()后者onMessage之后签收，还有Session.
- 2016-12-19 09:48回答 1 已采纳 http://blog.csdn.net/acceptedxukai/article/details/7775746
- 2020-12-24 12:10weixin_39953356的博客 int acknowledgeMode) throws JMSException 1.transacted事务，事务成功commit,才会将消息发送到mom中 2.acknowledgeMode消息确认机制 1）、带事务的session 如果session带有事务，并且事务成功提交，则消息被自动...
- 2012-07-10 18:17回答 1 已采纳 亲测 搞了个小例子 我的例子代码来自： http://www.open-open.com/lib/view/open1328079945062.html 然后跑了一下 消费者能接到消息 Ac
- 2017-11-12 07:28回答 4 已采纳 mq为例： 1、并发转换：在并发场景下大部分数据也是并行处理的，但是对于一些特殊需求，需要逐个进行处理 2、同步处理转换为异步处理：通常时候有些场景下我们只需要完成主线业务，而且分支业务对我们来说
- 2018-07-10 13:02回答 3 已采纳 消费并不是定时的，而是基于消息驱动的。 就像js的事件驱动一样，你点击一个按钮，这个点击的操作就能触发一个事件，而activemq是消息驱动的，你可以理解为有消息入队了，在线消费者就能在第一时间知道
- 2021-01-29 20:58宇呀宇！的博客 上手案例1.1 模拟Queue发送消息1.2 模拟消费消息(同步阻塞方式版本)1.3 模拟消费消息(普通版) 一、入门概述 1.在什么场景下使用消息中间件，为什么使用 首先举个课后找老师提问的例子。 下课了，同学们争先恐后 ...
- 2017-01-03 03:02回答 3 已采纳 昨天找到了问题所在，JDK1.6版本不支持activemq-all-5.11.1jar，这个包需要用JDK1.7，
- 2018-08-02 05:55回答 4 已采纳 参考 https://blog.csdn.net/vtopqx/article/details/51788065
- 2017-11-29 01:02回答 1 已采纳 队列消息是按顺序排列的，消费时也按顺序消费，那么只要消费20个，也就得到了前20名。 前20名返回成功，后序消息返回秒杀失败。
- 2021-01-14 08:30聪妈的博客 1 基本处理方式1.1 topic(publish-subscribe)发布订阅模式，发布者发布消息到broker，所有订阅者都会接收到相同消息的copy。 1.2 queue(p2p)p2p是生产者生成消息，经过broker-queue，只能有一个消费者处理。在p2p的...
- 2018-03-16 08:02回答 3 已采纳 看你的日志打印了什么异常信息
- 2019-11-12 19:26lemonmini的博客 一、为什么需要MQ？ 主要原因是由于在高并发环境下，由于来不及同步处理...通过使用消息队列，我们可以异步处理请求，从而缓解系统的压力。 RPC和消息中间件的不同很大程度上就是“依赖性”和“同步性”。RPC方式是...
- 2019-07-09 14:37show_hand的博客 消息事务是在生产者producer到broker或broker到consumer过程中同一个session中发生的，保证几条消息在发送过程中的原子性。(Broker:消息队列核心，相当于一个控制中心，负责路由消息、保存订阅和连接、消息确认和...
- 没有解决我的问题, 去提问
