JAVA的MQ双写示例

public OrderDto create(final OrderDto order) throws OrderException{
  OrderDto createOrderDto = executeInShardingTrans((status)->{
  OrderDto insertOrderDto = convert(orderService.insert(order));
  return insertOrderDto;
});
//发MQ
orderMqProducer.publish(OrderMqType.CREATED,null,insertOrderDTO);
//写缓存
orderCache.put(createOrderDto);
return createdOrderDTO;
}