thinkphp5.1 如何将session内容中不保存作用域?
1、官方提供的session开发文档:https://www.kancloud.cn/manua...2、根据官方例子写出3、查看session内容:前面多了一个“|”(竖线)我想要实现保存到sess
顺晟科技
2022-09-15 19:43:57
199
1、官方提供的session开发文档:
https://www.kancloud.cn/manua...
2、根据官方例子写出
3、查看session内容:前面多了一个“|”(竖线)
我想要实现保存到session中的数据是其他语言可以 反格式化的明文数据,方便go语言根据sessionId获取session进行unserialize数据,实现php和go共用会话共享。
请问怎样实现,请指导一下方向
尝试失败结果:
1、自定义session驱动https://blog.csdn.net/u014265...
失败结果:自定义的session数据还是保留“|”,
-->尝试将每次保存时,去掉|,遇到了很奇怪的事,session::get后,数据会被清空,追踪代码4个小时没有得到结果。随后放弃。
2、session保存数据json格式,这样go语言获取json格式也轻松。但尝试后发现,改为自定义驱动+write()方法中写入json+read()反序列化json之后tp5.1会报错误。
正在尝试思路:
1、将go语言gin框架中自己实现获取redis并且去除merchant|xxx...开头的merchang|, 这样会写的比较怪异,不过相比于其他办法没辙做了,这个可以。
这样会写的比较怪异,不过相比于其他办法没辙做了,这个可以。
补充方法:
<?php
/**
 * Created by PhpStorm.
 * User: wangjiali
 * Date: 2022/9/11
 * Time: 11:04
 */
namespace app\special\session;
use SessionHandlerInterface;
use think\Exception;
/*
 * php session 编码,php 以json格式存储session,而不是默认的内置编码
 */
