开发者社区 > 云原生 > 消息队列 > 正文

RocketMQ 5.x的生产者,应该怎么配?

RocketMQ 5.x的生产者,应该怎么配?

展开
收起
cuicuicuic 2024-03-27 20:07:19 32 0
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长
    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-client-java</artifactId>
        <version>5.0.5</version>
    </dependency>
    

    使用ProducerBuilder来创建一个生产者实例

    
    Producer producer = ProducerBuilder.builder()
        .setClientConfiguration(ClientConfiguration.newBuilder()
            .setEndpoints("rmq-xxx.rocketmq.xxx.tencenttdmq.com:8081")
            .enableSsl(false)
            .setCredentialProvider(new StaticSessionCredentialsProvider("yourAccessKey", "yourSecretKey"))
            .build())
        .setTopics("yourNormalTopic")
        .build();
    
    2024-03-27 20:24:52
    赞同 展开评论 打赏

多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖多行业。

热门讨论

热门文章

相关电子书

更多
RocketMQ Client-GO 介绍 立即下载
RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载