使用PHP在站点下构建类似Twitter的系统

				
CREATE TABLE `users` (
`id` INT NOT NULL AUTO_INCREMENT PRIMARY KEY ,
`username` VARCHAR( 255 ) NOT NULL ,
`email` VARCHAR( 255 ) NOT NULL ,
`password` VARCHAR( 8 ) NOT NULL ,
`status` ENUM( 'active', 'inactive' ) NOT NULL
) ENGINE = MYISAM ;

				
CREATE TABLE `posts` (
`id` INT NOT NULL AUTO_INCREMENT PRIMARY KEY ,
`user_id` INT NOT NULL ,
`body` VARCHAR( 140 ) NOT NULL ,
`stamp` DATETIME NOT NULL
) ENGINE = MYISAM ;

				
CREATE TABLE `following` (
`user_id` INT NOT NULL ,
`follower_id` INT NOT NULL ,
PRIMARY KEY ( `user_id` , `follower_id` )
) ENGINE = MYISAM ;

				
$SERVER = 'localhost';
$USER = 'username';
$PASS = 'password';
$DATABASE = 'microblogger';


if (!($mylink = mysql_connect( $SERVER, $USER, $PASS))){
	echo  "
Sorry, could not connect to database.


	Please contact your system's admin for more help\n";
	exit;
}

mysql_select_db( $DATABASE );

				
function add_post($userid,$body){
	$sql = "insert into posts (user_id, body, stamp) 
			values ($userid, '". mysql_real_escape_string($body). "',now())";

	$result = mysql_query($sql);
}

				
session_start();
include_once('header.php');
include_once('functions.php');

$_SESSION['userid'] = 1;
?>
        "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">


	
	

vbody>

if (isset($_SESSION['message'])){
	echo "". $_SESSION['message']."";
	unset($_SESSION['message']);
}
?>

Your status:

				
session_start();
include_once("header.php");
include_once("functions.php");

$userid = $_SESSION['userid'];
$body = substr($_POST['body'],0,140);

add_post($userid,$body);
$_SESSION['message'] = "Your post has been added!";

header("Location:index.php");
?>

				
function show_posts($userid){
	$posts = array();

	$sql = "select body, stamp from posts
	 where user_id = '$userid' order by stamp desc";
	$result = mysql_query($sql);

	while($data = mysql_fetch_object($result)){
		$posts[] = array( 	'stamp' => $data->stamp, 
							'userid' => $userid, 
							'body' => $data->body
					);
	}
	return $posts;

}

				
$posts = show_posts($_SESSION['userid']);

if (count($posts)){
?>

foreach ($posts as $key => $list){
	echo "\n";
	echo "\n";
	echo "\n";
	echo "\n";
}
?>
".$list['userid'] ."
".$list['body'] ."
\n";
	echo "".$list['stamp'] ."

}else{
?>
You haven't posted anything yet!

}
?>

				
function show_users(){
	$users = array();
	$sql = "select id, username from users where status='active' order by username";
	$result = mysql_query($sql);

	while ($data = mysql_fetch_object($result)){
		$users[$data->id] = $data->username;
	}
	return $users;
}

				
session_start();
include_once("header.php");
include_once("functions.php");

?>
        "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">


	
	



List of Users
$users = show_users();

if (count($users)){
?>

foreach ($users as $key => $value){
	echo "\n";
	echo "\n";
	echo "\n";
	echo "\n";
}
?>
".$key ."
".$value ." follow

}else{
?>
There are no users in the system!

}
?>

see list of users

				
function following($userid){
	$users = array();

	$sql = "select distinct user_id from following
			where follower_id = '$userid'";
	$result = mysql_query($sql);

	while($data = mysql_fetch_object($result)){
		array_push($users, $data->user_id);

	}

	return $users;

}

				
$users = show_users();
$following = following($_SESSION['userid']);

