使用方法摘要

返回值方法名称方法描述
voidcreateTopic(String key, String newTopic, int queueNum)在broker上创建指定的topic
voidcreateTopic(String key, String newTopic, int queueNum, int topicSysFlag)在broker上创建指定的topic
longearliestMsgStoreTime(MessageQueue mq)查询最早的消息存储时间
ListfetchPublishMessageQueues(String topic)获取topic的消息队列
longmaxOffset(MessageQueue mq)查询给定消息队列的最大offset
longminOffset(MessageQueue mq)查询给定消息队列的最小offset
QueryResultqueryMessage(String topic, String key, int maxNum, long begin, long end)按关键字查询消息
longsearchOffset(MessageQueue mq, long timestamp)查找指定时间的消息队列的物理offset
SendResultsend(Collection msgs)同步批量发送消息
SendResultsend(Collection msgs, long timeout)同步批量发送消息
SendResultsend(Collection msgs, MessageQueue messageQueue)向指定的消息队列同步批量发送消息
SendResultsend(Collection msgs, MessageQueue messageQueue, long timeout)向指定的消息队列同步批量发送消息，并指定超时时间
SendResultsend(Message msg)同步单条发送消息
SendResultsend(Message msg, long timeout)同步发送单条消息，并指定超时时间
SendResultsend(Message msg, MessageQueue mq)向指定的消息队列同步发送单条消息
SendResultsend(Message msg, MessageQueue mq, long timeout)向指定的消息队列同步单条发送消息，并指定超时时间
voidsend(Message msg, MessageQueue mq, SendCallback sendCallback)向指定的消息队列异步单条发送消息，并指定回调方法
voidsend(Message msg, MessageQueue mq, SendCallback sendCallback, long timeout)向指定的消息队列异步单条发送消息，并指定回调方法和超时时间
SendResultsend(Message msg, MessageQueueSelector selector, Object arg)向消息队列同步单条发送消息，并指定发送队列选择器
SendResultsend(Message msg, MessageQueueSelector selector, Object arg, long timeout)向消息队列同步单条发送消息，并指定发送队列选择器与超时时间
voidsend(Message msg, MessageQueueSelector selector, Object arg, SendCallback sendCallback)向指定的消息队列异步单条发送消息
voidsend(Message msg, MessageQueueSelector selector, Object arg, SendCallback sendCallback, long timeout)向指定的消息队列异步单条发送消息，并指定超时时间
voidsend(Message msg, SendCallback sendCallback)异步发送消息
voidsend(Message msg, SendCallback sendCallback, long timeout)异步发送消息，并指定回调方法和超时时间
TransactionSendResultsendMessageInTransaction(Message msg, LocalTransactionExecuter tranExecuter, final Object arg)发送事务消息，并指定本地执行事务实例
TransactionSendResultsendMessageInTransaction(Message msg, Object arg)发送事务消息
voidsendOneway(Message msg)单向发送消息，不等待broker响应
voidsendOneway(Message msg, MessageQueue mq)单向发送消息到指定队列，不等待broker响应
voidsendOneway(Message msg, MessageQueueSelector selector, Object arg)单向发送消息到队列选择器的选中的队列，不等待broker响应
voidshutdown()关闭当前生产者实例并释放相关资源
voidstart()启动生产者
MessageExtviewMessage(String offsetMsgId)根据给定的msgId查询消息
MessageExtpublic MessageExt viewMessage(String topic, String msgId)根据给定的msgId查询消息，并指定topic