微服务架构是当前很热门的一个概念，它不是凭空产生的，是技术发展的必然结果。虽然微服务架构没有公认的技术标准和规范草案，但业界已经有一些很有影响力的开源微服务架构平台，架构师可以根据公司的技术实力并结合项目的特点来选择某个合适的微服务架构平台，以此稳妥地实施项目的微服务化改造或开发进程。本文选自《架构解密：从分布式到微服...

分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间我们自家的产品RocketMQ(MetaQ的内核)也顺利开源,得到大家的关注。那么,消息中间件性能究竟哪家强?带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、RabbitMQ、RocketMQ)做...

本地服务器的数据要同步到服务器上。因本地服务器有很多数据是公司内部OA录入或导入而生成的，外网并没有。而想要把某一部分数据对外公开，就需要做数据同步。自己做了分析，数据同步无外乎几种模式1、数据上报即本地写一个应用，服务器写一个接口接收。本地应用计划每隔5分钟跑一次，每次都把新的数据上报到服务器。这种方式利于做数据处理...

kafka是一个消息中间件，用于各个系统之间传递消息，并且消息可持久化！可以认为是队列模型，也可以看作是生产者消费着模型；简单的生产者消费者客户端代码如下：packagecom.pt.util.kafka;importjava.util.Date;importjava.util.Properties;importkaf...

　　网络通信过程中的四个概念：同步、异步、阻塞、非阻塞；看了些许文章的解说，发现并不是很明白，其中一个比较风趣的文章是这么写的！　　　　老张烧水，水壶放到炉子上，然后专心等待水烧开~~~同步阻塞，（老张太傻了）　　　　老张烧水，水壶放到炉子上，然后去客厅看电视，时不时去看看水有没有烧开~~~同步非阻塞（老张觉得自己变聪...

1.如果master不设置密码，那么直接在slave服务器配置slaveof即可配置如下#slaveofip端口slaveof221.224.85.1866379　配置好我们看下redis的日志看是否同步成功5014:S25Jan10:53:53.667*ConnectingtoMASTER221.224.85.186...

最近使用uwsgi出了一些问题，于是测试下Gunicorn测试对比下环境一颗cpu1g内存Centos系统Django作为后端应用，Gunicorn默认模式和异步模式，响应基本是无阻塞类型测试的request是一个加密操作，对url中的几个参数做一个ase加密说明：下面的模拟阻塞模式，类似于你的请求中有很多调用第三方a...

MySQL-Proxy读写分离、同步延时问题解决方案 使用MySQL将读写请求转接到主从Server。  一安装MySQLProxy MySQLProxy的二进制版非常方便，下载解压缩后即用。 解压缩的目录为： $mysql-proxy_installed_d...

远程过程调用（RPC）在第二节里我们学会了如何使用工作队列在多个工人中分布时间消耗性任务。 但如果我们想要运行存在于远程计算机上的方法并等待返回结果该如何去做呢？这就不太一样了，这种模式就是常说的远程过程调用（RPC）。 在本节我们会在本节我们会使用RabbitMQ创建一个RPC系统：一个客户端和一...

Topics在前面教程中我们改进了日志系统，相比较于使用fanout类型交易所只能傻瓜一样地广播，我们用direct获得了选择性接收日志的能力。虽然使用direct类型交易所改进了我们的系统，但它仍然有所限制——它不能做基于多重条件（multiplecriteria）的路由。 在日志系...

路由在上一节我们构建了一个简单的日志系统。我们能够广播消息给很多接收者。在本节我们将给它添加一些特性——我们让它只订阅所有消息的子集。例如，我们只把严重错误（criticalerror）导入到日志文件（存入磁盘空间），但仍然可以打印所有日志消息到控制台。绑定前面的例子中我们已经创建了绑定，像下面...

发布/订阅前面的教程中我们已经创建了一个工作队列。在一个工作队列背后的假设是每个任务恰好会传递给一个工人。在这一部分里我们会做一些完全不同的东西——我们会发送消息给多个消费者。这就是所谓的“发布/订阅”模式。为了解释这种模式，我们将会构建一个简单的日志系统。它包含两个程序...

目标：  利用RabbitMQ实现消息重试和失败处理，实现可靠的消费消费。在消息消费异常时，自动延时将消息重试，当重试超过一定次数后，则列为异常消息，等待后续特殊处理。准备：   TTL：Time-To-Live，通过给消息、队列设置过期时间（单位：毫秒），来控制消息、...

工作队列在第一节我们写了程序来向命名队列发送和接收消息。在本节我们会创建一个工作队列（WorkQueue）用来在多个工人（worker）中分发时间消耗型任务（time-consumingtasks）。工作队列(又叫做:TaskQueues)背后的主体思想是避免立刻去执行耗时任务并且等待它们完成。相反我们可以安排这样的任...

介绍RabbitMQ是一个消息中间人（broker）:它接收并且发送消息.你可以把它想象成一个邮局:当你把想要寄出的信放到邮筒里时,你可以确定邮递员会把信件送到收信人那里.在这个比喻中,RabbitMQ就是一个邮筒,同时也是邮局和邮递员. 和邮局的主要不同点在于RabbitMQ不处理纸质信件,而是接收（acc...