Java 帝国之消息队列

张家村的历史

Java 帝国的张家村正在迎来一次重大的变革。

5年前网上购物兴起的时候，帝国非常看好，决定向这个领域进军，于是兴建了张家村，在这里安装了Java 虚拟机和数据库，然后部署了一个基于Web的订单系统和一个库存系统，由张家村的人负责操作。

张家村的老村长很清楚，说是两个系统，其实是逻辑上的一种划分方式，在物理上两个系统还是部署在一个虚拟机中。那个时候用户量少，数据量也不大，村民们只要使用这一个Java 虚拟机和数据库就足够了。

订单和库存系统运转一直很好，用户的订单来了，会在订单系统中存下来，然后通知库存系统发货。

你要问怎么通知？老村长会告诉你说：其实简单的很，就是普通Java 方法的直接调用，调用库存系统某个类的某个方法而已。由于在同一个虚拟机之内，效率极高。

转眼间5年过去了，人类变得越来越懒，越来越喜欢网上购物，用户量和数据量暴增，再加上他们时不时搞个什么秒杀活动，更是让张家村变得不堪重负。为了应付汹涌而来的订单，张家村经常彻夜灯火通明，全村人三班倒才能勉强应付。

老村长向镇上报告了很多次都没有回音，要不是帝国的性能监控部门发现了这个异常，还不知道要被瞒到什么时候。

还好，钦差王大人来了，变革要开始了。

拆分

王大人经验丰富，目光如炬，一眼就看出了问题，立刻下达了第一道命令：拆分！把订单系统和库存系统分开！

老村长说： “那拆开了以后，我们村还是放不下啊”

王大人道： “订单系统还是留在张家村，库存系统挪到李家庄去”

老村长暗自思忖，订单系统是直接面向用户的，很重要，张家村一定要保住，至于库存系统，主要是后台操作，挪走就挪走吧，于是就答应了。

拆分不是那么容易的，订单和库存耦合的比较紧密，现在要把库存系统搬到李家庄的Java虚拟机和数据库去，免不了一番剧烈的折腾。

在王大人的指导下，原先那些直接的Java 方法调用，也被改成了Web 服务 -- 张家村和李家庄虽然距离较远，还是有网络相通的。

现在用户下了订单以后，先在张家村保存，然后由张家村调用李家庄的Web服务来通知库存系统。

数据库自然也做了拆分，老的库存数据被导出来，再导入到李家庄的新数据库中。

不管过程是多么艰难，两个系统还是分了家，李家庄喜气洋洋、敲锣打鼓的迎接了库存系统的部署，开始了试运营。

新问题

由于只需要处理订单，张家村的负载一下子降了下来，恢复了正常的作息。

可是好景不长，张家村很快发现李家庄对新系统根本不上心，派了一个酒鬼小李去负责操作库存Web服务，小李喝醉了啥都忘了， Web服务经常用不了。

这还不算，李家庄是严格的日出而作，日落而息，张家村正在繁忙的处理订单的时候，李家庄已经把系统关了，睡觉去了。

这可苦了张家村的小张，用户提交了订单，去调用Web服务通知库存发货，可是Web服务经常不响应，小张没有办法，只好反复重试、等待一段时间后再试，导致一个订单很长时间才能完成，用户体验极差，大家怨声载道。

小张向李家庄投诉了很多次都不管用，没人搭理，跨村庄协作可真是难啊！

小张活干的不好，工分减少，再这么下去，月底分粮的时候又要饿肚子了，小张想起来了自己经历过的《Java帝国之拨云见日识回调》，心里再次哀叹：为什么受伤的总是我？

晚上到家，小张苦思悯想：原来订单系统和库存系统都在一个虚拟机中，处理起来很方便，但是现在是个远程的Web服务，酒鬼小李不给我返回结果，我就没法结束，这是典型的同步操作，能不能改成异步的呢？

我把一个订单包裹发给小李，他什么时候处理我就不用管了，这样我这边的效率就会大大的提高！可是现在的Web服务并不支持这种方式，我怎么才能把包裹发过去呢？

消息队列

小张彻夜未眠，第二天一大早就去请教老村长。

村长说： “你能想到这一层，非常不错！近来我也一直在考虑这个问题啊，在大型的分布式系统中，怎么做异步通信是个大问题，我想到了一个叫消息队列的东西”

“消息队列？没有听说过”

