php语言 百分网手机站

php语言redis队列操作实例

时间:2020-09-14 10:05:54 php语言 我要投稿

php语言redis队列操作实例

  PHP是将程序嵌入到HTML文档中去执行,执行效率比完全生成HTML标记的CGI要高许多。下面是小编分享的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('127.0.0.1',6379);

  while(True){

  try{

  $value = 'value_'.date('Y-m-d H:i:s');

  $redis->LPUSH('key1',$value);

  sleep(rand()%3);

  echo $value." ";

  }catch(Exception $e){

  echo $e->getMessage()." ";

  }

  }

  ?>

  出队操作代码

  <?php

  $redis = new Redis();

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

  while(True){

  try{

  echo $redis->LPOP('key1')." ";

  }catch(Exception $e){

  echo $e->getMessage()." ";

  }

  sleep(rand()%3);

  }?>

  入队列操作文件 list_push.php

  <?php

  $redis = getRedisInstance();//从Redis服务器拿到redis实例

  $redis->connect('Redis服务器IP', 6379);

  while (true) {

  $redis->lPush('list1', 'A_'.date('Y-m-d H:i:s'));

  sleep(rand()%3);

  }

  ?>

  执行# php list_push.php &

  出队列操作 list_pop.php文件

  <?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.入队列(write.py)

  #!/usr/bin/env python

  import time

  from redis import Redis

  redis = Redis(host='127.0.0.1', port=6379)

  while True:

  now = time.strftime("%Y/%m/%d %H:%M:%S")

  redis.lpush('test_queue', now)

  time.sleep(1)

  2.出队列(read.py)

  #!/usr/bin/env python

  import sys

  from redis import Redis

  redis = Redis(host='127.0.0.1', port=6379)

  while True:

  res = redis.rpop('test_queue')

  if res == None:

  pass

  else:

  print str(res)

  在操作时,注意,要操作的是同一个list对象。


【php语言redis队列操作实例】相关文章:

PHP curl之操作实例08-17

实用的PHP语言实例代码08-29

C语言循环队列的表示与实例详解11-19

C语言文件操作解析详解及实例代码10-03

php简单伪静态实例09-28

php短域名互换实例10-01

php防盗链实例09-21

php操作mysql步骤09-19

PHP文件怎么操作09-01