快速学习-RocketMQ DefaultMQProducer

DefaultMQProducer

类简介

public class DefaultMQProducer extends ClientConfig implements MQProducer

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

public class Producer {
    public static void main(String[] args) throws MQClientException {
        // 创建指定分组名的生产者
        DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");

        // 启动生产者
        producer.start();

        for (int i = 0; i < 128; i++)
            try {
            	// 构建消息
                Message msg = new Message("TopicTest",
                        "TagA",
                        "OrderID188",
                        "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET));

                // 同步发送
                SendResult sendResult = producer.send(msg);

                // 打印发送结果
                System.out.printf("%s%n", sendResult);
            } catch (Exception e) {
                e.printStackTrace();
            }

        producer.shutdown();
    }
}

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

字段摘要

构造方法摘要

使用方法摘要

字段详细信息

• producerGroup private String producerGroup 生产者的分组名称。相同的分组名称表明生产者实例在概念上归属于同一分组。这对事务消息十分重要，如果原始生产者在事务之后崩溃，那么broker可以联系同一生产者分组的不同生产者实例来提交或回滚事务。 默认值：DEFAULT_PRODUCER 注意： 由数字、字母、下划线、横杠（-）、竖线（|）或百分号组成；不能为空；长度不能超过255。
• defaultMQProducerImpl protected final transient DefaultMQProducerImpl defaultMQProducerImpl 生产者的内部默认实现，在构造生产者时内部自动初始化，提供了大部分方法的内部实现。
• createTopicKey private String createTopicKey = MixAll.AUTO_CREATE_TOPIC_KEY_TOPIC 在发送消息时，自动创建服务器不存在的topic，需要指定Key，该Key可用于配置发送消息所在topic的默认路由。 默认值：TBW102 建议：测试或者demo使用，生产环境下不建议打开自动创建配置。
• defaultTopicQueueNums private volatile int defaultTopicQueueNums = 4 创建topic时默认的队列数量。 默认值：4
• sendMsgTimeout private int sendMsgTimeout = 3000 发送消息时的超时时间。 默认值：3000，单位：毫秒 建议：不建议修改该值，该值应该与broker配置中的sendTimeout一致，发送超时，可临时修改该值，建议解决超时问题，提高broker集群的Tps。
• compressMsgBodyOverHowmuch private int compressMsgBodyOverHowmuch = 1024 * 4 压缩消息体阈值。大于4K的消息体将默认进行压缩。 默认值：1024 * 4，单位：字节 建议：可通过DefaultMQProducerImpl.setZipCompressLevel方法设置压缩率（默认为5，可选范围[0,9]）；可通过DefaultMQProducerImpl.tryToCompressMessage方法测试出compressLevel与compressMsgBodyOverHowmuch最佳值。
• retryTimesWhenSendFailed private int retryTimesWhenSendFailed = 2 同步模式下，在返回发送失败之前，内部尝试重新发送消息的最大次数。 默认值：2，即：默认情况下一条消息最多会被投递3次。 注意：在极端情况下，这可能会导致消息的重复。
• retryTimesWhenSendAsyncFailed private int retryTimesWhenSendAsyncFailed = 2 异步模式下，在发送失败之前，内部尝试重新发送消息的最大次数。 默认值：2，即：默认情况下一条消息最多会被投递3次。 注意：在极端情况下，这可能会导致消息的重复。
• retryAnotherBrokerWhenNotStoreOK private boolean retryAnotherBrokerWhenNotStoreOK = false 同步模式下，消息保存失败时是否重试其他broker。 默认值：false 注意：此配置关闭时，非投递时产生异常情况下，会忽略retryTimesWhenSendFailed配置。
• maxMessageSize private int maxMessageSize = 1024 * 1024 * 4 消息的最大大小。当消息题的字节数超过maxMessageSize就发送失败。 默认值：1024 * 1024 * 4，单位：字节
• traceDispatcher private TraceDispatcher traceDispatcher = null 在开启消息追踪后，该类通过hook的方式把消息生产者，消息存储的broker和消费者消费消息的信息像链路一样记录下来。在构造生产者时根据构造入参enableMsgTrace来决定是否创建该对象。

构造方法详细信息

1. DefaultMQProducer public DefaultMQProducer() 创建一个新的生产者。
2. DefaultMQProducer DefaultMQProducer(final String producerGroup) 使用指定的分组名创建一个生产者。
   • 入参描述： 类型是否必须缺省值描述ucerGroupString是DEFAULT_PRODUCER
3. DefaultMQProducer DefaultMQProducer(final String producerGroup, boolean enableMsgTrace) 使用指定的分组名创建一个生产者，并设置是否开启消息追踪。
   • 入参描述： 类型是否必须缺省值描述ucerGroupString是DEFAULT_PRODUCERleMsgTraceboolean是false
4. DefaultMQProducer DefaultMQProducer(final String producerGroup, boolean enableMsgTrace, final String customizedTraceTopic) 使用指定的分组名创建一个生产者，并设置是否开启消息追踪及追踪topic的名称。
   • 入参描述： 类型是否必须缺省值描述ucerGroupString是DEFAULT_PRODUCERookRPCHook否nullleMsgTraceboolean是falseomizedTraceTopicString否RMQ_SYS_TRACE_TOPIC
5. DefaultMQProducer DefaultMQProducer(RPCHook rpcHook) 使用指定的hook创建一个生产者。
   • 入参描述： 类型是否必须缺省值描述ookRPCHook否null
6. DefaultMQProducer DefaultMQProducer(final String producerGroup, RPCHook rpcHook) 使用指定的分组名及自定义hook创建一个生产者。
   • 入参描述： 类型是否必须缺省值描述ucerGroupString是DEFAULT_PRODUCERookRPCHook否null
7. DefaultMQProducer DefaultMQProducer(final String producerGroup, RPCHook rpcHook, boolean enableMsgTrace,final String customizedTraceTopic) 使用指定的分组名及自定义hook创建一个生产者，并设置是否开启消息追踪及追踪topic的名称。
   • 入参描述：