class MyRedis implements SessionHandlerInterface
{
    /** @var \Redis */
    protected $handler = null;
    protected $config = [
        'host'         => '127.0.0.1', // redis主机
        'port'         => 6379, // redis端口
        'password'     => '', // 密码
        'select'       => 0, // 操作库
        'expire'       => 3600, // 有效期(秒)
        'timeout'      => 0, // 超时时间(秒)
        'persistent'   => true, // 是否长连接
        'session_name' => '', // sessionkey前缀
    ];
    public function __construct($config = [])
    {
        $this->config = array_merge($this->config, $config);
    }
    /**
     * 打开Session
     * @access public
     * @param  string $savePath
     * @param  mixed $sessName
     * @return bool
     * @throws Exception
     */
    public function open($savePath, $sessName)
    {
        if (extension_loaded('redis')) {
            $this->handler = new \Redis;
            // 建立连接
            $func = $this->config['persistent'] ? 'pconnect' : 'connect';
            $this->handler->$func($this->config['host'], $this->config['port'], $this->config['timeout']);
            if ('' != $this->config['password']) {
                $this->handler->auth($this->config['password']);
            }
            if (0 != $this->config['select']) {
                $this->handler->select($this->config['select']);
            }
        } elseif (class_exists('\Predis\Client')) {
            $params = [];
            foreach ($this->config as $key => $val) {
                if (in_array($key, ['aggregate', 'cluster', 'connections', 'exceptions', 'prefix', 'profile', 'replication'])) {
                    $params[$key] = $val;
                    unset($this->config[$key]);
                }
            }
            $this->handler = new \Predis\Client($this->config, $params);
        } else {
            throw new \BadFunctionCallException('not support: redis');
        }
        return true;
    }
    /**
     * 关闭Session
     * @access public
     */
    public function close()
    {
        $this->gc(ini_get('session.gc_maxlifetime'));
        $this->handler->close();
        $this->handler = null;
        return true;
    }
    /**
     * 读取Session
     * @access public
     * @param  string $sessID
     * @return string
     */
    public function read($sessID)
    {
        $_SESSION = json_decode($this->handler->get($this->config['session_name'] . $sessID), true);
        if (isset($_SESSION) && !empty($_SESSION) && $_SESSION != null) {
            return session_encode();
        }
        return "";
    }
    /**
     * 写入Session
     * @access public
     * @param  string $sessID
     * @param  string $sessData
     * @return bool
     */
    public function write($sessID, $sessData)
    {
        if ($this->config['expire'] > 0) {
            $result = $this->handler->setex($this->config['session_name'] . $sessID, $this->config['expire'], json_encode($_SESSION));
        } else {
            $result = $this->handler->set($this->config['session_name'] . $sessID, json_encode($_SESSION));
        }
        return $result ? true : false;
    }
    /**
     * 删除Session
     * @access public
     * @param  string $sessID
     * @return bool
     */
    public function destroy($sessID)
    {
        return $this->handler->del($this->config['session_name'] . $sessID) > 0;
    }
    /**
     * Session 垃圾回收
     * @access public
     * @param  string $sessMaxLifeTime
     * @return bool
     */
    public function gc($sessMaxLifeTime)
    {
        return true;
    }
    /**
     * Redis Session 驱动的加锁机制
     * @access public
     * @param  string $sessID 用于加锁的sessID
     * @param  integer $timeout 默认过期时间
     * @return bool
     */
    public function lock($sessID, $timeout = 10)
    {
        if (null == $this->handler) {
            $this->open('', '');
        }
        $lockKey = 'LOCK_PREFIX_' . $sessID;
        // 使用setnx操作加锁
        $isLock = $this->handler->setnx($lockKey, 1);
        if ($isLock) {
            // 设置过期时间,防止死任务的出现
            $this->handler->expire($lockKey, $timeout);
            return true;
        }
        return false;
    }
    /**
     * Redis Session 驱动的解锁机制
     * @access public
     * @param  string $sessID 用于解锁的sessID
     */
    public function unlock($sessID)
    {
        if (null == $this->handler) {
            $this->open('', '');
        }
        $this->handler->del('LOCK_PREFIX_' . $sessID);
    }
}
之前没怎么关注过这个问题, 刚刚专门去查证了一番,先要说明的是:“这个不是 ThinkPHP 的‘问题’,而是 PHP 的‘问题’。”
在 PHP 手册 中,有一个跟 Session 有关的配置项 session.serialize_handler ,这个配置项是用来给定 PHP 如何去序列化 Session 数据的。
session.serialize_handler 定义用来序列化/反序列化的处理器名字。 当前支持 PHP 序列化格式 (名为 php_serialize)、 PHP PHP 内部格式 (名为 php 及 php_binary) 和 WDDX (名为 wddx)。 如果 PHP 编译时加入了 WDDX 支持,则只能用 WDDX。 php_serialize 在内部简单地直接使用 serialize/unserialize 函数,并且不会有 php 和 php_binary 所具有的限制。 使用较旧的序列化处理器导致 $_SESSION 的索引既不能是数字也不能包含特殊字符(| and !) 。 使用 php_serialize 避免脚本退出时,数字及特殊字符索引导致出错。 默认使用 php。
可以看到,现在默认的是 php ,而他最终序列化的结果就是这样的。
Session::set('name', ['foo'=>'bar']);
Session::set('name2', [123]);
Session::set('name3', [123]);
// 最终序列化结果:name|a:1:{s:3:"foo";s:3:"bar";}name2|a:1:{i:0;i:123;}name3|a:1:{i:0;i:123;}这就是 php 序列化的方式,| 前面的是 session 的键名,竖线后面是一段 php 序列化(serialize 函数)的返回值,多个的拼接在一起则完成了序列化。
根据手册中的指引,其实还发现了另一个问题,就是 默认的序列化规则 php 的 Session 名字是不能包含 ! 和 |,经过测试也确实如此。
还有一点,默认情况下,session.php 里面有个 prefix 是配置的 think 在这里就会多套一层了,最终序列化结果的前面也就是 think 开头的,可以设置成空从而去掉这个 prefix,看你这里应该是已经设置了的。
那么,如何解决你这个问题?
虽然 PHP 手册中,并没有说应该如何自定义 session.serialize_handler ,但是可以设置自定义的 Session 处理器,自行实现 read 和 write 方法,在这里面再序列化一次,即可达到需求。
不过,默认的 session.serialize_handler 是 php 他的序列化格式不是很方便解析,可能需要我们自己去处理,但是好在有个 php_serialize 可选,它是使用 serialize 和 unserialize 来进行处理的,我们在 read 和 write 方法中拿到的也就是这个的结果,所以我们在此基础上进行二次对存储时的序列化即可,比如使用 JSON。
为此,我们需要创建一个自定义的 “驱动”。
这里以 Redis 为例,当然 ThinkPHP 已经内置了一个 Redis 驱动,所以我们可以直接继承这个类,从而省掉很大一部分代码,因为我们只需要修改 read 和 write 方法。
在 application 目录下创建一个 RedisonSession.php 文件,写入如下内容。
<?php
namespace app;
use think\session\driver\Redis;
class RedisSession extends Redis
{
    public function __construct($config = [])
    {
        // 修改 session.serialize_handler
        ini_set('session.serialize_handler', 'php_serialize');
        parent::__construct($config);
    }
    public function write($id, $data)
    {
        // 这里收到的是 PHP 内部序列化后的结果,现在把已经序列化的数据反序列化,然后在转为 JSON 进行存储
        $data = json_encode(unserialize($data));
        parent::write($id, $data);
    }
    public function read($sessID)
    {
        $data = parent::read($sessID);
        // 这里就是我们先前存储的内容 JSON,然后进行 JSON 解码,在使用 serialize 编码,因为 PHP 内部还会反序列化回去。
        return serialize(json_decode($data, true));
    }
}
然后打开 config/session.php 修改 type 为 \app\RedisSession::class。
现在 Session 将会被存储为 JSON 格式到 Redis。
这样你就不用给一个空的 session 名字了,你可以直接给。
1、因为这里只是为了示范,所以没有做任何的容错处理,对于旧的 Session 可能存在无法处理、处理失败从而造成旧的 Session 为空的情况,这将会影响到用户(理论上单个用户影响一次)Session 内容丢失,甚至可能会报错,建议在 read 方法里面做容错处理
2、多了反序列化、序列化的操作,如果 Session 的内容比较大的话,性能可能会有一些影响。
3、因为是简单粗暴的转为了 JSON,可能会导致一些问题,比如存入一个对象,最终取出来就变成了一个数组。
15
2022-09
15
2022-09
15
2022-09
15
2022-09
15
2022-09
15
2022-09