1. 中间件技术2. MetaQ中间件3. MetaQ编程实践

1. 数据库2. Apache的Tomcat3. IBM公司的WebSphere4. BEA公司的WebLogic[[应用服务器]5. 东方通公司的Tong系列中间件6. Kingdee公司的等

1. 过程调用2. 分布式组件3. 消息队列4. 事务5. 安全6. 连结器7. 商业流程8. 网络并发9. HTTP服务器10. Web Service

1. 平台化所谓平台就是能够独立运行并自主存在，为其所支撑的上层系统和应用提供运行所依赖的环境。中间件是一个平台，因此中间件是必须独立存在，是运行时刻的"系统软件"，它为上层的网络应用系统提供一个运行环境，并通过标准的接口和API来隔离其支撑的系统，实现其独立性，也就是平台性。J2EE应用服务器提供JAVA应用的运行环境，就是经典的中间件2. 应用支撑中间件的最终目的是解决上层应用系统的问题，而且也是软件技术发展到今天对应用软件提供最完善彻底的解决方案。    1) 高级程序设计语言的发明，使得软件开发变成一个独立的科学和技术体系，而操作系统平台的出现，使得应用软件通过标准的API接口，实现了软件与硬件的分离。　　    2) 现代面向服务(SOA)的中间件在软件的模型、结构、互操作以及开发方法等四个方面提供了更强的应用支撑能力：　　        2.1) 模型：构件模型弹性粒度化        通过抽象层度更高的构件模型，实现具备更高结构独立性、内容自包含性和业务完整性的可复用构件，即服务(RESTFUL API就是一个最好的例子)。并且在细粒度服务基础上，提供了更粗粒度的服务封装方式，即业务层面的封装，形成业务组件，就可以实现从组件模型到业务模型的全生命周期企业建模的能力。　　        2.2) 结构：结构松散化        将"服务描述"和"服务功能实现"分离，将"服务的使用者"和"提供者"分离，从而避免分布式应用系统构建和集成时常见的技术、组织、时间等不良约束。　　        2.3) 互操作：交互过程标准化        将与互操作相关的内容进行标准化定义，如服务封装、描述、发布、发现、调用等契约，通信协议以及数据交换格式等等。最终实现访问互操作、连接互操作和语义互操作(RESTFUL、SOAP、WPF、WebService、SCA/SDO)　　        2.4) 开发集成方法：        应用系统的构建方式由代码编写转为主要通过服务间的快捷组合及编排，完成更为复杂的业务逻辑的按需提供和改善，从而大大简化和加速应用系统的搭建及重构过程(一种典型的轻耦合思想)而要最终解决软件的质量问题、效率问题、互操作问题、灵活应变问题这四大问题，需要在软件技术的内在结构(Structure)、架构(Architecture)层面进行思考。解决这些问题，技术的本质是复用、松耦合、互操作(标准)等软件技术的内在机制。这也是中间件技术和产品的本质特征3. 软件复用软件复用，即软件的重用，也叫再用，是指同一事物不作修改或稍加改动就多次重复使用。从软件复用技术的发展来看，就是不断提升抽象级别，扩大复用范围。最早的复用技术是子程序，人们发明子程序，就可以在不同系统之间进行复用了。但是，子程序是最原始的复用，因为这种复用范围是一个可执行程序内复用，静态开发期复用，如果子程序修改，意味着所有调用这个子程序的程序必须重新编译、测试和发布复用对象复用范围    1) 子程序: 一个可执行程序内复用: 静态开发期复用    2) 组件(DLL、Com..): 系统内复用，动态运行期复用    3) 企业对象组件(Com+、.NET、EJB..): 企业网络内复用，不同系统之间复用    4) 服务(RESTFUL、SOAP、WPF、WebService、SCA/SDO): 不同企业之间、跨系统、跨异构环境复用，动态可配置4. 耦合关系     1) 分布式对象技术将"连接逻辑"进行分离    2) 消息中间件将"连接逻辑"进行异步处理，增加了更大的灵活性    3) 消息代理和一些分布式对象中间件将数据转换也进行了分离    4) 而SOA架构，通过服务的封装，实现了业务逻辑与网络连接、数据转换等进行完全的解耦5. 互操作性在软件的互操作方面，传统中间件只是实现了访问互操作，即通过标准化的API实现了同类系统之间的调用互操作，而连接互操作还是依赖于特定的访问协议，如JAVA使用RMI，CORBA使用IIOP等。而SOA通过标准的、支持Internet、与操作系统无关的SOAP协议实现了连接互操作。而且，服务的封装是采用XML协议，具有自解析和自定义的特性，这样，基于SOA的中间件还可以实现语义互操作总之，服务化体现的是中间件在完整业务复用、灵活业务组织方面的发展趋势，其核心目标是提升IT基础设施的业务敏捷性。因此，中间件将成为SOA的主要实现平台

