本文主要是介绍spring使用@Resource 注入map,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
spring使用@Resource 注入map
注入多个Service:
/*** 单笔付款状态 MQ消费** @author zkg* @since 2024-09-06 16:11:19*/
@Slf4j
@Component
@RocketMQMessageListener(topic = PayGlobalConstants.PAY_APPL_SINGLE_TOPIC, consumerGroup = PayGlobalConstants.PAY_APPL_SINGLE_CONSUMER_GROUP, selectorExpression = PayGlobalConstants.PAY_APPL_SINGLE_TAG)
public class PayApplSingleConsumer extends AbstractMessageListener<PayApplSingleMessage> {@Resourceprivate Map<String, PayApplSingleService> serviceMap;@Overrideprotected void handleMessage(PayApplSingleMessage message) {try {log.info("PayApplSingleConsumer=======message: {}", message);// 付社保公积金serviceMap.get("SGFK").handleMessage(message);} catch (Exception e) {log.error("PayApplSingleConsumer 处理异常: {}", e);}}}
PayApplSingleService:
public interface PayApplSingleService {/*** mq消息处理** @param message 消息体*/void handleMessage(PayApplSingleMessage message);}
SipfApplServiceImpl 实现 PayApplSingleService
@Service("SGFK")
public class SipfApplServiceImpl implements PayApplSingleService {@Resourceprivate CommonFlowApi commonFlowApi;@Resourceprivate PaySipfApplMapper paySipfApplMapper;/*** mq消息处理** @param message 消息体*/@Overridepublic void handleMessage(PayApplSingleMessage message) {// 消费mq消息}}
这篇关于spring使用@Resource 注入map的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!