SpringBoot整合RocketMq

短命女 2022-09-03 15:15 277阅读 0赞

# SpringBoot整合RocketMq #

简单在SpringBoot整合一下整合RocketMq

版本 JDK11  
RocketMq 4.7.1  
SpringBoot 2.0.3

### 添加依赖 ###

<properties>
            <java.version>11</java.version>
            <rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot-starter-version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
            <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>
    
        </dependencies>

### 配置文件 ###

# application.properties
    rocketmq.name-server=localhost:9876
    rocketmq.producer.group=my-group

### 启动类 ###

@SpringBootApplication
    public class DemoApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(DemoApplication.class, args);
        }
    
    }

生产者

@RestController
    public class produce { 
    
    
        @Autowired
        private RocketMQTemplate rocketMQTemplate;
    
        @RequestMapping("produce")
        public void test1() { 
            rocketMQTemplate.convertAndSend("test-mq", "我是消息 哈哈哈哈哈 rocketmq");
        }
    }

推消息消费  
消息监听器

@Component
    @RocketMQMessageListener(topic = "test-mq", consumerGroup = "springboot-mq-consumer-1")
    public class Consume implements RocketMQListener<String> { 
    
        @Override
        public void onMessage(String message) { 
            System.out.println(("Receive message：" + message));
        }
    }