时通讯：支持好友，群组，发图片、文件，消息声音提醒，离线消息，保留聊天记录工作流模块1.模型管理  ：web在线流程设计器、预览

引言分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间我们自家的产品RocketMQ(MetaQ的内核)也顺利开源,得到大家的关注。那么,消息中间件性能究竟哪家强?带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、RabbitMQ、RocketMQ)做了性

SpringCloudStream是消息中间件组件，它集成了kafka和rabbitmq。本篇文章以RabbitMQ为消息中间件系统为基础，介绍SpringCloudStream的使用。如果你没有用过消息中间件，可以到RabbitMQ的官网看一下，或者参考这个http://rabbitmq.mrping.com/。理

SPI服务发现机制SPI是JavaJDK内部提供的一种服务发现机制。SPIServiceProviderInterface,服务提供接口，是JavaJDK内置的一种服务发现机制通过在ClassPath路径下的METAINF/services文件夹查找文件，自动加载文件里所定义的类

ActiveMQ:传统的消息队列，使用Java语言编写。基于JMS（JavaMessageService），采用多线程并发，资源消耗比较大。支持P2P和发布订阅两种模式。RabbitMQ:是使用Erlang语言开发的开源消息队列系统。基于AMQP协议来实现的。AMQP的主要特征是面向消息、队列、路由(

一、Kafka简介Kafka是LinkedIn使用Scala开发的一个分布式消息中间件，它以水平扩展能力和高吞吐率著称，被广泛用于日志处理、ETL等应用场景。Kafka具有以下主要特点：\\消息的发布、订阅均具有高吞吐量：\\据统计数字表明，Kafka每秒可以生产约25万消息（50MB），每秒处理55万消息（110MB）。

1、默认生产者消息是持久的:会存数据库\消费者的持久：createDurableSubscriber是指消费者能收到所有它订阅时间点之后的消息，即使消费者注册后关闭，当它重启就能收到注册时间点之后所有的消息;即当此消费用户ID(AAA)在producer发送之前就已经注册，那么此id能收到producer发送的所有消息，如果是在produce

PythonGC机制对于Python这种高级语言来说，开发者不需要自己管理和维护内存。Python采用了引用计数机制为主，标记清除和分代收集两种机制为辅的垃圾回收机制。首先，需要搞清楚变量和对象的关系：变量：通过变量指针引用对象。变量指针指向具体对象的内存空间，取对象的值。对象，类型已知，每个对象都包

一、内容提要：　　1、反射机制是什么　　2、反射机制能做什么　　3、反射机制相关的API　　4、通过一个对象获得完整的包名和类名　　5、实例化Class类对象　　6、获取一个对象的父类与实现的接口　　7、获取某个类的全部构造函数　　8、通过反射机制实例化一个类的对象　　9、获取某个类的全部属性　　10、

由于商品变更MQ消息量巨大，为了提升更新ES的性能，防止出现MQ消息积压问题，所以本系统使用了BulkProcessor进行批量异步更新。