Springboot 集成Rocketmq基础案例

目录

一、依赖

二、目录结构

三、生产者

四、消费者

一、依赖

        
            org.apache.rocketmq
            rocketmq-spring-boot-starter
            2.2.2
        
        
            org.springframework.boot
            spring-boot-starter-test
        
        
            org.springframework.boot
            spring-boot-starter-web
        
    

二、目录结构

三、生产者

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ProducerService {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendMessage(){
        rocketMQTemplate.convertAndSend("test-topic","hello 233");
        System.out.println("消息已发送");
    }
}

配置：

rocketmq:
  name-server: rocket-server:9876
  producer:
    group: test-group

四、消费者

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;


@Component
@RocketMQMessageListener(topic = "test-topic",consumerGroup = "test-group")
public class ConsumerService implements RocketMQListener {
    @Override
    public void onMessage(String s) {
        System.out.println("消费信息："+s);
    }
}

配置文件：

server:
  port: 8081

rocketmq:
  name-server: rocket-server:9876