全国服务热线4000-662-088 专线13828842088 在线咨询 预约方案申请

Java 帝国之消息队列

【摘要】2017-6-8   小B

 

                                                                        Java 帝国之消息队列

                                                                                                                                      2017-6-8   小B


 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一下子出名了!