kk个人博客

愿居于一城,与卿所见美好......

推荐文章

springboot整合rocketmq-spring-boot-starter:2.10

    前言:

    这里有点坑,之前的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
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    
    **
     * 生产者
     * 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("发送成功");
        }
    
    
    }
    阅读全文>>

作者:kk分类:【javaEE浏览(2443评论(0

2020-12-07 19:53:27