redisphp机制
这篇文章主要介绍了php实现redis数据库指定库号迁移的方法,涉及对于redis数据库的操作技巧,非常具有实用价值,需要的朋友可以参考下
本文实例讲述了php实现redis数据库指定库号迁移的方法,分享给大家供大家参考。具体如下：
redis普通的数据库迁移,只能整个redis
save,或者利用主从,当然也可以安装一个redis-mp,不过比较麻烦,这里提供一种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
=
0;
$total
=
count($keys);
foreach($keys
as
$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,
0,
-1);
foreach($list
as
$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,
0,
-1,
true);
foreach($zset
as
$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程序设计有所帮助。
❷ thinkphp redis 怎么选择数据库
1、redis 中的每一个数据库，都由一个 redisDb 的结构存储。其中，redisDb.id 存储着 redis 数据库以整数表示的号码。redisDb.dict 存储着该库所有的键值对数据。redisDb.expires 保存着每一个键的过期时间。
2、当redis 服务器初始化时，会预先分配 16 个数据库（该数量可以通过配置文件配置），所有数据库保存到结构 redisServer 的一个成员 redisServer.db 数组中。当我们选择数据库 select number 时，程序直接通过 redisServer.db[number] 来切换数据库。有时候当程序需要知道自己是在哪个数据库时，直接读取 redisDb.id 即可。
3、既然我们知道一个数据库的所有键值都存储在redisDb.dict中，那么我们要知道如果找到key的位置，就有必要了解一下dict 的结构了：
typedef struct dict {
// 特定于类型的处理函数
dictType *type;
// 类型处理函数的私有数据
void *privdata;
// 哈希表（2个）
dictht ht[2];
// 记录 rehash 进度的标志，值为-1 表示 rehash 未进行
int rehashidx;
// 当前正在运作的安全迭代器数量
int iterators;
} dict;
由上述的结构可以看出，redis 的字典使用哈希表作为其底层实现。dict 类型使用的两个指向哈希表的指针，其中 0 号哈希表（ht[0]）主要用于存储数据库的所有键值，而1号哈希表主要用于程序对 0 号哈希表进行 rehash 时使用，rehash 一般是在添加新值时会触发，这里不做过多的赘述。所以redis 中查找一个key，其实就是对进行该dict 结构中的 ht[0] 进行查找操作。
4、既然是哈希，那么我们知道就会有哈希碰撞，那么当多个键哈希之后为同一个值怎么办呢？redis采取链表的方式来存储多个哈希碰撞的键。也就是说，当根据key的哈希值找到该列表后，如果列表的长度大于1，那么我们需要遍历该链表来找到我们所查找的key。当然，一般情况下链表长度都为是1，所以时间复杂度可看作o(1)。
二、当redis 拿到一个key 时，如果找到该key的位置。
了解了上述知识之后，我们就可以来分析redis如果在内存找到一个key了。
1、当拿到一个key后， redis 先判断当前库的0号哈希表是否为空，即：if (dict->ht[0].size == 0)。如果为true直接返回NULL。
2、判断该0号哈希表是否需要rehash，因为如果在进行rehash，那么两个表中者有可能存储该key。如果正在进行rehash，将调用一次_dictRehashStep方法，_dictRehashStep 用于对数据库字典、以及哈希键的字典进行被动 rehash，这里不作赘述。
3、计算哈希表，根据当前字典与key进行哈希值的计算。
4、根据哈希值与当前字典计算哈希表的索引值。
5、根据索引值在哈希表中取出链表，遍历该链表找到key的位置。一般情况，该链表长度为1。
6、当 ht[0] 查找完了之后，再进行了次rehash判断，如果未在rehashing，则直接结束，否则对ht[1]重复345步骤。
到此我们就找到了key在内存中的位置了。
❸ php涓轰粈涔堜娇鐢╮edis
1銆 Redis绠浠
redis鏄疦osql鏁版嵁搴扑腑浣跨敤杈冧负骞挎硾镄勯潪鍏崇郴鍨嫔唴瀛樻暟鎹搴掳纴redis鍐呴儴鏄涓涓猭ey-value瀛桦偍绯荤粺銆傚畠鏀鎸佸瓨鍌ㄧ殑value绫诲瀷鐩稿规洿澶氾纴鍖呮嫭string(瀛楃︿覆)銆乴ist(阈捐〃)銆乻et(闆嗗悎)銆亃set(sorted set _链夊簭闆嗗悎)鍜宧ash锛埚搱甯岀被鍨嬶纴绫讳技浜嶫ava涓镄刴ap锛夈俣edis锘轰簬鍐呭瓨杩愯屽苟鏀鎸佹寔涔呭寲镄凬oSQL鏁版嵁搴掳纴鏄褰揿墠链鐑闂ㄧ殑NoSql鏁版嵁搴扑箣涓锛屼篃琚浜轰滑绉颁负鏁版嵁缁撴瀯链嶅姟鍣ㄣ
2銆 浜掕仈缃戞椂浠ｈ儗鏅涓嫔ぇ链洪亣锛屼粈涔堣佷娇鐢∟osql锛
1锛 褰撴暟鎹閲忕殑镐诲ぇ灏忎竴涓链哄櫒鏀句笉涓嬫椂銆
2锛 鏁版嵁绱㈠紩涓涓链哄櫒镄勫唴瀛樻斁涓崭笅镞躲
3锛 璁块梾閲忥纸璇诲啓娣峰悎锛変竴涓瀹炰緥鏀句笉涓嬫椂銆
鍗曟満镞朵唬妯″瀷
濡傛灉姣忔″瓨鍌ㄦ垚鍗冧笂涓囨浔鏁版嵁锛岃繖镙峰緢浼氩艰嚧MySQL镄勬ц兘寰埚樊锛屽瓨鍌ㄤ互鍙婅诲彇阃熷害寰堟参锛岀劧钖庡氨婕斿彉鎴愮紦瀛+mysql+鍨傜洿𨰾嗗垎镄勬柟寮忋
Cache浣滀负涓闂寸紦瀛
灏嗘墍链夌殑鏁版嵁鍏堜缭瀛桦埌缂揿瓨涓锛岀劧钖庡啀瀛桦叆mysql涓锛屽噺灏忔暟鎹搴揿帇锷涳纴鎻愰珮鏁堢巼銆 浣嗘槸褰撴暟鎹鍐嶆″炲姞鍒板张涓涓閲忕骇锛屼笂闱㈢殑鏂瑰纺涔熶笉鑳芥弧瓒抽渶姹傦纴鐢变簬鏁版嵁搴撶殑鍐椤叆铡嫔姏澧炲姞锛孧emcached鍙鑳界紦瑙ｆ暟鎹搴撶殑璇诲彇铡嫔姏銆
璇诲啓闆嗕腑鍦ㄤ竴涓鏁版嵁搴扑笂璁╂暟鎹搴扑笉鍫閲嶈礋锛屽ぇ閮ㄥ垎缃戠珯寮濮嬩娇鐢ㄤ富浠庡嶅埗鎶链𨱒ヨ揪鍒拌诲啓鍒嗙伙纴浠ユ彁楂樿诲啓镐ц兘鍜岃诲簱镄勫彲镓╁𪾢镐с侻ysql镄刴aster-slave妯″纺鎴愪负杩欎釜镞跺欑殑缃戠珯镙囬厤浜嗐
涓讳粠鍒嗙绘ā寮
鍦╮edis镄勯珮阃熺紦瀛桡纴MySQL镄勪富浠庡嶅埗锛岃诲啓鍒嗙荤殑锘虹涔嬩笂锛岃繖镞祃ySQL涓诲簱镄勫啓铡嫔姏寮濮嫔嚭鐜扮摱棰堬纴钥屾暟鎹閲忕殑鎸佺画鐚涘烇纴鐢变簬MyISAM浣跨敤琛ㄩ挛锛屽湪楂桦苟鍙戜笅浼氩嚭鐜颁弗閲岖殑阌侀梾棰桡纴澶ч噺镄勯珮骞跺彂MySQL搴旂敤寮濮嬩娇鐢↖nnoDB寮曟搸浠ｆ浛MyISAM銆
鍒呜〃鍒嗗簱妯″纺
灏嗗彉鍖栧皬镄勚佷笟锷＄浉鍏崇殑鏀惧湪涓涓鏁版嵁搴掳纴鍙桦寲澶氱殑锛屼笉鐩稿叧镄勬暟鎹鏀惧湪涓涓鏁版嵁搴撱
3銆 nosql鏁版嵁搴撶殑浼桦娍
1锛夋槗镓╁𪾢
杩欎簺绫诲瀷镄勬暟鎹瀛桦偍涓嶉渶瑕佸浐瀹氱殑妯″纺锛屾棤闇澶氢綑镄勬搷浣滃氨鍙浠ヨ繘琛屾í钖戠殑镓╁𪾢銆傜浉瀵逛簬鍏崇郴鍨嬫暟鎹搴揿彲浠ュ噺灏戣〃鍜屽瓧娈电壒鍒澶氱殑𨱍呭喌銆备篃镞犲瀷涔嬮棿鍦ㄦ灦鏋勭殑灞傞溃涓婂甫𨱒ヤ简鍙镓╁𪾢镄勮兘锷
2锛夊ぇ鏁版嵁閲忔彁楂樻ц兘
3锛夊氭牱𨱔垫椿镄勬暟鎹妯″瀷
鍦╪osql涓涓崭粎鍙浠ュ瓨鍌⊿tring锛宧ash锛宻et銆乑set绛夋暟鎹绫诲瀷锛岃缮鍙浠ヤ缭瀛榡avaBean浠ュ强澶氱嶅嶆潅镄勬暟鎹绫诲瀷銆
4銆 NoSql镄勫簲鐢
1锛 澶ф暟鎹镞朵唬娣桦疂銆佸井淇°佷互鍙婂井鍗氱瓑閮藉箍娉涚殑浣跨敤浜唕edis鏁版嵁搴掳纴灏嗕竴浜涘浐瀹氢笉鍙樼殑鏁版嵁渚嫔傚︽牎锛屽尯锘熺瓑锲哄畾镄勪俊鎭淇濆瓨鍦ㄥ叧绯诲瀷鏁版嵁搴扑腑銆傜劧钖庡逛簬缁忓父鍙桦寲镄勬暟鎹渚嫔傛窐瀹濇疮涓鑺傛棩閮戒细链夋瘆杈幂儹闂ㄧ殑鎼灭储鏄剧ず鍦ㄦ悳绱㈡嗭纴褰撹妭镞ヨ繃铡诲叧阌瀛楄嚜锷ㄥ垹闄わ纴涓轰简渚夸簬绠＄悊锛屽彲浠ュ皢杩欎簺鏁版嵁淇濆瓨鍦╮edis鏁版嵁搴扑腑锛屽苟璁剧疆杩囨湡镞堕棿锛屽埌杈炬椂闂村氨镊锷ㄥ垹闄ゃ
2锛変负浜嗙紦瑙ｆ暟鎹搴揿帇锷涳纴寰鍗氶栧厛灏嗗彂阃佺殑寰鍗氢缭瀛桦埌redis鏁版嵁搴掳纴镊宸卞彲浠ョ珛鍗虫煡鐪嫔埌锛岀劧钖庡皢鍐呭瓨涓镄勬暟鎹钖屾ュ埌鍏崇郴鍨嬫暟鎹搴撱
浠ヤ笂鍐呭逛粎渚涘弬钥冿紒
鎺ㄨ崘瑙嗛戞暀绋嬶细redis鏁欑▼
❹ php 使用redis锁限制并发访问类示例
本文介绍了php
使用redis锁限制并发访问类，并详细的介绍了并发访问限制方法。
1.并发访问限制问题
对于一些需要限制同一个用户并发访问的场景，如果用户并发请求多次，而服务器处理没有加锁限制，用户则可以多次请求成功。
例如换领优惠券，如果用户同一时间并发提交换领码，在没有加锁限制的情况下，用户则可以使用同一个换领码同时兑换到多张优惠券。
伪代码如下：
if
A(可以换领)
B(执行换领)
C(更新为已换领)
D(结束)
如果用户并发提交换领码，都能通过可以换领(A)的判断，因为必须有一个执行换领(B)后，才会更新为已换领(C)。因此如果用户在有一个更新为已换领之前，有多少次请求，这些请求都可以执行成功。
2.并发访问限制方法
使用文件锁可以实现并发访问限制，但对于分布式架构的环境，使用文件锁不能保证多台服务器的并发访问限制。
Redis是一个开源的使用ANSI
C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。
本文将使用其setnx方法实现分布式锁功能。setnx即Set
it
N**ot
eX**ists。
当键值不存在时，插入成功（获取锁成功），如果键值已经存在，则插入失败（获取锁失败）
RedisLock.class.PHP
<?php
/**
*
Redis锁操作类
*
Date:
2016-06-30
*
Author:
fdipzone
*
Ver:
1.0
*
*
Func:
*
public
lock
获取锁
*
public
unlock
释放锁
*
private
connect
连接
*/
class
RedisLock
{
//
class
start
private
$_config;
private
$_redis;
/**
*
初始化
*
@param
Array
$config
redis连接设定
*/
public
function
__construct($config=array()){
$this->_config
=
$config;
$this->_redis
=
$this->connect();
}
/**
*
获取锁
*
@param
String
$key
锁标识
*
@param
Int
$expire
锁过期时间
*
@return
Boolean
*/
public
function
lock($key,
$expire=5){
$is_lock
=
$this->_redis->setnx($key,
time()+$expire);
//
不能获取锁
if(!$is_lock){
//
判断锁是否过期
$lock_time
=
$this->_redis->get($key);
//
锁已过期，删除锁，重新获取
if(time()>$lock_time){
$this->unlock($key);
$is_lock
=
$this->_redis->setnx($key,
time()+$expire);
}
}
return
$is_lock?
true
:
false;
}
/**
*
释放锁
*
@param
String
$key
锁标识
*
@return
Boolean
*/
public
function
unlock($key){
return
$this->_redis->del($key);
}
/**
*
创建redis连接
*
@return
Link
*/
private
function
connect(){
try{
$redis
=
new
Redis();
$redis->connect($this->_config['host'],$this->_config['port'],$this->_config['timeout'],$this->_config['reserved'],$this->_config['retry_interval']);
if(empty($this->_config['auth'])){
$redis->auth($this->_config['auth']);
}
$redis->select($this->_config['index']);
}catch(RedisException
$e){
throw
new
Exception($e->getMessage());
return
false;
}
return
$redis;
}
}
//
class
end
?>
demo.php
<?php
require
'RedisLock.class.php';
$config
=
array(
'host'
=>
'localhost',
'port'
=>
6379,
'index'
=>
0,
'auth'
=>
'',
'timeout'
=>
1,
'reserved'
=>
NULL,
'retry_interval'
=>
100,
);
//
创建redislock对象
$oRedisLock
=
new
RedisLock($config);
//
定义锁标识
$key
=
'mylock';
//
获取锁
$is_lock
=
$oRedisLock->lock($key,
10);
if($is_lock){
echo
'get
lock
success<br>';
echo
'do
sth..<br>';
sleep(5);
echo
'success<br>';
$oRedisLock->unlock($key);
//
获取锁失败
}else{
echo
'request
too
frequently<br>';
}
?>
测试方法：
打开两个不同的浏览器,同时在A,B中访问demo.php
如果先访问的会获取到锁
输出
get
lock
success
do
sth..
success
另一个获取锁失败则会输出request
too
frequently
保证同一时间只有一个访问有效，有效限制并发访问。
为了避免系统突然出错导致死锁，所以在获取锁的时候增加一个过期时间，如果已超过过期时间，即使是锁定状态都会释放锁，避免死锁导致的问题。
源码下载地址：点击查看
❺ 在php中 为什么不能使用redis类
redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)和zset(有序集合)。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。
Redis 是一个高性能的key-value数据库。redis的出现，很大程度补偿了memcached这类keyvalue存储的不足，在部 分场合可以对关系数据库起到很好的补充作用。它提供了Python，Ruby，Erlang，PHP客户端，使用很方便。
若想在PHP中使用redis，首先要先安装redis。然后在PHP中配置扩展。
安装redis。
首先下载好redis安装文件，解压到D盘或其他盘。
然后通过Dos命令行进行安装。
把这个文件夹复制到其它地方，比如D：\redis 目录下。
打开一个cmd窗口 使用cd命令切换目录到D:\redis 运行 redis-server.exe redis.conf
如果想方便的话，可以把redis的路径加到系统的环境变量里，这样就省得再输路径了，后面的那个redis.conf可以省略，如果省略，会启用默认的。
这时候另启一个cmd窗口，原来的不要关闭，不然就无法访问服务端了
切换到redis目录下运行 redis-cli.exe -h 127.0.0.1 -p 6379
这时候，就已经完成配置了。
完成了配置之后，要在PHP中添加redis的扩展，之后才可以用PHP灵活的使用它。
在windows下安装php的redis扩展非常简单，下载一个.dll扩展包放到php的ext目录下，在php.ini里边添加一行配置就可以了。
php代码测试
redis=newRedis();redis->connect(‘127.0.0.1′,6379);
redis−>set(‘test′,′helloworld!′);echoredis->get(‘test’);
输出hello world!
❻ redis 怎么缓存好友列表 php
参数可选Redis::MULTI或Redis::PIPELINE. 默认是 Redis::MULTI
Redis::MULTI：将多个操作当成一个事务执行
Redis::PIPELINE:让（多条）执行命令简单的，更加快速的发送给服务器，但是没有任何原子性的保证
discard:删除一个事务
返回值
multi()，返回一个redis对象，并进入multi-mode模式，一旦进入multi-mode模式，
以后调用的所有方法都会返回相同的对象，只到exec(）方法被调用。
watch, unwatch （代码测试后，不能达到所说的效果）
监测一个key的值是否被其它的程序更改。如果这个key在watch 和 exec （方法）间被修改，
这个 MULTI/EXEC 事务的执行将失败（return false）
unwatch 取消被这个程序监测的所有key
参数，一对key的列表
$redis->watch('x');
$ret = $redis->multi() ->incr('x') ->exec();
subscribe *
方法回调。注意，该方法可能在未来里发生改变
publish *
发表内容到某一个通道。注意，该方法可能在未来里发生改变
exists
判断key是否存在。存在 true 不在 false
❼ php redis做mysql的缓存，怎么异步redis同步到mysql数据库
对于变化频率非常快的数据来说，如果还选择传统的静态缓存方式（Memocached、File System等）展示数据，可能在缓存的存取上会有很大的开销，并不能很好的满足需要，而Redis这样基于内存的NoSQL数据库，就非常适合担任实时数据的容器。
但是往往又有数据可靠性的需求，采用MySQL作为数据存储，不会因为内存问题而引起数据丢失，同时也可以利用关系数据库的特性实现很多功能。
所以就会很自然的想到是否可以采用MySQL作为数据存储引擎，Redis则作为Cache。而这种需求目前还没有看到有特别成熟的解决方案或工具，因此采用Gearman+PHP+MySQL UDF的组合异步实现MySQL到Redis的数据复制。
MySQL到Redis数据复制方案
无论MySQL还是Redis，自身都带有数据同步的机制，比较常用的MySQL的Master/Slave模式，就是由Slave端分析Master的binlog来实现的，这样的数据复制其实还是一个异步过程，只不过当服务器都在同一内网时，异步的延迟几乎可以忽略。
那么理论上也可以用同样方式，分析MySQL的binlog文件并将数据插入Redis。但是这需要对binlog文件以及MySQL有非常深入的理解，同时由于binlog存在Statement/Row/Mixedlevel多种形式，分析binlog实现同步的工作量是非常大的。
因此这里选择了一种开发成本更加低廉的方式，借用已经比较成熟的MySQL UDF，将MySQL数据首先放入Gearman中，然后通过一个自己编写的PHP Gearman Worker，将数据同步到Redis。比分析binlog的方式增加了不少流程，但是实现成本更低，更容易操作。
Gearman的安装与使用
Gearman是一个支持分布式的任务分发框架。设计简洁，获得了非常广泛的支持。一个典型的Gearman应用包括以下这些部分：
Gearman Job Server：Gearman核心程序，需要编译安装并以守护进程形式运行在后台
Gearman Client：可以理解为任务的收件员，比如在后台执行一个发送邮件的任务，可以在程序中调用一个Gearman Client并传入邮件的信息，然后就可以将执行结果立即展示给用户，而任务本身会慢慢在后台运行。
Gearman Worker：任务的真正执行者，一般需要自己编写具体逻辑并通过守护进程方式运行，Gearman Worker接收到Gearman Client传递的任务内容后，会按顺序处理。
以前曾经介绍过类似的后台任务处理项目Resque。两者的设计其实非常接近，简单可以类比为：
Gearman Job Server：对应Resque的Redis部分
Gearman Client：对应Resque的Queue操作
Gearman Worker：对应Resque的Worker和Job
这里之所以选择Gearman而不是Resque是因为Gearman提供了比较好用的MySQL UDF，工作量更小。
安装Gearman及PHP Gearman扩展
以下均以Ubuntu12.04为例。
apt-get install gearman gearman-server libgearman-dev
检查Gearman的运行状况：
/etc/init.d/gearman-job-server status
* gearmand is running
说明Gearman已经安装成功。
PHP的Gearman扩展可以通过pecl直接安装
pecl install gearman
echo "extension=gearman.so">/etc/php5/conf.d/gearman.ini
service php5-fpm restart
但是实测发现ubuntu默认安装的gearman版本过低，直接运行pecl install gearman会报错
configure: error: libgearman version 1.1.0or later required
因此Gearman + PHP扩展建议通过编译方式安装，这里为了简单说明，选择安装旧版本扩展：
pecl install gearman-1.0.3
Gearman + PHP实例
为了更容易理解后文Gearman的运行流程，这里不妨从一个最简单的Gearman实例来说明，比如要进行一个文件处理的操作，首先编写一个Gearman Client并命名为client.php：
<?php
$client =newGearmanClient();
$client->addServer();
$client->doBackground('writeLog','Log content');
echo '文件已经在后台操作';
运行这个文件，相当于模拟用户请求一个Web页面后，将处理结束的信息返回用户：
php client.php
查看一下Gearman的状况：
(echo status ; sleep 0.1)| netcat127.0.0.14730
可以看到输出为
writeLog 100.
说明已经在Gearman中建立了一个名为writeLog的任务，并且有1个任务在队列等待中。
而上面的4列分别代表当前的Gearman的运行状态：
任务名称
在等待队列中的任务
正在运行的任务
正在运行的Worker进程
可以使用watch进行实时监控：
watch -n 1"(echo status; sleep 0.1) | nc 127.0.0.1 4730"
然后我们需要编写一个Gearman Worker命名为worker.php：
<?php
$worker =newGearmanWorker();
$worker->addServer();
$worker->addFunction('writeLog','writeLog');while($worker->work());function writeLog($job){
$log = $job->workload();file_put_contents(__DIR__ .'/gearman.log', $log ." ", FILE_APPEND | LOCK_EX);}
Worker使用一个while死循环实现守护进程，运行
php worker.php
可以看到Gearman状态变为：
writeLog 001
同时查看同目录下gearman.log，内容应为从Client传入的值Log content。
通过MySQL UDF + Trigger同步数据到Gearman
MySQL要实现与外部程序互通的最好方式还是通过MySQL UDF（MySQL user defined functions）来实现。为了让MySQL能将数据传入Gearman，这里使用了lib_mysqludf_json和gearman-mysql-udf的组合。
安装lib_mysqludf_json
使用lib_mysqludf_json的原因是因为Gearman只接受字符串作为入口参数，可以通过lib_mysqludf_json将MySQL中的数据编码为JSON字符串
apt-get install libmysqlclient-dev
wget https://github.com/mysqludf/lib_mysqludf_json/archive/master.zip
unzip master.zip
cd lib_mysqludf_json-master/
rm lib_mysqludf_json.so
gcc $(mysql_config --cflags)-shared -fPIC -o lib_mysqludf_json.so lib_mysqludf_json.c
可以看到重新编译生成了 lib_mysqludf_json.so 文件，此时需要查看MySQL的插件安装路径：
mysql -u root -pPASSWORD --execute="show variables like '%plugin%';"+---------------+------------------------+|Variable_name|Value|+---------------+------------------------+| plugin_dir |/usr/lib/mysql/plugin/|+---------------+------------------------+
然后将 lib_mysqludf_json.so 文件复制到对应位置：
cp lib_mysqludf_json.so /usr/lib/mysql/plugin/
最后登入MySQL运行语句注册UDF函数：
CREATE FUNCTION json_object RETURNS STRING SONAME 'lib_mysqludf_json.so';
安装gearman-mysql-udf
方法几乎一样：
apt-get install libgearman-dev
wget https://launchpad.net/gearman-mysql-udf/trunk/0.6/+download/gearman-mysql-udf-0.6.tar.gz
tar -xzf gearman-mysql-udf-0.6.tar.gz
cd gearman-mysql-udf-0.6./configure --with-mysql=/usr/bin/mysql_config
-libdir=/usr/lib/mysql/plugin/
make && make install
登入MySQL运行语句注册UDF函数：
CREATE FUNCTION gman_do_background RETURNS STRING SONAME 'libgearman_mysql_udf.so';
CREATE FUNCTION gman_servers_set RETURNS STRING SONAME 'libgearman_mysql_udf.so';
最后指定Gearman服务器的信息：
SELECT gman_servers_set('127.0.0.1:4730');
通过MySQL触发器实现数据同步
最终同步哪些数据，同步的条件，还是需要根据实际情况决定，比如将数据表data的数据在每次更新时同步，那么编写Trigger如下：
DELIMITER $$
CREATE TRIGGER datatoredis AFTER UPDATE ON data
FOR EACH ROW BEGIN
SET @ret=gman_do_background('syncToRedis', json_object(NEW.id as`id`, NEW.volume as`volume`));END$$
DELIMITER ;
尝试在数据库中更新一条数据查看Gearman是否生效。
Gearman PHP Worker将MySQL数据异步复制到Redis
Redis作为时下当热的NoSQL缓存解决方案无需过多介绍，其安装及使用也非常简单：
apt-get install redis-server
pecl install redis
echo "extension=redis.so">/etc/php5/conf.d/redis.ini
然后编写一个Gearman Worker：redis_worker.php
#!/usr/bin/env php<?
$worker =newGearmanWorker();
$worker->addServer();
$worker->addFunction('syncToRedis','syncToRedis');
$redis =newRedis();
$redis->connect('127.0.0.1',6379);while($worker->work());function syncToRedis($job){global $redis;
$workString = $job->workload();
$work = json_decode($workString);if(!isset($work->id)){returnfalse;}
$redis->set($work->id, $workString);}
最后需要将Worker在后台运行：
nohup php redis_worker.php &
通过这种方式将MySQL数据复制到Redis，经测试单Worker基本可以瞬时完成。
❽ 如何用php代码来操做redis
存储普通数据就用set，读取就用get。存储普通数据段码就用set，读取就用get。庆乱
但是存储之前最好是先判断一下。
下面是一段相关的代码。
<?php
$redis=newRedis();
$redis->connect('127.0.0.1',6379);//连接redis
if(!$redis->exists("content")){
//如果没有content这个key，就新建一个，并存储数据。
$redis->set("content",$content);
}else{
//如果存在，握差哪则读取content这个key里面的数据
echo$redis->get("content");
}
?>
推荐去三体教程看看，有redis存储读取数据方法的详解。
❾ PHP 如何在Redis中实现事物（事物提交和事物
public function index()
{
$serv = new \swoole_server("0.0.0.0", 9501);
$serv->set([
'worker_num' => 1,//一般设置为服务器CPU数的1-4倍
'task_worker_num' => 8,//task进程的数量
'daemonize' => 1,//以守护进程执行
'max_request' => 10000,//最大请求数量
"task_ipc_mode " => 2 //使用消息队列通信，并设置为争抢模式
]);
$serv->on('Receive', [$this, 'onReceive']);//接收任务，并投递
$serv->on('Task', [$this, 'onTask']);//可以在这个方法里面处理任务
$serv->on('Finish', [$this, 'onFinish']);//任务完成时候调用
$serv->start();
}
❿ redis使用php怎么进行更新
php/redis 更新缓存的问题 [ 2.0 版本 ]
if(!$redis->exists('cache'))
{
echo '写入缓存<br>';
$sql = "select * from user limit 0,3";
$rs = mysqli_query($connect,$sql) or die('db conn error');
while( $result = mysqli_fetch_assoc($rs) )
{
array_push($results,$result);
}
$cache = json_encode($results);
echo $cache;
$redis->set('cache',$cache,1200);
}
else
{
echo '读取缓存<br>';
echo $redis->get('cache');
}
后台进行add/update/delete时，自动让缓存失效。