http://zh.wikipedia.org/wiki/%E4%B8%AD%E9%97%B4%E4%BB%B6http://kb.cnblogs.com/page/196448/http://jm.taobao.org/

//全称串行操作用户注册->通知给红包中心给用户发新手红包->博客系统给用户准备对应的博客账号->进行合法性验证->告知SNS系统给用户导入新的用户 

1. MetaQ是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点。2. Producer、Consumer、队列都可以分布式。3. 能够保证严格的消息顺序4. 提供丰富的消息拉取模式5. 高效的订阅者水平扩展能力6. 实时的消息订阅机制7. 亿级消息堆积能力

1. Message全部写入到一个独立的队列，完全的顺序写2. Message在文件的位置信息写入到另外的文件，串行方式写

http://blog.csdn.net/blogdevteam/article/details/8449916https://github.com/killme2008/Metamorphosis/wikihttp://m.bianceng.cn/web/Skills/201407/42090.htmhttp://www.bkjia.com/ASPjc/871354.html 

[zookeeper]zk.zkConnect=localhost:2181zk.zkSessionTimeoutMs=30000zk.zkConnectionTimeoutMs=30000zk.zkSyncTimeMs=5000

//停止local模式启动的broker1，并重新以集群模式启动bin/metaServer.sh start 

