springboot整合rocketmq，rocketmq-spring-boot-starter：2.0.3

这里有点坑，之前的springboot与rocketmq的依赖，maven中央仓库并没有收纳，所以要想使用，需要自己去自己通过源码install到本地仓库的。但这里我一直没有弄成功，我不死心，去maven官网一直查找，终于找到了

如图，maven中央仓库是在今年一月份才开始收纳springboot与rocketmq的依赖，到现在为止也只有三个版本，而且使用的人很少，所以接下来我们就开心的使用吧
导入依赖：这里也坑啊，我只有导入2.0.3版本才可以测试成功

#依赖
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.0.3</version>
</dependency>

#配置文件，一定要写这两个
#而且注意这里不要写为spring.rocketmq.producer.group，这个版本的写法不一样
rocketmq.name-server=192.168.44.151:9877
rocketmq.producer.group=shuai

**
 * 生产者
 * springboot整合rocketmq
 */
@Component
public class SpringProducer {

  @Autowired
  private RocketMQTemplate rocketMQTemplate;

  @Autowired
  private DefaultMQProducer defaultMQProducer;

  public void sendMsg(String topic,String msg){

    rocketMQTemplate.convertAndSend(topic,msg);
  }
}

#测试用例
@RunWith(SpringRunner.class)
@SpringBootTest
public class TestSpringRocketMQ {
    @Autowired
    private SpringProducer springProducer;
    @Test
    public void testSendMsg(){
        String msg = "我的第1个SpringRocketMQ消息!";
        this.springProducer.sendMsg("spring-my-topic", msg);
        System.out.println("发送成功");
    }


}