大厂五剑客之RocketMQ---1--基础

什么是JMS: Java消息服务（Java Message Service),Java平台中关于面向消息中间件的接口

JMS是一种与厂商无关的 API，用来访问消息收发系统消息，它类似于JDBC(Java Database Connectivity)。这里，JDBC 是可以用来访问许多不同关系数据库的 API

使用场景：

核心应用

解耦：订单系统-》物流系统
异步：用户注册-》发送邮件，初始化信息
削峰：秒杀、日志处理
跨平台、多语言

分布式事务、最终一致性

RPC调用上下游对接，数据源变动->通知下属

大厂五剑客之RocketMQ---1--基础异步

削峰值。

大厂五剑客之RocketMQ---1--基础分布式事务最终一致性。

------------------------------------------------------2-1---------------------------------------------------------------

常见概念
- JMS提供者：连接面向消息中间件的，JMS接口的一个实现，RocketMQ,ActiveMQ,Kafka等等
- JMS生产者(Message Producer)：生产消息的服务
- JMS消费者(Message Consumer)：消费消息的服务
- JMS消息：数据对象
- JMS队列：存储待消费消息的区域
- JMS主题：一种支持发送消息给多个订阅者的机制
- JMS消息通常有两种类型：点对点（Point-to-Point)、发布/订阅（Publish/Subscribe）
基础编程模型
- MQ中需要用的一些类
- ConnectionFactory ：连接工厂，JMS 用它创建连接
- Connection ：JMS 客户端到JMS Provider 的连接
- Session：一个发送或接收消息的线程
- Destination ：消息的目的地;消息发送给谁.
- MessageConsumer / MessageProducer：消息消费者，消息生产者

消息的提供者：消息中间件

消息的生产者：用户注册

消息的消费者：短信服务

数据对象：传递的数据

消息中间件：消息中间件会维护一个队列

主题：用户注册，支付

消息类型：点对点，发布订阅

-------

大厂五剑客之RocketMQ---1--基础

--------------------------2-2-------------------------------

Apache ActiveMQ、Kafka、RabbitMQ、RocketMQ

ActiveMQ：http://activemq.apache.org/

缺点：吞吐量不高，多队列的时候性能下降，存在消息丢失的情况，比较少大规模使用
- Apache出品，历史悠久，支持多种语言的客户端和协议，支持多种语言Java, .NET, C++ 等，基于JMS Provider的实现
Kafka：http://kafka.apache.org/ 大数据采集用户的行为

缺点：不支持批量和广播消息，运维难度大，文档比较少, 需要掌握Scala
- 是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理大规模的网站中的所有动作流数据(网页浏览，搜索和其他用户的行动)，副本集机制，实现数据冗余，保障数据尽量不丢失；支持多个生产者和消费者
RabbitMQ：http://www.rabbitmq.com/

缺点：使用Erlang开发，阅读和修改源码难度大
- 是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不错
RocketMQ：http://rocketmq.apache.org/
- 阿里开源的一款的消息中间件, 纯Java开发，具有高吞吐量、高可用性、适合大规模分布式系统应用的特点, 性能强劲(零拷贝技术)，支持海量堆积, 支持指定次数和时间间隔的失败消息重发,支持consumer端tag过滤、延迟消息等，在阿里内部进行大规模使用，适合在电商，互联网金融等领域使用

-------------------------2-3--------------------------------

大厂五剑客之RocketMQ---1--基础

相关推荐