赞
踩
下载rocketmq-spring项目
将rocketmq-spring安装到本地仓库
mvn install -Dmaven.skip.test=true
- <parent>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-parent</artifactId>
- <version>2.0.1.RELEASE</version>
- </parent>
-
- <properties>
- <rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot-starter-version>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.rocketmq</groupId>
- <artifactId>rocketmq-spring-boot-starter</artifactId>
- <version>${rocketmq-spring-boot-starter-version}</version>
- </dependency>
- <dependency>
- <groupId>org.projectlombok</groupId>
- <artifactId>lombok</artifactId>
- <version>1.18.6</version>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-test</artifactId>
- <scope>test</scope>
- </dependency>
-
- </dependencies>
- # application.properties
- rocketmq.name-server=192.168.25.135:9876;192.168.25.138:9876
- rocketmq.producer.group=my-group
- @SpringBootApplication
- public class MQProducerApplication {
- public static void main(String[] args) {
- SpringApplication.run(MQSpringBootApplication.class);
- }
- }
- @RunWith(SpringRunner.class)
- @SpringBootTest(classes = {MQSpringBootApplication.class})
- public class ProducerTest {
-
- @Autowired
- private RocketMQTemplate rocketMQTemplate;
-
- @Test
- public void test1(){
- rocketMQTemplate.convertAndSend("springboot-mq","hello springboot rocketmq");
- }
- }
同消息生产者
同消息生产者
- @SpringBootApplication
- public class MQConsumerApplication {
- public static void main(String[] args) {
- SpringApplication.run(MQSpringBootApplication.class);
- }
- }
- @Slf4j
- @Component
- @RocketMQMessageListener(topic = "springboot-mq",consumerGroup = "springboot-mq-consumer-1")
- public class Consumer implements RocketMQListener<String> {
-
- @Override
- public void onMessage(String message) {
- log.info("Receive message:"+message);
- }
- }
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。