springboot下rocketmq的基础使用

        spring-boot-starter-parent
        org.springframework.boot
        2.1.3.RELEASE
    

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

server:
  port: 8181
  servlet:
    context-path: /rocketmq-producer
spring:
  application:
    name: rocketmq-producer
rocketmq:
  name-server: rocketmq-nameserver的ip:9876
  producer:
    group: demo-producer-group

@Component
public class ProducerSimple {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendSyncMsg(String topic,String msg){
        rocketMQTemplate.syncSend(topic,msg);
    }
}

@Component
@RocketMQMessageListener(topic = "rocketmq-demo",consumerGroup = "demo-consumer-group")
public class ConsumerSimple implements RocketMQListener {
    @Override
    public void onMessage(String s) {
        System.out.println(s);
    }
}