本书64页的demo存在bug,while循环会快速消耗rabbitmq的资源,导致rabbitmq挂掉.
198页 小节【1.自动提交】 “但这还是完全避免消息重复消费的” 感觉不对劲
“但这还是完全避免消息重复消费的”
老师,你好!我想问下,基于ActiveMQ的分布式事务的项目中,为什么只有userService.j**a里的newUser()方法使用了事务?其他地方没有使用呢?我感觉UserEventService.j**a里的executeEvent()和PointMessageListener.j**a里的onMessage()和PointEventService.j**a里的executeEvent()也需要事务,也要保证一致性。
UserEventService.j**a里的executeEvent():发消息和更新db1的event表记录是两件事情PointMessageListener.j**a里的onMessage():收消息和新增db2的event表记录是两件事情PointEventService.j**a里的executeEvent():新增db2的point表记录和更新event表记录是两件事情谢谢!
倪炜老师,有个问题不太明白,过来交流一下,有关ActiveMQ集群的问题。我这里使用的网络连接器,uri使用failover的方式。如果连接到了S1服务器,信息也是在S1持久化。那么传递给S2的信息是什么?如果S1宕机了,那么S2能继续去消费这个消息吗?两个服务器之间共享队列和消费者列表,这里的共享是什么意思?如果S2把消息消费了,它怎么通知S1这条消息,我消费了?
你好,我公司在rabbitmq配置上有点不同。配置了MessageListenerAdapter 和 **MessageListenerContainer. 可不可以讲讲adapter?
好的,非常感谢你的意见。后续考虑增补 rabbitmq 中 adapter 相应的内容。
本书64页的demo存在bug,while循环会快速消耗rabbitmq的资源,导致rabbitmq挂掉.
198页 小节【1.自动提交】
“但这还是完全避免消息重复消费的”
感觉不对劲老师,你好!
我想问下,基于ActiveMQ的分布式事务的项目中,为什么只有userService.j**a里的newUser()方法使用了事务?其他地方没有使用呢?
我感觉UserEventService.j**a里的executeEvent()和PointMessageListener.j**a里的onMessage()和PointEventService.j**a里的executeEvent()也需要事务,也要保证一致性。
UserEventService.j**a里的executeEvent():发消息和更新db1的event表记录是两件事情
PointMessageListener.j**a里的onMessage():收消息和新增db2的event表记录是两件事情
PointEventService.j**a里的executeEvent():新增db2的point表记录和更新event表记录是两件事情
谢谢!
倪炜老师,有个问题不太明白,过来交流一下,有关ActiveMQ集群的问题。我这里使用的网络连接器,uri使用failover的方式。如果连接到了S1服务器,信息也是在S1持久化。那么传递给S2的信息是什么?如果S1宕机了,那么S2能继续去消费这个消息吗?两个服务器之间共享队列和消费者列表,这里的共享是什么意思?如果S2把消息消费了,它怎么通知S1这条消息,我消费了?
你好,我公司在rabbitmq配置上有点不同。配置了MessageListenerAdapter 和 **MessageListenerContainer. 可不可以讲讲adapter?