Heim > Artikel > Backend-Entwicklung > PHP聊天室技术

PHP聊天室技术

PHPzOriginal: 2016-07-29 08:34:243536Durchsuche

这篇文章主要介绍了PHP聊天室简单实现方法，结合实例形式详细分析了php聊天室相关数据库操作与ajax交互等操作技巧，需要的朋友可以参考下

本文实例讲述了PHP聊天室简单实现方法。分享给大家供大家参考，具体如下：

用户 => 客服（先把信息入库，然后通过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 &#39;接受方&#39;,
`sender` varchar（10） NOT NULL COMMENT &#39;发送方&#39;,
`content` text NOT NULL COMMENT &#39;发送内容&#39;,
`is_new` tinyint（4） NOT NULL DEFAULT &#39;1&#39; COMMENT &#39;信息 1新信息 0 已读信息&#39;,
PRIMARY KEY （`log_id`,`rec`）
） ENGINE=MyISAM AUTO_INCREMENT=105 DEFAULT CHARSET=utf8 COMMENT=&#39;用户客服聊天轮询表&#39;

第二步：链接数据库： connect.php

$link = mysql_connect（&#39;localhost&#39;, &#39;root&#39;, &#39;&#39;）；
mysql_query（"set names utf8"）；
mysql_select_db（"chat"）；

第三步：用户聊天界面： client.php

<!doctype html>
<html>
<head>
<meta charset="UTF-8">
<title>User窗口</title>
<style>
#user {
width: 440px;
height: 300px;
border: 1px solid blue;
}
</style>
<script src=&#39;http://code.jquery.com/jquery-latest.js&#39;></script>
<script>
$（function （） {
$（"#btn"）。click（function （） {
var content = $（"textarea"）。val（）；
if（content == &#39;&#39;）{alert（&#39;发送内容不能为空&#39;）；return;}
// 发送给客服
<!-- 把提交数据通过toServer.php存入数据库-->
$.post（"toServer.php", {&#39;msg&#39;:content}, function （res） {
var obj = JSON.parse（res）；
$（"#user"）。append（"<b>你向客服发送：</b>" + obj + "<br>"）；
$（"textarea"）。val（" "）；
}）；
}）；
// 用ajax轮询方式 从数据库获取 客服是否有发送消息给用户
var polling = {
"url"   : &#39;fromServer.php&#39;,
"dataType" : &#39;json&#39;,
success  : function （res） {
//ajax请求返回的数据
var obj = res;
//追加到User聊天的页面
$（"#user"）。append（"<b style=&#39;color:red&#39;>客服回复：" + obj.content + "</b><br>"）；
$.ajax（polling）；
}
};
$.ajax（polling）； //轮询发送ajax请求
}）
</script>
</head>
<body>
<iframe src="" width="0" height="0" frameborder="0"></iframe>
<h3>与客服聊天窗口</h3>
<div contenteditable="true" id="user"></div>
<div>
<textarea name="msg_list" id="" cols="60" rows="15"></textarea>
<button id="btn" type="button">send</button>
</div>
</body>
</html>

第四：用户发送信息入库 + ajax轮询查询有无客服回复信息

toServer.php
require（&#39;connect.php&#39;）；
$msg = htmlspecialchars（$_POST[&#39;msg&#39;], ENT_QUOTES）；
$sql = "INSERT INTO `chat_log` （rec, sender, content） VALUES（&#39;admin&#39;, &#39;user&#39;, &#39;$msg&#39; ）";
mysql_query（$sql, $link）；
echo json_encode（$msg）；
fromServer.php
require（&#39;connect.php&#39;）；
set_time_limit（0）；//永不超时
while （true）{
$sql = "SELECT * FROM `chat_log` WHERE rec=&#39;user&#39; 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[&#39;log_id&#39;];
mysql_query（$sql,$link）；
die（json_encode（$row））；
}
}

第五步：客服聊天页面 server.php

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>客服窗口</title>
<style>
#server {
width: 440px;
height: 300px;
border: 1px solid blue;
}
</style>
<script src=&#39;http://code.jquery.com/jquery-latest.js&#39;></script>
<!-- 进行ob缓存输出 -->
<script>
function showMsg（res） {
var obj = eval（res）；
$（"#server"）。append（"<b style=&#39;color:red&#39;>User向你发送：" + obj.content + "</b><br/>"）；
}
//回复User信息
$（function （） {
$（"#btn"）。click（function （） {
var content = $（"textarea"）。val（）；
//客服发送的信息通过toClient.php存入数据库
$.post（"toClient.php", {&#39;msg&#39;:content},function （res） {
var obj = JSON.parse（res）；
$（"#server"）。append（"你向User发送：" + obj+ "<br>"）；
$（"textarea"）。val（""）；
}）
}）；
}）
</script>
</head>
<body>
<iframe src="./fromClient.php" width="0" height="0" frameborder="0"></iframe>
<h3>与User聊天窗口</h3>
<div contenteditable="true" id="server"></div>
<div>
<textarea name="msg_list" id="" cols="60" rows="15"></textarea>
<button id="btn" type="button">send</button>
</div>
</body>
</html>

第六步：客服查询数据库有无用户发送信息 + 发送信息给用户

fromClient.php
require（&#39;connect.php&#39;）；
ob_start（）；       //打开一个输出缓冲区，所有的输出信息不再直接发送到浏览器，而是保存在输出缓冲区里面
echo str_repeat（&#39;&#39;, 4096）；
ob_end_flush（）；     //发送内部缓冲区到浏览器，删除缓冲区内容，关闭缓冲区
ob_flush（）；       //发送内部缓冲区的内容到浏览器，删除缓冲区的内容，不关闭缓冲区
set_time_limit（0）；//永不超时
while（true）{
$sql = "select * from `chat_log` where rec= &#39;admin&#39; 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[&#39;log_id&#39;];
mysql_query（$sql, $link）；
echo "<script>parent.showMsg（".json_encode（$row）。"）</script>";
ob_flush（）；
flush（）；      //将ob_flush释放出来的内容，以及不在PHP缓冲区中的内容，全部输出至浏览器；刷新内部缓冲区的内容，并输出
sleep（1）；
}
}
toClient.php
require（&#39;connect.php&#39;）；
$msg = htmlspecialchars（$_POST[&#39;msg&#39;], ENT_QUOTES）；
if（！empty（$msg））{
$sql = "insert into chat_log（rec, sender, content） values（&#39;user&#39;, &#39;admin&#39;, &#39;$msg&#39;）";
mysql_query（$sql）；
echo json_encode（$msg）；
}

这里我在电脑上运行（server.php和client.php）聊天，一开始卡得不行，过一会好了之后就正常聊天了，只是不太清楚原因，有知道的朋友麻烦告诉一下我，感激不尽！

Stellungnahme：

Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Vorheriger Artikel：excel2003官方下载免费完整版二十行语句实现从Excel到mysql的转化Nächster Artikel：supercalifragilisticexpialidoc 模仿OSO的论坛（四）

In Verbindung stehende Artikel

Mehr sehen