Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)

#

# There is insufficient memory for the Java Runtime Environment to continue.

# Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory.

# An error report file with more information is saved as:

# /usr/local/rocketmq-all-4.3.0/distribution/target/apache-rocketmq/hs_err_pid7209.lo

Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: Send [1] times, still failed, cost [4190]ms, Topic: TopicTest, BrokersSent: [bogon]

See http://rocketmq.apache.org/docs/faq/ for further details.

    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:610)

    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendOneway(DefaultMQProducerImpl.java:905)

    at org.apache.rocketmq.client.producer.DefaultMQProducer.sendOneway(DefaultMQProducer.java:285)

    at cn.sp.simple.OnewayProducer.main(OnewayProducer.java:21)

Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.19.0.1:10909> failed

    at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeOneway(NettyRemotingClient.java:561)

    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:324)

    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:294)

    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:785)

    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:529)

    ... 3 more

#进入rocketmq根目录

cd /usr/local/rocketmq-all-4.3.2/distribution/target/apache-rocketmq

#编写配置文件，并写好配置

echo "brokerIP1=10.2.x.x" > broker.properties

#启动 mqnamesrv

nohup sh bin/mqnamesrv &

#重点：mrbroker 启动时通过 -c 加载配置文件

nohup sh bin/mqbroker -n localhost:9876 -c /usr/local/rocketmq-all-4.3.2/distribution/target/apache-rocketmq/broker.properties &

public class AsyncProducer {

  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("192.168.75.132:9876");

    //Launch the instance.

    producer.start();

    producer.setRetryTimesWhenSendAsyncFailed(0);

    int messageCount  = 100;

    final CountDownLatch countDownLatch  = new CountDownLatch(messageCount);

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

      final int index = i;

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

      Message msg = new Message("TopicTest",

          "TagA",

          "OrderID188",

          "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET));

      producer.send(msg, new SendCallback() {

        @Override

        public void onSuccess(SendResult sendResult) {

          countDownLatch.countDown();

          System.out.printf("%-10d OK %s %n", index,

              sendResult.getMsgId());

        }

        @Override

        public void onException(Throwable e) {

          countDownLatch.countDown();

          System.out.printf("%-10d Exception %s %n", index, e);

          e.printStackTrace();

        }

      });

    }

    countDownLatch.await();

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

    producer.shutdown();

  }

}