RocketMQ之手动创建Topic、发送消息(同步&异步)_java创建rocketmq的topic

目录

手动创建topic

发送消息(同步)

发送消息(异步)

手动创建topic

topic是broker中的一个个分组,如果设置topic自动创建的话如果创建多了，可能会影响电脑的运行速度，所以我们来手动创建。

首先我们先在Demo项目中新建一个TopicDemo类，关于Demo项目的搭建在这篇博客中有提到

https://blog.csdn.net/Delicious_Life/article/details/104969043

package cn.itcast.rocketmq.topic;
 
 
import org.apache.rocketmq.client.producer.DefaultMQProducer;
 
public class TopicDemo {
    public static void main(String[] args) throws Exception {
        //分组名haoke这个可以任意设置
        DefaultMQProducer producer = new DefaultMQProducer("haoke");
 
        //设置nameserver的地址
        producer.setNamesrvAddr("192.168.62.132:9876");
 
        //启动生产者
        producer.start();
 
        /**
         * 创建topic，参数分别是：borker的名称，topic的名称，queue的数量
         * broker要和虚拟机broker.conf配置文件中brokername的名字一致
         * newTopic的名字随便起，queueNum8的意思是新建的消息队列数为8个
         */
        producer.createTopic("broker_haoke_im","my-topic",8);
        System.out.println("topic创建成功！");
        producer.shutdown();
    }
}

然后我们启动这个测试类，我们看到它提示topic创建成功

这时候我