start mqnamesrv.cmd

start mqbroker.cmd -n 127.0.0.1:9876 -c ../conf/broker.conf

https://github.com/apache/rocketmq-externals.git

127.0.0.1.9876

mvn clean package -Dmaven.test.skip=true

java -jar rocketmq-console-ng-1.0.1.jar

http://127.0.0.1:8081/

public static void main(String[] args) throws InterruptedException, MQClientException {

        // Instantiate with specified consumer group name.

        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("please_rename_unique_group_name");

        // Specify name server addresses.

        consumer.setNamesrvAddr("localhost:9876");

        // Subscribe one more more topics to consume.

        consumer.subscribe("TopicTest", "*");

        // Register callback to execute on arrival of messages fetched from brokers.

        consumer.registerMessageListener(new MessageListenerConcurrently() {

            @Override

            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,

                                                            ConsumeConcurrentlyContext context) {

                System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);

                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;

            }

        });

        //Launch the consumer instance.

        consumer.start();

        System.out.printf("Consumer Started.%n");

    }

public static void main(String[] args) throws Exception {

        //Instantiate with a producer group name.

        DefaultMQProducer producer = new

                DefaultMQProducer("please_rename_unique_group_name");

        // Specify name server addresses.

        producer.setNamesrvAddr("localhost:9876");

        //Launch the instance.

        producer.start();

        for (int i = 0; i < 10; i++) {

            //Create a message instance, specifying topic, tag and message body.

            Message msg = new Message("TopicTest" /* Topic */,

                    "TagA" /* Tag */,

                    ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */

            );

            //Call send message to deliver message to one of brokers.

            SendResult sendResult = producer.send(msg);

            System.out.printf("%s%n", sendResult);

        }

        //Shut down once the producer instance is not longer in use.

        producer.shutdown();

    }