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

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

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

展开
收起
真的很搞笑 2024-03-27 20:07:19 89 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、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

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