RocketMQ入门与部署 2020-01-07 RocketMQ4.x 特性 支持 Broker(减少带宽的传输)和 Consumer 端消息过滤 支持发布订阅模型,和点对点, 支持拉 pull 和推 push 两种消息模式 单一队列百万消息、亿级消息堆积 支持单 master 节点,多 master 节点,多 master 多 slave 节点 任意一点都是高可用,水平拓展,Producer、Consumer、队列都可以分布式 消息失败重试机制、支持特定 level 的定时消息 新版本底层采用 Netty 4.3.x 支持分布式事务 适合金融类业务,高可用性跟踪和审计功能。 角色 Producer:消息生产者 Producer Group:消息生产者组,发送同类消息的一个消息生产组 Consumer:消费者 Consumer Group:消费同类消息的多个实例 Tag:标签,子主题(二级分类)对 topic 的进一步细化,用于区分同一个主题下的不同业务的消息 Topic:主题, 如订单类消息,queue 是消息的物理管理单位,而 topic 是逻辑管理单位。一个 topic 下可以有多个 queue。(默认自动创建是 4 个....
JMS与消息中间件核心概念 2020-01-07 JMS 消息服务 Java 消息服务(Java Message Service),Java 平台中关于面向消息中间件的接口。JMS 是一种与厂商无关的 API,用来访问消息收发系统消息,它类似于 JDBC(Java Database Connectivity)。—— JDBC 是可以用来访问许多不同关系数据库的 API。而 JMS 则提供同样与厂商无关的访问方法,以访问消息收发服务。许多厂商都支持 JMS。 消息中间件使用场景 解耦:订单系统-》物流系统(责任转移) 异步:用户注册-》发送邮件(串行变并行,加快响应速度) 削峰:秒杀、日志处理(缓冲队列) 消息中间件常见概念 JMS 提供者:连接面向消息中间件的,JMS 接口的一个实现,RocketMQ,ActiveMQ,Kafka 等等 JMS 生产者(Message Producer):生产消息的服务 JMS 消费者(Message Consumer):消费消息的服务 JMS 消息:数据对象(POJO) JMS 队列:存储待消费消息的区域 JMS 主题:一种支持发送消息给多个订阅者的机制 JMS 消息通常有两种类型:点对点(....