if (count($users)){
?>

foreach ($users as $key => $value){
	echo "\n";
	echo "\n";
	echo "\n";
	echo "\n";
}
?>
".$key ."
".$value;
	if (in_array($key,$following)){
		echo " 
		unfollow
		";
	}else{
		echo " 
		follow
		";
	}
	echo "





接下来的步骤很简单：创建 follow 和 unfollow 链接使用的 action.php 文件。该文件接受两个?GET?参数：一个用于用户 ID，另一个用于 follow 或 unfollow。如清单 14 所示，这个文件和 add.php 文件一样简短。


清单 14. action.php 文件



				
session_start();
include_once("header.php");
include_once("functions.php");

$id = $_GET['id'];
$do = $_GET['do'];

switch ($do){
	case "follow":
		follow_user($_SESSION['userid'],$id);
		$msg = "You have followed a user!";
	break;

	case "unfollow":
		unfollow_user($_SESSION['userid'],$id);
		$msg = "You have unfollowed a user!";
	break;

}
$_SESSION['message'] = $msg;

header("Location:index.php");
?>






可以看到，这里取决于之前选择的链接，采取两种不同的动作 —?follow_user()?或unfollow_user()。然后，设置一条消息，并将用户重定向回 index.php 页面。用户回到 index.php 页面后，不仅可以看到自己的消息，还可以看到他们追随的用户最近添加的消息。或者，如果之前选择 unfollow 链接，那么那个用户的消息将从列表中消失。稍后需要在 index.php 中添加这点代码。现在，将?follow_user()?和?unfollow_user()?函数添加到 functions.php 中。
对 于这两个函数要小心一点。不能只是因为用户单击了那个链接，就盲目地追随或放弃追随一个用户。首先，需要检查 following 表中是否存在这样的关系。如果存在，那么可以忽略请求（单击 follow 链接时），或者接受请求（单击 unfollow 链接时）。为简单起见，编写两种情况下都可以使用的一个check_count()?函数，如下面的清单所示。


清单 15.?check_count()?函数



				
function check_count($first, $second){
	$sql = "select count(*) from following 
			where user_id='$second' and follower_id='$first'";
	$result = mysql_query($sql);

	$row = mysql_fetch_row($result);
	return $row[0];

}

function follow_user($me,$them){
	$count = check_count($me,$them);

	if ($count == 0){
		$sql = "insert into following (user_id, follower_id) 
				values ($them,$me)";

		$result = mysql_query($sql);
	}
}


function unfollow_user($me,$them){
	$count = check_count($me,$them);

	if ($count != 0){
		$sql = "delete from following 
				where user_id='$them' and follower_id='$me'
				limit 1";

		$result = mysql_query($sql);
	}
}






接下来的步骤很容易：在主页上显示当前用户正在追随的其他用户的列表。虽然已经有了一个show_users()?函数，但那个函数是显示所有?用户。可以通过增加一个非必需的参数，轻松地改变这个函数的用途。这个参数是一个用户 ID，可以用该参数将用户列表限制为该用户 ID 所追随的那些用户。
清单 16 中重新编写的代码所做的事情是检查传入的?$user_id?参数。如果该用户 ID 大于 0，则使用一个查询获取此 ID 追随的所有用户的 ID。使用?implode()?函数将获得的数组转换为一个以逗号分隔的列表。然后将这个字符串 — 大致为?and id in (1,2,3...n)?— 插入到已有的 SQL 查询中，从而将用户列表限制为该用户正在追随的那些用户。


清单 16. 重新编写的代码，用于限制通过查询获得的用户列表



				
function show_users($user_id=0){

	if ($user_id > 0){
		$follow = array();
		$fsql = "select user_id from following
				where follower_id='$user_id'";
		$fresult = mysql_query($fsql);

		while($f = mysql_fetch_object($fresult)){
			array_push($follow, $f->user_id);
		}

		if (count($follow)){
			$id_string = implode(',', $follow);
			$extra =  " and id in ($id_string)";

		}else{
			return array();
		}

	}

	$users = array();
	$sql = "select id, username from users 
		where status='active' 
		$extra order by username";


	$result = mysql_query($sql);

	while ($data = mysql_fetch_object($result)){
		$users[$data->id] = $data->username;
	}
	return $users;
}






接下来，将清单 17 中的代码添加到主页中，用于显示所有那些被追随的用户。


清单 17. 修改 index.php 以显示被追随的用户



				
Users you're following


$users = show_users($_SESSION['userid']);

if (count($users)){
?>

foreach ($users as $key => $value){
	echo "
".$value."
\n";
}
?>

}else{
?>
You're not following anyone yet!

}
?>













添加其他用户?贴子
要将其他用户的贴子添加到一个用户的时间表（timeline）上，只需重用之前编写的一些代码。例如，现在已经知道如何获得当前用户正在追随的用户的列表。也知道如何获得某个用户发出的所有贴子。因此只需稍微修改后一个函数，使之能够接受一个用户列表，而不是单个用户。
现在只需在 index.php 文件中将第一个函数上移一点，以便马上使用它，然后使用通过该函数获得的用户 ID 列表，从他们的时间表中获取一定数量的贴子 — 这里不需要所有的贴子，只需 5 个左右。记住，要按日期倒序（最近的在上）排列那些用户的贴子。
首先，为?show_posts()?函数增加一个 limit 参数，将它的值默认为 0。如果 limit 大于 0，则将一个限制值添加到用于检索贴子的 SQL 语句中。另外要做的是将?$userid?参数放入到一个数组中，并将该数组解析到一个以逗号分隔的字段中，最后将该字段传递给 SQL 语句。这需要做一点额外工作，但是可以获得丰厚的回报，因为如您所见，所有贴子都将以倒序显示。


清单 18. 更新?show_posts()，以接受一个用户数组



				
function show_posts($userid,$limit=0){
	$posts = array();

	$user_string = implode(',', $userid);
	$extra =  " and id in ($user_string)";

	if ($limit > 0){
		$extra = "limit $limit";
	}else{
		$extra = '';	
	}

	$sql = "select user_id,body, stamp from posts 
		where user_id in ($user_string) 
		order by stamp desc $extra";
	echo $sql;
	$result = mysql_query($sql);

	while($data = mysql_fetch_object($result)){
		$posts[] = array( 	'stamp' => $data->stamp, 
							'userid' => $data->user_id, 

/phprm/26282.htmlwww.phpzy.comtrue/phprm/26282.htmlTechArticle使用PHP在站点下构建类似Twitter的系统 使用 PHP 在站点上构建类似 Twitter 的系统 http://blog.csdn.net/sfshine/article/details/8184510 如果您曾经留意过，就会知道 Twitter 是 Web 2.0 世界最大的轰动事件...



 
相关文章

 
ubuntu10.04配备nginx+php-fpm模式
php 分页原理详解
php win下Socket方式发邮件类
PHP 开源框架22个简单简介
PHP使用PDO、mysqli扩展实现与数据库交互操
PHP抽象类和接口用法实例详解，




		
		

		

 
今日最新相关阅读：
 
ubuntu10.04配备nginx+php-fpm模式
php实现当前用户在线人数
PHP运行出现Notice : Use of undefined constant 的解决
PHP采集、模拟登陆论坛小程序
PHP采集程序开发视频教程
php 分页原理详解

 
 




PHP之友评论
 


今天推荐