php+Memcached实现简单留言板功能示例

2021-04-22 16:00水晶依恋 PHP教程

这篇文章主要介绍了php+Memcached实现简单留言板功能,结合实例形式较为详细的分析了php结合memcached实现留言板的具体步骤与相关操作技巧,需要的朋友可以参考下

本文实例讲述了php+memcached实现简单留言板功能。分享给大家供大家参考，具体如下：

mypdo.php

				?

									<?php

									class mypdo{

									  private $pdo;

									  function __construct()

									  {

									    $this->pdo = $this->getpdo();

									  }

									   /**

									   * createpdo

									   *

									   * @return pdo

									   */

									  public function getpdo()

									  {

									    $dbms='mysql';

									    $dbname='testdb';

									    $user='root';

									    $pwd='diligentyang';

									    $host='localhost';

									    $dsn="$dbms:host=$host;dbname=$dbname";

									    try{

									      $pdo=new pdo($dsn,$user,$pwd);

									    }catch(exception $e){

									      echo $e->getmessage().'<br>';

									      exit();

									    }

									    $pdo->setattribute(pdo::attr_emulate_prepares, false);

									    $pdo->exec("set names utf8");

									    return $pdo;

									  }

									   /**

									   * execute sql

									   *

									   * @param string $sql sql

									   * @param string $mode mode

									   *

									   * @return mixed

									   */

									  function query($sql = "", $mode = "array")

									  {

									    $sql = trim($sql);

									    if ($sql == "") {

									      $this->showerrors("the mothe query neet at least one param!");

									    }

									    $query = $this->pdo->query($sql);

									    if (!$query) {

									      $this->showerrors("the sql string is false");

									    }

									    if (strpos(strtolower($sql), "select") ===false) {

									      return $query;

									    }

									    switch ($mode) {

									    case 'array' :

									      $res = $query->fetchall(pdo::fetch_assoc);

									      break;

									    case 'object' :

									      $res = $query->fetchobject();

									      break;

									    case 'count':

									      $res = $query->rowcount();

									      break;

									    default:

									      $this->showerrors("sqlerror: please check your second param!");

									    }

									    return $res;

									  }

									  /**

									  * 提示错误

									  *

									  * @param string $str 错误提示内容

									  */

									  public function showerrors($str)

									  {

									    echo "<h1>$str<h1/>";

									    exit();

									  }

									}

showmessage.php

				?

									<?php

									include("mypdo.php");

									//连接memcached服务器

									$m = new memcached();

									$m->addserver('127.0.0.1',11211);

									//获取memcached中的list

									$res = $m->get("list");

									//如果没有数据，则从数据库中查出，并放入memcached中，如果有数据则直接输出

									if(!$res){

									  $mypdo = new mypdo();

									  $res = $mypdo->query("select * from message","array");

									  $m->set('list',$res,3600);

									}

									foreach($res as $val){

									  echo $val['title']."-------".$val['content']."<br>";

									}

									?>

									<a href="addmessage.php" rel="external nofollow" >添加留言</a>

addmessage.php

				?

									<form action="checkadd.php" method="post">

									  标题：<input type="text" name="title"><br>

									  内容：<input type="text" name="content"><br>

									  <input type="submit" value="提交">

									</form>

checkadd.php

				?

									<?php

									include("mypdo.php");

									//连接memcached服务器

									$m = new memcached();

									$m->addserver('127.0.0.1',11211);

									$title = $_post['title'];

									$content = $_post['content'];

									$mypdo = new mypdo();

									$res = $mypdo->query("insert into message(title,content) values('$title','$content')");

									if($res){//如果insert语句执行成功则清除memcache中的缓存

									  $m->delete("list");

									}

									header("location:showmessage.php");