首頁 > 後端開發 > php教程 > PHP聊天室技術

PHP聊天室技術

PHPz
發布: 2019-02-12 11:38:48
原創
3538 人瀏覽過

這篇文章主要介紹了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 '接受方',
`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

<!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)聊天,一開始卡得不行,過一會好了之後就正常聊天了,只是不太清楚原因,有知道的朋友麻煩告訴一下我,感激不盡!


相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板