|
|
@@ -639,7 +639,7 @@ us.polling = function (requset, response, userid, pageid, type) {
|
|
|
if (_userarray[pageid]) {
|
|
|
_userarray[pageid].response = response;
|
|
|
if (_messagearray && _messagearray.message.length > 0) {
|
|
|
- response.write(JSON.stringify(JSON.stringify(_messagearray.message)) + "\r\n");
|
|
|
+ response.write(JSON.stringify(_messagearray.message) + "\r\n");
|
|
|
_messagearray.message = [];
|
|
|
}
|
|
|
else {
|
|
|
@@ -1543,7 +1543,7 @@ us.broadcast = function (messageinfo, pageid, type) {
|
|
|
try {
|
|
|
if (_userconnect[j] && _userconnect[j][_recievedpageid]) {
|
|
|
console.log(_recievedpageid);
|
|
|
- _issend = _userconnect[j][_recievedpageid].response.write(JSON.stringify(JSON.stringify(_messageinfo)) + "\r\n"); //发送消息
|
|
|
+ _issend = _userconnect[j][_recievedpageid].response.write(JSON.stringify(_messageinfo) + "\r\n"); //发送消息
|
|
|
//用户在轮询切换的时候的中间，会产生数据无法接受，这里是存储数据
|
|
|
if (!_issend) {
|
|
|
us.offLineMessage[_recievedpageid].message.push(_messageinfo); //将消息加入用户离线消息中
|
root