阿里高级架构师教你使用Spring JMS处理消息事务源码案例

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

消费者在接收JMS异步消息的过程中会发生执行错误，这可能会导致信息的丢失。该源码展示如何使用本地事务解决这个问题。这种解决方案可能会导致在某些情况下消息的重复（例如，当它会将信息储存到数据库，然后监听执行失败）。之所以出现这种情况是因为JMS交易是独立于像数据库等事务性资源。如果您的处理不是幂等或者如果您的应用程序不支持重复消息检测，那么你将不得不使用分布式事务。分布式事务是超出了本源码案例的范围。

消费者的代码如下：

@Component("notificationProcessor")

public class NotificationProcessor implements MessageListener {

private static Logger logger = LoggerFactory.getLogger(NotificationProcessor.class);

@Autowired

private JdbcTemplate jdbcTemplate;

@Override

public void onMessage(Message message) {

try {

Notification notification = (Notification) ((ObjectMessage) message).getObject();

logger.info("Received notification | Id: "+notification.getId()+" | Redelivery: "+getDeliveryNumber(message));

checkPreprocessException(notification);

saveToBD(notification);

checkPostprocessException(message, notification);

} catch (JMSException e) {

throw JmsUtils.convertJmsAccessException(e);

}

}

...

}