用户 => 客服 (先把信息入库,然后通过ob+长连接不断从数据库查询数据发送给客服)
客服 => 用户 (先接收用户信息,然后把回复信息入库,最后通过ajax轮询不断请求数据,显示到用户聊天界面)
【注意:】如果所有页面搭建好,先链接客服聊天页面(server.php) ,接着再链接用户页面(client.php)
附图说明:

第一步:建表
说明: rec : 接收信息方, sender : 发送信息方, content : 发送内容 , is_new : 作为标记,1是 新信息 2是 已读信息 (默认是1)
CREATE TABLE `chat_log` ( `log_id` int(11) NOT NULL AUTO_INCREMENT, `rec` varchar(10) NOT NULL COMMENT '接受方', `sender` varchar(10) NOT NULL COMMENT '发送方', `content` text NOT NULL COMMENT '发送内容', `is_new` tinyint(4) NOT NULL DEFAULT '1' COMMENT '信息 1新信息 0 已读信息', PRIMARY KEY (`log_id`,`rec`) ) ENGINE=MyISAM AUTO_INCREMENT=105 DEFAULT CHARSET=utf8 COMMENT='用户客服聊天轮询表'
第二步:链接数据库 : connect.php
$link = mysql_connect('localhost', 'root', '');
mysql_query("set names utf8");
mysql_select_db("chat");第三步:用户聊天界面: client.php
User窗口 与客服聊天窗口
第四:用户发送信息入库 + ajax轮询查询有无客服回复信息
toServer.php
require('connect.php');
$msg = htmlspecialchars($_POST['msg'], ENT_QUOTES);
$sql = "INSERT INTO `chat_log` (rec, sender, content) VALUES('admin', 'user', '$msg' )";
mysql_query($sql, $link);
echo json_encode($msg);fromServer.php
require('connect.php');
set_time_limit(0);//永不超时
while (true){
$sql = "SELECT * FROM `chat_log` WHERE rec='user' AND is_new=1 ORDER BY log_id DESC LIMIT 1";
$res = mysql_query($sql, $link);
if($row = mysql_fetch_assoc($res)){
$sql = "UPDATE `chat_log` SET is_new=0 WHERE log_id=".$row['log_id'];
mysql_query($sql,$link);
die(json_encode($row));
}
}第五步: 客服聊天页面 server.php
客服窗口 与User聊天窗口
第六步: 客服查询数据库有无用户发送信息 + 发送信息给用户
fromClient.php
require('connect.php');
ob_start(); //打开一个输出缓冲区,所有的输出信息不再直接发送到浏览器,而是保存在输出缓冲区里面
echo str_repeat('', 4096);
ob_end_flush(); //发送内部缓冲区到浏览器,删除缓冲区内容,关闭缓冲区
ob_flush(); //发送内部缓冲区的内容到浏览器,删除缓冲区的内容,不关闭缓冲区
set_time_limit(0);//永不超时
while(true){
$sql = "select * from `chat_log` where rec= 'admin' and is_new= 1 ORDER BY log_id DESC LIMIT 1 ";
$res = mysql_query($sql, $link);
if($row = mysql_fetch_assoc($res)){
$sql = "UPDATE `chat_log` SET is_new=0 where log_id=".$row['log_id'];
mysql_query($sql, $link);
echo "";
ob_flush();
flush(); //将ob_flush释放出来的内容,以及不在PHP缓冲区中的内容,全部输出至浏览器;刷新内部缓冲区的内容,并输出
sleep(1);
}
}toClient.php
require('connect.php');
$msg = htmlspecialchars($_POST['msg'], ENT_QUOTES);
if(!empty($msg)){
$sql = "insert into chat_log(rec, sender, content) values('user', 'admin', '$msg')";
mysql_query($sql);
echo json_encode($msg);
}1、执行速度快。2、具有很好的开放性和可扩展性。3、PHP支持多种主流与非主流的数据库。4、面向对象编程:PHP提供了类和对象。5、版本更新速度快。6、具有丰富的功能。7、可伸缩性。8、功能全面,包括图形处理、编码与解码、压缩文件处理、xml解析等。
下一篇:使用PHP怎么实现文件操作