spingboot-rocketmq事务消息

package com.xiaoge.mq; import com.xiaoge.domain.OperateIntergralVo; import com.xiaoge.domain.OrderInfo; import com.xiaoge.service.IOrderInfoService; import com.alibaba.fastjson.JSON; import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener; import org.apache.rocketmq.spring.core.RocketMQLocalTransactionListener; import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.messaging.Message; import org.springframework.stereotype.Component; import java.nio.charset.Charset; /** * Created by wolfcode-lanxw */ @Component @RocketMQTransactionListener(txProducerGroup = "tx_group") public class OrderTransactionMessageListener implements RocketMQLocalTransactionListener { @Autowired private IOrderInfoService orderInfoService; //执行本地事务 @Override public RocketMQLocalTransactionState executeLocalTransaction(Message message, Object o) { System.out.println("2.执行本地事务方法"); byte[] contents = (byte[]) message.getPayload(); String objStr = new String(contents, Charset.defaultCharset()); OperateIntergralVo vo = JSON.parseObject(objStr,OperateIntergralVo.class); System.out.println(vo); String orderNo = (String) o; try{ //本地业务逻辑 orderInfoService.updateRefundStatus(orderNo); System.out.println("3.执行成功"); return RocketMQLocalTransactionState.UNKNOWN; }catch(Exception e){ e.printStackTrace(); System.out.println("4.执行失败"); return RocketMQLocalTransactionState.ROLLBACK; } } //回查方法 @Override public RocketMQLocalTransactionState checkLocalTransaction(Message message) { System.out.println("9.回查方法"); String orderNo = (String) message.getHeaders().get("orderNo"); OrderInfo orderInfo = orderInfoService.find(orderNo); if(OrderInfo.STATUS_REFUND.equals(orderInfo.getStatus())){ //已经退款成功,说明本地事务执行成功 System.out.println("10.commit"); return RocketMQLocalTransactionState.COMMIT; }else{ //说明本地事务执行失败. System.out.println("11.rollback"); return RocketMQLocalTransactionState.ROLLBACK; } } }