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

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

http://blog.csdn.net/sfshine/article/details/8184510

如果您曾经留意过，就会知道 Twitter 是 Web 2.0 世界最大的轰动事件之一。简单来说，Twitter（Twitter.com 上提供的一个服务）是一个简单的微博客服务，用户可以发最多 140 个字符的贴子（称作?tweet），回答 “你现在在做什么?” 之类的问题。用户可以追随他们感兴趣的人，也有自己的追随者。通过这种方式，可以将信息发布给追随者或是广泛地转发。

随意浏览一下某个 Twitter 账户可以发现，用户常常发布关于很多不同话题的 tweet，从日常生活（例如 “我在吃三明治”）到更不平凡的话题。其中常常嵌入了图像、媒体文件和日志的链接。这些 URL 常常被 TinyURL 之类的服务缩短，主要是为了使贴子的总字符数不超过 140 个字符。

很多人喜欢上了 Twitter，使超短格式成了一种艺术形式，甚至将之用于与其他用户交谈（例如将他们的评论定向到 @user）。从这个简单的起点开始，涌现了大量支持 Twitter 的移动应用程序和其他工具。现在甚至还有专门为最有趣、最卓越和最详实的 tweet 而设置的奖项，另外还有跟踪不同 Twitter 应用程序的状态的在线应用程序。

很多其他站点和服务，例如 LinkedIn 和 Facebook 现在允许用户用仿照 Twitter 的方式更新他们的当前状态。换句话说，在 Facebook 更新状态需要使用短消息，当然，状态通常是回答 “你现在在干什么” 之类的问题。

为您自己的站点添加微博客或状态更新工具不需要做很多工作，但是却可以为用户带来乐趣和简单的交流方式。本文的目标是展示如何实现这个目的。但是，首先需要对您作一些假设。

首先，假设您对 PHP 和 MySQL 有所了解。同时假设您可以访问某个运行 PHP 和 MySQL 的本地 Apache Web 服务器。对于本文，我在使用 Macintosh、Apache、MySQL 和 PHP（MAMP）的 MacBook Products 上进行开发，这个免费程序将整个开发环境打包到一个包中。但是，您应该能够毫无困难地在 Microsoft? Windows? 或 Linux? 上进行开发。最后，假设您已经有一个可以立即运行的应用程序，该应用程序现在有一些用户，您打算以某种方式将微博客或 tweeting 添加到该应用程序中。为此，我简化应用程序中侧重用户的一些方面（例如登录、管理个人文件等），而侧重于贴子。

设计应用程序的后端

简言之，Twitter 服务以两个名词为中心：用户和消息。如果您已经构建了一个应用程序，并且希望将类似 Twitter 的服务添加到应用程序中，那么很可能已经有了用户管理功能。如果还没有，那么需要采用某种方式使用一个数据库表（一个主键，通常是一个整数）、一个用户名（也是惟一的）、一个电子邮件地址和密码等标识每个用户。

tweet（即贴子）存储在一个 posts 表中，每个贴子有一个主键（某种连续整数）、一个指向发出该贴的用户的外键关系、贴子本身（限制为一定数量的字符）和日期/时间戳。

最容易令人感到迷惑的是显示用户追随关系的数据库表。这里需要某种方式记录用户 ID 和追随者 ID，使应用程序能够快速建立追随者列表，并轻松地将信息转发给那些已注册为要追随某用户的其他用户。

理解这些内容后，现在就可以着手建立这 3 个数据库表。使用清单 1 中的 SQL 代码创建第一个表，即 users 表（如果已经有一个 users 表，则可以跳过这一步）。

