properties
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = SYNC_MASTER
flushDiskType = ASYNC_FLUSH
properties
listenPort=9876
brokerServerURL=\
http://rocketmq01:9933;\
http://rocketmq02:9933
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>3.6.2.Final</version>
</dependency>
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;
public class MessageProducer {
public static void main(String[] args) {
DefaultMQProducer producer = new DefaultMQProducer("producer_group_name");
producer.setNamesrvAddr("localhost:9876");
try {
producer.start();
for (int i = 0; i < 10; i++) {
Message message = new Message("topic_name", "tag_name", ("Hello RocketMQ " + i).getBytes());
producer.send(message);
}
e.printStackTrace();
} finally {
producer.shutdown();
}
}
}
java MessageProducer
