使用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']);
}
?>

				
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()，以接受一个用户数组

                        

                            

                                
< 上一篇
PHP幻术常量
                            
                            

                                 
下一篇 >
PHP创建缩略图造成图片质量低上的完美解决办法
                            
                        
                    

                        
人气教程排行
                    

			
                        

						
 

                                
                                    174次
                                    1
                                   php如何获取跳转前的url                                
                            
							  								  														  

                                
                                    174次
                                    2
                                   php格林威治时间转换成当前时间的方法                                
                            
								  														  								  

                                
                                    174次
                                    3
                                   为什么php不能做大型系统？                                
                            
														  								  							

                                
                                    174次
                                    4
                                   range函数怎么用                                
                            
							  								  							

                                
                                    174次
                                    5
                                   php中计算页面加载时间几种方法总结_PHP教程                                
                            
							  								  							

                                
                                    174次
                                    6
                                   求帮助，关于paypal支付返回值修改订单状态                                
                            
							  								  							

                                
                                    174次
                                    7
                                   typecho怎么配置文章内容页?                                
                            
							  								  							

                                
                                    174次
                                    8
                                   PhpStorm左侧structure不显示文件的方法列表是这么回事？                                
                            
							  								  							

                                
                                    174次
                                    9
                                   查看PHP的环境变量_PHP                                
                            
							  								  							

                                
                                    174次
                                    10
                                   PHP Primary script unknown 解决方法总结                                
                            
							  								  							

                                
                                    174次
                                    11
                                   php的命名空间与自动加载实现方法                                
                            
							  								  							

                                
                                    174次
                                    12
                                   解决laravel 出现ajax请求419(unknown status)的问题                                
                            
							  								  							

                                
                                    173次
                                    13
                                   php 如何删除mysql记录                                
                            
							  								  							

                                
                                    173次
                                    14
                                   PHP如何替换数组中的指定元素                                
                            
							  								  							

                                
                                    173次
                                    15
                                   怎么去除字符串中非汉字、非字母、非数字的字符                                
                            
							  								  							

                                
                                    173次
                                    16
                                   mysql如何一次执行多条SQL语句                                
                            
							  								  							

                                
                                    173次
                                    17
                                   修改header里面的Connection为close解决方法                                
                            
							  								  							

                                
                                    173次
                                    18
                                   PHP基于session.upload_progress 实现文件上传进度显示功能详解                                
                            
							  								  							

                                
                                    173次
                                    19
                                   php5.6.x到php7.0.x特性小结                                
                            
							  								  							

                                
                                    172次
                                    20
                                   php为什么会出现504错误                                
                            

                        
                    

   本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！


登录

 










                 
                
                
                
                记住我的登录                            
        忘记密码？ 
  
登录
 
  




  

    
    

    
  

   
  

    
    
  

    
      
      我已阅读用户协议及版权声明
  
  

注册

 



				
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, 
							'body' => $data->body
					);
	}
	return $posts;

}