redisphp单例 php redis单例模式

很多站长朋友们都不太清楚redisphp单例，今天小编就来给大家整理redisphp单例，希望对各位有所帮助，具体内容如下：

本文目录一览： 1、在php队列php-resque里头使用了数据库的单例模式显示MySQL server has gone away 2、 php redis如何使用 3、 php实现redis数据库指定库号迁移的方法 4、 php redis 需要使用单例吗 5、 PHP实现负载均衡session共享redis缓存操作示例 6、如何用php+redis做订单到时间自动完成功能在php队列php-resque里头使用了数据库的单例模式显示MySQL server has gone away

PHP的轻量消息队列php-resque使用说明

消息队列处理后台任务带来的问题

项目中经常会有后台运行任务的需求，比如发送邮件时，因为要连接邮件服务器，往往需要5-10秒甚至更长时间，如果能先给用户一个成功的提示信息，然后在后台慢慢处理发送邮件的操作，显然会有更好的用户体验。

为了实现类似的需求，Web项目中一般的实现方法是使用消息队列(Message Queue)，比如MemcacheQ，RabbitMQ等等，都是很著名的产品。

消息队列说白了就是一个最简单的先进先出队列，队列的一个成员就是一段文本。正是因为消息队列实在太简单了，当拿着消息队列时，反而有点无从下手的感觉，因为这仅仅一个发送邮件的任务，就会引申出很多问题：

消息队列只能存储字符串类型的数据，如何将一个发送邮件这样的“任务”，转换为消息队列中的一个“消息”?

消息队列只负责数据的存放与进出，本身不能执行任何程序，那么我们要如何从消息队列中一个一个取出数据，再将这些数据转化回任务并执行。

我们无法预知消息队列何时会有数据产生，所以我们的任务执行程序还需要具备监控消息队列的能力，也就是一个常驻后台的守护进程。

一般的Web应用PHP都以cgi方式运行，无法常驻内存。我们知道php还有cli模式，那么守护进程是否能以php cli来实现，效率如何？

当守护进程运行时，Web应用能否与后台守护进程交互，实现开启/杀死进程的功能以及获得进程的运行状态？

Resque对后台任务的设计与角色划分

对以上这些问题，目前为止我能找到的最好答案，并不是来自php，而是来自Ruby的项目Resque，正是由于Resque清晰简单的解决了后台任务带来的一系列问题，Resque的设计也被Clone到Python、php、NodeJs等语言：比如Python下的pyres以及PHP下的php-resque等等，这里有各种语言版本的Resque实现，而在本篇日志里，我们当然要以PHP版本为例来说明如何用php-resque运行一个后台任务，可能一些细节方面会与Ruby版有出入，但是本文中以php版为准。

Resque是这样解决这些问题的：

后台任务的角色划分

其实从上面的问题已经可以看出，只靠一个消息队列是无法解决所有问题的，需要新的角色介入。在Resque中，一个后台任务被抽象为由三种角色共同完成：

Job | 任务：一个Job就是一个需要在后台完成的任务，比如本文举例的发送邮件，就可以抽象为一个Job。在Resque中一个Job就是一个Class。

Queue | 队列：也就是上文的消息队列，在Resque中，队列则是由Redis实现的。Resque还提供了一个简单的队列管理器，可以实现将Job插入/取出队列等功能。

Worker | 执行者：负责从队列中取出Job并执行，可以以守护进程的方式运行在后台。

那么基于这个划分，一个后台任务在Resque下的基本流程是这样的：

将一个后台任务编写为一个独立的Class，这个Class就是一个Job。

在需要使用后台程序的地方，系统将Job Class的名称以及所需参数放入队列。

以命令行方式开启一个Worker，并通过参数指定Worker所需要处理的队列。

Worker作为守护进程运行，并且定时检查队列。

当队列中有Job时，Worker取出Job并运行，即实例化Job Class并执行Class中的方法。

至此就可以完整的运行完一个后台任务。

在Resque中，还有一个很重要的设计：一个Worker，可以处理一个队列，也可以处理很多个队列，并且可以通过增加Worker的进程/线程数来加快队列的执行速度。

php-resque的安装

需要提前说明的是，由于涉及到进程的开辟与管理，php-resque使用了php的PCNTL函数，所以只能在Linux下运行，并且需要php编译PCNTL函数。如果希望用Windows做同样的工作，那么可以去找找Resque的其他语言版本，php在Windows下非常不适合做后台任务。

