所有软件包的分层结构

软件包分层结构：

com.taobao.common.store, com.taobao.common.store.journal, com.taobao.common.store.journal.impl, com.taobao.common.store.memory, com.taobao.common.store.util, com.taobao.metamorphosis, com.taobao.metamorphosis.client, com.taobao.metamorphosis.client.consumer, com.taobao.metamorphosis.client.consumer.storage, com.taobao.metamorphosis.client.extension, com.taobao.metamorphosis.client.extension.consumer, com.taobao.metamorphosis.client.extension.log4j, com.taobao.metamorphosis.client.extension.producer, com.taobao.metamorphosis.client.extension.spring, com.taobao.metamorphosis.client.extension.storage, com.taobao.metamorphosis.client.producer, com.taobao.metamorphosis.client.transaction, com.taobao.metamorphosis.cluster, com.taobao.metamorphosis.cluster.json, com.taobao.metamorphosis.consumer, com.taobao.metamorphosis.exception, com.taobao.metamorphosis.gregor, com.taobao.metamorphosis.gregor.master, com.taobao.metamorphosis.gregor.slave, com.taobao.metamorphosis.http, com.taobao.metamorphosis.http.processor, com.taobao.metamorphosis.metaslave, com.taobao.metamorphosis.network, com.taobao.metamorphosis.server, com.taobao.metamorphosis.server.assembly, com.taobao.metamorphosis.server.exception, com.taobao.metamorphosis.server.filter, com.taobao.metamorphosis.server.network, com.taobao.metamorphosis.server.stats, com.taobao.metamorphosis.server.store, com.taobao.metamorphosis.server.transaction, com.taobao.metamorphosis.server.transaction.store, com.taobao.metamorphosis.server.utils, com.taobao.metamorphosis.storm.scheme, com.taobao.metamorphosis.storm.spout, com.taobao.metamorphosis.tools.domain, com.taobao.metamorphosis.tools.monitor, com.taobao.metamorphosis.tools.monitor.alert, com.taobao.metamorphosis.tools.monitor.core, com.taobao.metamorphosis.tools.monitor.msgprobe, com.taobao.metamorphosis.tools.monitor.offsetcompareprob, com.taobao.metamorphosis.tools.monitor.offsetprob, com.taobao.metamorphosis.tools.monitor.statsprobe, com.taobao.metamorphosis.tools.monitor.system, com.taobao.metamorphosis.tools.query, com.taobao.metamorphosis.tools.query.test, com.taobao.metamorphosis.tools.shell, com.taobao.metamorphosis.tools.utils, com.taobao.metamorphosis.transaction, com.taobao.metamorphosis.utils, com.taobao.metamorphosis.utils.codec, com.taobao.metamorphosis.utils.codec.impl, com.taobao.metamorphosis.utils.log, com.taobao.metamorphosis.utils.monitor, com.taobao.metamorphosis.utils.test

类分层结构

