🔥🔥🔥轻量级动态线程池,内置监控告警功能,集成三方中间件线程池管理,基于主流配置中心(已支持Nacos、Apollo,Zookeeper、Consul、Etcd,可通过SPI自定义实现)。Lightweight dynamic threadpool, with monitoring and alarming functions, base on popular config centers (already support Nacos、Apollo、Zookeeper、Consul, can be customized through SPI).
报错信息:
java.lang.NoSuchMethodError: org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.getAsyncSenderExecutor()Ljava/util/concurrent/ExecutorService;
at org.dromara.dynamictp.adapter.rocketmq.RocketMqDtpAdapter.adaptProducerExecutors(RocketMqDtpAdapter.java:110)
at org.dromara.dynamictp.adapter.rocketmq.RocketMqDtpAdapter.initialize(RocketMqDtpAdapter.java:67)
at org.dromara.dynamictp.adapter.common.AbstractDtpAdapter.onContextRefreshedEvent(AbstractDtpAdapter.java:80)
at org.dromara.dynamictp.common.spring.OnceApplicationContextEventListener.onApplicationEvent(OnceApplicationContextEventListener.java:50)
at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:402)
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:359)
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:896)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:163)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:552)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:142)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:316)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1260)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1248)
首先感谢您使用 DynamicTp,如果使用过程中有任何问题,请按照下述模板反馈问题,建议使用 Markdown 语法。
版本信息
问题描述
RocketMqDtpAdapter这边,我们项目rocketMq-client 是4.3.0版本的,没有4.9.3的getAsyncSenderExecutor 这个发送者线程池方法,导致加载报错,这边需要做个兼容
复现步骤
其他信息
无