Detailed explanation of how PHP publishes Weibo based on Redis message queue-PHP Tutorial-php.cn

Detailed explanation of how PHP publishes Weibo based on Redis message queue

墨辰丷

Release： 2023-03-27 15:48:02

Original

1570 people have browsed it

This article mainly introduces the method of publishing Weibo in PHP based on the Redis message queue. It analyzes the installation, connection, reading, insertion and other related operation skills of the PHP redis database in the form of examples. Friends in need can refer to the following

phpRedisAdmin:github address Graphical management interface

git clone [url]https://github.com/ErikDubbelboer/phpRedisAdmin.git[/url]
cd phpRedisAdmin
git clone [url]https://github.com/nrk/predis.git[/url] vendor

Copy after login

First install the above-mentioned Redis graphical management interface, which can conveniently manage Redis Data

In order to reduce the number of Mysql concurrency, first store the user's Weibo in Redis

Assume that the user needs three fields when posting, uid( User ID number), username (user name), content ('user's comment')

For example, the user passes the following information

//此处需要安装phpredis
$redis = new Redis();
$redis->connect(&#39;127.0.0.1&#39;, 6379);
// 连接redis
$web_info= array(
&#39;uid&#39; => &#39;123456&#39;,
&#39;username&#39; => &#39;123&#39;,
&#39;content&#39; =>&#39;123&#39;
);
//将数组转成json来存储
$list = json_encode($web_info);
//lpush向KEY对应的头部添加一个字符串元素
$redis->lpush(&#39;weibo_lists&#39;,$list);
$redis->close();
///var_dump(json_encode($web_info));
var_dump($list);
?>

Copy after login

Here you can see that our redis already has data

//创建一个PDO数据库链接 data.php
class qq{
 public function post($uid=&#39;&#39;,$username=&#39;&#39;,$content=&#39;&#39;){
  try{
   $dsn = "mysql:host;dbname=localhost;dbname=test";
   $db = new PDO($dsn,&#39;root&#39;,&#39;root&#39;);
   $db->exec("SET NAMES UTF8");
   $sql ="insert into test(uid,username,content)values(&#39;$uid&#39;,&#39;$username&#39;,&#39;$content&#39;)";
   $db->exec($sql);
  }catch(PDOException $e){
   $e->getMessage();
  }
 }
}

Copy after login

//处理redis数据库的数据 并把数据放到MYSQL数据库中
include "data.php";
$qq = new qq();
$redis = new Redis();
$redis->connect(&#39;127.0.0.1&#39;, 6379);
//返回的列表的大小。如果列表不存在或为空，该命令返回0。如果该键不是列表，该命令返回FALSE
if($redis -> lsize(&#39;weibo_lists&#39;)){
 //从LIST头部删除并返回删除数据
 $info = $redis->rPop(&#39;weibo_lists&#39;);
 $info = json_decode($info);
 $qq->post($info->uid,$info->username,$info->content);
}
$redis->close();
var_dump($info);
?>

Copy after login

We can see that the database already has data

The above is the entire content of this article, I hope it will be helpful to everyone's study.

Related recommendations:

PHPFunction date and time function date() detailed explanation_php basics

Summary of php time calculation related issues_php skills

##php stream_get_meta_data return value_php basics

The above is the detailed content of Detailed explanation of how PHP publishes Weibo based on Redis message queue. For more information, please follow other related articles on the PHP Chinese website!