基于MQ+Redis实现高并发分流-课件

基于MQ+Redis实现

高并发分流基于MQ+Redis实现

高并发分流2/17线上线下平台预习2/17线上线下平台预习本次课目标了解消息中间件的相关概念了解消息中间件作用了解消息中间件消息模式掌握使用消息中间件解决请求阻塞问题掌握使用消息中间件解决分布式事务问题3/17本次课目标了解消息中间件的相关概念3/17问题请求阻塞4/17请求阻塞问题请求阻塞4/17请求阻塞解决方案消息中间件，缓存请求5/17解决方案解决方案5/17解决方案消息的传递者6/17消息中间件消息的传递者6/17消息中间件1.异步处理2.应用解耦7/17消息中间件作用1.异步处理7/17消息中间件作用队列模式发布订阅8/17消息模式队列模式8/17消息模式Kafka由Scala和Java编写，一般用于处理日志ActiveMQApache出品，消息中间件的“瑞士军刀”RabbitMQ事务性好，常应用于金融领域的事务控制9/17常见消息中间件Kafka9/17常见消息中间件步骤搭建ActiveMQ环境集成ActiveMQ业务10/17技术实现步骤10/17技术实现搭建ActiveMQ环境下载/解压版本：5.14.0启动打开/usr/local/apache-activemq-5.14.0/bin./activemqstart注意事项JDK环境依赖（1.7+）11/17搭建ActiveMQ环境下载/解压11/17集成ActiveMQ实现步骤引入依赖实现工具类编写配置文件测试实现队列模式实现发布订阅模式<dependency><groupId>javax.jms</groupId><artifactId>jms</artifactId><version>1.1</version></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-core</artifactId><version>5.7.0</version></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-pool</artifactId><version>5.7.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-activemq</artifactId></dependency>12/17演示示例1：集成ActiveMQ集成ActiveMQ实现步骤<dependency>12/1使用ActiveMQ解决请求阻塞13/17实现步骤请求->消息消费消息状态记录使用ActiveMQ解决请求阻塞13/17实现步骤使用ActiveMQ处理分布式事务14/17使用ActiveMQ处理分布式事务14/17消息中间件的概念消息中间件的消息模式常见的消息中间件ActiveMQ依赖的安装环境使用ActiveMQ解决消息阻塞问题使用ActiveMQ解决分布式事务问题15/17总结消息中间件的概念15/17总结16/17问题及作业集中问题&课后作业16/17问题及作业集中问题&课后作业扫一扫关注课工场扫一扫下载APP扫一扫关注课工场扫一扫下载APP基于MQ+Redis实现

高并发分流基于MQ+Redis实现

高并发分流19/17线上线下平台预习2/17线上线下平台预习本次课目标了解消息中间件的相关概念了解消息中间件作用了解消息中间件消息模式掌握使用消息中间件解决请求阻塞问题掌握使用消息中间件解决分布式事务问题20/17本次课目标了解消息中间件的相关概念3/17问题请求阻塞21/17请求阻塞问题请求阻塞4/17请求阻塞解决方案消息中间件，缓存请求22/17解决方案解决方案5/17解决方案消息的传递者23/17消息中间件消息的传递者6/17消息中间件1.异步处理2.应用解耦24/17消息中间件作用1.异步处理7/17消息中间件作用队列模式发布订阅25/17消息模式队列模式8/17消息模式Kafka由Scala和Java编写，一般用于处理日志ActiveMQApache出品，消息中间件的“瑞士军刀”RabbitMQ事务性好，常应用于金融领域的事务控制26/17常见消息中间件Kafka9/17常见消息中间件步骤搭建ActiveMQ环境集成ActiveMQ业务27/17技术实现步骤10/17技术实现搭建ActiveMQ环境下载/解压版本：5.14.0启动打开/usr/local/apache-activemq-5.14.0/bin./activemqstart注意事项JDK环境依赖（1.7+）28/17搭建ActiveMQ环境下载/解压11/17集成ActiveMQ实现步骤引入依赖实现工具类编写配置文件测试实现队列模式实现发布订阅模式<dependency><groupId>javax.jms</groupId><artifactId>jms</artifactId><version>1.1</version></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-core</artifactId><version>5.7.0</version></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-pool</artifactId><version>5.7.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-activemq</artifactId></dependency>29/17演示示例1：集成ActiveMQ集成ActiveMQ实现步骤<dependency>12/1使用ActiveMQ解决请求阻塞30/17实现步骤请求->消息消费消息状态记录使用ActiveMQ解决请求阻塞13/17实现步骤使用ActiveMQ处理分布式事务31/17使用ActiveMQ处理分布式事务14/17消息中间件的概念消息中间件的消息模式常见的