public Log4J2NacosLogging() {
        String location = this.getLocation("classpath:nacos-log4j2.xml");
        if(!StringUtils.isBlank(location)) {
            this.locationList.add(location);
        }

    }

    public void loadConfiguration() {
        if(!this.locationList.isEmpty()) {
            List configList = this.findConfig(this.getCurrentlySupportedConfigLocations());
            if(configList != null) {
                this.locationList.addAll(configList);
            }

            ArrayList configurations = new ArrayList();
            LoggerContext loggerContext = (LoggerContext)LogManager.getContext(false);
            Iterator compositeConfiguration = this.locationList.iterator();

            while(compositeConfiguration.hasNext()) {
                String location = (String)compositeConfiguration.next();

                try {
                    Configuration e = this.loadConfiguration(loggerContext, location);
                    if(e instanceof AbstractConfiguration) {
                        configurations.add((AbstractConfiguration)e);
                    }
                } catch (Exception var7) {
                    throw new IllegalStateException("Could not initialize Log4J2 Nacos logging from " + location, var7);
                }
            }

            CompositeConfiguration compositeConfiguration1 = new CompositeConfiguration(configurations);
            loggerContext.start(compositeConfiguration1);
        }
    }

private String[] getCurrentlySupportedConfigLocations() {
        ArrayList supportedConfigLocations = new ArrayList();
        if(ClassUtils.isPresent("com.fasterxml.jackson.dataformat.yaml.YAMLParser")) {
            Collections.addAll(supportedConfigLocations, new String[]{"log4j2.yaml", "log4j2.yml", "log4j2-test.yaml", "log4j2-test.yml"});
        }

        if(ClassUtils.isPresent("com.fasterxml.jackson.databind.ObjectMapper")) {
            Collections.addAll(supportedConfigLocations, new String[]{"log4j2.json", "log4j2.jsn", "log4j2-test.json", "log4j2-test.jsn"});
        }

        supportedConfigLocations.add("log4j2.xml");
        supportedConfigLocations.add("log4j2-test.xml");
        return (String[])supportedConfigLocations.toArray(new String[supportedConfigLocations.size()]);
    }

aliyun.mq.onsAddr=<地址>
aliyun.mq.accessKey=
aliyun.mq.secretKey=
aliyun.mq.TopicIdRblc=
#为false表示不引入producer，为true则producerId必须提供
aliyun.mq.producer.enabled=true
aliyun.mq.producer.producerId=
#为false表示不引入consumer，为true则consumerId必须提供
aliyun.mq.consumer.enabled=true

@Autowired
OrderMessageTemplate orderMessageTemplate;

//发送
orderMessageTemplate(new MessageEvent("{topic}", "{tag}", msgBody));

@Autowired
RocketMQTemplate rocketMQTemplate;

// 发送普通消息
rocketMQTemplate.send(new MessageEvent("{topic}", "{tag}", msgBody));
// 延时消息，单位毫秒（ms），在指定延迟时间（当前时间之后）进行投递，例如消息在 3 秒后投递
rocketMQTemplate.sendAsync(new MessageEvent("{topic}", "{tag}", msgBody),3000);
// 延时消息，指定时间进行投递。例如消息在1天之后投递
Calendar cal = Calendar.getInstance();
cal.setTime(date);
cal.add(Calendar.DATE, 1);
rocketMQTemplate.sendAsync(new MessageEvent("{topic}", "{tag}", msgBody), cal.getTime(););

@Autowired
TransactionMessageTemplate messageTemplate;

// 发送事务消息
/**封装消息*/
MessageEvent event = new MessageEvent();
event.setTopic("base_sms");
event.setTag("Tag_user");
   
User user = new User();
user.setName("Paul");
user.setAdds("北京市 昌平区 龙锦苑东二区");
 /**封装任意类型领域对象*/
event.setDomain(user);
    
transactionMessageTemplate.send(event,new TransactionExecuter() {
@Override
public TransactionStatus executer(MessageEvent messageEvent, Long hashValue, Object arg) {
	String transactionId = TransactionDemo.createTransaction();
	TransactionStatus status = TransactionDemo.checker();
	return status;
}
),"参数对象,以本字符串示例,会传递给TransactionExecuter.executer");

@RocketMQMessageListener(topic = "${aliyun.mq.TopicIdRblc}", tag = "giveCoupon", consumerId = "CID_shopping_giveCoupon", consumeMode = MessageExtConst.CONSUME_MODE_ORDERLY)
public class GiveCouponMessageListener extends AbstractMessageListener<MessageEvent> {
    /**
     * 消息处理
     */
    @Override
    public void handle(MessageEvent messageEvent) throws Exception {
    	//TODO 业务处理
    }
}

@RocketMQMessageListener(topic = "${aliyun.mq.TopicIdRblc}", tag = "giveCoupon", consumerId = "CID_shopping_giveCoupon", consumeMode = MessageExtConst.CONSUME_MODE_ORDERLY)
public class GiveCouponMessageListener extends AbstractMessageOrderListener <MessageEvent> {
    /**
     * 消息处理
     */
    @Override
    public void handle(MessageEvent messageEvent) throws Exception {
    	//TODO 业务处理
    }
}