• java.lang.Object
  • com.taobao.metamorphosis.AbstractBrokerPlugin
    • com.taobao.metamorphosis.BrokerPlugins
    • com.taobao.metamorphosis.gregor.slave.GregorSlaveBroker
    • com.taobao.metamorphosis.http.MetamorphosisOnJettyBroker
    • com.taobao.metamorphosis.metaslave.MetamorphosisSlaveBroker
    • com.taobao.metamorphosis.gregor.master.SamsaMasterBroker
  • java.util.concurrent.AbstractExecutorService (implements java.util.concurrent.ExecutorService)
    • java.util.concurrent.ThreadPoolExecutor
      • com.taobao.metamorphosis.gregor.slave.OrderedThreadPoolExecutor
  • org.eclipse.jetty.util.component.AbstractLifeCycle (implements org.eclipse.jetty.util.component.LifeCycle)
    • org.eclipse.jetty.util.component.AggregateLifeCycle (implements org.eclipse.jetty.util.component.Destroyable, org.eclipse.jetty.util.component.Dumpable)
      • org.eclipse.jetty.server.handler.AbstractHandler (implements org.eclipse.jetty.server.Handler)
        • com.taobao.metamorphosis.http.processor.MetamorphosisOnJettyProcessor
  • java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
    • java.util.HashMap<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • java.util.LinkedHashMap<K,V> (implements java.util.Map<K,V>)
        • com.taobao.common.store.util.LRUHashMap<K,V>
  • com.google.protobuf.AbstractMessageLite (implements com.google.protobuf.MessageLite)
    • com.google.protobuf.AbstractMessage (implements com.google.protobuf.Message)
      • com.google.protobuf.GeneratedMessage (implements java.io.Serializable)
        • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.AppendMessageCommand (implements com.taobao.metamorphosis.server.transaction.store.TransactionCommands.AppendMessageCommandOrBuilder)
        • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionOperation (implements com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionOperationOrBuilder)
        • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommand (implements com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommandOrBuilder)
  • com.google.protobuf.AbstractMessageLite.Builder<BuilderType> (implements com.google.protobuf.MessageLite.Builder)
    • com.google.protobuf.AbstractMessage.Builder<BuilderType> (implements com.google.protobuf.Message.Builder)
      • com.google.protobuf.GeneratedMessage.Builder<BuilderType>
        • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.AppendMessageCommand.Builder (implements com.taobao.metamorphosis.server.transaction.store.TransactionCommands.AppendMessageCommandOrBuilder)
        • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionOperation.Builder (implements com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionOperationOrBuilder)
        • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommand.Builder (implements com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommandOrBuilder)
  • com.taobao.metamorphosis.client.extension.spring.AbstractMetaqMessageSessionFactory<T> (implements org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<T>)
    • com.taobao.metamorphosis.client.extension.spring.MetaqMessageSessionFactoryBean
    • com.taobao.metamorphosis.client.extension.spring.XAMetaqMessageSessionFactoryBean
  • com.taobao.metamorphosis.client.producer.AbstractPartitionSelector (implements com.taobao.metamorphosis.client.producer.PartitionSelector)
    • com.taobao.metamorphosis.client.producer.RandomPartitionSelector
    • com.taobao.metamorphosis.client.producer.RoundRobinPartitionSelector
  • com.taobao.metamorphosis.tools.monitor.core.AbstractProber (implements com.taobao.metamorphosis.tools.monitor.core.Prober)
    • com.taobao.metamorphosis.tools.monitor.msgprobe.MsgProber
    • com.taobao.metamorphosis.tools.monitor.offsetcompareprob.OffsetCompareProber
    • com.taobao.metamorphosis.tools.monitor.offsetprob.OffsetProber
    • com.taobao.metamorphosis.tools.monitor.statsprobe.RealTimeStatsProber
    • com.taobao.metamorphosis.tools.monitor.system.SystemProber
      • com.taobao.metamorphosis.tools.monitor.system.CPULoadProber
      • com.taobao.metamorphosis.tools.monitor.system.DiskUsedProber
      • com.taobao.metamorphosis.tools.monitor.system.JvmMemoryProber
      • com.taobao.metamorphosis.tools.monitor.system.MetaConnProber
      • com.taobao.metamorphosis.tools.monitor.system.NetWorkUsedProber
      • com.taobao.metamorphosis.tools.monitor.system.PreparedTransactionProber
      • com.taobao.metamorphosis.tools.monitor.system.ZKConnProber
  • com.taobao.metamorphosis.client.consumer.AbstractRecoverManager (implements com.taobao.metamorphosis.client.consumer.RecoverManager)
    • com.taobao.metamorphosis.client.extension.consumer.RecoverNotifyManager
    • com.taobao.metamorphosis.client.consumer.RecoverStorageManager
  • com.taobao.metamorphosis.network.AbstractRequestCommand (implements com.taobao.metamorphosis.network.MetaEncodeCommand, com.taobao.gecko.core.command.RequestCommand)
    • com.taobao.metamorphosis.network.GetCommand
    • com.taobao.metamorphosis.network.OffsetCommand
    • com.taobao.metamorphosis.network.PutCommand
      • com.taobao.metamorphosis.network.SyncCommand
    • com.taobao.metamorphosis.network.QuitCommand
    • com.taobao.metamorphosis.network.StatsCommand
    • com.taobao.metamorphosis.network.VersionCommand (implements com.taobao.gecko.core.command.kernel.HeartBeatRequestCommand)
  • com.taobao.metamorphosis.network.AbstractResponseCommand (implements com.taobao.metamorphosis.network.MetaEncodeCommand, com.taobao.gecko.core.command.ResponseCommand)
    • com.taobao.metamorphosis.network.BooleanCommand (implements com.taobao.gecko.core.command.kernel.BooleanAckCommand)
    • com.taobao.metamorphosis.network.DataCommand
  • com.taobao.metamorphosis.server.transaction.store.AddMsgLocationUtils
  • com.taobao.metamorphosis.tools.monitor.alert.Alarm
  • com.taobao.metamorphosis.tools.monitor.alert.Alarm.EachAlarm
  • org.apache.log4j.AppenderSkeleton (implements org.apache.log4j.Appender, org.apache.log4j.spi.OptionHandler)
    • com.taobao.metamorphosis.client.extension.log4j.StreamAppender
      • com.taobao.metamorphosis.client.extension.log4j.FileStreamAppender
        • com.taobao.metamorphosis.client.extension.log4j.DailyRollingFileStreamAppender
    • org.apache.log4j.WriterAppender
      • org.apache.log4j.FileAppender
        • org.apache.log4j.DailyRollingFileAppender
          • com.taobao.metamorphosis.utils.log.MetaqDailyRollingFileAppender
  • backtype.storm.topology.base.BaseComponent (implements backtype.storm.topology.IComponent)
    • backtype.storm.topology.base.BaseRichSpout (implements backtype.storm.topology.IRichSpout)
      • com.taobao.metamorphosis.storm.spout.MetaSpout
  • com.taobao.metamorphosis.tools.query.Bootstrap
  • com.taobao.metamorphosis.cluster.Broker
  • com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor (implements com.taobao.metamorphosis.server.CommandProcessor)
    • com.taobao.metamorphosis.gregor.slave.GregorCommandProcessor (implements com.taobao.metamorphosis.gregor.slave.SyncCommandProcessor)
    • com.taobao.metamorphosis.gregor.master.SamsaCommandProcessor
  • com.taobao.metamorphosis.server.assembly.BrokerCommandProcessor.StoreAppendCallback (implements com.taobao.metamorphosis.server.store.AppendCallback)
  • com.taobao.metamorphosis.server.BrokerZooKeeper (implements java.beans.PropertyChangeListener)
  • com.taobao.metamorphosis.server.utils.BuildProperties
  • com.taobao.common.store.util.BytesKey (implements java.io.Serializable)
  • com.taobao.metamorphosis.network.ByteUtils
  • com.taobao.metamorphosis.server.transaction.store.Checkpoint (implements java.io.Closeable)
  • com.taobao.metamorphosis.utils.CheckSum
  • com.taobao.metamorphosis.utils.test.ClockWatch (implements java.lang.Runnable)
  • com.taobao.metamorphosis.cluster.Cluster
  • com.taobao.metamorphosis.utils.codec.CodecBuilder
  • com.taobao.metamorphosis.tools.utils.CommandLineUtils
  • com.taobao.metamorphosis.tools.query.CommandParser
  • com.taobao.metamorphosis.server.CommandProcessorFilter (implements com.taobao.metamorphosis.server.CommandProcessor)
    • com.taobao.metamorphosis.server.assembly.TransactionalCommandProcessor (implements com.taobao.metamorphosis.server.assembly.TransactionalCommandProcessorMBean)
  • com.taobao.common.store.journal.impl.ConcurrentIndexMap (implements com.taobao.common.store.journal.IndexMap)
  • com.taobao.metamorphosis.client.consumer.ConcurrentLRUHashMap (implements com.taobao.metamorphosis.client.consumer.MessageIdCache)
  • com.taobao.metamorphosis.utils.test.ConcurrentTestCase
  • com.taobao.metamorphosis.utils.test.ConcurrentTestRunner (implements java.lang.Runnable)
  • com.taobao.metamorphosis.utils.Config
    • com.taobao.metamorphosis.server.utils.MetaConfig (implements com.taobao.metamorphosis.server.utils.MetaConfigMBean, java.io.Serializable)
    • com.taobao.metamorphosis.server.utils.SlaveConfig (implements java.io.Serializable)
    • com.taobao.metamorphosis.server.utils.TopicConfig
    • com.taobao.metamorphosis.utils.ZkUtils.ZKConfig (implements java.io.Serializable)
  • com.taobao.metamorphosis.client.extension.producer.ConfigPartitionsSupport (implements com.taobao.metamorphosis.client.extension.producer.ConfigPartitionsAware, com.taobao.metamorphosis.client.producer.PartitionSelector)
    • com.taobao.metamorphosis.client.extension.producer.OrderedMessagePartitionSelector
  • com.taobao.metamorphosis.tools.utils.ConnectionUtil
  • com.taobao.metamorphosis.client.consumer.ConsisHashStrategy (implements com.taobao.metamorphosis.client.consumer.LoadBalanceStrategy)
  • com.taobao.metamorphosis.tools.utils.ConsoleConstant
  • com.taobao.metamorphosis.gregor.Constants
  • com.taobao.metamorphosis.server.filter.ConsumerFilterManager (implements com.taobao.metamorphosis.server.Service)
  • com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper (implements com.taobao.metamorphosis.client.ZkClientChangedListener)
    • com.taobao.metamorphosis.metaslave.SlaveConsumerZooKeeper
  • com.taobao.metamorphosis.client.consumer.ConsumerZooKeeper.ZKLoadRebalanceListener (implements org.I0Itec.zkclient.IZkChildListener, java.lang.Runnable)
  • com.taobao.metamorphosis.server.utils.CopyOnWriteMap<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
  • com.taobao.metamorphosis.tools.monitor.core.CoreManager
  • com.taobao.metamorphosis.tools.utils.CPULoadUtil
  • com.taobao.common.store.journal.DataFileAppender
  • com.taobao.metamorphosis.client.consumer.DefaultLoadBalanceStrategy (implements com.taobao.metamorphosis.client.consumer.LoadBalanceStrategy)
  • com.taobao.metamorphosis.client.extension.spring.DefaultMessageListener<T> (implements org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, com.taobao.metamorphosis.client.consumer.MessageListener)
  • com.taobao.metamorphosis.server.store.DeleteJob (implements org.quartz.Job)
  • com.taobao.metamorphosis.server.store.DeletePolicyFactory
  • com.taobao.metamorphosis.utils.DiamondUtils
  • com.taobao.metamorphosis.server.store.DiscardDeletePolicy (implements com.taobao.metamorphosis.server.store.DeletePolicy)
    • com.taobao.metamorphosis.server.store.ArchiveDeletePolicy
  • com.taobao.metamorphosis.tools.utils.DiskUsedUtil
  • com.taobao.metamorphosis.gregor.slave.DummyConnection (implements com.taobao.gecko.service.Connection)
  • com.taobao.metamorphosis.server.assembly.EmbedZookeeperServer
  • com.taobao.metamorphosis.EnhancedBroker
  • com.taobao.metamorphosis.server.assembly.ExecutorsManager (implements com.taobao.metamorphosis.server.Service)
  • com.taobao.metamorphosis.client.consumer.FetchRequest (implements java.util.concurrent.Delayed)
  • com.taobao.metamorphosis.server.store.FileMessageSet (implements java.io.Closeable, com.taobao.metamorphosis.server.store.MessageSet)
  • com.taobao.metamorphosis.server.utils.FileUtils
  • com.taobao.metamorphosis.server.network.GetProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.metamorphosis.tools.domain.Group
  • com.taobao.metamorphosis.utils.codec.impl.Hessian1Deserializer (implements com.taobao.metamorphosis.utils.codec.Deserializer)
  • com.taobao.metamorphosis.utils.codec.impl.Hessian1Serializer (implements com.taobao.metamorphosis.utils.codec.Serializer)
  • com.taobao.metamorphosis.server.transaction.HeuristicTransactionJournal (implements java.io.Closeable)
  • com.taobao.metamorphosis.utils.HexSupport
  • com.taobao.metamorphosis.network.HttpStatus
  • com.taobao.metamorphosis.utils.IdGenerator
  • com.taobao.metamorphosis.utils.IdWorker
  • com.taobao.metamorphosis.gregor.slave.IoCatalog
  • com.taobao.metamorphosis.utils.codec.impl.JavaDeserializer (implements com.taobao.metamorphosis.utils.codec.Deserializer)
  • com.taobao.metamorphosis.client.extension.spring.JavaSerializationMessageBodyConverter (implements com.taobao.metamorphosis.client.extension.spring.MessageBodyConverter<T>)
  • com.taobao.metamorphosis.utils.codec.impl.JavaSerializer (implements com.taobao.metamorphosis.utils.codec.Serializer)
  • com.taobao.metamorphosis.client.consumer.storage.JDBCUtils
  • com.taobao.metamorphosis.tools.utils.JMXClient
  • com.taobao.metamorphosis.server.transaction.store.JournalLocation (implements java.lang.Comparable<T>, java.io.Serializable)
  • com.taobao.common.store.journal.JournalStore (implements com.taobao.common.store.journal.JournalStoreMBean, com.taobao.common.store.Store)
    • com.taobao.metamorphosis.client.extension.storage.MessageStore
  • com.taobao.metamorphosis.server.transaction.store.JournalStore (implements java.io.Closeable)
  • com.taobao.common.store.journal.JournalStore.InflyWriteData
  • com.taobao.metamorphosis.server.transaction.store.JournalTransactionStore (implements com.taobao.metamorphosis.server.transaction.store.JournalTransactionStoreMBean, com.taobao.metamorphosis.server.transaction.TransactionStore)
  • com.taobao.metamorphosis.server.transaction.store.JournalTransactionStore.AddMsgOperation (implements com.taobao.metamorphosis.server.transaction.store.JournalTransactionStore.TxOperation)
  • com.taobao.metamorphosis.server.transaction.store.JournalTransactionStore.Tx
  • com.taobao.metamorphosis.utils.JSONUtils
  • com.taobao.metamorphosis.tools.utils.JvmMemoryUtil
  • com.taobao.metamorphosis.utils.monitor.Keys (implements java.io.Serializable)
  • com.taobao.metamorphosis.client.extension.producer.LocalMessageStorageManager (implements com.taobao.metamorphosis.client.extension.producer.MessageRecoverManager)
    • com.taobao.metamorphosis.client.extension.producer.OrderedLocalMessageStorageManager
  • com.taobao.metamorphosis.client.consumer.storage.LocalOffsetStorage (implements com.taobao.metamorphosis.client.consumer.storage.OffsetStorage)
  • com.taobao.metamorphosis.server.network.LocalTransactionRollbackListener (implements com.taobao.gecko.service.ConnectionLifeCycleListener)
  • com.taobao.metamorphosis.server.store.Location
    • com.taobao.metamorphosis.server.transaction.store.JournalTransactionStore.AddMsgLocation
  • com.taobao.metamorphosis.utils.LongSequenceGenerator
  • com.taobao.common.store.journal.impl.LRUIndexMap (implements com.taobao.common.store.journal.IndexMap)
  • com.taobao.common.store.memory.MemStore (implements com.taobao.common.store.Store)
  • com.taobao.metamorphosis.Message (implements java.io.Serializable)
  • com.taobao.metamorphosis.MessageAccessor
  • com.taobao.metamorphosis.client.extension.spring.MessageBuilder
  • com.taobao.metamorphosis.tools.query.test.MessageConsumerTest
  • com.taobao.metamorphosis.utils.MessageFlagUtils
  • com.taobao.metamorphosis.consumer.MessageIterator
  • com.taobao.metamorphosis.client.consumer.MessageIterator
  • com.taobao.metamorphosis.client.extension.spring.MessageListenerContainer (implements org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean)
  • com.taobao.metamorphosis.tools.query.test.MessageSenderTest
  • com.taobao.metamorphosis.server.store.MessageStoreManager (implements com.taobao.metamorphosis.server.Service)
  • com.taobao.metamorphosis.utils.MessageUtils
  • com.taobao.metamorphosis.utils.MessageUtils.DecodedMessage
  • com.taobao.metamorphosis.client.MetaClientConfig (implements java.io.Serializable)
    • com.taobao.metamorphosis.client.consumer.ConsumerConfig
  • com.taobao.metamorphosis.server.utils.MetaMBeanServer
  • com.taobao.metamorphosis.client.MetaMessageSessionFactory (implements com.taobao.metamorphosis.client.MessageSessionFactory)
    • com.taobao.metamorphosis.client.extension.AsyncMetaMessageSessionFactory (implements com.taobao.metamorphosis.client.extension.AsyncMessageSessionFactory)
    • com.taobao.metamorphosis.client.extension.MetaBroadcastMessageSessionFactory (implements com.taobao.metamorphosis.client.extension.BroadcastMessageSessionFactory)
      • com.taobao.metamorphosis.client.extension.ExtMetaMessageSessionFactory (implements com.taobao.metamorphosis.client.extension.ExtMessageSessionFactory)
    • com.taobao.metamorphosis.client.extension.OrderedMetaMessageSessionFactory (implements com.taobao.metamorphosis.client.extension.OrderedMessageSessionFactory)
    • com.taobao.metamorphosis.metaslave.SlaveMetaMessageSessionFactory
    • com.taobao.metamorphosis.client.XAMetaMessageSessionFactory (implements com.taobao.metamorphosis.client.XAMessageSessionFactory)
  • com.taobao.metamorphosis.storm.spout.MetaMessageWrapper
  • com.taobao.metamorphosis.server.assembly.MetaMorphosisBroker (implements com.taobao.metamorphosis.server.assembly.MetaMorphosisBrokerMBean)
  • com.taobao.metamorphosis.server.MetamorphosisStartup
  • com.taobao.metamorphosis.client.extension.spring.MetaqMessage<T>
  • com.taobao.metamorphosis.client.extension.spring.MetaqTemplate (implements org.springframework.beans.factory.DisposableBean)
  • com.taobao.metamorphosis.client.extension.spring.MetaqTopic
  • com.taobao.metamorphosis.tools.domain.MetaServer (implements java.lang.Comparable<T>)
  • com.taobao.metamorphosis.metaslave.MetaSlaveListener (implements com.taobao.metamorphosis.client.consumer.MessageListener)
  • com.taobao.metamorphosis.utils.MetaStatLog
  • com.taobao.metamorphosis.utils.MetaStatLog.RealTimeStatRestTask (implements java.lang.Runnable)
  • com.taobao.metamorphosis.client.MetaTopicBrowser (implements com.taobao.metamorphosis.client.TopicBrowser)
  • com.taobao.metamorphosis.client.MetaTopicBrowser.Itr (implements java.util.Iterator<E>)
  • com.taobao.metamorphosis.utils.MetaZookeeper
  • com.taobao.metamorphosis.utils.MetaZookeeper.ZKGroupDirs
    • com.taobao.metamorphosis.utils.MetaZookeeper.ZKGroupTopicDirs
  • com.taobao.metamorphosis.tools.monitor.core.MonitorConfig
  • com.taobao.metamorphosis.tools.monitor.core.MonitorConfig.GroupTopicPair
  • com.taobao.metamorphosis.utils.monitor.MonitorConstants
  • com.taobao.metamorphosis.utils.monitor.MonitorLog
  • com.taobao.metamorphosis.tools.utils.MonitorResult
  • com.taobao.metamorphosis.tools.monitor.MonitorStartup
  • com.taobao.metamorphosis.tools.monitor.msgprobe.MsgProber.ProbContext
  • com.taobao.metamorphosis.tools.monitor.core.MsgReceiver
  • com.taobao.metamorphosis.tools.monitor.core.MsgSender
  • com.taobao.common.store.util.MyMBeanServer
  • com.taobao.metamorphosis.client.consumer.storage.MysqlOffsetStorage (implements com.taobao.metamorphosis.client.consumer.storage.OffsetStorage)
  • com.taobao.metamorphosis.tools.query.MysqlOffsetStorageQuery (implements com.taobao.metamorphosis.tools.query.OffsetStorageQuery)
  • com.taobao.metamorphosis.utils.NamedThreadFactory (implements java.util.concurrent.ThreadFactory)
  • com.taobao.metamorphosis.tools.utils.NetWorkUtil
  • com.taobao.common.store.journal.impl.NotifyEldestEntryHandler (implements com.taobao.common.store.util.LRUHashMap.EldestEntryHandler<K,V>)
  • com.taobao.metamorphosis.server.network.OffsetProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.metamorphosis.tools.query.OffsetQueryDO
  • com.taobao.common.store.journal.OpItem
  • com.taobao.common.store.journal.impl.OpItemEntry
  • com.taobao.common.store.journal.impl.OpItemHashMap
  • com.taobao.metamorphosis.gregor.slave.OrderedThreadPoolExecutor.TasksQueue
  • com.taobao.metamorphosis.cluster.Partition (implements java.lang.Comparable<T>, java.io.Serializable)
  • com.taobao.metamorphosis.utils.PatternUtils
  • com.taobao.metamorphosis.tools.monitor.msgprobe.ProbeListener
    • com.taobao.metamorphosis.tools.monitor.msgprobe.AlarmProbeListener
    • com.taobao.metamorphosis.tools.monitor.msgprobe.DefaultProbeListener
  • com.taobao.metamorphosis.tools.monitor.ProberManager
  • com.taobao.metamorphosis.tools.monitor.core.ProbTask (implements java.lang.Runnable)
  • com.taobao.metamorphosis.tools.monitor.system.ProcessResultHook
  • com.taobao.metamorphosis.client.extension.producer.ProducerDiamondManager
  • com.taobao.metamorphosis.client.producer.ProducerZooKeeper (implements com.taobao.metamorphosis.client.ZkClientChangedListener)
  • com.taobao.metamorphosis.client.producer.ProducerZooKeeper.BrokersInfo
  • com.taobao.metamorphosis.server.network.PutProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.metamorphosis.tools.query.Query
  • com.taobao.metamorphosis.server.network.QuitProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.metamorphosis.server.stats.RealTimeStat (implements com.taobao.metamorphosis.server.stats.RealTimeStatMBean)
  • com.taobao.metamorphosis.client.RemotingClientWrapper (implements com.taobao.gecko.service.RemotingClient)
  • com.taobao.metamorphosis.network.RemotingUtils
  • com.taobao.metamorphosis.utils.ResourceUtils
  • com.taobao.metamorphosis.tools.monitor.core.ReveiceResult
  • com.taobao.metamorphosis.gregor.master.SamsaCommandProcessor.SyncAppendCallback (implements com.taobao.metamorphosis.server.store.AppendCallback, com.taobao.gecko.service.SingleRequestCallBackListener)
  • com.taobao.metamorphosis.server.store.SegmentInfo
  • com.taobao.metamorphosis.tools.monitor.msgprobe.SendReceiveMonitor
  • com.taobao.metamorphosis.client.producer.SendResult
  • com.taobao.metamorphosis.tools.monitor.core.SendResultWrapper
  • com.taobao.metamorphosis.ServerStartup
  • com.taobao.metamorphosis.server.network.SessionContextHolder
  • com.taobao.metamorphosis.server.network.SessionContextImpl (implements com.taobao.metamorphosis.server.network.SessionContext)
  • com.taobao.metamorphosis.tools.shell.ShellTool
    • com.taobao.metamorphosis.tools.shell.BrokerStatsTool
    • com.taobao.metamorphosis.tools.shell.ClosePartitionsTool
    • com.taobao.metamorphosis.tools.shell.CopyOffsetInZk
    • com.taobao.metamorphosis.tools.shell.DeletePartitionFiles
    • com.taobao.metamorphosis.tools.shell.MovePartitionFiles
    • com.taobao.metamorphosis.tools.shell.OpenPartitionsTool
    • com.taobao.metamorphosis.tools.shell.ReloadConfig
    • com.taobao.metamorphosis.tools.shell.SlaveResubscribe
    • com.taobao.metamorphosis.tools.shell.SlaveStatus
    • com.taobao.metamorphosis.tools.shell.StopBrokerTool
    • com.taobao.metamorphosis.tools.shell.TimetunnelPluginTool
  • com.taobao.metamorphosis.client.consumer.SimpleFetchManager (implements com.taobao.metamorphosis.client.consumer.FetchManager)
  • com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer (implements com.taobao.metamorphosis.client.consumer.InnerConsumer, com.taobao.metamorphosis.client.consumer.MessageConsumer)
  • com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer.DropPolicy (implements com.taobao.metamorphosis.client.consumer.RejectConsumptionHandler)
  • com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer.LocalRecoverPolicy (implements com.taobao.metamorphosis.client.consumer.RejectConsumptionHandler)
  • com.taobao.metamorphosis.client.producer.SimpleMessageProducer (implements com.taobao.metamorphosis.client.producer.MessageProducer, com.taobao.metamorphosis.client.transaction.TransactionSession)
    • com.taobao.metamorphosis.client.extension.producer.AsyncMetaMessageProducer (implements com.taobao.metamorphosis.client.extension.producer.AsyncMessageProducer, com.taobao.metamorphosis.client.extension.producer.MessageRecoverManager.MessageRecoverer)
    • com.taobao.metamorphosis.client.extension.producer.OrderedMessageProducer
    • com.taobao.metamorphosis.client.producer.SimpleXAMessageProducer (implements com.taobao.metamorphosis.client.producer.ProducerZooKeeper.BrokerChangeListener, com.taobao.metamorphosis.client.producer.XAMessageProducer)
  • com.taobao.metamorphosis.metaslave.SlaveOffsetStorage (implements com.taobao.metamorphosis.client.consumer.storage.OffsetStorage)
  • com.taobao.metamorphosis.metaslave.SlaveStatsManager
  • com.taobao.metamorphosis.tools.utils.SSHSupport
  • com.taobao.metamorphosis.StartupHelp
  • com.taobao.metamorphosis.utils.StatConstants
  • com.taobao.metamorphosis.server.stats.StatsManager (implements com.taobao.metamorphosis.server.Service)
  • com.taobao.metamorphosis.server.stats.StatsManager.TopicStats
  • com.taobao.metamorphosis.server.network.StatsProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.metamorphosis.client.StatsResult (implements java.io.Serializable)
  • com.taobao.metamorphosis.tools.monitor.core.StatsResult
  • com.taobao.metamorphosis.storm.scheme.StringScheme (implements backtype.storm.spout.Scheme)
  • com.taobao.metamorphosis.tools.utils.StringUtil
  • com.taobao.metamorphosis.metaslave.SubscribeHandler (implements com.taobao.metamorphosis.metaslave.SubscribeHandlerMBean)
  • com.taobao.metamorphosis.client.consumer.SubscribeInfoManager
  • com.taobao.metamorphosis.client.consumer.SubscribeInfoManagerAccessor
  • com.taobao.metamorphosis.client.consumer.SubscriberInfo
  • com.taobao.metamorphosis.gregor.slave.SyncProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.metamorphosis.server.utils.SystemTimer
  • com.taobao.metamorphosis.client.consumer.storage.TairOffsetStorage (implements com.taobao.metamorphosis.client.consumer.storage.OffsetStorage)
  • java.lang.Thread (implements java.lang.Runnable)
    • com.taobao.metamorphosis.tools.query.ConsoleThread
    • com.taobao.metamorphosis.server.store.MessageStore (implements java.io.Closeable)
  • com.taobao.metamorphosis.utils.ThreadUtils
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • com.taobao.metamorphosis.tools.monitor.InitException
      • com.taobao.metamorphosis.tools.utils.JMXClientException
      • com.taobao.metamorphosis.exception.MetaClientException
        • com.taobao.metamorphosis.client.extension.producer.AvailablePartitionNumException
        • com.taobao.metamorphosis.exception.InvalidMessageException
        • com.taobao.metamorphosis.exception.MetaOpeartionTimeoutException
        • com.taobao.metamorphosis.exception.NetworkException
        • com.taobao.metamorphosis.exception.TransactionInProgressException
      • com.taobao.metamorphosis.server.exception.MetamorphosisException
      • com.taobao.gecko.service.exception.NotifyRemotingException
        • com.taobao.metamorphosis.client.extension.producer.AsyncMetaMessageProducer.MetaMessageOverflowException
      • java.lang.RuntimeException
        • com.taobao.metamorphosis.AppendMessageErrorException
        • com.taobao.metamorphosis.exception.GetRecoverStorageErrorException
        • java.lang.IllegalArgumentException
          • com.taobao.metamorphosis.exception.InvalidCheckSumException
          • com.taobao.metamorphosis.exception.InvalidConsumerConfigException
          • com.taobao.metamorphosis.exception.InvalidOffsetStorageException
          • com.taobao.metamorphosis.server.exception.WrongPartitionException
        • com.taobao.metamorphosis.server.exception.IllegalTopicException
        • com.taobao.metamorphosis.exception.InvalidBrokerException
        • com.taobao.metamorphosis.exception.InvalidSystemClock
        • com.taobao.metamorphosis.client.consumer.storage.JDBCUtils.CannotGetConnectionException
        • com.taobao.metamorphosis.exception.MetaCodecException
        • com.taobao.metamorphosis.server.exception.MetamorphosisServerStartupException
        • com.taobao.metamorphosis.tools.utils.RemoteExecuteException
        • com.taobao.metamorphosis.server.exception.ServiceStartupException
        • com.taobao.metamorphosis.metaslave.SubscribeMasterMessageException
        • com.taobao.metamorphosis.exception.UnknowCodecTypeException
        • com.taobao.metamorphosis.server.exception.UnknownDeletePolicyException
  • com.taobao.metamorphosis.cluster.json.TopicBroker (implements java.io.Serializable)
  • com.taobao.metamorphosis.client.consumer.TopicPartitionRegInfo (implements java.io.Serializable)
  • com.taobao.metamorphosis.server.transaction.Transaction (implements java.io.Serializable)
    • com.taobao.metamorphosis.server.transaction.LocalTransaction
    • com.taobao.metamorphosis.server.transaction.XATransaction (implements java.io.Serializable)
  • com.taobao.metamorphosis.network.TransactionCommand (implements com.taobao.metamorphosis.network.MetaEncodeCommand, com.taobao.gecko.core.command.RequestCommand)
  • com.taobao.metamorphosis.server.transaction.store.TransactionCommands
  • com.taobao.metamorphosis.client.transaction.TransactionContext (implements javax.transaction.xa.XAResource)
  • com.taobao.metamorphosis.transaction.TransactionId (implements java.io.Serializable)
    • com.taobao.metamorphosis.transaction.LocalTransactionId (implements java.lang.Comparable<T>)
    • com.taobao.metamorphosis.transaction.NullTransactionId
    • com.taobao.metamorphosis.transaction.XATransactionId (implements java.lang.Comparable<T>, java.io.Serializable, javax.transaction.xa.Xid)
  • com.taobao.metamorphosis.transaction.TransactionInfo
  • com.taobao.metamorphosis.server.network.TransactionProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.metamorphosis.tools.utils.TransactionUtil
  • com.taobao.common.store.util.UniqId
  • com.taobao.metamorphosis.utils.URIUtils
  • com.taobao.common.store.util.Util
  • com.taobao.metamorphosis.utils.Utils
  • com.taobao.metamorphosis.utils.Utils.Action
  • com.taobao.metamorphosis.utils.monitor.ValueObject
  • com.taobao.metamorphosis.server.network.VersionProcessor (implements com.taobao.gecko.service.RequestProcessor<T>)
  • com.taobao.gecko.service.config.WireFormatType
    • com.taobao.metamorphosis.network.MetamorphosisWireFormatType
  • com.taobao.metamorphosis.tools.shell.ZkManager
  • com.taobao.metamorphosis.client.consumer.storage.ZkOffsetStorage (implements com.taobao.metamorphosis.client.consumer.storage.OffsetStorage, com.taobao.metamorphosis.client.ZkClientChangedListener)
  • com.taobao.metamorphosis.tools.query.ZkOffsetStorageQuery (implements com.taobao.metamorphosis.tools.query.OffsetStorageQuery)
  • com.taobao.metamorphosis.utils.ZkUtils
  • com.taobao.metamorphosis.utils.ZkUtils.StringSerializer (implements org.I0Itec.zkclient.serialize.ZkSerializer)

