php+ajax长轮询实现web即时聊天-白红宇

web im的实现方式有很多种：

1．普通轮询，原理通过js定时重复发送ajax请求服务端，获取数据后显示。

2. 长轮询，ajax请求服务端，服务端有数据会立即返回。服务端无数据时会一直等待，直到有数据了才立即返回。

3．socket长连接。

特征分析：

方法１：实现起来最容易，定时重复请求服务端会产生无意义的http连接，消耗服务端资源，实时性较差．

方法2：实现起来较容易，会减少无效的ajax请求产生的http连接，能即时返回数据，但服务端会一直挂着，会消耗一定的资源，处理并发能力不强，比较适合于中小型应用服务．（comet）

方法３：门槛较高，需了解socket通讯协议，是http实现长连接的最佳方式，也是真正意义上的server push技术．

Comet技术简介

　　以即时通信为代表的web应用程序对数据的Low Latency（低延时）要求，传统的基于轮询的方式已经无法满足，而且也会带来不好的用户体验。于是一种基于http长连接的“服务器推”技术便被hack出来。这种技术被命名为Comet，这个术语由Dojo Toolkit 的项目主管Alex Russell在博文首次提出，并沿用下来。

其实，服务器推很早就存在了，在经典的client/server模型中有广泛使用，只是浏览器太懒了，并没有对这种技术提供很好的支持。但是Ajax的出现使这种技术在浏览器上实现成为可能， google的gmail和gtalk的整合首先使用了这种技术。随着一些关键问题的解决（比如 IE 的加载显示问题），很快这种技术得到了认可，目前已经有很多成熟的开源Comet框架。

以下是典型的Ajax和Comet数据传输方式的对比，区别简单明了。典型的Ajax通信方式也是http协议的经典使用方式，要想取得数据，必须首先发送请求。在Low Latency要求比较高的web应用中，只能增加服务器请求的频率。Comet则不同，客户端与服务器端保持一个长连接，只有客户端需要的数据更新时，服务器才主动将数据推送给客户端。

本文介绍第二种实现方法

案例名称：web即时聊天(ajax长轮询方式实现)

项目地址：

功能介绍：

对话双方都在线（浏览器没有关闭的情况下），对话即时推送．

支持离线发送消息．当离线方上线时，会自动接收离线消息．

采用确认机制确保数据推送成功．

采用超时退出机制，降低服务器资源浪费．

~~本项目只注重php服务端的实现机制和性能优化，前端界面粗糙请忽略．适合中级php程序员学习借鉴，欢迎各位指教交流～～

预览

项目文件结构：

                            
GetMessage.php
SendMessage.php
client.php
jquery.
min
.js
sql
         
       

准备工作：数据库

                            
mysql> 
desc
message;
+
-------------+------------------+------+-----+---------+----------------+
| Field       | Type             | 
Null
| 
Key
| 
Default
| Extra          |
+
-------------+------------------+------+-----+---------+----------------+
| id          | 
int
(10)          | 
NO
| PRI | 
NULL
| auto_increment |
| reciver_uid | 
int
(10) unsigned | 
NO
| MUL | 0       |                |
| sender_uid  | 
int
(10) unsigned | 
NO
|     | 0       |                |
| content     | 
varchar
(1000)    | 
NO
|     |         |                |
| create_time | 
int
(10) unsigned | 
NO
|     | 0       |                |
| status      | tinyint(1)       | 
NO
|     | 0       |                |
+
-------------+------------------+------+-----+---------+----------------+
         
       

客户端Client.php

实现功能：１．发送聊天信息，２即时获取并显示聊天内容

页面基本结构

                            
<
div
id
=
"message-list"
>
<!--这里显示对话内容-->
</
div
>
<
div
id
=
"message-send"
>
<!--这里填写对话内容，并发送-->
    
<
input
type
=
"textarea"
id
=
"message-box"
/>
    
<
input
type
=
"button"
id
=
"submit-message"
value
=
"发送消息"
>
</
div
>
         
       

功能1:发送内容操作

                            
<script type=
"text/javascript"
>
    
//-------------发送消息---------
    