package com.taobao.metamorphosis.example;import java.io.BufferedReader;import java.io.InputStreamReader;import java.io.BufferedReader;import java.io.InputStreamReader;import com.taobao.metamorphosis.Message;import com.taobao.metamorphosis.client.MessageSessionFactory;import com.taobao.metamorphosis.client.MetaClientConfig;import com.taobao.metamorphosis.client.MetaMessageSessionFactory;import com.taobao.metamorphosis.client.producer.MessageProducer;import com.taobao.metamorphosis.client.producer.SendResult;import com.taobao.metamorphosis.utils.ZkUtils.ZKConfig;public class Producer {    public static void main(String[] args) throws Exception {        final MetaClientConfig metaClientConfig = new MetaClientConfig();        final ZKConfig zkConfig = new ZKConfig();        //设置zookeeper地址        zkConfig.zkConnect = "192.168.207.128:2181";        metaClientConfig.setZkConfig(zkConfig);        // New session factory,强烈建议使用单例        MessageSessionFactory sessionFactory = new MetaMessageSessionFactory(metaClientConfig);        /*         *  create producer,强烈建议使用单例         *  消息生产者的接口是MessageProducer，你可以通过它来发送消息         */        MessageProducer producer = sessionFactory.createProducer();        // publish topic        final String topic = "test";        /*         * 这一步在发送消息前是必须的，你必须发布你将要发送消息的topic         * 这是为了让会话工厂帮你去查找接收这些topic的meta服务器地址并初始化连接         * 这个步骤针对每个topic只需要做一次，多次调用无影响         */        producer.publish(topic);        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));        String line = null;        while ((line = reader.readLine()) != null)         {            /*             * send message             * 在Meta里，每个消息对象都是Message类的实例，Message表示一个消息对象，它包含这么几个属性：             * 1) id: Long型的消息id,消息的唯一id，系统自动产生，用户无法设置，在发送成功后由服务器返回，发送失败则为0。             * 2) topic: 消息的主题，订阅者订阅该主题即可接收发送到该主题下的消息，生产者通过指定发布的topic查找到需要连接的服务器地址，必须。             * 3) data: 消息的有效载荷，二进制数据，也就是消息内容，meta永远不会修改消息内容，你发送出去是什么样子，接收到就是什么样子。消息内容通常限制在1M以内，我的建议是最好不要发送超过上百K的消息，必须。数据是否压缩也完全取决于用户。             * 4) attribute: 消息属性，一个字符串，可选。发送者可设置消息属性来让消费者过滤。             */            SendResult sendResult = producer.sendMessage(new Message(topic, line.getBytes()));            // check result            if (!sendResult.isSuccess())             {                System.err.println("Send message failed,error message:" + sendResult.getErrorMessage());            }            else {                System.out.println("Send message successfully,sent to " + sendResult.getPartition());            }        }    }}

package com.taobao.metamorphosis.example;import java.util.concurrent.Executor;import com.taobao.metamorphosis.Message;import com.taobao.metamorphosis.client.MessageSessionFactory;import com.taobao.metamorphosis.client.MetaClientConfig;import com.taobao.metamorphosis.client.MetaMessageSessionFactory;import com.taobao.metamorphosis.client.consumer.ConsumerConfig;import com.taobao.metamorphosis.client.consumer.MessageConsumer;import com.taobao.metamorphosis.client.consumer.MessageListener;import com.taobao.metamorphosis.utils.ZkUtils.ZKConfig;public class AsyncConsumer {    public static void main(String[] args) throws Exception {        final MetaClientConfig metaClientConfig = new MetaClientConfig();        final ZKConfig zkConfig = new ZKConfig();        //设置zookeeper地址        zkConfig.zkConnect = "192.168.207.128:2181";        metaClientConfig.setZkConfig(zkConfig);        // New session factory,强烈建议使用单例        MessageSessionFactory sessionFactory = new MetaMessageSessionFactory(metaClientConfig);        // subscribed topic        final String topic = "test";        // consumer group        final String group = "meta-example";        /*         * create consumer,强烈建议使用单例         * 通过createConsumer方法来创建MessageConsumer，注意到我们传入一个ConsumerConfig参数，         * 这是消费者的配置对象。每个消息者都必须有一个ConsumerConfig配置对象，         * 我们这里只设置了group属性，这是消费者的分组名称。         * Meta的Producer、Consumer和Broker都可以为集群。         * 消费者可以组成一个集群共同消费同一个topic，发往这个topic的消息将按照一定的负载均衡规则发送给集群里的一台机器。         * 同一个消费者集群必须拥有同一个分组名称，也就是同一个group。我们这里将分组名称设置为meta-example         */        MessageConsumer consumer = sessionFactory.createConsumer(new ConsumerConfig(group));        /*         * subscribe topic         * 订阅消息通过subscribe方法，这个方法接受三个参数          * 1) topic，订阅的主题         * 2) maxSize，因为meta是一个消费者主动拉取的模型，这个参数规定每次拉取的最大数据量，单位为字节，这里设置为1M，默认最大为1M。         * 3) MessageListener，消息监听器，负责消息消息。         */        consumer.subscribe(topic, 1024 * 1024, new MessageListener() {            public void recieveMessages(Message message) {                System.out.println("Receive message " + new String(message.getData()));            }            public Executor getExecutor() {                // Thread pool to process messages,maybe null.                return null;            }        });        // complete subscribe        consumer.completeSubscribe();    }}

https://github.com/killme2008/Metamorphosis/wiki/%E5%A6%82%E4%BD%95%E5%BC%80%E5%A7%8Bhttp://www.it165.net/admin/html/201402/2409.html