“就拿你遇到的情况来说吧，我们开发一个消息队列，名称我都想好了，就叫ZhangMQ(Zhang Message Queue), 把它部署在我们张家村和李家庄之间，我们村产生的订单，你只要负责把订单消息写到这个队列里就完事大吉了。 ”

“奥，李家庄的酒鬼小李醒了，就让他从这个消息队列中读取消息，进行处理，对吧”

“没错，这不就变成异步的了？酒鬼小李不处理，那就是他们的责任了”

"那订单消息的格式需要和李家庄商量好，另外次序也不能乱掉，还有, 要是断电了或者重启了，消息队列中的订单消息也不能丢失 " 小张想的很深入

“没错，这些都是我们的ZhangMQ要考虑的，要实现持久化，把订单消息存到硬盘上”

“这真是不错“ 小张跃跃欲试 ”村长，我想去开发这个ZhangMQ，一定要让我参加啊“

”没问题，不过我当前最重要的是说服李家庄，让他们来采用我们的消息队列“

经过据理力争和艰难协商，李家庄终于同意了消息队列的方案，毕竟对他们也没啥损失，也不用听张家村没完没了的投诉了，只需要改一点点代码，从消息队列中读取订单即可。

小张和其他人在家里埋头开发ZhangMQ，半年后，ZhangMQ正式上线，彻底解决了异步通信的问题。

前钦差王大人对张家村做了回访，发现了消息队列，赞不绝口，回去后就发来了褒奖令，还下令在帝国推广， ZhangMQ一下子出名了！

你看到的只是冰山一角，更多精彩文章，参见《码农翻身全年文章精华》

有心得想和大家分享？欢迎投稿！我的联系方式：微信：liuxinlehan QQ: 3340792577

from: http://mp.weixin.qq.com/s/80g7uI1UHCpZ2POaPFfICA

Java 帝国之消息队列相关推荐

rabbitmq java实例_RabbitMQ消息队列入门篇（环境配置+Java实例+基础概念）
转载http://blog.csdn.net/u013142781 一.消息队列使用场景或者其好处消息队列一般是在项目中,将一些无需即时返回且耗时的操作提取出来,进行了异步处理,而这种异步处理的方式 ...
java并发包消息队列
消息队列常用于有生产者和消费者两类角色的多线程同步场景 BlockingQueue也是java.util.concurrent下的主要用来控制线程同步的工具. 主要的方法是:put.take一对阻塞存 ...
activimq java集成_Java消息队列-Spring整合ActiveMq
1.概述首先和大家一起回顾一下Java 消息服务,在我之前的博客<Java消息队列-JMS概述>中,我为大家分析了: 消息服务:一个中间件,用于解决两个活多个程序之间的耦合,底层由Jav ...
java中的消息队列
消息队列:可以看做是一个存储消息的容器,它是分布式系统中的重要组件之一. 目的是: 1.为了通过异步处理来提高系统的性能来减少系统响应的时间一般的步骤是客户端发起请求给服务端,服务端在请求给数据库, ...
Java redis实现消息队列
文章目录一.单元测试Java多线程二.redis实现消息队列三.java多线程模拟生产者消费者四.阻塞读一.单元测试Java多线程使用junit测试多线程代码,但是等到程序结束,输出结果不 ...
Java实现redis消息队列发布/订阅模式
最近在一个老项目中需要用消息队列,本来想着用卡夫卡,但是试了几个版本之后发现jdk和卡夫卡版本一直对不上,最后选择用redis来实现消息队列的发布/订阅模式.感谢这位大佬的博客给了我很多的帮助,htt ...
Java笔试面试-消息队列面试题总结
1.消息队列的应用场景有哪些? 答:消息队列的应用场景如下. 应用解耦,比如,用户下单后,订单系统需要通知库存系统,假如库存系统无法访问,则订单减库存将失败,从而导致订单失败.订单系统与库存系统耦合, ...
Java架构之消息队列（一）：消息队列的概述
消息队列系列分享大纲: 一.消息队列的概述二.消息队列之RabbitMQ的使用三.消息队列之Kafka的使用四.消息队列之RabbitMQ的原理详解五.消息队列之Kafka的原理详解六.消息 ...
消息队列如何使用java,想使用消息队列，先考虑下这些问题！，消息队列如何使用...
想使用消息队列,先考虑下这些问题!,消息队列如何使用原创:Java派(微信公众号:Java派),欢迎分享,转载请保留出处. 消息队列优势消息队列(Message Queue,简称MQ),其主要用于在 ...

Java 帝国之消息队列

Java 帝国之消息队列相关推荐

最新文章

热门文章