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 数据的。可以看到,现在默认的是
php
,而他最终序列化的结果就是这样的。这就是
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
文件,写入如下内容。然后打开
config/session.php
修改type
为\app\RedisSession::class
。现在 Session 将会被存储为 JSON 格式到 Redis。
这样你就不用给一个空的 session 名字了,你可以直接给。
注意事项
1、因为这里只是为了示范,所以没有做任何的容错处理,对于旧的 Session 可能存在无法处理、处理失败从而造成旧的 Session 为空的情况,这将会影响到用户(理论上单个用户影响一次)Session 内容丢失,甚至可能会报错,建议在 read 方法里面做容错处理
2、多了反序列化、序列化的操作,如果 Session 的内容比较大的话,性能可能会有一些影响。
3、因为是简单粗暴的转为了 JSON,可能会导致一些问题,比如存入一个对象,最终取出来就变成了一个数组。