rabbitmq

介绍

有api 接口，可以前置WAF进行负载均衡和安全防护。

test.sh

fig up -d && fig ps ######http://127.0.0.1:15672/#/ guest/guest

##业务场景1-数据同步

• 实现一个topic 的路由，实现消息的自动匹配
• 详见 test-sync-data.sh

##业务场景2-日志记录

• 定义日志的路由与消息队列
• log_by_lua_file 调用 rabbitmq-插入日志数据；
• 详见 test-sync-log.sh

##业务场景3-消息事件触发

• 定义消息时间路由与队列
• 消息推送消费API的绑定； todo 通用方式
• 非阻塞消息推送
• 同日志记录，实现方式一样

###RabbitMQ

• RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用 性等方面表现不俗。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。

###Redis

• 是一个Key-Value的NoSQL数据库，开发维护很活跃，虽然它是一个Key-Value数据库存储系统，但它本身支持MQ功能，所以完全可以当做一个轻量级的队 列服务来使用。

###可靠消费

• Redis：没有相应的机制保证消息的消费，当消费者消费失败的时候，消息体丢失，需要手动处理
• RabbitMQ：具有消息消费确认，即使消费者消费失败，也会自动使消息体返回原队列，同时可全程持久化，保证消息体被正确消费

###可靠发布

• Reids：不提供，需自行实现
• RabbitMQ：具有发布确认功能，保证消息被发布到服务器

###高可用

• Redis：采用主从模式，读写分离，但是故障转移还没有非常完善的官方解决方案
• RabbitMQ：集群采用磁盘、内存节点，任意单点故障都不会影响整个队列的操作

###持久化

• Redis：将整个Redis实例持久化到磁盘
• RabbitMQ：队列，消息，都可以选择是否持久化

###消费者负载均衡

• Redis：不提供，需自行实现
• RabbitMQ：根据消费者情况，进行消息的均衡分发

###队列监控

• Redis：不提供，需自行实现
• RabbitMQ：后台可以监控某个队列的所有信息，（内存，磁盘，消费者，生产者，速率等）

###流量控制

• Redis：不提供，需自行实现
• RabbitMQ：服务器过载的情况，对生产者速率会进行限制，保证服务可靠性

###出入队性能

• 对于RabbitMQ和Redis的入队和出队操作，各执行100万次，每10万次记录一次执行时间。 测试数据分为128Bytes、512Bytes、1K和10K四个不同大小的数据。

###应用场景分析

• Redis：轻量级，高并发，延迟敏感 即时数据分析、秒杀计数器、缓存等

• RabbitMQ：重量级，高并发，异步 批量数据异步处理、并行任务串行化，高负载任务的负载均衡等