rocketmq中DefaultRocketMQListenerContainer的原理及用法

这篇文章主要介绍“rocketmq中DefaultRocketMQListenerContainer的原理及用法”，在日常操作中，相信很多人在rocketmq中DefaultRocketMQListenerContainer的原理及用法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”rocketmq中DefaultRocketMQListenerContainer的原理及用法”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！本文主要研究一下rocketmq的DefaultRocketMQListenerContainerrocketmq-spring-boot-2.0.3-sources.jar!/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.javaDefaultRocketMQListenerContainer实现了InitializingBean, RocketMQListenerContainer, SmartLifecycle, ApplicationContextAware接口；setRocketMQMessageListener方法会根据RocketMQMessageListener注解的信息来设置consumeMode、consumeThreadMax、messageModel、selectorExpression、selectorType、consumeTimeoutafterPropertiesSet方法执行了initRocketMQPushConsumer及getMessageType方法；initRocketMQPushConsumer方法会根据rpcHook是否为null来创建不同的DefaultMQPushConsumer，之后根据messageModel、selectorType、consumeMode等来配置consumer；如果rocketMQListener类型是RocketMQPushConsumerLifecycleListener的，则执行RocketMQPushConsumerLifecycleListener的prepareStart方法setupMessageListener方法主要是保存了rocketMQListener；isAutoStartup方法返回true；start方法主要是执行consumer.start()方法；stop及destroy方法主要是执行consumer.shutdown()rocketmq-spring-boot-2.0.3-sources.jar!/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.javaDefaultMessageListenerConcurrently方法实现了MessageListenerConcurrently接口；它的consumeMessage方法使用for循环try catch执行rocketMQListener.onMessage(doConvertMessage(messageExt))回调，都成功返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS，一旦异常则返回ConsumeConcurrentlyStatus.RECONSUME_LATERrocketmq-spring-boot-2.0.3-sources.jar!/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.javaDefaultMessageListenerOrderly实现了MessageListenerOrderly接口，其consumeMessage方法使用for循环try catch执行rocketMQListener.onMessage(doConvertMessage(messageExt))回调，都成功返回ConsumeOrderlyStatus.SUCCESS，一旦异常则返回ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENTDefa 香港云主机ultRocketMQListenerContainer实现了InitializingBean, RocketMQListenerContainer, SmartLifecycle, ApplicationContextAware接口；setRocketMQMessageListener方法会根据RocketMQMessageListener注解的信息来设置consumeMode、consumeThreadMax、messageModel、selectorExpression、selectorType、consumeTimeoutafterPropertiesSet方法执行了initRocketMQPushConsumer及getMessageType方法；initRocketMQPushConsumer方法会根据rpcHook是否为null来创建不同的DefaultMQPushConsumer，之后根据messageModel、selectorType、consumeMode等来配置consumer；如果rocketMQListener类型是RocketMQPushConsumerLifecycleListener的，则执行RocketMQPushConsumerLifecycleListener的prepareStart方法setupMessageListener方法主要是保存了rocketMQListener；isAutoStartup方法返回true；start方法主要是执行consumer.start()方法；stop及destroy方法主要是执行consumer.shutdown()到此，关于“rocketmq中DefaultRocketMQListenerContainer的原理及用法”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注开发云网站，小编会继续努力为大家带来更多实用的文章！

相关推荐: CentOS7虚拟机中如何安装并配置docker套件

本篇内容介绍了“CentOS7虚拟机中如何安装并配置docker套件”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！1. 打开vmware, 创建虚拟机, 选择光…