十分钟入门十分钟入门RocketMQ
消息中间件需要解决哪些问题？
Publish/Subscribe
发布订阅是消息中间件的最基本功能，也是相对于传统RPC通信而言。在此不再详述。
Message Priority
规范中描述的优先级是指在一个消息队列中，每条消息都有不同的优先级，一般用整数来描述，优先级高的消息先投递，如果
消息完全在一个内存队列中，那么在投递前可以按照优先级排序，令优先级高的先投递。
由于RocketMQ所有消息都是持久化的，所以如果按照优先级来排序，开销会非常大，因此RocketMQ没有特意支持消息优先
级，但是可以通过变通的方式实现类似功能，即单独配置一个优先级高的队列，和一个普通优先级的队列， 将不同优先级发
送到不同队列即可。
对于优先级问题，可以归纳为2类：
1.只要达到优先级目的即可，不是严格意义上的优先级，通常将优先级划分为高、中、低，或者再多几个级别。每个优先级可
以用不同的topic表示，发消息时，指定不同的topic来表示优先级，这种方式可以解决绝大部分的优先级问题，但是对业务的
优先级精确性做了妥协。
2.严格的优先级，优先级用整数表示，例如0 ~ 65535，这种优先级问题一般使用不同topic解决就非常不合适。如果要让MQ
解决此问题，会对MQ的性能造成非常大的影响。这里要确保一点，业务上是否确实需要这种严格的优先级，如果将优先级压
缩成几个，对业务的影响有多大？
Message Order
消息有序指的是一类消息消费时，能按照发送的顺序来消费。例如：一个订单产生了3条消息，分别是订单创建，订单付款，
订单完成。消费时，要按照这个顺序消费才能有意义。但是同时订单之间是可以并行消费的。
RocketMQ可以严格的保证消息有序。
Message Filter
Broker端消息过滤
在Broker中，按照Consumer的要求做过滤，优点是减少了对于Consumer无用消息的网络传输。
缺点是增加了Broker的负担，实现相对复杂。
1、淘宝Notify支持多种过滤方式，包含直接按照消息类型过滤，灵活的语法表达式过滤，几乎可以满足最苛刻的过滤需求。
2.淘宝RocketMQ支持按照简单的Message Tag过滤，也支持按照Message Header、body进行过滤。
3.CORBA Notification规范中也支持灵活的语法表达式过滤。
Consumer端消息过滤
这种过滤方式可由应用完全自定义实现，但是缺点是很多无用的消息要传输到Consumer端。
Message Persistence
消息中间件通常采用的几种持久化方式：
1.持久化到数据库，例如Mysql。
2.持久化到KV存储，例如levelDB、伯克利DB等KV存储系统。
3.文件记录形式持久化，例如Kafka，RocketMQ
4.对内存数据做一个持久化镜像，例如beanstalkd，VisiNotify
5.(1)、(2)、(3)三种持久化方式都具有将内存队列Buffer进行扩展的能力，(4)只是一个内存的镜像，作用是当Broker挂掉重启
后仍然能将之前内存的数据恢复出来。
JMS与CORBA Notification规范没有明确说明如何持久化，但是持久化部分的性能直接决定了整个消息中间件的性能。
资源评论
weixin_38655347
- 粉丝: 9
- 资源: 919
最新资源
- C#ASP.NET小型OA办公管理系统源码带文档数据库 SQL2008源码类型 WebForm
- rabbitmq-server-3.13.3-windows安装包
- 办公必备小工具+【筛选符合条件的文件】+【根据文件名和文件格式】
- rabbitmq-server-3.13.4-windows安装包
- rabbitmq-server-3.13.5-windows安装包
- rabbitmq-server-3.13.6-windows安装包
- 理光Ricoh 7502打印机驱动下载
- python爬虫bs4的基本使用、代理IP和bs4解析【实战讲解-爬取斗鱼颜值主播数据】.zip
- 科目一，扣分法规的的的的
- 科目一易错题，整理的的的的
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
