Workman无法获取MVC框架Session数据解决方法

最近在做一个自己家用的物联网项目，其中服务器端采用thinkphp5和workman搭建的后台，开发过程中发现workman获取不到thinkphp的Session数据。经过研究最终找到了一个思路，现在波波将相关思路分享如下。

其实仔细阅读Workman文档会发现Workman运行在CLI模式下，其Session用法与thinkPHP的会话方式有很大的区别，所以这里波波引用了一个Session共享的方法。如下图所示：

Workman无法获取MVC框架Session数据解决方法

这个方法就是我们把MVC的Session数据保存在Redis中，Workman需要读取MVC框架Session的时候可以直接读取Redis数据，这个过程中需要PHP开启Redis扩展，不仅运行与CGI模式下的需要开启，运行于CLI模式下的PHP同样需要开启（主要防止多版本共存情况出现错误）。

原理就是Session共享的思路，很简单。下面波波分享一下波波为Workman写的Redis数据驱动。与workman一起运行于CLI模式下。

  1. <?php
  2. /**
  3.  * Created by bobo.
  4.  * DateTime: 2019/11/16 13:40
  5.  * Function:Workman MVC session验证器
  6.  */
  7. namespace app\pigeon\model;
  9. class EventsModel{
  10.     //Redis配置
  11.     protected $options = [
  12.         'host'       => '127.0.0.1',
  13.         'port'       => 6379,
  14.         'password'   => '',
  15.         'select'     => 0,
  16.         'timeout'    => 0,
  17.         'expire'     => 0,
  18.         'persistent' => false,
  19.         'prefix'     => '',
  20.     ];
  23.     //构造函数
  24.     public function __construct($options = []){
  25.         if (!extension_loaded('redis')) {
  26.             throw new \Exception('not support: redis');
  27.         }
  28.         if (!emptyempty($options)) {
  29.             $this->options = array_merge($this->options, $options);
  30.         }
  31.         $func          = $this->options['persistent'] ? 'pconnect' : 'connect';
  32.         $this->handler = new \Redis;
  33.         $this->handler->$func($this->options['host'], $this->options['port'], $this->options['timeout']);
  35.         if ('' != $this->options['password']) {
  36.             $this->handler->auth($this->options['password']);
  37.         }
  39.         if (0 != $this->options['select']) {
  40.             $this->handler->select($this->options['select']);
  41.         }
  42.     }
  44.     protected function getCacheKey($name){
  45.         return $this->options['prefix'] . $name;
  46.     }
  48.     public function has($name)
  49.     {
  50.         return $this->handler->get($this->getCacheKey($name)) ? true : false;
  51.     }
  52.     //设置标签
  53.     protected function setTagItem($name)
  54.     {
  55.         if ($this->tag) {
  56.             $key       = 'tag_' . md5($this->tag);
  57.             $this->tag = null;
  58.             if ($this->has($key)) {
  59.                 $value   = explode(',', $this->get($key));
  60.                 $value[] = $name;
  61.                 $value   = implode(',', array_unique($value));
  62.             } else {
  63.                 $value = $name;
  64.             }
  65.             $this->set($key, $value, 0);
  66.         }
  67.     }
  69.     //查询Redis数据
  70.     public function get($name, $default = false){
  71.         $value = $this->handler->get($this->getCacheKey($name));
  72.         if (is_null($value)) {
  73.             return $default;
  74.         }
  75.         $jsonData = json_decode($value, true);
  76.         // 检测是否为JSON数据 true 返回JSON解析数组, false返回源数据
  77.         return (null === $jsonData) ? $value : $jsonData;
  78.     }
  80.     //写入Redis数据
  81.     public function set($name, $value, $expire = null)
  82.     {
  83.         if (is_null($expire)) {
  84.             $expire = $this->options['expire'];
  85.         }
  86.         if ($expire instanceof \DateTime) {
  87.             $expire = $expire->getTimestamp() - time();
  88.         }
  89.         if ($this->tag && !$this->has($name)) {
  90.             $first = true;
  91.         }
  92.         $key = $this->getCacheKey($name);
  93.         //对数组/对象数据进行缓存处理，保证数据完整性
  94.         $value = (is_object($value) || is_array($value)) ? json_encode($value) : $value;
  95.         if (is_int($expire) && $expire) {
  96.             $result = $this->handler->setex($key, $expire, $value);
  97.         } else {
  98.             $result = $this->handler->set($key, $value);
  99.         }
  100.         isset($first) && $this->setTagItem($key);
  101.         return $result;
  102.     }
  105. }

因为我在写这部分代码的时候结合MVC写到了model层，大家可以自己重新定义命名空间。到此彻底解决了workman无法获取Session数据的问题了。

总结：

其实关于用户信息的验证有很多种方法，为什么我一直纠结必须用Session呢？因为对于MVC框架来说，用户的Session意味着用户在线的活跃状态，随着用户关闭页面而终止（其实有过期时间），这在最大程度上可以保障用户信息的安全性和有效性。那么做为一个后端开发的人来讲，我们必须要力求逻辑的严谨性，虽然失误总是不可避免，BUG总会出现，但是只有力求完美才能给客户、给自己开发出稳定、安全的系统。

 

你想把广告放到这里吗？

发表评论

您必须 登录 才能发表留言！