如何使用php操作redis队列实例
对于不同的应用部 署,而只有一台数据库服务器来说,很“轻松”的就解决了这个并发的问题。所以现在考虑一下,是不是挪到应用上,避免数据库服务器也掺杂到业务上。就跟随本站小编一起去了解下吧,想了解更多相关信息请持续关注我们应届毕业生考试网!
Redis是一个比较高级的开源key-value存储系统,采用ANSI C实现。其与memcached类似,但是支持持久化数据存储,同时value支持多种类型:字符串 (同memcached中的value),列表 ,集合 (Set),有序集合 (OrderSet)和Hash 。所有的值类型均支持原子操作,如列表中追加弹出元素,集合中插入移除元素等。Rdids的数据大部分位于内存中,其读写效率非常高,其提供AOF(追加 式操作记录文件)和DUMP(定期数据备份)两种持久化方式。Redis支持自定义的VM(虚拟内存)机制,当数据容量超过内存时,可以将部分Value 存储到文件中。同时Redis支持Master-Slave机制,可以进行数据复制。
可以把Redis的list结构当队列来用.
从上面Redis的场景和作用来说,对于我们现在的开发活动,究竟能把Redis引入在那些场景,而不是把这么好的东东演变成“为了使用Redis,而Redis”的惨烈局面呢?当然,具体问题具体分析,这个真的很重要哈。
缓存?分布式缓存? 队列?分布式队列?
某些系统应用(例如,电信、银行和大型互联网应用等)都会使用到,当然,现在大行其道的memcache就是很好的证明;但从某一方面来 说,memcache是否能把两张囊括其中,而且能做到更好(没有实际的应用过,所以只是抛出)。但从Redis身上,我就能感觉到,Redis,就能把 队列和缓存两张都囊括其中,而且都不会产生并发环境下的困扰,因为Redis中的操作都是原子操作来着。
下面开始说说Redis中的队列(分布式)。
状况场景:
现在的项目,都是部署在多个服务器,或者多个IP上,而且前台经由F5分发,所以用户的请求究竟落在那一台的服务器上,是无法确定的'。对于项目 中,有一秒杀设计,刚开始没有考虑到这种部署,同时也是使用最容易处理的方式,直接给数据库表锁行记录(Oracle上的)。可以说,对于不同的应用部 署,而只有一台数据库服务器来说,很“轻松”的就解决了这个并发的问题。所以现在考虑一下,是不是挪到应用上,避免数据库服务器也掺杂到业务上。
比如,现在有2台应用服务器,1台数据库服务器。想法是,把Redis部署在数据库服务器上,两台服务器在操作并发缓存或者队列时,先从Redis服务器上取得在两台应用服务器的代理对象,再做入列出列的操作。
入队操作代码
<?php
$redis = new Redis();
$redis->connect('',6379);
while(True){
try{
$value = 'value_'('Y-m-d H:i:s');
$redis->LPUSH('key1',$value);
sleep(rand()%3);
echo $value."n";
}catch(Exception $e){
echo $e->getMessage()."n";
}
}
?>
出队操作代码
<?php
$redis = new Redis();
$redis->pconnect('',6379);
while(True){
try{
echo $redis->LPOP('key1')."n";
}catch(Exception $e){
echo $e->getMessage()."n";
}
sleep(rand()%3);
}?>
入队列操作文件 list_
<?php
$redis = getRedisInstance();//从Redis服务器拿到redis实例
$redis->connect('Redis服务器IP', 6379);
while (true) {
$redis->lPush('list1', 'A_'('Y-m-d H:i:s'));
sleep(rand()%3);
}
?>
执行# php list_ &
出队列操作 list_文件
<?php
$redis = getRedisInstance();//从Redis服务器拿到redis实例
$redis->pconnect('Redis服务器IP', 6379);
while(true) {
try {
var_export( $redis->blPop('list1', 10) );
} catch(Exception $e) {
//echo $e;
}
}
用Python实现:
1.入队列()
#!/usr/bin/env python
import time
from redis import Redis
redis = Redis(host='', port=6379)
while True:
now = time("%Y/%m/%d %H:%M:%S")
h('test_queue', now)
p(1)
2.出队列()
#!/usr/bin/env python
import sys
from redis import Redis
redis = Redis(host='', port=6379)
while True:
res = ('test_queue')
if res == None:
pass
else:
print str(res)
在操作时,注意,要操作的是同一个list对象。
-
如何实现yii2 数据库读写分离配置
导语:开始使用数据库首先需要配置数据库连接组件,下面小编给大家提供了如何实现yii2数据库读写分离配置,大家可以参考阅读,更多详情请关注应届毕业生考试网。开始使用数据库首先需要配置数据库连接组件,通过添加db组件到应用配置实现("基础的"Web应用是config/),DSN(Da...
-
PHP面试之php自带的几个防止sql注入的函数
毕业季又到了,同学们是不是正为此烦恼呢?以下是本站小编精心为大家整理的PHP面试之php自带的几个防止sql注入的函数,希望对大家有所帮助!更多内容请关注应届毕业生网!SQL注入攻击是黑客攻击网站最常用的手段。如果你的站点没有使用严格的用户输入检验,那么常容易...
-
PHP数据类型之数组变量详解
导语:PHP是一种通用开源脚本语言。语法吸收了C语言、Java和Perl的特点,利于学习,使用广泛,主要适用于Web开发领域。下面我们来看看PHP数据类型之数组变量详解,希望对大家有所帮助。PHP中的数组实际上是一个有序图,是一种把values映射到keys的类型。一个数组实际上就...
-
PHP的漏洞-如何防止PHP漏洞
漏洞无非这么几类,XSS、sql注入、命令执行、上传漏洞、本地包含、远程包含、权限绕过、信息泄露、cookie伪造、CSRF(跨站请求)等。下面是小编为大家带来的关于PHP的漏洞的知识,欢迎阅读。+sql注入其中占大头的自然是XSS与SQL注入,对于框架类型或者有公共文件的,建...