福州做网站费用十大跨界营销案例
同步和异步
（1）同步（按照流程一步一步做）使用openfengin传统的交互
- 响应时间长，需要将每一步的时间加起来。
- 如果一个环境出错了，整个就报错了。
- 并发压力大，前边的步骤有多大的并发量，后续就需要承担多大的并发量。
（2）异步（微服务A无需等待微服务B，之间返回，微服务B可以等他空闲的时候来消费）
- 响应时间相对更短，无需等待服务B执行完成就返回响应。
- 可以通过调节参数，减少后续服务的并发量。
削峰填谷：把高峰期的任务转移到低谷期执行。
qps：kafka>rocketmq>rabbitmq>activemq
rabbitmq有可靠的消息确认机制，并且吞吐量还行10w左右。
基础
消息发送端：生产者 消息消费端：消费者
TCP连接（三握四挥）
为了连接复用，建立了channel。
broker示例：搭建一个rabbitmq就叫一个broker，broker分成很多个虚拟机，
1.流程
生产者---------》channel---------》exchange：交换机（中转消息）--------》queue：队列（暂存消息）---------》channel-----------》消费者
2.交换机怎么知道把消息存放在那个队列中？
交换机通过binding队列
5672客户端交互 15672图形化界面交互
3.rabbitmq的使用模式
默认的交换机：
（1）简单工作队列模式：生产者–（队列）----消费者
（2）工作队列：生产者—默认交换机----（队列）----多个消费者（轮询竞争）
（3）发布订阅模式：生产者----fanout类型交换机-----多个队列-----指定消费者监听
fanout交换机，广播，将消息发布到多个队列。多个消费端对于队列的关系是竞争关系。路由键是空。
交换机类型：fanout广播、diret定向、topic通配符
(4)路由模式：生产者----direct交换机-----使用多个不同的ronuting key绑定队列-----多个消费者
交换消息的时候，指定交换机、路由键。channel和队列绑定，指定路由键。
（5）主题模式：生产者----topic交换机-----使用多个不同的ronuting key绑定队列-----多个消费者
在路由模式的基础上，使用通配符匹配。
使用
可靠性
故障：消息没有存放在消息队列，保存在队列（内存）服务器宕机丢失，消息没有消费成功。
1.消息没有发送到消息队列
解决
在生产者端进行确认，如果失败就重试。
（1）生产者端交换机和队列的确认机制:配置文件开启确认机制+配置类对mq模板增强。
（2）备份交换机制:目标交换器故障，备份交换机可以执行目标交换机的业务，或者做日志通知运维人员故障。在创建交换器的时候，可视化界面可以指定备份交换机（需要使用fanout类型）。
2.消息队列服务器宕机，内存数据丢失。
将消息持久化，默认是持久化的
3.消费端宕机或者消息没有消费成功
消费成功，消费端给mq返回ACK信息，消息队列删除该消息。
消费失败，消费端给mq返回NACK信息，重试（消费端的接口支持幂等性）。
配置手动确认返回ack通知。
削峰填谷
yml配置prefetch参数（每次取出的消息数量）
死信
消费者拒收消息+requeue=false（不把消息放到原目标队列）
消息队列溢出：消息放满了还放
消息超时（rabbitmq服务器会自动删除过期的消息，可以在创建队列时指定该队列存放消息的过期时间，也可以对消息指定过期时间。）
解决：
丢弃、入库、监听进入死信队列:消费者监听死信队列，做日志报警、人工干预。
延迟队列
消息超时时间+死信队列：某一个消息队列不监听，设置一个超时时间。超时之后进入死信队列，被消费者捕获到。
事务消息
当生产者代码出现错误的时候发送消息就会回滚，注解@RollBack（ture）。默认开启回滚事务。