redis简单队列

在 2015年4月29日上张贴由 BestLove

<?php
class Queue{
    static $redis = null;
    public function __construct() {
    }
    //
    public function setConnect($conn, $port) {
        if (Queue::$redis == null) {
            Queue::$redis = new \Redis();
            Queue::$redis->connect($conn, $port);
        }
    }
    //
    public function push($key, $callback, $params, $level=false) {
        $redis = Queue::$redis;
        if ($redis == null) {
            return;
        }
        $data = array(
            'callback' => $callback,
            'params' => $params
        );
        if ($level) {
            $redis->rPush($key, json_encode($data));
        } else {
            $redis->lPush($key, json_encode($data));
        }
    }
}
$queue = new Queue();
$queue->setConnect('127.0.0.1', 6379);
//测试插入
for ($i=200; $i < 300; ++$i) { 
    $queue->push('redisKey', array('Message', 'sendMess'), array('id' => $i, 'content' => '消息' . $i));
}
echo 'end';

<?php

class Queue{

static $redis = null;

public function __construct() {

}

public function setConnect($conn, $port) {

if (Queue::$redis == null) {

Queue::$redis = new \Redis();

Queue::$redis->connect($conn, $port);

}

public function push($key, $callback, $params, $level=false) {

$redis = Queue::$redis;

if ($redis == null) {

return;

}

$data = array(

'callback' => $callback,

'params' => $params

);

if ($level) {

$redis->rPush($key, json_encode($data));

} else {

$redis->lPush($key, json_encode($data));

}

$queue = new Queue();

$queue->setConnect('127.0.0.1', 6379);

//测试插入

for ($i=200; $i < 300; ++$i) {

$queue->push('redisKey', array('Message', 'sendMess'), array('id' => $i, 'content' => '消息' . $i));

}

echo 'end';

<?php
class Task{
    static $redis = null;
    private $key = null;
    public function __construct() {
    }
    //
    public function setKey($key) {
        $this->key = $key;
    }
    //
    public function setConnect($conn, $port) {
        if (Task::$redis == null) {
            Task::$redis = new \Redis();
            Task::$redis->connect($conn, $port);
        }
    }
    //
    public function doTask() {
        if ($this->key == null || Task::$redis == null) {
            return 'key or connect error';
        }
        while ( $rs = Task::$redis->rpop($this->key)) {
            $data = json_decode($rs, true);
            call_user_func_array($data['callback'], $data['params']);
        }
        return 'end';
    }
}
//
class Message{
    static $db = null;
    public static function sendMess($id, $content){
        if (Message::$db == null) {
            Message::$db = new \PDO('mysql:host=127.0.0.1;port=3306;dbname=test;', 'root', '', array(PDO::MYSQL_ATTR_INIT_COMMAND => "set names 'utf8'"));
        }
        Message::$db->query("insert into message values ('{$id}','{$content}')");
    }
}
//
$task = new Task();
$task->setConnect('127.0.0.1', 6379);
$task->setKey('redisKey');
$rs = $task->doTask();
var_dump($rs);

<?php

class Task{

static $redis = null;

private $key = null;

public function __construct() {

}

public function setKey($key) {

$this->key = $key;

}

public function setConnect($conn, $port) {

if (Task::$redis == null) {

Task::$redis = new \Redis();

Task::$redis->connect($conn, $port);

}

public function doTask() {

if ($this->key == null || Task::$redis == null) {

return 'key or connect error';

}

while ( $rs = Task::$redis->rpop($this->key)) {

$data = json_decode($rs, true);

call_user_func_array($data['callback'], $data['params']);

}

return 'end';

}

class Message{

static $db = null;

public static function sendMess($id, $content){

if (Message::$db == null) {

Message::$db = new \PDO('mysql:host=127.0.0.1;port=3306;dbname=test;', 'root', '', array(PDO::MYSQL_ATTR_INIT_COMMAND => "set names 'utf8'"));

}

Message::$db->query("insert into message values ('{$id}','{$content}')");

}

$task = new Task();

$task->setConnect('127.0.0.1', 6379);

$task->setKey('redisKey');

$rs = $task->doTask();

var_dump($rs);

redis-安全

在 2015年2月28日2015年3月3日上张贴由 BestLove

上文已经把常用的redis配置全部罗列了一遍。

此文着重讲一下redis的密码配置以及限制ip配置。

配置的时候我碰到了一个坑，因为我使用的是lnmp的redis.sh一键安装。在安装的时候没有指定redis的配置文件，导致怎么修改配置文件都没有效果。。。

所以，首先先要指定一下配置文件。

//找到redis进程的进程id 进程id为24465
[root@iZ23t2zaa4vZ bin]# ps aux | grep redis
//将当前redis进程杀掉
[root@iZ23t2zaa4vZ bin]# ps aux | kill -9 24465
//将redis配置为守护进程(建议这么干)
[root@iZ23t2zaa4vZ etc]# vim redis.conf   修改 daemonize yes
//启动redis并指定加载配置文件
[root@iZ23t2zaa4vZ bin]# ./redis-server /usr/local/***/redis.conf

//找到redis进程的进程id 进程id为24465

[root@iZ23t2zaa4vZ bin]# ps aux | grep redis

//将当前redis进程杀掉

[root@iZ23t2zaa4vZ bin]# ps aux | kill -9 24465

//将redis配置为守护进程(建议这么干)

[root@iZ23t2zaa4vZ etc]# vim redis.conf 修改 daemonize yes

//启动redis并指定加载配置文件

[root@iZ23t2zaa4vZ bin]# ./redis-server /usr/local/***/redis.conf

此时，可以对配置文件进行修改了。

//修改redis配置文件
[root@iZ23t2zaa4vZ etc]# vim redis.conf
修改 requirepass 你的密码
修改 bind 127.0.0.1    //表示redis只能本机访问(可配置其它内网ip访问，可配置多个)
//重启redis
[root@iZ23t2zaa4vZ etc]# /ect/init.d/redis restart

//此时，redis已经配置完成
<?php 
$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);
//这里需要加入密码才能访问redis，并且外网无法连接
$redis->auth('你的密码');
echo $redis->get('test');

//修改redis配置文件

[root@iZ23t2zaa4vZ etc]# vim redis.conf

修改 requirepass 你的密码

修改 bind 127.0.0.1 //表示redis只能本机访问(可配置其它内网ip访问，可配置多个)

//重启redis

[root@iZ23t2zaa4vZ etc]# /ect/init.d/redis restart

//此时，redis已经配置完成

<?php

$redis = new \Redis();

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

//这里需要加入密码才能访问redis，并且外网无法连接

$redis->auth('你的密码');

echo $redis->get('test');

附：

/etc/init.d/redis start //开启

/etc/init.d/redis stop //关闭

/etc/init.d/redis restart //重启

redis–配置

在 2015年2月28日2015年2月28日上张贴由 BestLove

本文摘自：http://www.cnblogs.com/wenanry/archive/2012/02/26/2368398.html

1. Redis默认不是以守护进程的方式运行，可以通过该配置项修改，使用yes启用守护进程

daemonize no

2. 当Redis以守护进程方式运行时，Redis默认会把pid写入/var/run/redis.pid文件，可以通过pidfile指定

pidfile /var/run/redis.pid

3. 指定Redis监听端口，默认端口为6379，作者在自己的一篇博文中解释了为什么选用6379作为默认端口，因为6379在手机按键上MERZ对应的号码，而MERZ取自意大利歌女Alessia Merz的名字

port 6379

4. 绑定的主机地址

bind 127.0.0.1

5.当客户端闲置多长时间后关闭连接，如果指定为0，表示关闭该功能

timeout 300

6. 指定日志记录级别，Redis总共支持四个级别：debug、verbose、notice、warning，默认为verbose

loglevel verbose

7. 日志记录方式，默认为标准输出，如果配置Redis为守护进程方式运行，而这里又配置为日志记录方式为标准输出，则日志将会发送给/dev/null

logfile stdout

8. 设置数据库的数量，默认数据库为0，可以使用SELECT <dbid>命令在连接上指定数据库id

databases 16

9. 指定在多长时间内，有多少次更新操作，就将数据同步到数据文件，可以多个条件配合

save <seconds> <changes>

Redis默认配置文件中提供了三个条件：

save 900 1

save 300 10

save 60 10000

分别表示900秒（15分钟）内有1个更改，300秒（5分钟）内有10个更改以及60秒内有10000个更改。

10. 指定存储至本地数据库时是否压缩数据，默认为yes，Redis采用LZF压缩，如果为了节省CPU时间，可以关闭该选项，但会导致数据库文件变的巨大

rdbcompression yes

11. 指定本地数据库文件名，默认值为dump.rdb

dbfilename dump.rdb

12. 指定本地数据库存放目录

dir ./

13. 设置当本机为slav服务时，设置master服务的IP地址及端口，在Redis启动时，它会自动从master进行数据同步

slaveof <masterip> <masterport>

14. 当master服务设置了密码保护时，slav服务连接master的密码

masterauth <master-password>

15. 设置Redis连接密码，如果配置了连接密码，客户端在连接Redis时需要通过AUTH <password>命令提供密码，默认关闭

requirepass foobared

16. 设置同一时间最大客户端连接数，默认无限制，Redis可以同时打开的客户端连接数为Redis进程可以打开的最大文件描述符数，如果设置 maxclients 0，表示不作限制。当客户端连接数到达限制时，Redis会关闭新的连接并向客户端返回max number of clients reached错误信息

maxclients 128

17. 指定Redis最大内存限制，Redis在启动时会把数据加载到内存中，达到最大内存后，Redis会先尝试清除已到期或即将到期的Key，当此方法处理后，仍然到达最大内存设置，将无法再进行写入操作，但仍然可以进行读取操作。Redis新的vm机制，会把Key存放内存，Value会存放在swap区

maxmemory <bytes>

18. 指定是否在每次更新操作后进行日志记录，Redis在默认情况下是异步的把数据写入磁盘，如果不开启，可能会在断电时导致一段时间内的数据丢失。因为 redis本身同步数据文件是按上面save条件来同步的，所以有的数据会在一段时间内只存在于内存中。默认为no

appendonly no

19. 指定更新日志文件名，默认为appendonly.aof

appendfilename appendonly.aof

20. 指定更新日志条件，共有3个可选值：
no：表示等操作系统进行数据缓存同步到磁盘（快）
always：表示每次更新操作后手动调用fsync()将数据写到磁盘（慢，安全）
everysec：表示每秒同步一次（折衷，默认值）

appendfsync everysec

21. 指定是否启用虚拟内存机制，默认值为no，简单的介绍一下，VM机制将数据分页存放，由Redis将访问量较少的页即冷数据swap到磁盘上，访问多的页面由磁盘自动换出到内存中（在后面的文章我会仔细分析Redis的VM机制）

vm-enabled no

22. 虚拟内存文件路径，默认值为/tmp/redis.swap，不可多个Redis实例共享

vm-swap-file /tmp/redis.swap

23. 将所有大于vm-max-memory的数据存入虚拟内存,无论vm-max-memory设置多小,所有索引数据都是内存存储的(Redis的索引数据就是keys),也就是说,当vm-max-memory设置为0的时候,其实是所有value都存在于磁盘。默认值为0

vm-max-memory 0

24. Redis swap文件分成了很多的page，一个对象可以保存在多个page上面，但一个page上不能被多个对象共享，vm-page-size是要根据存储的数据大小来设定的，作者建议如果存储很多小对象，page大小最好设置为32或者64bytes；如果存储很大大对象，则可以使用更大的page，如果不确定，就使用默认值

vm-page-size 32

25. 设置swap文件中的page数量，由于页表（一种表示页面空闲或使用的bitmap）是在放在内存中的，，在磁盘上每8个pages将消耗1byte的内存。

vm-pages 134217728

26. 设置访问swap文件的线程数,最好不要超过机器的核数,如果设置为0,那么所有对swap文件的操作都是串行的，可能会造成比较长时间的延迟。默认值为4

vm-max-threads 4

27. 设置在向客户端应答时，是否把较小的包合并为一个包发送，默认为开启

glueoutputbuf yes

28. 指定在超过一定的数量或者最大的元素超过某一临界值时，采用一种特殊的哈希算法

hash-max-zipmap-entries 64

hash-max-zipmap-value 512

29. 指定是否激活重置哈希，默认为开启（后面在介绍Redis的哈希算法时具体介绍）

activerehashing yes

30. 指定包含其它的配置文件，可以在同一主机上多个Redis实例之间使用同一份配置文件，而同时各个实例又拥有自己的特定配置文件

include /path/to/local.conf

redis–简单了解

在 2015年2月27日2016年1月29日上张贴由 BestLove

Redis可以理解为内存缓存，但它能使用硬盘持久化存储。Redis是单线程的。

Redis最为常用的数据类型主要有以下五种：

String
Hash
List
Set
Sorted set

String：

String 数据结构是简单的key-value类型，value其实不仅是String，也可以是数字.

常用命令: set,get,decr,incr,mget 等。

应用场景：普通的key/value存储。

Hash

常用命令：hget,hset,hgetall 等。

应用场景：要通过redis存储某一个商品信息。包括id、name、price、sell_num等。此时如果使用String存储的话，通常的做法是以id为key，序列化之后的值为value。这样每次存取或修改都需要序列化跟反序列化一次，不仅增大了开销，而且在并发的情况下可能会出错(A用户正在序列化、B用户正在反序列化)。如果以多字段组合为key的话，可以避免序列化和反序列化，但是明显是不可取的，因为会产生太多的key，浪费内存。所以，此时使用Hash方式存储是最为合适的。Hash方式存储还是以id为key，但是对应的value是一个Hashmap，这样就可以通过id(key)->field(Hashmap的key)来定位到相应数据了。注意：hgetall可以直接取全部Hashmap的数据，但是如果内部Map的成员很多，那么涉及到遍历整个内部Map的操作，由于Redis单线程模型的缘故，这个遍历操作可能会比较耗时，而另其它客户端的请求完全不响应，这点需要格外注意。

上面已经说到Redis Hash对应Value内部实际就是一个HashMap，实际这里会有2种不同实现，这个Hash的成员比较少时Redis为了节省内存会采用类似一维数组的方式来紧凑存储，而不会采用真正的HashMap结构，对应的value redisObject的encoding为zipmap,当成员数量增大时会自动转成真正的HashMap,此时encoding为ht。

List

常用命令：lpush,rpush,lpop,rpop,lrange等。

应用场景：可以利用List的PUSH操作，将任务存在List中，然后工作线程再用POP操作将任务取出进行执行。Redis还提供了操作List中某一段的api，你可以直接查询，删除Lists中某一段的元素。

Redis list的实现为一个双向链表，即可以支持反向查找和遍历，更方便操作，不过带来了部分额外的内存开销，Redis内部的很多实现，包括发送缓冲队列等也都是用的这个数据结构。

常用命令：sadd,spop,smembers,sunion 等。

应用场景：Redis set对外提供的功能与list类似是一个列表的功能，特殊之处在于set是可以自动排重的，当你需要存储一个列表数据，又不希望出现重复数据时，set是一个很好的选择，并且set提供了判断某个成员是否在一个set集合内的重要接口，这个也是list所不能提供的。Set集合的概念就是一堆不重复值的组合。利用Redis提供的Set数据结构，可以存储一些集合性的数据，比如在微博应用中，可以将一个用户所有的关注人存在一个集合中，将其所有粉丝存在一个集合。Redis还为集合提供了求交集、并集、差集等操作，可以非常方便的实现如共同关注、共同喜好、二度好友等功能，对上面的所有集合操作，你还可以使用不同的命令选择将结果返回给客户端还是存集到一个新的集合中。

set 的内部实现是一个 value永远为null的HashMap，实际就是通过计算hash的方式来快速排重的，这也是set能提供判断一个成员是否在集合内的原因。

Sorted set

常用命令：zadd,zrange,zrem,zcard等

应用场景：Redis sorted set的使用场景与set类似，区别是set不是自动有序的，而sorted set可以通过用户额外提供一个优先级(score)的参数来为成员排序，并且是插入有序的，即自动排序。当你需要一个有序的并且不重复的集合列表，那么可以选择sorted set数据结构。另外还可以用Sorted Set来做带权重的队列，比如普通消息的score为1，重要消息的score为2，然后工作线程可以选择按score的倒序来获取工作任务。让重要的任务优先执行。

Redis sorted set的内部使用HashMap和跳跃表(SkipList)来保证数据的存储和有序，HashMap里放的是成员到score的映射，而跳跃表里存放的是所有的成员，排序依据是HashMap里存的score,使用跳跃表的结构可以获得比较高的查找效率，并且在实现上比较简单。

redis–phpredis扩展

在 2015年2月27日2015年2月27日上张贴由 BestLove

下载phpredis：https://github.com/nicolasff/phpredis

通过ftp上传到服务器

[root@iZ23t2zaa4vZ src]# cd /lnmp/download/phpredis/
//解压缩
[root@iZ23t2zaa4vZ phpredis]# unzip phpredis-master.zip
//进入安装目录
[root@iZ23t2zaa4vZ phpredis]# cd phpredis-master/
//生成编译文件
[root@iZ23t2zaa4vZ phpredis-master]# phpize
//配置
[root@iZ23t2zaa4vZ phpredis-master]# ./configure --with-php-config=/usr/local/php/bin/php-config
//编译
[root@iZ23t2zaa4vZ phpredis-master]# make
//安装
[root@iZ23t2zaa4vZ phpredis-master]# make install
//配置php.ini
[root@iZ23t2zaa4vZ phpredis-master]# cd /usr/local/php/etc/
vim php.ini  加入extension=redis.so
//重启lnmp
[root@iZ23t2zaa4vZ etc]# /root/lnmp restart

[root@iZ23t2zaa4vZ src]# cd /lnmp/download/phpredis/

//解压缩

[root@iZ23t2zaa4vZ phpredis]# unzip phpredis-master.zip

//进入安装目录

[root@iZ23t2zaa4vZ phpredis]# cd phpredis-master/

//生成编译文件

[root@iZ23t2zaa4vZ phpredis-master]# phpize

//配置

[root@iZ23t2zaa4vZ phpredis-master]# ./configure --with-php-config=/usr/local/php/bin/php-config

//编译

[root@iZ23t2zaa4vZ phpredis-master]# make

//安装

[root@iZ23t2zaa4vZ phpredis-master]# make install

//配置php.ini

[root@iZ23t2zaa4vZ phpredis-master]# cd /usr/local/php/etc/

vim php.ini 加入extension=redis.so

//重启lnmp

[root@iZ23t2zaa4vZ etc]# /root/lnmp restart

<?php
$redis = new \Redis();
$redis->connect('127.0.0.1',6379);
//由于上文中已给test设置了一个hello world
//最终输出的结果也是hello world 表示配置成功
echo $redis->get('test');

<?php

$redis = new \Redis();

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

//由于上文中已给test设置了一个hello world

//最终输出的结果也是hello world 表示配置成功

echo $redis->get('test');

redis–安装

在 2015年2月27日2015年2月27日上张贴由 BestLove

redis官网地址：http://redis.io/download 建议下载stable版本

lnmp官网地址：http://www.lnmp.org/

http://lnmp.org/faq/lnmp-software-list.html

/lnmp/download/lnmp1.1-full/redis.sh

1	/lnmp/download/lnmp1.1-full/redis.sh

//下载压缩包
wget http://download.redis.io/releases/redis-2.8.8.tar.gz
//解压缩
tar -zxvf redis-2.8.8.tar.gz 
//编译安装
cd redis-2.8.8
make
cd src
make install

//下载压缩包

wget http://download.redis.io/releases/redis-2.8.8.tar.gz

//解压缩

tar -zxvf redis-2.8.8.tar.gz

//编译安装

cd redis-2.8.8

make

cd src

make install

//启用redis
cd src
./redis-server
//启用客户端测试
[root@iZ23t2zaa4vZ src]# ./redis-cli 
127.0.0.1:6379> set test hello world
(error) ERR syntax error
127.0.0.1:6379> set test 'hello world'
OK
127.0.0.1:6379> get test
"hello world"

//启用redis

cd src

./redis-server

//启用客户端测试

[root@iZ23t2zaa4vZ src]# ./redis-cli

127.0.0.1:6379> set test hello world

(error) ERR syntax error

127.0.0.1:6379> set test 'hello world'

127.0.0.1:6379> get test

"hello world"

唐晓锋–BLOG

This is just a personal note.

分类：redis

redis简单队列

redis-安全

redis–配置

redis–简单了解

redis–phpredis扩展

redis–安装