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

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

展开
收起
真的很搞笑 2024-03-27 20:07:19 129 分享 版权
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-learning.com/

还有其他疑问?
咨询AI助理