软件包 com.taobao.metamorphosis.client.extension.producer

接口摘要

AsyncMessageProducer	异步发送消息的生产者.
AsyncMessageProducer.IgnoreMessageProcessor	用于处理发送失败和超出流控的消息
ConfigPartitionsAware	支持获取某topic预配置的分区分布情况
MessageRecoverManager	消息暂存和recover管理器的抽象
MessageRecoverManager.MessageRecoverer	指定消息如何recover

类摘要

AsyncMetaMessageProducer	异步单向发送消息给服务器的生产者实现.
ConfigPartitionsSupport	支持获取某topic分区总数的Selector
LocalMessageStorageManager	消息缓存在本地磁盘,并定期或手动recover
OrderedLocalMessageStorageManager	针对顺序消息做了特殊处理的LocalMessageStorageManager
OrderedMessagePartitionSelector	支持获取某topic分区总数,当前可用分区数跟配置分区不对应时 将抛出一个特殊的异常 AvailablePartitionNumException, 以便发送消息时可识别这个失败原因,从而做相应处理.
OrderedMessageProducer	有序消息生产者的实现类,需要按照消息内容(例如某个id)散列到固定分区并要求有序的场景中使用.
ProducerDiamondManager	负责从diamond取得分区的配置信息（针对顺序消息的分区预配置）

异常摘要

AsyncMetaMessageProducer.MetaMessageOverflowException	表示消息流量过载的异常
AvailablePartitionNumException	表示某topic当前可用的分区个数不正确,比如跟期望的总数不一致等