$(
function
() { 
        
var
reciver_uid = <?php echo $reciverUid;?>;
        
var
sender_uid = <?php echo $senderUid;?>;
        
$(
'#submit-message'
).on(
'click'
, 
function
() { 
            
var
message_content = $(
'#message-box'
).val();
            
if
(message_content != 
''
) { 
                
$(
this
).attr(
'disabled'
, 
'disabled'
);
                
var
send_url = 
'./SendMessage.php'
;
                
var
send_data = { 
                    
'message'
: message_content,
                    
'reciver_uid'
: reciver_uid,
                    
'sender_uid'
: sender_uid,
                
};
                
$.post(send_url, send_data, 
function
(response) { 
                    
if
(response.status == 1) { 
                        
$(
'#message-box'
).val(
''
);
                        
$(
'#submit-message'
).removeAttr(
'disabled'
);
                        
var
send_message_str = 
'<li style="text-align: right;padding-right: 10px;">'
;
                        
send_message_str += 
'您对'
+ send_data.reciver_uid + 
'说：'
+ send_data.message;
                        
send_message_str += 
'</li>'
;
                        
$(
'#message-list'
).append(send_message_str);
                    
} 
else
{ 
                        
console.log(
'发送失败!！'
);
                    
}
                
}, 
'json'
);
            
}
        
});
    
});
</script>
         
       

处理发生消息SendMessage.php

实现功能：保存发送信息

                            
$link
= mysqli_connect(    
    
'127.0.0.1'
,  
/* The host to connect to 连接MySQL地址 */
    
'root'
,      
/* The user to connect as 连接MySQL用户名 */
    
''
,         
/* The password to use 连接MySQL密码 */
    
'web_im'
);    
/* The default database to query 连接数据库名称*/
if
(!
$link
) {    
    
printf(
"Can't connect to MySQL Server. Errorcode: %s "
, mysqli_connect_error());    
    
exit
;    
}    
//只能用函数来判断是否连接成功    
if
(mysqli_connect_errno()) {    
    
echo
mysqli_connect_error();    
}  
  
$senderUid
= (int)
$_POST
[
'sender_uid'
];    
$reciverUid
= (int)
$_POST
[
'reciver_uid'
];    
$message
= 
str_replace
([
' '
, 
','
], 
''
, 
$_POST
[
'message'
]);    
$time
= time();
    
$sql
= 
"insert into message values(NULL ,'{$reciverUid}','{$senderUid}','{$message}','{$time}','1')"
;    
$result
= mysqli_query(
$link
, 
$sql
);    
$insertId
= mysqli_insert_id(
$link
);    
if
(
$insertId
) {    
    
$returnArr
= [
'status'
=> 1,
'info'
=> 
$insertId
,];    
} 
else
{    
    
$returnArr
= [
'status'
=> 0,
'info'
=> 
''
,];    
}    
echo
json_encode(
$returnArr
);    
mysqli_close(
$link
);    
exit
();
         
       

再回到客户端Client.php的功能２

功能２:即时获取并显示聊天内容（注意：客户端使用了递归跟服务端自动应答）

                            
<script type=
"text/javascript"
>
    
var
reciver_uid = <?php echo $senderUid;?>;
    
var
sender_uid = <?php echo $reciverUid;?>;
    
var
url = 
'./GetMessage.php'
;
    
$(
function
() { 
        
get_message_reply(url, reciver_uid, sender_uid, 
'get_message'
, 
''
);
    
});
    
//获取消息并应答
    
//get_get_message_reply()
    
//param request_type  请求类型 详解：
    
//      get_message   获取信息
    
//      comfrim_read  确认已经读取了信息
    
