默认的

lyshfire · Jul 9, 2016 · fadcd87 · fadcd87
1 parent 7725eb8
commit fadcd87
Show file tree

Hide file tree

Showing 7 changed files with 1,882 additions and 284 deletions.
diff --git a/Backend/Common/Conf/config.php b/Backend/Common/Conf/config.php
@@ -26,8 +26,13 @@
         'auth' => 'mastertestpassword',
     ),
     'REDIS_SLAVE1' => array(
-        'HOST' => '127.0.0.1',
-        'PORT' => 6000,
-        'AUTH' => '',
-    )
+        'host' => '127.0.0.1',
+        'port' => 6000,
+        'auth' => '',
+    ),
+     'REDIS_SLAVE2' => array(
+    'host' => '127.0.0.1',
+    'port' => 6001,
+    'auth' => '',
+)
 );
diff --git a/Backend/Home/Controller/RedisController.class.php b/Backend/Home/Controller/RedisController.class.php
@@ -1,9 +1,136 @@
 <?php
 namespace Home\Controller;
+use Org\Util\Redis;
 use Think\Controller;
 class RedisController extends Controller {
+    public static $configMaster = array('host'=>'127.0.0.1','port'=>6379,'auth'=>'mastertestpassword');
+    public $redis;
+
+    public function __construct()
+    {
+        parent::__construct();
+
+    }
+
     public function index()
     {
         echo 'redis';
     }
+
+    public function RedisTest()
+    {
+        /**
+         * Write Redis
+         */
+        $configMaster = array('host'=>'127.0.0.1','port'=>6379,'auth'=>'mastertestpassword');
+        $redisWrite = Redis::getInstance($configMaster);
+        /*$redisWrite->zAdd('WanYin',90,'语文',100,'数学');
+        $redisWrite->sAdd();*/
+        /**
+         * Read Redis Data
+         */
+        var_dump(C('REDIS_MASTER'));
+        $redisRead = Redis::getInstance(C('REDIS_MASTER'));
+        var_dump($redisRead->keys('*'));
+    }
+
+    public function readRedis(){
+        $redis = Redis::getInstance(C('REDIS_SLAVE2'));
+        var_dump($redis->keys('*'));
+    }
+
+    /**
+     * 对某人进行关注
+     * void
+     * @param $targetUser
+     * @param $user
+     */
+    public function follow($targetUser,$user){
+        $configMaster = array('host'=>'127.0.0.1','port'=>6379,'auth'=>'mastertestpassword');
+        $redisWrite = Redis::getInstance($configMaster);
+        //自己关注的列表
+        $followingKey = 'following:'.$user['uid'];
+        $redisWrite->sadd( $followingKey, $targetUser['uid']);
+        //被关注者的粉丝列表
+        $followersKey = 'followers:'.$targetUser['uid'];
+        $redisWrite->sadd( $followersKey, $user['uid']);
+        $followers = $redisWrite->sCard($followersKey); //获取粉丝数
+        $redisWrite->hset( 'user:'.$targetUser['uid'], 'fans', $followers);
+    }
+
+    /**
+     * 对某人取消关注
+     * void
+     * @param $targetUser
+     * @param $user
+     */
+    function unfollow($targetUser,$user){
+        $configMaster = array('host'=>'127.0.0.1','port'=>6379,'auth'=>'mastertestpassword');
+        $redisWrite = Redis::getInstance($configMaster);
+        //自己关注的列表
+        $followingKey='following:'.$user['uid'];
+        $redisWrite->sRem( $followingKey, $targetUser['uid']);
+        //被关注者的粉丝列表
+        $followersKey='followers:'.$targetUser['uid'];
+        $redisWrite->sRem( $followersKey, $user['uid']);
+        $followers = $this->redis->sCard($followersKey);
+        //获取粉丝数
+        $redisWrite->hset( 'user:'.$targetUser['uid'], 'fans', $followers);
+    }
+
+    /**
+     * 用户自己的微博数据
+     * array
+     * @param $uid
+     * @return array
+     */
+    function getUserPosts($uid){
+        $postList = array();
+        $post_ids = $this->redis->lRange("$uid:posts",0,-1);
+        //获取微博的内容
+        foreach ($post_ids as $post_id)
+        {
+            $post_line = $this->redis->get("post:$post_id");
+            $postList[] = $this->convert($post_line);
+        }
+        return $postList;
+    }
+
+    /**
+     * mixed
+     * @return mixed
+     */
+    function getNextPostId(){
+        $this->redis->incr('next_post_id');
+        return $this->redis->get('next_post_id');
+    }
+
+    /**
+     * void
+     * @param $content
+     */
+    function add($content){
+        #创建投稿id
+        $next_post_id = $this->getNextPostId();
+        $uid = $this->base->user['uid'];
+        #保存投稿数据
+        $this->redis->set('post:'.$next_post_id, $uid.'|'.$this->base->time.'|'.$content);
+        #包含全部用户微博的时间线中追加投稿id
+        $this->redis->lPush('timeline',$next_post_id);
+        #所有粉丝的时间线中追加投稿id,包括自己
+        $followers = $this->redis->sMembers("followers:$uid");
+        $followers[]= $uid; //加上自己
+        foreach ($followers as $follower_uid) {
+            $this->redis->lPush("timeline:$follower_uid", $next_post_id );
+        }
+        #往自己的微博数据中追加投稿id
+        $this->redis->lPush("$uid:posts", $next_post_id );
+        #增加发微博的条数
+        $this->redis->hIncrBy( "user:$uid", 'posts', 1);
+
+    }
+
+    public function getDefine(){
+       var_dump(C('REDIS_CONFIG')['HOST']);
+    }
 }