以Ubuntu12.04LTS为例，Ubuntu用apt安装的php已经默认编译了PCNTL函数，无需任何配置，以下指令均为root帐号安装Redis

apt-get install redis-server

安装Composer

apt-get install curl

cd /usr/local/bin

curl -s | phpchmod a+x composer.phar

alias composer='/usr/local/bin/composer.phar'

使用Composer安装php-resque

假设web目录在/opt/htdocs

apt-get install git git-core

cd /opt/htdocs

git clone git://github测试数据/chrisboulton/php-resque.gitcd php-resque

composer install

php-resque的使用

编写一个Worker

其实php-resque已经给出了简单的例子， demo/job.php文件就是一个最简单的Job：

class PHP_Job

{

public function perform()

{

sleep(120);

fwrite(STDOUT, 'Hello!');

}

这个Job就是在120秒后向STDOUT输出字符Hello!

在Resque的设计中，一个Job必须存在一个perform方法，Worker则会自动运行这个方法。

将Job插入队列

php-resque也给出了最简单的插入队列实现 demo/queue.php：

if(empty($argv[1])) {

die('Specify the name of a job to add. e.g, php queue.php PHP_Job');}

require __DIR__ . '/init.php';

date_default_timezone_set('GMT');

Resque::setBackend('127.0.0.1:6379');

$args = array(

'time' => time(),

'array' => array(

'test' => 'test',

);

$jobId = Resque::enqueue('default', $argv[1], $args, true);echo "Queued job ".$jobId."\n\n";

在这个例子中，queue.php需要以cli方式运行，将cli接收到的第一个参数作为Job名称，插入名为'default'的队列，同时向屏幕输出刚才插入队列的Job Id。在终端输入：

php demo/queue.php PHP_Job

结果可以看到屏幕上输出：

Queued job b1f01038e5e833d24b46271a0e31f6d6即Job已经添加成功。注意这里的Job名称与我们编写的Job Class名称保持一致：PHP_Job查看Job运行情况

php-resque同样提供了查看Job运行状态的例子，直接运行：

php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6可以看到输出为：

Tracking status of b1f01038e5e833d24b46271a0e31f6d6. Press [break] to stop.

Status of b1f01038e5e833d24b46271a0e31f6d6 is: 1我们刚才创建的Job状态为1。在Resque中，一个Job有以下4种状态：

Resque_Job_Status::STATUS_WAITING = 1; (等待)Resque_Job_Status::STATUS_RUNNING = 2; (正在执行)Resque_Job_Status::STATUS_FAILED = 3; (失败)Resque_Job_Status::STATUS_COMPLETE = 4; (结束)因为没有Worker运行，所以刚才创建的Job还是等待状态。

运行Worker

这次我们直接编写demo/resque.php：

<?php

date_default_timezone_set('GMT');

require 'job.php';

require 'bin/resque';

可以看到一个Worker至少需要两部分：

可以直接包含Job类文件，也可以使用php的自动加载机制，指定好Job Class所在路径并能实现自动加载包含Resque的默认Worker： bin/resque

在终端中运行：

QUEUE=default php demo/resque.php

前面的QUEUE部分是设置环境变量，我们指定当前的Worker只负责处理default队列。也可以使用QUEUE=* php demo/resque.php

来处理所有队列。

运行后输出为

#!/usr/bin/env php

*** Starting worker

用ps指令检查一下：

ps aux | grep resque

可以看到有一个php的守护进程已经在运行了

1000 4607 0.0 0.1 74816 11612 pts/3 S+ 14:52 0:00 php demo/resque.php再使用之前的检查Job指令

php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d62分钟后可以看到

Status of b1f01038e5e833d24b46271a0e31f6d6 is: 4任务已经运行完毕，同时屏幕上应该可以看到输出的Hello!

至此我们已经成功的完成了一个最简单的Resque实例的全部演示，更复杂的情况以及遗留的问题会在下一次的日志中说明。

php redis如何使用

开始在 PHP 中使用 Redis 前，要确保已经安装了 redis 服务及 PHP redis 驱动，且你的机器上能正常使用 PHP。

PHP安装redis扩展

/usr/local/php/bin/phpize #php安装后的路径

./configure --with-php-config=/usr/local/php/bin/php-config

make make install

修改php.ini文件

vi /usr/local/php/lib/php.ini

增加如下内容:

extension_dir = "/usr/local/php/lib/php/extensions/no-debug-zts-20090626"

extension=redis.so

安装完成后重启php-fpm 或 apache。查看phpinfo信息，就能看到redis扩展。

连接到 redis 服务

<?php

//连接本地的 Redis 服务

$redis = new Redis();

$redis->connect('127.0.0.1', 6379);

echo "Connection to server sucessfully";

//查看服务是否运行

echo "Server is running: " . $redis->ping();

执行脚本，输出结果为：

Connection to server sucessfully

Server is running: PONG

Redis PHP String(字符串) 实例

<?php

//连接本地的 Redis 服务

$redis = new Redis();

$redis->connect('127.0.0.1', 6379);

echo "Connection to server sucessfully";

//设置 redis 字符串数据

$redis->set("tutorial-name", "Redis tutorial");

// 获取存储的数据并输出

echo "Stored string in redis:: " . jedis.get("tutorial-name");

执行脚本，输出结果为：

Connection to server sucessfully

Stored string in redis:: Redis tutorial

Redis PHP List(列表) 实例

<?php

//连接本地的 Redis 服务

$redis = new Redis();

$redis->connect('127.0.0.1', 6379);

echo "Connection to server sucessfully";

//存储数据到列表中

$redis->lpush("tutorial-list", "Redis");

$redis->lpush("tutorial-list", "Mongodb");

$redis->lpush("tutorial-list", "Mysql");

// 获取存储的数据并输出

$arList = $redis->lrange("tutorial-list", 0 ,5);

echo "Stored string in redis:: "

print_r($arList);

执行脚本，输出结果为：

Connection to server sucessfully

Stored string in redis::

Redis

Mongodb

Mysql

Redis PHP Keys 实例

<?php

//连接本地的 Redis 服务

$redis = new Redis();

$redis->connect('127.0.0.1', 6379);

echo "Connection to server sucessfully";

// 获取数据并输出

$arList = $redis->keys("*");

echo "Stored keys in redis:: "

print_r($arList);

执行脚本，输出结果为：

Connection to server sucessfully

Stored string in redis::

tutorial-name

tutorial-list

php实现redis数据库指定库号迁移的方法

这篇文章主要介绍了php实现redis数据库指定库号迁移的方法,涉及对于redis数据库的操作技巧,非常具有实用价值,需要的朋友可以参考下

本文实例讲述了php实现redis数据库指定库号迁移的方法,分享给大家供大家参考。具体如下：

redis普通的数据库迁移,只能整个redis

save,或者利用主从,当然也可以安装一个redis-dump,不过比较麻烦,这里提供一种php的脚本,实现指定库号的迁移,其实也就是遍历根据存储类型,读出来,插入新库,效果是这样:

代码如下:

[root@localhost

~]#

php

1.php

1/407

101/407

201/407

301/407

401/407

PHP实例代码如下:

代码如下:

<?php

$from

'10.0.2.52:6379/7';

$to

'127.0.0.1:6379/7';

$from_redis

redis_init($from);

$to_redis

redis_init($to);

$keys

$from_redis->keys('*');

$count

$total

count($keys);

foreach($keys

$key){

if(++$count

100

1){

echo

"$count/$totaln";

}

$type

$from_redis->type($key);

switch($type){

case

Redis::REDIS_STRING:

$val

$from_redis->get($key);

$to_redis->set($key,

$val);

break;

case

Redis::REDIS_LIST:

$list

$from_redis->lRange($key,

-1);

foreach($list

$val){

$to_redis->rPush($key,

$val);

}

break;

case

Redis::REDIS_HASH:

$hash

$from_redis->hGetAll($key);

$to_redis->hMSet($key,

$hash);

break;

case

Redis::REDIS_ZSET:

$zset

$from_redis->zRange($key,

-1,

true);

foreach($zset

$val=>$score){

$to_redis->zAdd($key,

$score,

$val);

}

break;

}

function

redis_init($conf){

$redis

new

Redis();

preg_match('/^([^:]+)(:[0-9]+)?/(.+)?/',

$conf,

$ms);

$host

$ms[1];

$port

trim($ms[2],

':');

$db

$ms[3];

$redis->connect($host,

$port);

$redis->select($db);

return

$redis;

}

希望本文所述对大家的php程序设计有所帮助。

php redis 需要使用单例吗

<?php

/**

* Class RedisConnManager

* 单例模式对redis实例的操作的进一步封装

* 主要目的：防止过多的连接，一个页面只能存在一个声明连接

* @author ：cuihuan

class RedisManager

{

private static $redisInstance;

/**

* 私有化构造函数

* 原因：防止外界调用构造新的对象

private function __construct(){}

/**

* 获取redis连接的唯一出口

static public function getRedisConn(){

if(!self::$redisInstance instanceof self){

self::$redisInstance = new self;

}

// 获取当前单例

$temp = self::$redisInstance;

// 调用私有化方法

return $temp->connRedis();

}

/**

* 连接ocean 上的redis的私有化方法

* @return Redis

static private function connRedis()

{

try {

$redis_ocean = new Redis();

$redis_ocean->connect(G::$conf['redis-host'], G::$conf['redis-port']);

$redis_ocean->auth(G::$conf['redis-pass']);

}catch (Exception $e){

echo $e->getMessage().'<br/>';

}

return $redis_ocean;

}

PHP实现负载均衡session共享redis缓存操作示例

本文实例讲述了PHP实现负载均衡session共享redis缓存操作。分享给大家供大家参考，具体如下：

1、首先先创建html表单页面

<meta

chatset='utf-8'>

<form

action="se.php"

method="post">

<table>

<tr>

<td><input

type="text"

name="username"></td>

</tr>

<tr>

<td><input

type="password"

name="pwd"></td>

</tr>

<tr>

<td><input

type="submit"

value="登录"></td>

</tr>

</table>

</form>

</center>

2、创建接受表单的文件

<?php

header('content-type:text/html;charset=utf-8');

set_time_limit(10);

ini_set("session.save_handler",'redis');//开启php.ini中的redis配置

ini_set("session.save_path","tcp://192.168.1.70:6379");//第一台服务器的redis

session_start();//开启session

$username

$_POST['username'];

$_SESSION['username']

$username;

echo

"<script>alert('登录成功！');location.href='from.php'</script>";//登录成功后跳转到欢迎登录页面

3、跳转到from.php去判断第一台服务器的redis中的session是否存到了本台服务器的session中

<?php

header('content-type:text/html;charset=utf-8');

set_time_limit(10);

ini_set("session.save_handler",'redis');//开启php.ini中的redis配置

ini_set("session.save_path","tcp://192.168.1.70:6379");//第一台服务器的redis

session_start();//开启session

$username

isset($_SESSION['username'])

$_SESSION['username']

'';//判断当前是否存在session

//$id

$_SESSION['PHPSESSID'];

//echo

$id;

if(empty($username)){

echo

"<script>alert('请重新登录！');location.href='index.php'</script>";

}else{

echo

"欢迎".$username."登录";

}

这样就简单了实现了redis

session共享的功能,要测试的话需要两台服务器,建议使用linux

比较好用

linux上安装redis可参考《Linux平台安装redis及redis扩展的方法》

更多关于PHP相关内容感兴趣的读者可查看本站专题：《php缓存技术总结》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《PHP错误与异常处理方法总结》、《php面向对象程序设计入门教程》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。

您可能感兴趣的文章:Nginx

安装笔记(含PHP支持、虚拟主机、反向代理负载均衡)PHP开发负载均衡指南PHP实现负载均衡下的session共用功能Thinkphp结合AJAX长轮询实现PC与APP推送详解PHP经典算法集锦【经典收藏】php

分库分表hash算法php的hash算法介绍PHP中对各种加密算法、Hash算法的速度测试对比代码PHP实现的一致性Hash算法详解【分布式算法】PHP实现负载均衡的加权轮询方法分析

如何用php+redis做订单到时间自动完成功能

1、每分钟内要完成的订单id存到redis；

2、php做逻辑处理

3、配置crontab每分钟执行一次php，读取要完成的订单id；

关于redisphp单例的介绍到此就结束了，不知道本篇文章是否对您有帮助呢？如果你还想了解更多此类信息，记得收藏关注本站，我们会不定期更新哦。

查看更多关于redisphp单例 php redis单例模式的详细内容...

声明：本文来自网络，不代表【好得很程序员自学网】立场，转载请注明出处：http://www.haodehen.cn/did208911

更新时间：2023-05-03 阅读：14次