public class SyncProducer {
            public static void main(String[] args) throws Exception {
                //Instantiate with a Producer group name.
                DefaultMQProducer Producer = new
                    DefaultMQProducer("please_rename_unique_group_name");
                producer.setNamesrvAddr("192.168.100.131:9876");

                //Launch the instance.
                Producer.start();
                for (int i = 0; i < 100; 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();
            }
        }

              /＊
                ＊ Instantiate with specified Consumer group name.
                ＊/
                DefaultMQPushConsumer Consumer = new DefaultMQPushConsumer("please
                    rename to unique group name");
                /＊
                ＊ Specify name server addresses.
                Consumer.setNamesrvAddr("192.168.249.47:9876");
                /＊
                ＊ Specify where to start in case the specified Consumer group is a
                    brand new one.
                ＊/
      Consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
                //Consumer.setMessageModel(MessageModel.BROADCASTING);
                /＊
                ＊ 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() {
                    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt>
                        msgs,   ConsumeConcurrentlyContext context) {
                        System.out.printf(Thread.currentThread().getName()  +  "
                            Receive New Messages: " + msgs + "%n");
                        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                    }
                });
                /＊
                  ＊  Launch the Consumer instance.
                  ＊/
                Consumer.start();