   名类型是否必须缺省值描述oducerGroupString是DEFAULT_PRODUCER生产者的分组名称cHookRPCHook否null每个远程命令执行后会回调rpcHookableMsgTraceboolean是false是否开启消息追踪stomizedTraceTopicString否RMQ_SYS_TRACE_TOPIC消息跟踪topic的名称

使用方法详细信息

1. createTopic public void createTopic(String key, String newTopic, int queueNum) 在broker上创建一个topic。
   • 入参描述： 类型是否必须默认值值范围说明String是访问密钥。opicString是eNumint是0(0, maxIntValue]
   • 返回值描述： void
   • 异常描述： MQClientException - 生产者状态非Running；未找到broker等客户端异常。
2. createTopic public void createTopic(String key, String newTopic, int queueNum, int topicSysFlag) 在broker上创建一个topic。
   • 入参描述： 类型是否必须默认值值范围说明String是访问密钥。opicString是eNumint是0(0, maxIntValue]cSysFlagint是0
   • 返回值描述： void
   • 异常描述： MQClientException - 生产者状态非Running；未找到broker等客户端异常。
3. earliestMsgStoreTime public long earliestMsgStoreTime(MessageQueue mq) 查询最早的消息存储时间。
   • 入参描述： 类型是否必须默认值值范围说明MessageQueue是要查询的消息队列
   • 返回值描述： 指定队列最早的消息存储时间。单位：毫秒。
   • 异常描述： MQClientException - 生产者状态非Running；没有找到broker；broker返回失败；网络异常；线程中断等客户端异常。
4. fetchPublishMessageQueues public List<MessageQueue> fetchPublishMessageQueues(String topic) 获取topic的消息队列。
   • 入参描述： 类型是否必须默认值值范围说明cString是
   • 返回值描述： 传入topic下的消息队列。
   • 异常描述： MQClientException - 生产者状态非Running；没有找到broker；broker返回失败；网络异常；线程中断等客户端异常。
5. maxOffset public long maxOffset(MessageQueue mq) 查询消息队列的最大物理偏移量。
   • 入参描述： 类型是否必须默认值值范围说明MessageQueue是要查询的消息队列
   • 返回值描述： 给定消息队列的最大物理偏移量。
   • 异常描述： MQClientException - 生产者状态非Running；没有找到broker；broker返回失败；网络异常；线程中断等客户端异常。
6. minOffset public long minOffset(MessageQueue mq) 查询给定消息队列的最小物理偏移量。
   • 入参描述： 类型是否必须默认值值范围说明MessageQueue是要查询的消息队列
   • 返回值描述： 给定消息队列的最小物理偏移量。
   • 异常描述： MQClientException - 生产者状态非Running；没有找到broker；broker返回失败；网络异常；线程中断等客户端异常。
7. queryMessage public QueryResult queryMessage(String topic, String key, int maxNum, long begin, long end) 按关键字查询消息。
   • 入参描述： 类型是否必须默认值值范围说明cString是String否null查找的关键字umint是nlong是long是结束时间戳，单位：毫秒
   • 返回值描述： 查询到的消息集合。
   • 异常描述： MQClientException - 生产者状态非Running；没有找到broker；broker返回失败；网络异常等客户端异常客户端异常。 InterruptedException - 线程中断。
8. searchOffset public long searchOffset(MessageQueue mq, long timestamp) 查找指定时间的消息队列的物理偏移量。
   • 入参描述： 类型是否必须默认值值范围说明MessageQueue是要查询的消息队列。stamplong是
   • 返回值描述： 指定时间的消息队列的物理偏移量。
   • 异常描述： MQClientException - 生产者状态非Running；没有找到broker；broker返回失败；网络异常；线程中断等客户端异常。
9. send public SendResult send(Collection<Message> msgs) 同步批量发送消息。在返回发送失败之前，内部尝试重新发送消息的最大次数（参见retryTimesWhenSendFailed属性）。未明确指定发送队列，默认采取轮询策略发送。
   • 入参描述： 类型是否必须默认值值范围说明Collection是待发送的消息集合。集合内的消息必须属同一个topic。
   • 返回值描述： 批量消息的发送结果，包含msgId，发送状态等信息。
   • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
10. send public SendResult send(Collection<Message> msgs, long timeout) 同步批量发送消息，如果在指定的超时时间内未完成消息投递，会抛出RemotingTooMuchRequestException。 在返回发送失败之前，内部尝试重新发送消息的最大次数（参见retryTimesWhenSendFailed属性）。未明确指定发送队列，默认采取轮询策略发送。
    • 入参描述： 类型是否必须默认值值范围说明Collection是待发送的消息集合。集合内的消息必须属同一个topic。outlong是参见sendMsgTimeout属性
    • 返回值描述： 批量消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
11. send public SendResult send(Collection<Message> msgs, MessageQueue messageQueue) 向给定队列同步批量发送消息。 注意：指定队列意味着所有消息均为同一个topic。
    • 入参描述： 类型是否必须默认值值范围说明Collection是待发送的消息集合。集合内的消息必须属同一个topic。ageQueueMessageQueue是
    • 返回值描述： 批量消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
12. send public SendResult send(Collection<Message> msgs, MessageQueue messageQueue, long timeout) 向给定队列同步批量发送消息，如果在指定的超时时间内未完成消息投递，会抛出RemotingTooMuchRequestException。 注意：指定队列意味着所有消息均为同一个topic。
    • 入参描述： 类型是否必须默认值值范围说明Collection是待发送的消息集合。集合内的消息必须属同一个topic。outlong是参见sendMsgTimeout属性ageQueueMessageQueue是
    • 返回值描述： 批量消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
13. send public SendResult send(Message msg) 以同步模式发送消息，仅当发送过程完全完成时，此方法才会返回。 在返回发送失败之前，内部尝试重新发送消息的最大次数（参见retryTimesWhenSendFailed属性）。未明确指定发送队列，默认采取轮询策略发送。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。
    • 返回值描述： 消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
14. send public SendResult send(Message msg, long timeout) 以同步模式发送消息，如果在指定的超时时间内未完成消息投递，会抛出RemotingTooMuchRequestException。仅当发送过程完全完成时，此方法才会返回。 在返回发送失败之前，内部尝试重新发送消息的最大次数（参见retryTimesWhenSendFailed属性）。未明确指定发送队列，默认采取轮询策略发送。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。outlong是参见sendMsgTimeout属性
    • 返回值描述： 消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
15. send public SendResult send(Message msg, MessageQueue mq) 向指定的消息队列同步发送单条消息。仅当发送过程完全完成时，此方法才会返回。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。MessageQueue是待投递的消息队列。
    • 返回值描述： 消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
16. send public SendResult send(Message msg, MessageQueue mq, long timeout) 向指定的消息队列同步发送单条消息，如果在指定的超时时间内未完成消息投递，会抛出RemotingTooMuchRequestException。仅当发送过程完全完成时，此方法才会返回。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。outlong是参见sendMsgTimeout属性MessageQueue是待投递的消息队列。指定队列意味着待投递消息均为同一个topic。
    • 返回值描述： 消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
17. send public void send(Message msg, MessageQueue mq, SendCallback sendCallback) 向指定的消息队列异步发送单条消息，异步发送调用后直接返回，并在在发送成功或者异常时回调sendCallback，所以异步发送时sendCallback参数不能为null，否则在回调时会抛出NullPointerException。 异步发送时，在成功发送前，其内部会尝试重新发送消息的最大次数（参见retryTimesWhenSendAsyncFailed属性）。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。MessageQueue是待投递的消息队列。指定队列意味着待投递消息均为同一个topic。CallbackSendCallback是
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
18. send public void send(Message msg, MessageQueue mq, SendCallback sendCallback, long timeout) 向指定的消息队列异步发送单条消息，异步发送调用后直接返回，并在在发送成功或者异常时回调sendCallback，所以异步发送时sendCallback参数不能为null，否则在回调时会抛出NullPointerException。 若在指定时间内消息未发送成功，回调方法会收到RemotingTooMuchRequestException异常。 异步发送时，在成功发送前，其内部会尝试重新发送消息的最大次数（参见retryTimesWhenSendAsyncFailed属性）。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。MessageQueue是待投递的消息队列。CallbackSendCallback是outlong是参见sendMsgTimeout属性
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
19. send public SendResult send(Message msg, MessageQueueSelector selector, Object arg) 向通过MessageQueueSelector计算出的队列同步发送消息。 可以通过自实现MessageQueueSelector接口，将某一类消息发送至固定的队列。比如：将同一个订单的状态变更消息投递至固定的队列。 注意：此消息发送失败内部不会重试。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。ctorMessageQueueSelector是Object否供队列选择器使用的参数对象。
    • 返回值描述： 消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
20. send public SendResult send(Message msg, MessageQueueSelector selector, Object arg, long timeout) 向通过MessageQueueSelector计算出的队列同步发送消息，并指定发送超时时间。 可以通过自实现MessageQueueSelector接口，将某一类消息发送至固定的队列。比如：将同一个订单的状态变更消息投递至固定的队列。 注意：此消息发送失败内部不会重试。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。ctorMessageQueueSelector是Object否供队列选择器使用的参数对象。outlong是参见sendMsgTimeout属性
    • 返回值描述： 消息的发送结果，包含msgId，发送状态等信息。
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 MQBrokerException - broker发生错误。 InterruptedException - 发送线程中断。 RemotingTooMuchRequestException - 发送超时。
21. send public void send(Message msg, MessageQueueSelector selector, Object arg, SendCallback sendCallback) 向通过MessageQueueSelector计算出的队列异步发送单条消息，异步发送调用后直接返回，并在在发送成功或者异常时回调sendCallback，所以异步发送时sendCallback参数不能为null，否则在回调时会抛出NullPointerException。 异步发送时，在成功发送前，其内部会尝试重新发送消息的最大次数（参见retryTimesWhenSendAsyncFailed属性）。 可以通过自实现MessageQueueSelector接口，将某一类消息发送至固定的队列。比如：将同一个订单的状态变更消息投递至固定的队列。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。ctorMessageQueueSelector是Object否供队列选择器使用的参数对象。CallbackSendCallback是
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
22. send public void send(Message msg, MessageQueueSelector selector, Object arg, SendCallback sendCallback, long timeout) 向通过MessageQueueSelector计算出的队列异步发送单条消息，异步发送调用后直接返回，并在在发送成功或者异常时回调sendCallback，所以异步发送时sendCallback参数不能为null，否则在回调时会抛出NullPointerException。 异步发送时，在成功发送前，其内部会尝试重新发送消息的最大次数（参见retryTimesWhenSendAsyncFailed属性）。 可以通过自实现MessageQueueSelector接口，将某一类消息发送至固定的队列。比如：将同一个订单的状态变更消息投递至固定的队列。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。ctorMessageQueueSelector是Object否供队列选择器使用的参数对象。CallbackSendCallback是outlong是参见sendMsgTimeout属性
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
23. send public void send(Message msg, SendCallback sendCallback) 异步发送单条消息，异步发送调用后直接返回，并在在发送成功或者异常时回调sendCallback，所以异步发送时sendCallback参数不能为null，否则在回调时会抛出NullPointerException。 异步发送时，在成功发送前，其内部会尝试重新发送消息的最大次数（参见retryTimesWhenSendAsyncFailed属性）。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。CallbackSendCallback是
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
24. send public void send(Message msg, SendCallback sendCallback, long timeout) 异步发送单条消息，异步发送调用后直接返回，并在在发送成功或者异常时回调sendCallback，所以异步发送时sendCallback参数不能为null，否则在回调时会抛出NullPointerException。 异步发送时，在成功发送前，其内部会尝试重新发送消息的最大次数（参见retryTimesWhenSendAsyncFailed属性）。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。CallbackSendCallback是outlong是参见sendMsgTimeout属性
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
25. sendMessageInTransaction public TransactionSendResult sendMessageInTransaction(Message msg, LocalTransactionExecuter tranExecuter, final Object arg) 发送事务消息。该类不做默认实现，抛出RuntimeException异常。参见：TransactionMQProducer类。
    • 入参描述： 类型是否必须默认值值范围说明Message是待投递的事务消息ExecuterLocalTransactionExecuter是Object是供本地事务执行程序使用的参数对象
    • 返回值描述： 事务结果，参见：LocalTransactionState类。
    • 异常描述： RuntimeException - 永远抛出该异常。
26. sendMessageInTransaction public TransactionSendResult sendMessageInTransaction(Message msg, final Object arg) 发送事务消息。该类不做默认实现，抛出RuntimeException异常。参见：TransactionMQProducer类。
    • 入参描述： 类型是否必须默认值值范围说明Message是待投递的事务消息Object是供本地事务执行程序使用的参数对象
    • 返回值描述： 事务结果，参见：LocalTransactionState类。
    • 异常描述： RuntimeException - 永远抛出该异常。
27. sendOneway public void sendOneway(Message msg) 以oneway形式发送消息，broker不会响应任何执行结果，和UDP类似。它具有最大的吞吐量但消息可能会丢失。 可在消息量大，追求高吞吐量并允许消息丢失的情况下使用该方式。
    • 入参描述： 类型是否必须默认值值范围说明Message是待投递的消息
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
28. sendOneway public void sendOneway(Message msg, MessageQueue mq) 向指定队列以oneway形式发送消息，broker不会响应任何执行结果，和UDP类似。它具有最大的吞吐量但消息可能会丢失。 可在消息量大，追求高吞吐量并允许消息丢失的情况下使用该方式。
    • 入参描述： 类型是否必须默认值值范围说明Message是待投递的消息MessageQueue是待投递的消息队列
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
29. sendOneway public void sendOneway(Message msg, MessageQueueSelector selector, Object arg) 向通过MessageQueueSelector计算出的队列以oneway形式发送消息，broker不会响应任何执行结果，和UDP类似。它具有最大的吞吐量但消息可能会丢失。 可在消息量大，追求高吞吐量并允许消息丢失的情况下使用该方式。
    • 入参描述： 类型是否必须默认值值范围说明Message是待发送的消息。ctorMessageQueueSelector是Object否供队列选择器使用的参数对象。
    • 返回值描述： void
    • 异常描述： MQClientException - broker不存在或未找到；namesrv地址为空；未找到topic的路由信息等客户端异常。 RemotingException - 网络异常。 InterruptedException - 发送线程中断。
30. shutdown public void shutdown() 关闭当前生产者实例并释放相关资源。
    • 入参描述： 无。
    • 返回值描述： void
    • 异常描述：
31. start public void start() 启动生产者实例。在发送或查询消息之前必须调用此方法。它执行了许多内部初始化，比如：检查配置、与namesrv建立连接、启动一系列心跳等定时任务等。
    • 入参描述： 无。
    • 返回值描述： void
    • 异常描述： MQClientException - 初始化过程中出现失败。
32. viewMessage public MessageExt viewMessage(String offsetMsgId) 根据给定的msgId查询消息。
    • 入参描述： 类型是否必须默认值值范围说明etMsgIdString是
    • 返回值描述： 返回MessageExt，包含：topic名称，消息题，消息ID，消费次数，生产者host等信息。
    • 异常描述： RemotingException - 网络层发生错误。 MQBrokerException - broker发生错误。 InterruptedException - 线程被中断。 MQClientException - 生产者状态非Running；msgId非法等。
33. viewMessage public MessageExt viewMessage(String topic, String msgId) 根据给定的msgId查询消息，并指定topic。
    • 入参描述： 类型是否必须默认值值范围说明dString是cString是
    • 返回值描述： 返回MessageExt，包含：topic名称，消息题，消息ID，消费次数，生产者host等信息。
    • 异常描述： RemotingException - 网络层发生错误。 MQBrokerException - broker发生错误。 InterruptedException - 线程被中断。 MQClientException - 生产者状态非Running；msgId非法等。