在实际开发中，我们经常会需要做一件事：在完成某一个动作之后，需要另外以同步或者异步的方式去通知另外的对象去完成额外的操作，比如：当用户下单成功之后，需要发异步消息到给到邮件系统发邮件（短信）通知用户。(这里就涉及到异步消息的概念)消息队列是我们用来解决系统与系统之间异步与解耦的极佳实践工具，而在应用内部这个级别上，有时候也会需要这样的异步消息通知机制

前言这次咱们来玩一个在Python中很牛叉的爬虫框架——Scrapy。scrapy介绍标准介绍Scrapy是一个为了爬取网站数据，提取结构性数据而编写的应用框架，非常出名，非常强悍。所谓的框架就是一个已经被集成了各种功能（高性能异步下载，队列，分布式，解析，持久化等）的具有很强通用性的项目模板。对于框架的学习，重点是要学习其框架的特性、各个功能的

本系列是「RabbitMQ实战：高效部署分布式消息队列」书籍的总结笔记。上一篇总结了可能出现的异常场景，并对RabbitMQ提供的可用性保证进行了分析，在出现服务器宕机后，仍然可以正常服务。另外，需要尽快恢复异常的服务器，重新加入集群，推送未消费的消息，通过监控可第一时间接收到错误并进行处理。另外，我们想主动了解消息堆积和消费的情况，以及服务器节

Java多线程之线程池7大参数详解目录企业面试题线程池7大参数源码线程池7大参数详解底层工作原理详解线程池的4种拒绝策略理论简介面试的坑：线程池实际中使用哪一个？1\.企业面试题线程池的工作原理，几个重要参数，然后给了具体几个参数分析线程池会怎么做，最后问阻塞队列用是什么？线程池的构造类的方

1、Kafka是什么ApacheKafka是一个开源消息系统，由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。 Kafka最初是由LinkedIn开发，并于2011年初开源。2012年10月从ApacheIncubator毕业。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。

上次和大家分享了关于Notification的基础应用，包括简单的通知和自定义视图的通知。今天和大家分享一下如何实现一个可更新进度的通知。我们将会模拟一个下载任务，先启动一个线程负责模拟下载工作，在这个过程中更新进度信息，然后下载线程把最新的进度信息以消息的形式，发送到UI线程的消息队列中，最后UI线程负责根据最新的进度信息来更新进度通知的UI界面。

本次发布增强了Saga在spring下的支持，使用kafka提供重试以及重试失败后放入丢弃队列里Saga是用来在微服务中的长事务管理，具备ACID中的ACD，不具备I，隔离性。在一定业务条件下，可以使用Saga非常简单和方便的管理微服务事务。同理，也可以用于管理多库事务Saga要求微服务提供回滚操作，然后如果需要回滚，有Saga编排调度各个微服务对应

最近开发一个项目。客户端每隔10秒提交100行数据给服务端，服务端查重后写入。客户端约在几万左右，提交数据比较集中，不考虑读数据的问题。现在的设计是：数据库按客户端进行分表。每个表的数据量不高。服务端获得数据后，先插入redis队列，然后在通过定时任务插入数据库。问题是：1、服务端提供给客户端的接口，是否能满足几千上万的客

前面我们介绍了三种数据结构，第一种数组主要用作数据存储，但是后面的两种栈和队列我们说主要作为程序功能实现的辅助工具，其中在介绍栈时我们知道栈可以用来做单词逆序，匹配关键字符等等，那它还有别的什么功能吗？以及数据结构与本篇博客的主题前缀、中缀、后缀表达式有什么关系呢？1、人如何解析算术表达式　　如何解析算术表达式？或者换种说法，遇到某个算术表达

1前言前一篇介绍了JMS有两种通信模型，一种是点对点通信，另一种是发布/订阅模型，本篇将会继续探讨这两种模型。本篇文章需要按照严谨的实验顺序才能获得相同的结果，这是因为消息持久化和持久订阅这两个特性的原因，在文章结尾和下一篇文章会做解答。\\所有的实验在启动之前都必须到管理后台删除相关的队列或者topic，否则数据也可能不同\\在A