04消息生产者发送消息

1. 启动类:

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

2 配置文件:

rocketmq.name-server=192.168.184.129:9876
# ?????
rocketmq.producer.group=my-group

3. 测试类

@RunWith(SpringRunner.class)
@SpringBootTest(classes = {MQProducerApplication.class})
public class ProducerTest {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    @Test
    public void sendMessage(){
        String json = "普通消息";
        rocketMQTemplate.convertAndSend("sendMessage", json);
    }
    @Test
    public void test1(){
        rocketMQTemplate.convertAndSend("springboot-rocketmq","hello springboot rocketmq");
    }
}

4. pom.xml

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

    com.nengxing.springboot
    springboot-rocketmq-producer
    1.0-SNAPSHOT

    
        2.0.3
    


    

        
            org.apache.rocketmq
            rocketmq-spring-boot-starter
            ${rocketmq-spring-boot-starter-version}
        
        
            org.projectlombok
            lombok
            1.18.6
        
        
            org.springframework.boot
            spring-boot-starter-test
            test
        

    

5. 发送成功: