类简介

public class DefaultMQProducer extends ClientConfig implements MQProducer

DefaultMQProducer类是应用用来投递消息的入口，开箱即用，可通过无参构造方法快速创建一个生产者。主要负责消息的发送，支持同步/异步/oneway的发送方式，这些发送方式均支持批量发送。可以通过该类提供的getter/setter方法，调整发送者的参数。DefaultMQProducer提供了多个send方法，每个send方法略有不同，在使用前务必详细了解其意图。下面给出一个生产者示例代码，点击查看更多示例代码。

  1. public class Producer {
  2.     public static void main(String[] args) throws MQClientException {
  3.         // 创建指定分组名的生产者
  4.         DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
  6.         // 启动生产者
  7.         producer.start();
  9.         for (int i = 0; i < 128; i++)
  10.             try {
  11.                 // 构建消息
  12.                 Message msg = new Message("TopicTest",
  13.                         "TagA",
  14.                         "OrderID188",
  15.                         "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET));
  17.                 // 同步发送
  18.                 SendResult sendResult = producer.send(msg);
  20.                 // 打印发送结果
  21.                 System.out.printf("%s%n", sendResult);
  22.             } catch (Exception e) {
  23.                 e.printStackTrace();
  24.             }
  26.         producer.shutdown();
  27.     }
  28. }

注意：该类是线程安全的。在配置并启动完成后可在多个线程间安全共享。