redis终端简单命令
keys * 獲取所有鍵
lRange hongbao:44 0 -1獲取該鍵的所有值
del hongbao:44 刪除該鍵的所有值
hgetAll user:44 獲取該鍵的所有隊列
hget hongbao:44 8 獲取該隊列用戶為8的值
hset hongbao:44 7 'asdf'設(shè)置該隊列用戶為7的值
hdel user:44 8 刪除該隊列用戶為8的值
flushall 清空redis所有緩存數(shù)據(jù)
?
?
<?php
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
namespace Home\Controller;
use Think\Controller;
use Home\Util\ApiResponse;
/**
* Description of RedisController
*
* @author Administrator
*/
class SweepController extends BaseController{
/**
* 檢測redis是否正常運行
*/
public function __construct(){
parent::__construct();
if (!extension_loaded('redis')) {
E(L('_NOT_SUPPORT_') . ':redis');
}
if (empty($options)) {
$options = array(
'host' => C('REDIS_HOST') ? C('REDIS_HOST') : '127.0.0.1',
'port' => C('REDIS_PORT') ? C('REDIS_PORT') : 6379,
'timeout' => C('DATA_CACHE_TIMEOUT') ? C('DATA_CACHE_TIMEOUT') : false,
'persistent' => false,
);
}
$this->options = $options;
$this->options['expire'] = isset($options['expire']) ? $options['expire'] : C('DATA_CACHE_TIME');
$this->options['prefix'] = isset($options['prefix']) ? $options['prefix'] : C('DATA_CACHE_PREFIX');
$this->options['length'] = isset($options['length']) ? $options['length'] : 0;
$this->options['dbindex'] = isset($options['dbindex']) ? $options['dbindex'] : 0;
$func = $options['persistent'] ? 'pconnect' : 'connect';
$this->handler = new \Redis;
$options['timeout'] === false ?
$this->handler->$func($options['host'], $options['port']) :
$this->handler->$func($options['host'], $options['port'], $options['timeout']);
$this->handler->select($this->options['dbindex']);
}
/**
* redis連接
* @access private
* @return resource
* @author bieanju
*/
public function connectRedis() {
header('Content-Type:application/json; charset=utf-8');
$config = [
'host' => '127.0.0.1',
'port' => 6379,
];
$redis = new \Redis();
$redis->connect($config['host'], $config['port']);
$redis->select(0);
return $redis;
}
/**
* 紅包列表
*/
public function mine_sweeps(){
$p = I('get.p',1);
$user_id = $_SESSION['user']['uid'];
$count = M('hongbao')->alias('H')
->join('join hb_user as U on H.uid=U.id')
->order('H.addtime desc')
->field('H.*, U.headimg')
->count();
$Page = new \Think\HPage($count,4);// 實例化分頁類 傳入總記錄數(shù)和每頁顯示的記錄數(shù)
$show = $Page->show();// 分頁顯示輸出
$list['hongbao'] = M('hongbao')->alias('H')
->join('join hb_user as U on H.uid=U.id')
->order('H.addtime desc')
->field('H.*, U.headimg, U.name')
->limit($Page->firstRow.','.$Page->listRows)
->select();
foreach($list['hongbao'] as &$v){
$is_grab = M('record')->where(['uid' => ['eq', $user_id], 'h_id' => ['eq', $v['id']]])->getField('id');
$v['headimg'] = $v['headimg']?$v['headimg']:C('HEAD_IMG');
$v['sy_num'] = $v['num']-$v['lq_num'];
$v['is_red'] = !empty($is_grab)?2:1;
$v['is_user'] = $v['uid']==$user_id?1:2;
}
$list['user'] = M('user')->where(['id' => ['eq', $user_id], 'status' => ['eq', 1]])->field('headimg, name, total_money')->find();
$list['user']['headimg'] = $list['user']['headimg']?$list['user']['headimg']:C('HEAD_IMG');
$this->assign('list', $list);
$this->assign('page', $show);
$this->assign('p', $p);
$this->display();
}
/**
* 紅包列表頁顯示
*/
public function mine_sweep(){
$p = I('get.p',1);
$this->assign('p', $p);
$this->display();
}
/**
* 紅包列表api
*/
public function mine_sweep_api(){
try{
$p = I('get.p',1);
$user_id = $_SESSION['user']['uid'];
$sign_time = M('user')->where(['id' =>$user_id, 'status' => 1])->getField('sign_time');
$count = M('hongbao')->alias('H')
->join('join hb_user as U on H.uid=U.id')
->order('H.addtime desc')
->where(['H.addtime' => ['between' ,array($sign_time,time())]])
->field('H.*, U.headimg')
->count();
$Page = new \Think\HPage($count,4);// 實例化分頁類 傳入總記錄數(shù)和每頁顯示的記錄數(shù)
$show = $Page->show();// 分頁顯示輸出
$list['hongbao'] = M('hongbao')->alias('H')
->join('join hb_user as U on H.uid=U.id')
->order('H.addtime desc')
->field('H.*, U.headimg, U.name')
->where(['H.addtime' => ['between' ,array($sign_time,time())]])
->limit($Page->firstRow.','.$Page->listRows)
->select();
foreach($list['hongbao'] as &$v){
$is_grab = M('record')->where(['uid' => ['eq', $user_id], 'h_id' => ['eq', $v['id']]])->getField('id');
$v['headimg'] = $v['headimg']?$v['headimg']:C('HEAD_IMG');
$v['sy_num'] = $v['num']-$v['lq_num'];
$v['is_red'] = !empty($is_grab)?2:1;
$v['is_user'] = $v['uid']==$user_id?1:2;
}
$list['user'] = M('user')->where(['id' => ['eq', $user_id], 'status' => ['eq', 1]])->field('id,headimg, name, total_money')->find();
$list['user']['headimg'] = $list['user']['headimg']?$list['user']['headimg']:C('HEAD_IMG');
$show=str_replace("mine_sweep_api","mine_sweep",$show);
$list['page'] = $show;
$list['p'] = $p;
$this->doResponse(ApiResponse::SUCCESS, 'SUCCESS', $list);
} catch (Exception $e) {
$this->doResponse($e->getCode() ?: ApiResponse::SERVICE_ERROR, $e->getMessage());
}
}
/**
* 搶包詳情列表
*/
public function detail(){
header('Content-Type:application/json; charset=utf-8');
$hongbao_id = I('id');
$user_id = $_SESSION['user']['uid'];
$list['info'] = M('record')->alias('R')
->join('join hb_user as U on U.id=R.uid')
->where(['R.h_id' => ['eq', $hongbao_id]])
->field('U.headimg ,U.name ,U.id as user_id,R.*')
->select();
$list['user'] = M('hongbao')->alias('H')
->join('join hb_user as U on H.uid=U.id')
->where(['H.id' => ['eq', $hongbao_id]])
->field('U.name, U.headimg, H.money,H.num')
->find();
$list['user'] = M('user')->where(['id' => ['eq', $user_id], 'status' => ['eq', 1]])->field('name,headimg')->find();
$hongbao = M('hongbao')->where(['id' => ['eq', $hongbao_id]])->field('money,num')->find();
$list['user']['headimg'] = $list['user']['headimg']?$list['user']['headimg']:C('HEAD_IMG');
$list['user']['total_moneys'] = $hongbao['money'];
$list['user']['num'] = $hongbao['num'];
foreach($list['info'] as &$vo){
$vo['headimg'] = $vo['headimg']?$vo['headimg']:C('HEAD_IMG');
$vo['name'] = $vo['name']?$vo['name']:'無';
if($vo['user_id'] == $user_id){
$list['user']['money'] = $vo['money'];
}
}
// print_r($list);exit;
$this->assign('list', $list);
$this->display();
}
/**
* 發(fā)包顯示
*/
public function send(){
$user_id = $_SESSION['user']['uid'];
$pack = M('pack')->order('num asc')->select();
$choice_money = M('choice_money')->where(['type' => ['eq', 3]])->order('money asc')->select();
$user = M('user')->where(['id' => ['eq', $user_id], 'status' => ['eq', 1]])->field('name,total_money,headimg')->find();
$user['headimg'] = $user['headimg']?$user['headimg']:C('HEAD_IMG');
$this->assign('pack', $pack);
$this->assign('user', $user);
$this->assign('choice_money', $choice_money);
$this->display();
}
/*
* 用戶發(fā)紅包
*/
public function before_detail(){
// $_SESSION['user']['id'] = 1;//發(fā)包人id
$min = 0.01;
$pack_id = I('post.bao_id');
$zid = I('post.zid');//自定義金額
$money = I('post.money');//選擇金額
$lucky = I('post.lucky');//雷號 10-0
$pack = M('pack')->where(['id' => $pack_id])->find();
$num = $pack['num'];//包數(shù)
$multiple = $pack['multiple'];//倍數(shù)
$money = !empty($zid)?$zid:$money;
if (empty($pack_id)) {
$return['status'] = 0;
$return['msg'] = "請選擇包數(shù)！";
$this->ajaxReturn($return);
}
if (empty($lucky)) {
$return['status'] = 0;
$return['msg'] = "請選擇雷號！";
$this->ajaxReturn($return);
}
if(!preg_match('/^[0-9]+\.{0,1}[0-9]{0,2}$/',$money) || empty($money)){
$return['status'] = 0;
$return['msg'] = "請輸入正確的充值金額！";
$this->ajaxReturn($return);
}
if (!preg_match("/^[0-9]{1,}$/", $num)) {
$return['status'] = 0;
$return['msg'] = "紅包數(shù)量請輸入整數(shù)!";
$this->ajaxReturn($return);
}
if ($num * $min > $money) {
$return['status'] = 0;
$return['msg'] = "真摳";
$this->ajaxReturn($return);
}
$user_money = M('user')->where(['id' => ['eq', $_SESSION['user']['uid']], 'status' => ['eq', 1]])->getField('total_money');
if ($user_money < $money) {
$return['status'] = 0;
$return['msg'] = "您的余額不足，請充值！";
$this->ajaxReturn($return);
}
$lucky = $lucky==10?0:$lucky;
/*添加發(fā)包記錄*/
$data = [
'uid' => $_SESSION['user']['uid'],
'money' => $money,
'num' => $num,
'lucky' => $lucky,//雷號
'multiple' => $multiple,//倍數(shù)
'addtime' => time(),
'over_time' => time()+180,
];
$hongbao_redpacket = M('hongbao');
M('hongbao')->startTrans();
$hongbao_id = $hongbao_redpacket->add($data);
/*添加發(fā)包余額變動記錄*/
$data_profit = [
'uid' => $_SESSION['user']['uid'],
'money' => $user_money-$money,
'change' => $money,
'type' => 4,
'addtime' => time(),
];
$add_profit = M('profit')->add($data_profit);
$save_money = M('user')->where(['id' => ['eq', $_SESSION['user']['uid']], 'status' => ['eq', 1]])->setDec('total_money', $money);
if (empty($hongbao_id) || !$save_money || empty($add_profit)) {
$hongbao_redpacket->roolback();
$return['status']=0;
$return['msg']="發(fā)包失敗";
$this->ajaxReturn($return);
}
$this->hongbao_key = 'hongbao:' . $hongbao_id;
$redis = $this->connectRedis();
$gnRedis = $redis->llen("{$this->hongbao_key}");
/* 判斷第一個紅包不為雷 */
for ($x = 0; $x <= 100; $x++) {
$redpacket_money = $this->rand_section($min, $money, $num, $money);
if (mb_substr($redpacket_money[0], -1, 1) != $lucky) {
break;
}
}
/*redis添加紅包金額*/
if (!$gnRedis) {
for ($i = 0; $i < $num; $i ++) {
$redis->lpush("{$this->hongbao_key}", $redpacket_money[$i]);
}
}
$resetRedis = $redis->llen("{$this->hongbao_key}");
if (!$resetRedis) {
$hongbao_redpacket->roolback();
$return['status'] = 0;
$return['msg'] = "發(fā)包失敗";
$this->ajaxReturn($return);
}
$hongbao_redpacket->commit();
$return['status']=200;
$return['msg']="發(fā)包成功";
$this->ajaxReturn($return);
}
/*
* 紅包id、用戶id
*/
public function grab_number_queue(){
$hongbao_id = I('id');//紅包id
$user_id = $_SESSION['user']['uid'];
$this->user_key = 'user:'.$hongbao_id;
$this->hongbao_key = 'hongbao:'.$hongbao_id;
/* redis 隊列 */
$redis = $this->connectRedis();
/* 進入隊列 */
$hongbao_num = $redis->llen("{$this->hongbao_key}");
$user_num = $redis->hGet("{$this->user_key}",$user_id);
// 判斷用戶是否已在隊列
if ($user_num) {
$return['status'] = 200;
$return['msg'] = "您已搶過紅包";
$this->ajaxReturn($return);
}
$find_redpacket = M('hongbao')->where(['id' => $hongbao_id])->field('uid, money, status, lucky, multiple,over_time,lq_money,lq_num')->find();
$user_money = M('user')->where(['id' => ['eq', $user_id], 'status' => ['eq', 1]])->getField('total_money');
$peifu = $find_redpacket['money']*$find_redpacket['multiple'];
if (!$hongbao_num || $find_redpacket['status'] == 2) {
$return['status'] = 0;
$return['msg'] = "手慢了,紅包已派完";
$this->ajaxReturn($return);
}
/*判斷過期紅包*/
if($find_redpacket['over_time']<time()){
$return['status'] = 0;
$return['msg'] = "紅包已過期！";
$this->ajaxReturn($return);
}
/* 判斷用戶余額是否大于賠付金額 */
if ($user_money < $peifu) {
$return['status'] = 0;
$return['msg'] = "您的余額低于賠付金額，請充值！";
$this->ajaxReturn($return);
}
$goods_number_key = $redis->lpop("{$this->hongbao_key}");
if ($goods_number_key) {
// 插入搶購用戶信息
$userinfo = array(
"user_id" => $user_id,
"create_time" => time()
);
$Modelr = M('record');
$Modelr->startTrans();
$redis->hSet("{$this->user_key}", $user_id, serialize($userinfo));
/*判斷用戶是否中雷*/
if (mb_substr($goods_number_key, -1, 1) == $find_redpacket['lucky']) {
$is_type = 2;
$save_user_money = M('user')->where(['id' => ['eq', $user_id], 'status' => ['eq', 1]])->setDec('total_money', $peifu);
$hongbao_money = M('user')->where(['id' => ['eq', $find_redpacket['uid']], 'status' => ['eq', 1]])->getField('total_money');//查詢放在下面防止搶包與發(fā)包人同一個
$save_hongbao_money = M('user')->where(['id' => ['eq', $find_redpacket['uid']], 'status' => ['eq', 1]])->setInc('total_money', $peifu);
$ray = [[
'uid' => $user_id,
'money' => $user_money-$peifu,
'change' => $peifu,
'type' => 6,//用戶踩雷減余額
'addtime' => time(),
],[
'uid' => $find_redpacket['uid'],
'money' => $hongbao_money+$peifu,
'change' => $peifu,
'type' => 8,//用戶踩雷發(fā)包者加余額
'addtime' => time(),
]];
$addAll_money = M('profit')->addAll($ray);
if (empty($save_user_money) || empty($save_hongbao_money) || empty($addAll_money)) {
$Modelr->rollback();
$return['status'] = 0;
$return['msg'] = "搶包失敗！";
$this->ajaxReturn($return);
}
$user_money = $user_money-$peifu;
} else {
$is_type = 1;
}
/*用戶搶包添加金額*/
$add_money = M('user')->where(['id' => ['eq', $user_id], 'status' => ['eq', 1]])->setInc('total_money', $goods_number_key);
$lq_hongbao = M('hongbao')->where(['id' => ['eq', $hongbao_id]])->save(['lq_money' => $find_redpacket['lq_money']+$goods_number_key,'lq_num' => $find_redpacket['lq_num']+1]);
// 插入用戶搶包記錄
$redpack_log = [
'uid' => $user_id,
'money' => $goods_number_key,
'h_id' => $hongbao_id,
'lucky'=> $find_redpacket['lucky'],
'type' => $is_type,
'addtime' => time(),
];
$redpacket_user = M('record')->add($redpack_log);
/*添加用戶搶包余額變動記錄*/
$data_profit = [
'uid' => $user_id,
'money' => $user_money+$goods_number_key,
'change' => $goods_number_key,
'type' => 5,
'addtime' => time(),
];
$add_profit = M('profit')->add($data_profit);
if (empty($add_money) || empty($redpacket_user) || empty($add_profit) || empty($lq_hongbao)) {
$Modelr->rollback();
$return['status'] = 0;
$return['msg'] = "搶包失敗！";
$this->ajaxReturn($return);
}
$hongbao_num = $redis->llen("{$this->hongbao_key}");
if (!$hongbao_num) {
$save_redpacket = M('hongbao')->where(['id' => $hongbao_id])->save(['status' => 2]);
if (empty($save_redpacket)) {
$Modelr->rollback();
$return['status'] = 0;
$return['msg'] = "搶包失敗！";
$this->ajaxReturn($return);
}
$redisDel=$redis->del("{$this->user_key}");
}
$Modelr->commit();
$return['status'] = 200;
$return['msg'] = '紅包金額' . $goods_number_key;
$this->ajaxReturn($return);
} else {
$return['status'] = 0;
$return['msg'] = "系統(tǒng)繁忙";
$this->ajaxReturn($return);
}
}
/** 獲取區(qū)間內(nèi)隨機紅包（符合正態(tài)分布）
* @param $min 紅包最小值
* @param $max 紅包最大值
* @param $num 紅包個數(shù)
* @param $total 紅包金額
* @return array
*/
public function rand_section ($min,$max,$num,$total){
$data = array();
if ($min * $num > $total) {
return array();
}
if($max*$num < $total){
return array();
}
while ($num >= 1) {
$num--;
$kmix = max($min, $total - $num * $max);
$kmax = min($max, $total - $num * $min);
$kAvg = $total / ($num + 1);
//獲取最大值和最小值的距離之間的最小值
$kDis = min($kAvg - $kmix, $kmax - $kAvg);
//獲取0到1之間的隨機數(shù)與距離最小值相乘得出浮動區(qū)間，這使得浮動區(qū)間不會超出范圍
$r = ((float)(rand(1, 10000) / 10000) - 0.5) * $kDis * 2;
$k = sprintf("%.2f", $kAvg + $r);
$total -= $k;
$data[] = $k;
}
return $data;
}
/*
* redis調(diào)試
*/
public function order_num(){
$redis=$this->connectRedis();
// $redis->flushall();//清空redis所有緩存數(shù)據(jù)
$a = $redis->keys('*');
print_r($a);
}
}
轉(zhuǎn)載于:https://www.cnblogs.com/zhang-bin/p/10137506.html
總結(jié)
以上是生活随笔為你收集整理的redis终端简单命令的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 梦到家败了是什么意思
- 下一篇： Kubernetes持续交付-Jenki