消息中间件常见概念及产品对比

一、JMS 消息服务

1、什么是 JMS?

Java 消息服务(Java Message Service),Java 平台中关于面向消息中间件的接口。

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

2、使用场景

  • 核心应用
    • 解耦:订单系统-》物流系统。不同的业务分散在各自的系统,而不是一个系统涉及所有业务,实现解耦。
    • 异步:用户注册-》发送邮件,初始化信息。有些任务并不需要实时处理,放在队列里以后再处理。
    • 削峰:秒杀、日志处理。大量用户同时访问造成流量集中,比如秒杀商品,秒杀后的付款,物流并不一定需要同步处理,放在队列里之后处理也是可以的。
  • 跨平台 、多语言
  • 分布式事务、最终一致性
  • RPC 调用上下游对接,数据源变动->通知下属

3、缺点

  • 系统可用性降低:外部依赖越多,依赖越多,出问题风险越大
  • 系统复杂性提高:需要考虑多种场景,比如消息重复消费,消息丢失
  • 需要更多的机器和人力:消息队列一般集群部署,而且需要运维和监控,例如:Topic 申请等

二、消息中间件常见概念

1、常见概念

  • JMS 提供者:连接面向消息中间件的,JMS 接口的一个实现,RocketMQ、ActiveMQ、Kafka 等等
  • JMS 生产者(Message Producer):生产消息的服务
  • JMS 消费者(Message Consumer):消费消息的服务
  • JMS 消息:数据对象
  • JMS 队列:存储待消费消息的区域
  • JMS 主题:一种支持发送消息给多个订阅者的机制
  • JMS 消息通常有两种类型:点对点(Point-to-Point)、发布/订阅(Publish/Subscribe)

2、基础编程模型(MQ 中需要用的一些类)

 

  • ConnectionFactory :连接工厂,JMS 用它创建连接
  • Connection :JMS 客户端到 JMS Provider 的连接
  • Session: 一个发送或接收消息的线程
  • Destination :消息的目的地;消息发送给谁.
  • MessageConsumer / MessageProducer: 消息消费者,消息生产者

三、对比当下主流的消息队列和选择问题

1、ActiveMQ

http://activemq.apache.org/

Apache 出品,历史悠久,支持多种语言的客户端和协议,支持多种语言 Java、 .NET、C++ 等,基于 JMS Provider 的实现

缺点:吞吐量不高,多队列的时候性能下降,存在消息丢失的情况,比较少大规模使用

2、Kafka

http://kafka.apache.org/

是由 Apache 软件基金会开发的一个开源流处理平台,由 Scala 和 Java 编写。Kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理大规模的网站中的所有动作流数据(网页浏览,搜索和其他用户的行动),副本集机制,实现数据冗余,保障数据尽量不丢失;支持多个生产者和消费者 

缺点:不支持批量和广播消息,运维难度大,文档比较少, 需要掌握 Scala

3、RabbitMQ

http://www.rabbitmq.com/

是一个开源的 AMQP 实现,服务器端用 Erlang 语言编写,支持多种客户端,如:Python、Ruby、.NET、Java、JMS、C,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不错

缺点:使用 Erlang 开发,阅读和修改源码难度大

4、RocketMQ

http://rocketmq.apache.org/

阿里开源的一款的消息中间件,纯 Java 开发,具有高吞吐量、高可用性、适合大规模分布式系统应用的特点, 性能强劲(零拷贝技术),支持海量堆积,支持指定次数和时间间隔的失败消息重发,支持 consumer 端 tag 过滤、延迟消息等,在阿里内部进行大规模使用,适合在电商,互联网金融等领域使用。

原文地址:https://www.cnblogs.com/jwen1994/p/12301834.html