Memorphosis是一个消息中间件,它是linkedin开源MQ——

《Memorphosis是一个消息中间件,它是linkedin开源MQ——》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、Memorphosis是一个消息中间件，它是linkedin开源MQ——kafka的Java版本，针对淘宝内部应用做了定制和优化。Metamorphosis的设计原则·消息都是持久的，保存在磁盘·吞吐量第一·消费状态保存在客户端·分布式，生产者、服务器和消费者都可分布Metamorphosis的部署结构[]Metamorphosis的特点除了完整实现kafka的功能之外，我们还为meta加入了额外的功能，使得meta成为一个更为强大的通用消息中间件，包括·彻底用java重写的实现，高效的协议和通讯框架·发送端的负载均衡·Master/Slave异步和同步复制的高可用方案·专门用于广播消息的客户

2、端实现·与diamond结合使用的顺序发送消息功能·支持事务，包括本地事务和分布式事务，实现JTA规范。[]Gettingstarted我们在日常已经部署了metamorhposis环境，因此你可以直接在本地测试，如果你想部署一个自己的服务器，可以参照#服务器部署节。前面提到，meta是一个消息中间件。消息中间件中有两个角色：消息生产者和消息消费者。Meta里同样有这两个概念，消息生产者负责创建消息并发送到meta服务器，meta服务器会将消息持久化到磁盘，消息消费者从meta服务器拉取消息并提交给应用消费。[]消息会话工厂类在使用消息生产者和消费者之前，我们需要创建它们，这就需要用到消息会话

3、工厂类——MessageSessionFactory，由这个工厂帮你创建生产者或者消费者。除了这些，MessageSessionFactory还默默无闻地在后面帮你做很多事情，包括1.服务的查找和发现，通过diamond和zookeeper帮你查找日常的meta服务器地址列表2.连接的创建和销毁，自动创建和销毁到meta服务器的连接，并做连接复用，也就是到同一台meta的服务器在一个工厂内只维持一个连接。3.消息消费者的消息存储和恢复，后续我们会谈到这一点。4.协调和管理各种资源，包括创建的生产者和消费者的。因此，我们首先需要创建一个会话工厂类，MessageSessionFactory仅是一

4、个接口，它的实现类是MetaMessageSessionFactoryMessageSessionFactorysessionFactory=newMetaMessageSessionFactory(newMetaClientConfig());请注意,MessageSessionFactory应当全局共用一个[]消息生产者翠花，上代码packagecom.taobao.metamorphosis.example;importjava.io.BufferedReader;importjava.io.InputStreamReader;importcom.taobao.metamorphosis

5、.Message;importcom.taobao.metamorphosis.client.MessageSessionFactory;importcom.taobao.metamorphosis.client.MetaClientConfig;importcom.taobao.metamorphosis.client.MetaMessageSessionFactory;importcom.taobao.metamorphosis.client.producer.MessageProducer;importcom.taobao.metamorphosis.client.producer.Se

6、ndResult;publicclassProducer{publicstaticvoidmain(String[]args)throwsException{//Newsessionfactory,强烈建议使用单例MessageSessionFactorysessionFactory=newMetaMessageSessionFactory(newMetaClientConfig());//createproducer,强烈建议使用单例MessageProducerproducer=sessionFactory.createProducer();//publishtopicfinalStrin

7、gtopic="meta-test";producer.publish(topic);BufferedReaderreader=newBufferedReader(newInputStreamReader(System.in));Stringline=null;while((line=reader.readLine())!=null){//sendmessageSendResultsendResu