接口分层结构

• com.taobao.metamorphosis.server.store.AppendCallback
• com.taobao.metamorphosis.client.extension.producer.AsyncMessageProducer.IgnoreMessageProcessor
• com.taobao.metamorphosis.utils.test.ConcurrentTestTask
• com.taobao.metamorphosis.client.extension.producer.ConfigPartitionsAware
• com.taobao.metamorphosis.consumer.ConsumerMessageFilter
• com.taobao.metamorphosis.server.store.DeletePolicy
• com.taobao.metamorphosis.utils.codec.Deserializer
• com.taobao.metamorphosis.client.consumer.FetchManager
• com.taobao.common.store.journal.IndexMap
• com.taobao.metamorphosis.client.consumer.InnerConsumer
• com.taobao.metamorphosis.client.consumer.storage.JDBCUtils.ConnectionCallback
• com.taobao.metamorphosis.client.consumer.storage.JDBCUtils.PreparedStatementCallback
• com.taobao.metamorphosis.client.consumer.storage.JDBCUtils.ResultSetCallback
• com.taobao.common.store.journal.JournalStoreMBean
• com.taobao.metamorphosis.server.transaction.store.JournalTransactionStore.TxOperation
• com.taobao.metamorphosis.server.transaction.store.JournalTransactionStoreMBean
• com.taobao.metamorphosis.client.consumer.LoadBalanceStrategy
• com.taobao.common.store.util.LRUHashMap.EldestEntryHandler<K,V>
• com.taobao.metamorphosis.client.extension.spring.MessageBodyConverter<T>
• com.taobao.metamorphosis.client.consumer.MessageIdCache
• com.taobao.metamorphosis.client.consumer.MessageListener
• com.google.protobuf.MessageLiteOrBuilder
  • com.google.protobuf.MessageOrBuilder
    • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.AppendMessageCommandOrBuilder
    • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionOperationOrBuilder
    • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommandOrBuilder
  • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.AppendMessageCommandOrBuilder
  • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionOperationOrBuilder
  • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommandOrBuilder
• com.taobao.metamorphosis.client.extension.producer.MessageRecoverManager.MessageRecoverer
• com.taobao.metamorphosis.server.store.MessageSet
• com.taobao.metamorphosis.server.utils.MetaConfigMBean
• com.taobao.metamorphosis.network.MetaEncodeCommand
• com.taobao.metamorphosis.server.assembly.MetaMorphosisBrokerMBean
• com.taobao.metamorphosis.client.consumer.storage.OffsetStorage
• com.taobao.metamorphosis.tools.query.OffsetStorageQuery
• com.taobao.metamorphosis.client.producer.PartitionSelector
• com.taobao.metamorphosis.tools.monitor.core.Prober
• com.taobao.metamorphosis.client.producer.ProducerZooKeeper.BrokerChangeListener
• com.taobao.metamorphosis.server.network.PutCallback
• com.taobao.metamorphosis.server.stats.RealTimeStatMBean
• com.taobao.metamorphosis.client.consumer.RejectConsumptionHandler
• java.lang.Runnable
  • com.taobao.metamorphosis.gregor.slave.IoEvent
• com.taobao.metamorphosis.client.producer.SendMessageCallback
• com.taobao.metamorphosis.utils.codec.Serializer
• com.taobao.metamorphosis.server.Service
  • com.taobao.metamorphosis.server.CommandProcessor
  • com.taobao.metamorphosis.server.transaction.TransactionStore