清单 1. users 表

				<br style="padding: 0px; margin: 0px;">CREATE TABLE `users` (<br style="padding: 0px; margin: 0px;">`id` INT NOT NULL AUTO_INCREMENT PRIMARY KEY ,<br style="padding: 0px; margin: 0px;">`username` VARCHAR( 255 ) NOT NULL ,<br style="padding: 0px; margin: 0px;">`email` VARCHAR( 255 ) NOT NULL ,<br style="padding: 0px; margin: 0px;">`password` VARCHAR( 8 ) NOT NULL ,<br style="padding: 0px; margin: 0px;">`status` ENUM( 'active', 'inactive' ) NOT NULL<br style="padding: 0px; margin: 0px;">) ENGINE = MYISAM ;<br style="padding: 0px; margin: 0px;">

下面是第二个表，即 posts 表。

清单 2. posts 表

				<br style="padding: 0px; margin: 0px;">CREATE TABLE `posts` (<br style="padding: 0px; margin: 0px;">`id` INT NOT NULL AUTO_INCREMENT PRIMARY KEY ,<br style="padding: 0px; margin: 0px;">`user_id` INT NOT NULL ,<br style="padding: 0px; margin: 0px;">`body` VARCHAR( 140 ) NOT NULL ,<br style="padding: 0px; margin: 0px;">`stamp` DATETIME NOT NULL<br style="padding: 0px; margin: 0px;">) ENGINE = MYISAM ;<br style="padding: 0px; margin: 0px;">

清单 3 显示了最后一个表，即 following 表。注意这个表有两个主键。

清单 3. following 表

				<br style="padding: 0px; margin: 0px;">CREATE TABLE `following` (<br style="padding: 0px; margin: 0px;">`user_id` INT NOT NULL ,<br style="padding: 0px; margin: 0px;">`follower_id` INT NOT NULL ,<br style="padding: 0px; margin: 0px;">PRIMARY KEY ( `user_id` , `follower_id` )<br style="padding: 0px; margin: 0px;">) ENGINE = MYISAM ;<br style="padding: 0px; margin: 0px;">

然后，先创建一个名为 header.php 的文件，将所有用于 MySQL 的连接字符串放到该文件中。如果已经有一个这样的文件，可以跳过这一步。请务必在各处都包括这个文件，因为将来需要用到它。清单 4 展示了这个文件的内容。

清单 4. 样例 header.php 文件

				<br style="padding: 0px; margin: 0px;">$SERVER = 'localhost';<br style="padding: 0px; margin: 0px;">$USER = 'username';<br style="padding: 0px; margin: 0px;">$PASS = 'password';<br style="padding: 0px; margin: 0px;">$DATABASE = 'microblogger';<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">if (!($mylink = mysql_connect( $SERVER, $USER, $PASS))){<br style="padding: 0px; margin: 0px;">	echo  "<h3 id="Sorry-could-not-connect-to-database">Sorry, could not connect to database.</h3><br/><br style="padding: 0px; margin: 0px;">	Please contact your system's admin for more help\n";<br style="padding: 0px; margin: 0px;">	exit;<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">mysql_select_db( $DATABASE );<br style="padding: 0px; margin: 0px;">

请记住，还可以随意将任何其他类型的安全检查添加到这个 header.php 文件中。例如，可以检查一个会话变量中是否设置了一个用户 ID（表明该用户已经登录）。如果用户没有登录，那么可以将用户重定向到登录页面。本文不会深入讨论这一点，不过需要时可以很容易地添加安全检查。

创建输入表单

设置好后端表之后，就可以考虑处理数据插入和更新的 PHP。现在需要的是一些简单的函数，这些函数将：

1. 允许用户登录和添加贴子。
2. 将那些贴子转发给追随那个用户的人。
3. 允许用户追随其他用户。

我 通常在模型-视图-控制器（Model-View-Controller，MVC）应用程序框架（例如 CodeIgniter）的上下文中工作，因为它提供了一套工具用于创建这些类型的应用程序。例如，我一般先创建两个模型（一个用于用户，另一个用于贴 子），这两个模型使我可以与 users、posts 和 following 表交互，然后从这两个模型开始继续前进。

