1.集成rocketMQ,引入哪些jar包
2.web项目创建producer者类和消费者类
3.web项目启动了,生产者和消费者如何启动,是不是在web容器初始化启动生产者和消费者,还是在调用的时候?
4.如果在web容器初始化,如何弄?
5.希望有代码解决?
1.集成rocketMQ,引入哪些jar包
2.web项目创建producer者类和消费者类
3.web项目启动了,生产者和消费者如何启动,是不是在web容器初始化启动生产者和消费者,还是在调用的时候?
4.如果在web容器初始化,如何弄?
5.希望有代码解决?
com.alibaba.rocketmq rocketmq-client 3.2.6
生产者只要发送消息的时候调用一下
消费者需要初始化时启动监听
spring可以继承InitializingBean ,或者使用@PostConstruct注解