function
get_message_reply(url, reciver_uid, sender_uid, request_type, send_data) { 
        
var
setting = { 
            
url: url,
            
data: { 
                
'request_type'
: request_type,
                
'reciver_uid'
: reciver_uid,
                
'sender_uid'
: sender_uid,
                
'send_data'
: send_data,
            
},
            
type: 
'post'
,
            
dataType: 
'json'
,
            
success: 
function
(response) { 
                
if
(response.status == 1) { 
                    
if
(response.response_type == 
'is_read'
) { 
                        
//将消息写入到消息盒子
                        
var
messages = response.info;
                        
var
message_str = 
''
;
                        
var
id_arr = 
new
Array();
                        
for
(
var
i 
in
messages) { 
                            
id_arr.push(messages[i][
'id'
]);
                            
message_str += 
'<li>'
+ messages[i][
'sender_uid'
] + 
'在'
+ messages[i][
'send_time'
] + 
'的时候对您说：'
+ messages[i][
'content'
] + 
'</li>'
;
                        
}
                        
$(
'#message-list'
).append(message_str);
                        
//确认收到消息
                        
get_message_reply(url, reciver_uid, sender_uid, 
'comfrim_read'
, id_arr);
                    
} 
else
if
(response.response_type == 
'is_connecting'
) { 
                        
//继续获取消息
                        
get_message_reply(url, reciver_uid, sender_uid, 
'get_message'
, 
''
);
                    
}
                
}
            
}
        
};
        
$.ajax(setting);
    
}
</script>
         
       

NOTICE：下面是核心中的核心

服务端推送消息GetMessage.php

                            
set_time_limit(0);    
$maxInvalidCount
= 30;    
$link
= mysqli_connect(    
    
'127.0.0.1'
,  
/* The host to connect to 连接MySQL地址 */
    
'root'
,      
/* The user to connect as 连接MySQL用户名 */
    
''
,         
/* The password to use 连接MySQL密码 */
    
'web_im'
);    
/* The default database to query 连接数据库名称*/
if
(!
$link
) {    
    
printf(
"Can't connect to MySQL Server. Errorcode: %s "
, mysqli_connect_error());    
    
exit
;    
}    
//只能用函数来判断是否连接成功    
if
(mysqli_connect_errno()) {    
    
echo
mysqli_connect_error();    
}
    
$requestType
= 
$_POST
[
'request_type'
];    
switch
(
$requestType
) {    
    
case
'get_message'
:
//客户端请求读取消息    
        
break
;    
    
case
'comfrim_read'
:
//客户端确认已经读取了信息,服务端需要更新读取状态    
        
$idsArr
= 
$_POST
[
'send_data'
];    
        
$ids
= implode(
','
, 
$idsArr
);    
        
$sql
= 
"update message set status = 2 where id in ({$ids})"
;    
        
mysqli_query(
$link
, 
$sql
);    
        
mysqli_close(
$link
);    
        
break
;    
    
default
:    
        
break
;    
} 
   
$sql
= 
"select * from message where reciver_uid='{$_POST['reciver_uid']}' and sender_uid='{$_POST['sender_uid']}' and status='1'"
;    
$i
= 0;    
while
(true) {    
    
//读取数据    
    
$result
= mysqli_query(
$link
, 
$sql
);    
    
if
(
$result
) {    
        
$returnArr
= [];    
        
while
(
$row
= mysqli_fetch_assoc(
$result
)) {    
            
$row
[
'send_time'
] = 
date
(
'Y-m-d H:i:s'
, 
$row
[
'create_time'
]);    
            
$returnArr
[] = 
$row
;    
        
}    
        
if
(!
empty
(
$returnArr
)) {    
            
//返回结果    
            
$data
= [    
                
'status'
=> 1,    
                
'response_type'
=> 
'is_read'
,    
                
'info'
=> 
$returnArr
,    
            
];    
            
echo
json_encode(
$data
);    
            
mysqli_free_result(
$result
);    
            
mysqli_close(
$link
);    
            
exit
();    
        
}    
    
}
        
    
$i
++;    
    
//需要给客户端发送确认信息是否还在连接服务器,客户端无回应则整个过程结束    
    
if
(
$i
== 
$maxInvalidCount
) {    
        
$data
= [    
            
'status'
=> 1,    
            
'response_type'
=> 
'is_connecting'
,    
            
'info'
=> 
''
,    
        
];    
        
echo
json_encode(
$data
);    
        
mysqli_close(
$link
);    
        
exit
();    
    
}    
    
//file_put_contents('./test.log', date('Y-m-d H:i:s') . "已经重试{$i}次没有获取到信息" . "\r\n", FILE_APPEND);    
    
sleep(1);    
}
         
       

本文转自 hgditren 51CTO博客，原文链接：http://blog.51cto.com/phpme/1890859，如需转载请自行联系原作者