各MQ 并发性能比较
|
吞吐量
| |
|
kafka
|
17.3w/s
|
|
rocketMQ
|
11.6w/s
|
|
RabbitMQ
|
5.96w/s
|
RocketMQ组件
broker 核心业务组件
nameServe 保存broker 的ip、端口、上下线信息等。 类似注册中心
启动nameServe 时会调用 runserver
启动broker ，会默认读取/conf/broker.conf mqbroker.cmd -c ../conf/broker.conf
多节点集群
2m-2s-async 主从间异步同步
2m-2s-sync 主从间异步同步
2m-noslave 没有主从
|
参数
|
参数含义
|
|
brokerClusterName
|
集群的名字，同一网段内的相同集群名组成一个集群
|
|
brokerName
|
节点名，一对主从节点名相同
|
|
brokerRole
|
节点角色，ASYNC_MASTER异步主节点 AYNC_MASTER同步主节点 SLAVE 从节点
|
生产者发送消息的三种方式
同步发送
异步发送
单向发送
顺序消息
保证局部有序，不用关全局有序。局部有序，比如只用管单通会话有序，不用管所有用户的消息都是有序的
即，每个消息队列（MessageQueue）中是有序的，消息队列之间不保证有序
普通是在消费中注册 MessageListenerOderly
顺序消费注册的是 MessageListenerCurrently
延迟消息
Message对象 有18种预设的延迟级别，可以改配置
//1s、5s、10s、30s、1m、2m、3m、4m、5m、6m、7m、8m、9m、10m、20m、30m、1h、2h
msg.setDelayTimeLevel( 3); //延迟 10秒
在开源版中自定义延迟消息，是改造的重点。
批量消息
将多条消息整合到一条消息一次性发送，减少网络请求次数和IO
过滤消息
-
tag标签，一条消息只有一个tag，一个消费者
-
sql 语法过滤， 支持 <>= "<>" in 、not in 等
实现机制 将
consumer
指定的sql过滤规则推送到broker，由broker计算将最终结果推给 consumer
事务消息---只与生产者有关
TransactionMQProducer 本地有两个事务 execute 和 check 。broker会对unknown状态消息，过段时间调用一次本地check方法，默认最大调用次数是15。
实际运用举例（待后续与定时任务的实现方式效率比较）
配置好rocketMQ在下单后5分钟内不断让订单系统检查订单是否支付，支付后再将订单推到下游系统。
ACL权限控制
对各用户对topic 的访问限制
