package cn.learn.rocketmq.topic;import org.apache.rocketmq.client.producer.DefaultMQProducer;public class TopicDemo {public static void main(String[] args) throws Exception {DefaultMQProducer producer = new DefaultMQProducer("learn");//設(shè)置nameserver的地址producer.setNamesrvAddr("localhost:9876");// 啟動生產(chǎn)者producer.start();/*** 創(chuàng)建topic，參數(shù)分別是：broker的名稱，topic的名稱，queue的數(shù)量*/producer.createTopic("broker_learn_im", "my-topic", 8);System.out.println("topic創(chuàng)建成功!");producer.shutdown();} }

?

總結(jié)

以上是生活随笔為你收集整理的RocketMQ快速入门之手动创建topic的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。