• com.taobao.metamorphosis.server.network.SessionContext
• com.taobao.metamorphosis.client.Shutdownable
  • com.taobao.metamorphosis.client.extension.producer.AsyncMessageProducer
  • com.taobao.metamorphosis.client.extension.AsyncMessageSessionFactory
  • com.taobao.metamorphosis.client.extension.BroadcastMessageSessionFactory
    • com.taobao.metamorphosis.client.extension.ExtMessageSessionFactory
  • com.taobao.metamorphosis.client.extension.ExtMessageSessionFactory
  • com.taobao.metamorphosis.client.consumer.MessageConsumer
  • com.taobao.metamorphosis.client.producer.MessageProducer
    • com.taobao.metamorphosis.client.extension.producer.AsyncMessageProducer
    • com.taobao.metamorphosis.client.producer.XAMessageProducer
  • com.taobao.metamorphosis.client.extension.producer.MessageRecoverManager
  • com.taobao.metamorphosis.client.MessageSessionFactory
    • com.taobao.metamorphosis.client.extension.AsyncMessageSessionFactory
    • com.taobao.metamorphosis.client.extension.BroadcastMessageSessionFactory
      • com.taobao.metamorphosis.client.extension.ExtMessageSessionFactory
    • com.taobao.metamorphosis.client.extension.ExtMessageSessionFactory
    • com.taobao.metamorphosis.client.extension.OrderedMessageSessionFactory
    • com.taobao.metamorphosis.client.XAMessageSessionFactory
  • com.taobao.metamorphosis.client.extension.OrderedMessageSessionFactory
  • com.taobao.metamorphosis.client.consumer.RecoverManager
  • com.taobao.metamorphosis.client.TopicBrowser
  • com.taobao.metamorphosis.client.producer.XAMessageProducer
  • com.taobao.metamorphosis.client.XAMessageSessionFactory
