RocketMQ快速入门之手动创建topic

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");//设置nameserver的地址producer.setNamesrvAddr("localhost:9876");// 启动生产者producer.start();/*** 创建topic，参数分别是：broker的名称，topic的名称，queue的数量*/producer.createTopic("broker_learn_im", "my-topic", 8);System.out.println("topic创建成功!");producer.shutdown();}
}

RocketMQ快速入门之手动创建topic相关推荐

java 创建topic,RocketMQ在Java代码之中手动创建Topic
Rocketmq在Java代码之中手动创建Topic [原创,转载请注明出处] 我的 [博客园主页] [CSDN主页] [简书主页] 加V进Java交流群,备注Java交流:w1129574379 * ...
分布式消息队列RocketMQ 快速入门
分布式消息队列RocketMQ 一 RocketMQ概述概述 1.MQ简介 MQ,Message Queue,是一种提供消息队列服务的中间件,是一套提供了消息生产.存储.消费全过程API的软件系统. ...
RocketMq快速入门（详解）
目录 Docker-compose安装RocketMQ 一.docker目录下建立以下目录文件二.docker-compose.yml配置三.修改broker.conf 四.开启端口五. 安装启 ...
【RocketMQ】RocketMQ快速入门
RocketMQ的介绍 RocketMQ版本发展 Metaq1.x是RocketMQ前身的第一个版本,本质上把Kafka做了一次java版本的重写(Kafka是scala语言开发). Meta2.x, ...
java中创建对象的一般格式是什么_Java零基础快速入门|对象的创建和使用（下）...
本篇文章主要内容:构造方法Constructor 空指针异常当实例变量是一个引用方法调用时参数的传递问题难点解惑构造方法Constructor 什么是构造方法?构造方法怎么定义?构造方法怎么调 ...
RocketMQ快速入门之消息过滤器（用户自定义属性）
默认配置下,不支持自定义属性,需要设置开启: #加入到broker的配置文件中 enablePropertyFilter=true package cn.learn.rocketmq.filter;i ...
ObjectC快速入门教程(1)--创建类
背景本文记录学习ObjectC过程中的心得,参照网易云课堂视频,职坐标,记录视频的练习代码,并将要点进行总结.其实很多视频教程都不错,之前看的M了个J老师.本文包含创建一个Person类及Fract ...
RocketMQ带你快速入门
1. MQ介绍 ##1.1 为什么要用MQ 消息队列是一种"先进先出"的数据结构转存失败重新上传取消其应用场景主要包含以下3个方面应用解耦系统的耦合性越高,容错性就越低.以 ...
RocketMQ自动创建topic原理-TBW102
自动创建Topic原理介绍 RocketMQ在发送消息的时候,我们一般会先去Broker创建Topic信息,Producer在发送消息的时候会先去nameSrv拉取Topic信息,那么如果拉取不到 ...

RocketMQ快速入门之手动创建topic

RocketMQ快速入门之手动创建topic相关推荐

最新文章

热门文章