由于您可能已经在使用不同的框架，所以我决定在此不使用上述方法。相反，我选择一种更简单的、独立于框架的方法。对于本文，我们走走捷径，直接将记录添加到 users 表中，以创建一系列测试用户，供应用程序使用。我创建 3 个用户，并将他们的用户名设为?jane、?tommy?和?bill。

然后，创建一个简单的名为 functions.php 的 PHP 文件，该文件将包含主要的功能。在该文件中要创建少量的函数，以支持微博客应用程序上下文中的动作。

如清单 5 所示，第一个函数是一个简单的函数，用于将内容添加到 posts 表中。

清单 5. 用于将内容添加到 posts 表中的函数

				<br style="padding: 0px; margin: 0px;">function add_post($userid,$body){<br style="padding: 0px; margin: 0px;">	$sql = "insert into posts (user_id, body, stamp) <br style="padding: 0px; margin: 0px;">			values ($userid, '". mysql_real_escape_string($body). "',now())";<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">

为了测试这个简单的函数，还需要添加另外两个 PHP 文件。一个是 index.php 文件，目前包含一个基本的小表单 — 后面将向页面添加更多内容。另一个 PHP 文件是 add.php，上述表单将被发布到该文件。清单 6 是 index.php 文件的摘录。请注意，在此使用一个 PHP 会话将一个用户 ID 值硬编码为 1，这是我的数据库中的用户?jane。现在这样做完全没有问题，但是在后面显然需要更改。

清单 6. index.php 文件摘录

				<br style="padding: 0px; margin: 0px;"><?php <br style="padding: 0px; margin: 0px;">session_start();<br style="padding: 0px; margin: 0px;">include_once('header.php');<br style="padding: 0px; margin: 0px;">include_once('functions.php');<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">$_SESSION['userid'] = 1;<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"<br style="padding: 0px; margin: 0px;">        "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"><br style="padding: 0px; margin: 0px;"><html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en"><br style="padding: 0px; margin: 0px;"><head><br style="padding: 0px; margin: 0px;">	<meta http-equiv="content-type" content="text/html; charset=utf-8" /><br style="padding: 0px; margin: 0px;">	<title>Microblogging Application</title><br style="padding: 0px; margin: 0px;"></head><br style="padding: 0px; margin: 0px;">vbody><br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">if (isset($_SESSION['message'])){<br style="padding: 0px; margin: 0px;">	echo "<b>". $_SESSION['message']."</b>";<br style="padding: 0px; margin: 0px;">	unset($_SESSION['message']);<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><form method='post' action='add.php'><br style="padding: 0px; margin: 0px;"><p>Your status:</p><br style="padding: 0px; margin: 0px;"><textarea name='body' rows='5' cols='40' wrap=VIRTUAL></textarea><br style="padding: 0px; margin: 0px;"><p><input type='submit' value='submit'/></p><br style="padding: 0px; margin: 0px;"></form><br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;"></body><br style="padding: 0px; margin: 0px;"></html><br style="padding: 0px; margin: 0px;">

此外还应注意，我在表单上为状态消息留下了空间，这将在 add.php 中动态地设置，如下面的清单所示。

清单 7. 用 add.php 文件将贴子添加到数据库中

				<br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">session_start();<br style="padding: 0px; margin: 0px;">include_once("header.php");<br style="padding: 0px; margin: 0px;">include_once("functions.php");<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">$userid = $_SESSION['userid'];<br style="padding: 0px; margin: 0px;">$body = substr($_POST['body'],0,140);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">add_post($userid,$body);<br style="padding: 0px; margin: 0px;">$_SESSION['message'] = "Your post has been added!";<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">header("Location:index.php");<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;">

上述代码应该没有什么特别令人奇怪的东西。它只是接受表单的?body?字段和 PHP 会话中设置的 user ID，然后将它们传递给 functions.php 文件中的?add_post()?函数。然后，设置另一个会话变量（更新消息），并将用户重定向回 index.php 页面。

如果要测试这个小函数，惟一的方法是检查数据库中的 posts 表。这不太符合用户友好性，不是吗？这里需要的是更新主页上的贴子。为此，需要再将一个函数添加到 functions.php 文件中，并在主页上使用它。

添加一系列的更新

现在可以打开 functions.php 文件并在其中添??另一个函数。这一次，将函数命名为show_posts()。它将显示特定用户 ID 的所有贴子，如下面的清单所示。

清单 8.?show_posts()?函数

				<br style="padding: 0px; margin: 0px;">function show_posts($userid){<br style="padding: 0px; margin: 0px;">	$posts = array();<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$sql = "select body, stamp from posts<br style="padding: 0px; margin: 0px;">	 where user_id = '$userid' order by stamp desc";<br style="padding: 0px; margin: 0px;">	$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	while($data = mysql_fetch_object($result)){<br style="padding: 0px; margin: 0px;">		$posts[] = array( 	'stamp' => $data->stamp, <br style="padding: 0px; margin: 0px;">							'userid' => $userid, <br style="padding: 0px; margin: 0px;">							'body' => $data->body<br style="padding: 0px; margin: 0px;">					);<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;">	return $posts;<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">

如果为这个函数传递一个用户 ID，它将在一个多维数组中按日期倒序的顺序返回那个用户发出的贴子。要使用该函数，只需在 index.php 上调用它，并检索那个用户的所有贴子。由于对于每个记录只需处理少量的数据，这种查询可以很好地进行扩展。

清单 9 是添加到 index.php 页面的代码，这些代码就放在前面添加的表单之后。通过使用show_posts()?函数和会话变量，可以获得登录的用户发出的所有贴子。如果没有贴子，则显示某种错误消息。如果有贴子，则在一个表中逐个显示它们 — 或者，如果想别致一点，可以使用自己的级联样式表（CSS）。

清单 9. 在 index.php 页面上显示贴子

				<br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">$posts = show_posts($_SESSION['userid']);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">if (count($posts)){<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><table border='1' cellspacing='0' cellpadding='5' width='500'><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">foreach ($posts as $key => $list){<br style="padding: 0px; margin: 0px;">	echo "<tr valign='top'>\n";<br style="padding: 0px; margin: 0px;">	echo "<td>".$list['userid'] ."</td>\n";<br style="padding: 0px; margin: 0px;">	echo "<td>".$list['body'] ."<br/>\n";<br style="padding: 0px; margin: 0px;">	echo "<small>".$list['stamp'] ."</small></td>\n";<br style="padding: 0px; margin: 0px;">	echo "</tr>\n";<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"></table><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">}else{<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><p><b>You haven't posted anything yet!</b></p><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;">

图 1 显示到目前为止的基本界面 — 还不错，几分钟就有这样的成绩。

图 1. 基本界面
?

容 易的部分就完成了。现在有了一个基本的应用程序，用户可以发布状态，并看到它在页面上显示。但是，还缺少一个重要的部分：除了发布状态的人以外，没有人看 到状态更新。在下一节中，将创建一个简单的界面，其中列出系统中的所有用户，并且允许已登录的用户追随其他用户并看到他们的状态更新。

追随其他用户

接下来可以将更多东西添加到 functions.php 文件中。这里需要一个?show_users()?函数，该函数可以返回系统中所有用户的一个列表。后面将使用这个函数填充一个用户列表。

清单 10.?show_users()?函数

				<br style="padding: 0px; margin: 0px;">function show_users(){<br style="padding: 0px; margin: 0px;">	$users = array();<br style="padding: 0px; margin: 0px;">	$sql = "select id, username from users where status='active' order by username";<br style="padding: 0px; margin: 0px;">	$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	while ($data = mysql_fetch_object($result)){<br style="padding: 0px; margin: 0px;">		$users[$data->id] = $data->username;<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;">	return $users;<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">

有了?show_users()?函数之后，接下来可以创建一个 users.php 文件，该文件将运行这个函数，并显示系统中所有用户的一个列表，对于每个用户，在用户名的旁边都有一个?follow?链接。

清单 11. 运行?show_users()?函数的 users.php 文件

				<br style="padding: 0px; margin: 0px;"><?php <br style="padding: 0px; margin: 0px;">session_start();<br style="padding: 0px; margin: 0px;">include_once("header.php");<br style="padding: 0px; margin: 0px;">include_once("functions.php");<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"<br style="padding: 0px; margin: 0px;">        "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"><br style="padding: 0px; margin: 0px;"><html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en"><br style="padding: 0px; margin: 0px;"><head><br style="padding: 0px; margin: 0px;">	<meta http-equiv="content-type" content="text/html; charset=utf-8" /><br style="padding: 0px; margin: 0px;">	<title>Microblogging Application - Users</title><br style="padding: 0px; margin: 0px;"></head><br style="padding: 0px; margin: 0px;"><body><br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;"><h1 id="List-of-Users">List of Users</h1><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">$users = show_users();<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">if (count($users)){<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><table border='1' cellspacing='0' cellpadding='5' width='500'><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">foreach ($users as $key => $value){<br style="padding: 0px; margin: 0px;">	echo "<tr valign='top'>\n";<br style="padding: 0px; margin: 0px;">	echo "<td>".$key ."</td>\n";<br style="padding: 0px; margin: 0px;">	echo "<td>".$value ." <small><a href='#'>follow</a></small></td>\n";<br style="padding: 0px; margin: 0px;">	echo "</tr>\n";<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"></table><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">}else{<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><p><b>There are no users in the system!</b></p><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"></body><br style="padding: 0px; margin: 0px;"></html><br style="padding: 0px; margin: 0px;">

为了访问这个用户列表，在 index.php 文件中表单的上方添加一个到 users.php 的链接：

<p><a href='users.php'>see list of users</a></p><br style="padding: 0px; margin: 0px;">

现在有了一个易于使用的用户名列表，每个用户名旁有一个?follow?链接。

图 2. 用户列表
?

在进入下一个阶段之前，还需要编写一个小函数，该函数将返回当前用户正在追随的用户。这样一来，用户就可以用这个列表来确定是否追随另一个用户。

回到 functions.php 文件，添加一个名为?following()?的函数，如清单 12 所示。将当前用户 ID 传递给该函数，就可以得到该用户正在追随的每个用户的 ID。

清单 12.?following()?函数

				<br style="padding: 0px; margin: 0px;">function following($userid){<br style="padding: 0px; margin: 0px;">	$users = array();<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$sql = "select distinct user_id from following<br style="padding: 0px; margin: 0px;">			where follower_id = '$userid'";<br style="padding: 0px; margin: 0px;">	$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	while($data = mysql_fetch_object($result)){<br style="padding: 0px; margin: 0px;">		array_push($users, $data->user_id);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	return $users;<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">

现在可以在 users.php 上运行这个函数，检查某个用户 ID 是否在该数组中。如果在，则使用 unfollow 链接。如果不在，则使用默认的 follow 链接。清单 13 显示修改后的代码。

清单 13. 修改后的 users.php 文件，它将显示 follow 和 unfollow 链接

				<br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">$users = show_users();<br style="padding: 0px; margin: 0px;">$following = following($_SESSION['userid']);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">if (count($users)){<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><table border='1' cellspacing='0' cellpadding='5' width='500'><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">foreach ($users as $key => $value){<br style="padding: 0px; margin: 0px;">	echo "<tr valign='top'>\n";<br style="padding: 0px; margin: 0px;">	echo "<td>".$key ."</td>\n";<br style="padding: 0px; margin: 0px;">	echo "<td>".$value;<br style="padding: 0px; margin: 0px;">	if (in_array($key,$following)){<br style="padding: 0px; margin: 0px;">		echo " <small><br style="padding: 0px; margin: 0px;">		<a href='action.php?id=$key&do=unfollow'>unfollow</a><br style="padding: 0px; margin: 0px;">		</small>";<br style="padding: 0px; margin: 0px;">	}else{<br style="padding: 0px; margin: 0px;">		echo " <small><br style="padding: 0px; margin: 0px;">		<a href='action.php?id=$key&do=follow'>follow</a><br style="padding: 0px; margin: 0px;">		</small>";<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;">	echo "</td>\n";<br style="padding: 0px; margin: 0px;">	echo "</tr>\n";<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;">

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

清单 14. action.php 文件

				<br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">session_start();<br style="padding: 0px; margin: 0px;">include_once("header.php");<br style="padding: 0px; margin: 0px;">include_once("functions.php");<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">$id = $_GET['id'];<br style="padding: 0px; margin: 0px;">$do = $_GET['do'];<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">switch ($do){<br style="padding: 0px; margin: 0px;">	case "follow":<br style="padding: 0px; margin: 0px;">		follow_user($_SESSION['userid'],$id);<br style="padding: 0px; margin: 0px;">		$msg = "You have followed a user!";<br style="padding: 0px; margin: 0px;">	break;<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	case "unfollow":<br style="padding: 0px; margin: 0px;">		unfollow_user($_SESSION['userid'],$id);<br style="padding: 0px; margin: 0px;">		$msg = "You have unfollowed a user!";<br style="padding: 0px; margin: 0px;">	break;<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">$_SESSION['message'] = $msg;<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">header("Location:index.php");<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;">

可以看到，这里取决于之前选择的链接，采取两种不同的动作 —?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()?函数

				<br style="padding: 0px; margin: 0px;">function check_count($first, $second){<br style="padding: 0px; margin: 0px;">	$sql = "select count(*) from following <br style="padding: 0px; margin: 0px;">			where user_id='$second' and follower_id='$first'";<br style="padding: 0px; margin: 0px;">	$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$row = mysql_fetch_row($result);<br style="padding: 0px; margin: 0px;">	return $row[0];<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">function follow_user($me,$them){<br style="padding: 0px; margin: 0px;">	$count = check_count($me,$them);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	if ($count == 0){<br style="padding: 0px; margin: 0px;">		$sql = "insert into following (user_id, follower_id) <br style="padding: 0px; margin: 0px;">				values ($them,$me)";<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">		$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">function unfollow_user($me,$them){<br style="padding: 0px; margin: 0px;">	$count = check_count($me,$them);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	if ($count != 0){<br style="padding: 0px; margin: 0px;">		$sql = "delete from following <br style="padding: 0px; margin: 0px;">				where user_id='$them' and follower_id='$me'<br style="padding: 0px; margin: 0px;">				limit 1";<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">		$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">

接下来的步骤很容易：在主页上显示当前用户正在追随的其他用户的列表。虽然已经有了一个show_users()?函数，但那个函数是显示所有?用户。可以通过增加一个非必需的参数，轻松地改变这个函数的用途。这个参数是一个用户 ID，可以用该参数将用户列表限制为该用户 ID 所追随的那些用户。

清单 16 中重新编写的代码所做的事情是检查传入的?$user_id?参数。如果该用户 ID 大于 0，则使用一个查询获取此 ID 追随的所有用户的 ID。使用?implode()?函数将获得的数组转换为一个以逗号分隔的列表。然后将这个字符串 — 大致为?and id in (1,2,3...n)?— 插入到已有的 SQL 查询中，从而将用户列表限制为该用户正在追随的那些用户。

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

				<br style="padding: 0px; margin: 0px;">function show_users($user_id=0){<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	if ($user_id > 0){<br style="padding: 0px; margin: 0px;">		$follow = array();<br style="padding: 0px; margin: 0px;">		$fsql = "select user_id from following<br style="padding: 0px; margin: 0px;">				where follower_id='$user_id'";<br style="padding: 0px; margin: 0px;">		$fresult = mysql_query($fsql);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">		while($f = mysql_fetch_object($fresult)){<br style="padding: 0px; margin: 0px;">			array_push($follow, $f->user_id);<br style="padding: 0px; margin: 0px;">		}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">		if (count($follow)){<br style="padding: 0px; margin: 0px;">			$id_string = implode(',', $follow);<br style="padding: 0px; margin: 0px;">			$extra =  " and id in ($id_string)";<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">		}else{<br style="padding: 0px; margin: 0px;">			return array();<br style="padding: 0px; margin: 0px;">		}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$users = array();<br style="padding: 0px; margin: 0px;">	$sql = "select id, username from users <br style="padding: 0px; margin: 0px;">		where status='active' <br style="padding: 0px; margin: 0px;">		$extra order by username";<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	while ($data = mysql_fetch_object($result)){<br style="padding: 0px; margin: 0px;">		$users[$data->id] = $data->username;<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;">	return $users;<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">

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

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

				<br style="padding: 0px; margin: 0px;"><h2 id="Users-you-re-following">Users you're following</h2><br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">$users = show_users($_SESSION['userid']);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">if (count($users)){<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><ul><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">foreach ($users as $key => $value){<br style="padding: 0px; margin: 0px;">	echo "<li>".$value."</li>\n";<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"></ul><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">}else{<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;"><p><b>You're not following anyone yet!</b></p><br style="padding: 0px; margin: 0px;"><?php<br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">?><br style="padding: 0px; margin: 0px;">

添加其他用户?贴子

要将其他用户的贴子添加到一个用户的时间表（timeline）上，只需重用之前编写的一些代码。例如，现在已经知道如何获得当前用户正在追随的用户的列表。也知道如何获得某个用户发出的所有贴子。因此只需稍微修改后一个函数，使之能够接受一个用户列表，而不是单个用户。

现在只需在 index.php 文件中将第一个函数上移一点，以便马上使用它，然后使用通过该函数获得的用户 ID 列表，从他们的时间表中获取一定数量的贴子 — 这里不需要所有的贴子，只需 5 个左右。记住，要按日期倒序（最近的在上）排列那些用户的贴子。

首先，为?show_posts()?函数增加一个 limit 参数，将它的值默认为 0。如果 limit 大于 0，则将一个限制值添加到用于检索贴子的 SQL 语句中。另外要做的是将?$userid?参数放入到一个数组中，并将该数组解析到一个以逗号分隔的字段中，最后将该字段传递给 SQL 语句。这需要做一点额外工作，但是可以获得丰厚的回报，因为如您所见，所有贴子都将以倒序显示。

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

				<br style="padding: 0px; margin: 0px;">function show_posts($userid,$limit=0){<br style="padding: 0px; margin: 0px;">	$posts = array();<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$user_string = implode(',', $userid);<br style="padding: 0px; margin: 0px;">	$extra =  " and id in ($user_string)";<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	if ($limit > 0){<br style="padding: 0px; margin: 0px;">		$extra = "limit $limit";<br style="padding: 0px; margin: 0px;">	}else{<br style="padding: 0px; margin: 0px;">		$extra = '';	<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	$sql = "select user_id,body, stamp from posts <br style="padding: 0px; margin: 0px;">		where user_id in ($user_string) <br style="padding: 0px; margin: 0px;">		order by stamp desc $extra";<br style="padding: 0px; margin: 0px;">	echo $sql;<br style="padding: 0px; margin: 0px;">	$result = mysql_query($sql);<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">	while($data = mysql_fetch_object($result)){<br style="padding: 0px; margin: 0px;">		$posts[] = array( 	'stamp' => $data->stamp, <br style="padding: 0px; margin: 0px;">							'userid' => $data->user_id, <br style="padding: 0px; margin: 0px;">							'body' => $data->body<br style="padding: 0px; margin: 0px;">					);<br style="padding: 0px; margin: 0px;">	}<br style="padding: 0px; margin: 0px;">	return $posts;<br style="padding: 0px; margin: 0px;"><br style="padding: 0px; margin: 0px;">}<br style="padding: 0px; margin: 0px;">