redis中队列消息实现利用解耦的方法

消息队列的场景

我们都知道，消息是在两台计算机之间传送的数据单位，这个“消息”可以非常简单，例如只包括文本字符串，也能够更复杂，可能包括嵌入对象。而所谓的“消息队列”是在消息的传输进程中保存消息的容器。在web程序中，可能我们需要将用户的要求数据更新或添加到数据库中，但是在高炳发的情况下，虽然作为用户的我们不知道后台是甚么缘由，但是照旧会抱怨或吐槽这个程序反应缓慢，比如在过去的几年里，你有无吐槽过12306抢票很难？反应很慢？有无在使用某个程序的时候收到“service is too busy”,而这实际上是由于当时的并发访问过量，超过了系统的最大负载能力。固然我们可以通过添加服务器集群中服务器的数量来增加程序的负载能力。

过度耦合的缺点：php利用中，过度的耦合使得系统拓展性变弱，联动性毛病。

今天我给大家介绍的是利用redis的队列消息实现模块间的解耦。

利用场景：用户在采购模块下单买了一批货物回来，签收时要在仓库模块添加相应的库存，普通的做法就是在签收完成的时候通过接口给仓库模块推送数据履行入库操作。但是这么做如果仓库模块发送毛病，没有入库成功就会致使采购模块签收失败，这就是耦合给系统带来的缺点。

解决方案：应用php+redis队列消息的技术，当用户签收获功的时候，把数据放入队列中，入列成功采购模块则返回签收获功的提示给用户，后续的操作都不需要采购模块操心，然后仓库系统可以通过redis的定阅发布模式来进行监听，当有数据入列，则仓库系统就履行入库逻辑代码的

运行。

关键点：

1、如果redis服务器挂掉了怎样办啊？

在采购模块的签收逻辑代码中做判断，如果入列成功则返回签收完成，如果入列失败这运行传统方法，通过接口入库的方法。如果redis也挂了，仓库模块也挂了怎样办啊，那你就整理包袱回家吧。

2、怎么实现传统方式那样实时入库啊？

采取redis的定阅发布模式就能够解决。定阅的代码放在仓库模块，发布的代码放在采购模块。

定阅代码sub.php

<?php
$redis = new Redis();
$redis->connect('localhost', 6379);
$redis->subscribe(['ruku'], function ($redis, $chan, $msg) {//定阅入库频道　　　if($msg==2500){　　 //如果监听到有发布信息则从队列中拿取信息进行入库操作 　　 。。。。。。。  }　　
});

发布代码pub.php

<?php
$redis = new Redis();
$redis->connect('localhost', 6379);
$order = ['id' => 1, 'name' => '小米6', 'price' => 2499, 'created_at' => '2017-07⑴4'];$redis->lpush('order',$order);
$redis->publish("ruku", 2500);

总结

本篇文章到此结束，如果您有相关技术方面疑问可以联系我们技术人员远程解决，感谢大家支持本站！