• com.taobao.common.store.Store
• com.taobao.metamorphosis.metaslave.SubscribeHandlerMBean
• com.taobao.metamorphosis.gregor.slave.SyncCommandProcessor
• com.taobao.metamorphosis.server.assembly.TransactionalCommandProcessorMBean
• com.taobao.metamorphosis.server.transaction.TransactionRecoveryListener
• com.taobao.metamorphosis.client.transaction.TransactionSession
• com.taobao.metamorphosis.client.ZkClientChangedListener

注释类型分层结构

• com.taobao.metamorphosis.utils.Key (implements java.lang.annotation.Annotation)
• com.taobao.metamorphosis.utils.Ignore (implements java.lang.annotation.Annotation)

枚举分层结构

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.taobao.common.store.util.SerializationType
    • com.taobao.metamorphosis.transaction.TransactionInfo.TransactionType
    • com.taobao.metamorphosis.utils.codec.CodecBuilder.Codec_Type
    • com.taobao.metamorphosis.client.consumer.LoadBalanceStrategy.Type
    • com.taobao.metamorphosis.client.consumer.HashAlgorithm
    • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TxCommandType (implements com.google.protobuf.ProtocolMessageEnum)
    • com.taobao.metamorphosis.server.transaction.store.TransactionCommands.TransactionType (implements com.google.protobuf.ProtocolMessageEnum)
    • com.taobao.metamorphosis.tools.query.OffsetQueryDO.QueryType
    • com.taobao.metamorphosis.client.extension.consumer.ConsumerRecoverType