Skip to content

客户端的使用

gaoyf edited this page Jul 28, 2023 · 9 revisions
  1. 【可选】客户端增加如下依赖:

    <dependency>
        <groupId>com.sohu.tv</groupId>
        <artifactId>mq-client-open</artifactId>
        <version>x.x.x</version>
    </dependency>
    

    建议依赖sohu客户端:5.1.1-sohu-1,否则很多功能无法完整使用。

    当然可以使用RocketMQ原生客户端,但是客户端统计,版本等将无法上报。

  2. 初始化后设置

    RocketMQConsumerRocketMQProducer在调用start()方法前需要进行如下配置:

    setMqCloudDomain("通用配置模块的domain");
    
  3. 其余的使用参照生产者接入消费者接入