ThinkPHP结合ajax、Mysql实现的客户端通信功能代码示例
该实例通过ThinkPHP结合Ajax与mysql实现了客户端的通信功能，具体如下：
1、使用js的ajax局部刷新功能，每次刷新将数据库中读取出的新记录插入到页面的显示区域，代码如下：
window.onload =setInterval(showWords1000);//加载完成之后开始执行刷新功能
function showWords()//刷新时被调用函数，实现ajax请求
{
xmlHttp=GetXmlHttpObject();//从自定义的函数中获取请求对象。
if (xmlHttp==null)
{
alert ("Browser does not support HTTP Request")
return;
}
var url="index.php?g=Ksks&m=Comments&a=refresh";//要请求的路径使用shuipfcms框架，所以g是分组，m是action控制器，a是模板
url=url+"&data_id="+$("#data_id").val();//接上，data_id传的参数，用于查询数据库的id
url=url+"&lasttime="+$("i").last().siblings('input').val();//lasttime是页面显示数据的最后一个记录的时间戳，查找时根据大于这个时间戳的条件查找
xmlHttp.onreadystatechange=stateChanged;//响应状态改变时调用的函数
xmlHttp.open("GET",url,true);//使用get方法提交
xmlHttp.send();//上面传参之后，这句可要可不要
}
function stateChanged() //实现向页面插入数据功能
{
var str ="";
if(xmlHttp.readyState==4 || xmlHttp.readyState=="complete")
{
eval("var arrs="+xmlHttp.responseText);//获取由action响应输出的数据，因为数据室php数组格式，需用eval或json转化成js数组格式
var chdiv=$("#conversation_history");//通信聊天记录框
for(var j=0;j<arrs.length;j++){//循环插入数据
var obj=$("<tr><td><h3></h3></td><td></td></tr>");//定义页面当中记录框的html格式代码
var i=$("<i> "+arrs[j].times+"</i><input type='hidden' value='"+arrs[j].times+"'>");//i标签i为thinkphp定义的直接将时间输出到input隐藏并且存储得到数据里面的聊天发送时间
var p=$("<p></p>");
p.html(arrs[j].content);//聊天内容
p.append(i);
var h3value=arrs[j].name;//发送的作者
obj.find("h3").html(h3value+"：");
if(h3value=="主持人")
{obj.find("h3").addClass("presenter");}//主持人会特别显示
obj.find("td:last").append(p);
chdiv.append(obj);//追加到table里面
}
chdiv.parent().scrollTop(chdiv.parent()[0].scrollHeight+0);//滚动到底部
}
}
function GetXmlHttpObject()//定义ajax请求对象
{
var xmlHttp=null;
try
{
// Firefox, Opera 8.0+, Safari
xmlHttp=new XMLHttpRequest();
}
catch (e)
{
//Internet Explorer
try
{
xmlHttp=new ActiveXObject("Msxml2.XMLHTTP");
}
catch (e)
{
xmlHttp=new ActiveXObject("Microsoft.XMLHTTP");
}
}
return xmlHttp;
}
2、action控制器，代码如下：
function refresh(){
$data_id = I('get.data_id');//获得嘉宾id
$lasttime = I('get.lasttime');
//print_r(date("Y-m-d H:i:s",$lasttime));
if(!$data_id)
$this->error("该访谈不存在！");
$data = M("ksks_words_memoir");
//print_r(date('Y-m-d H:i:s',$lasttime));
if(!$data)
$this->error("初始化数据失败！");
//$words = $data->where(array('dataid' => $data_id))->order('time asc')->select();
//print_r($data->where(array('time' => $lasttime))->select());
$where['time'] = array('gt',$lasttime);
$count = $data->where($where)->count();
//print_r(date("Y-m-d H:i:s",$lasttime));
$words = $data->where($where)->select();
$datas = array();//要返回的数组
$i = 0;
foreach($words as $word)
{
$datas[$i]['name'] = $word['name'];
$datas[$i]['content'] = $word['content'];
$datas[$i]['times'] = date('Y-m-d H:i:s',$word['time']);
$lasttime = $word['time'];
$i = $i+1;
}
setCookie('lasttime',$lasttime);
$datas = json_encode($datas);
//$this->cache();
echo $datas;
}
3、聊天页面，代码如下：
<volist name="words" id="vo">
<tr>
<td><h3 <if condition="$vo['name']=='主持人'">class="presenter"</if>>{$vo.name}：</h3></td>
<td>
<div>{$vo.content}<i> {$vo.time|date="Y-m-d H:i:s",###}</i>
<input type="hidden" name="time" value="{$vo.time}">
</div>
</td>
</tr>
</volist>
相关推荐
-
thinkphp下MySQL数据库读写分离代码剖析
当采用原生态的sql语句进行写入操作的时候,要用execute,读操作要用query. MySQL数据主从同步还是要靠MySQL的机制来实现,所以这个时候MySQL主从同步的延迟问题是需要优化,延迟时间太长不仅影响业务,还影响用户体验. thinkphp核心类Thinkphp/library/Model.class.php 中,query 方法,调用Thinkphp/library/Think/Db/Driver/Mysql.class.php /** * SQL查询 * @access pub
-
对于ThinkPHP框架早期版本的一个SQL注入漏洞详细分析
ThinkPHP官网上曾有一段公告指出,在ThinkPHP 3.1.3及之前的版本存在一个SQL注入漏洞,漏洞存在于ThinkPHP/Lib/Core/Model.class.php 文件 根据官方文档对"防止SQL注入"的方法解释(参考http://doc.thinkphp.cn/manual/sql_injection.html) 使用查询条件预处理可以防止SQL注入,没错,当使用如下代码时可以起到效果: $Model->where("id=%d and usern
-
thinkphp3.x连接mysql数据库的方法(具体操作步骤)
本文实例讲述了thinkphp3.x连接mysql数据库的方法.分享给大家供大家参考,具体如下: 惯例配置文件:ThinkPHP/conf/convention.php (1)在配置文件中填写配置信息(配置文件:"./xmall/conf/config.php"): 示例: <?php return array( //'配置项'=>'配置值' /* 数据库设置 */ 'DB_TYPE' => 'mysql', // 数据库类型 'DB_HOST' => 'loc
-
thinkPHP连接sqlite3数据库的实现方法(附Thinkphp代码生成器下载)
本文实例讲述了thinkPHP连接sqlite3数据库的简单实现方法.分享给大家供大家参考,具体如下: 首先检查Thinkphp目录下\Lib\Driver\Db目录里有没有DbPdo.class.php 这个文件. 如果没有就去这里下吧:http://www.thinkphp.cn/extend/205.html 然后再确认打开了PHP对sqlite的扩展支持,extension=php_sqlite.dll 连接sqlite3数据库: 在config.php 文件中添加如下配置: 'DB_T
-
Thinkphp实现MySQL读写分离操作示例
相对于其他方法实现MySQL的读写分离来说,采用Thinkphp框架实现MySQL的读写分离简单易用,其配置文件示例代码如下: 'DB_TYPE'=> 'mysql', 'DB_DEPLOY_TYPE' => 1, //开打支持多服务器 'DB_RW_SEPARATE'=>true,//数据库读写否分离 'DB_HOST'=> '192.168.11.101,192.168.11.102', 'DB_NAME'=>'test', 'DB_USER'=>'admin',
-
thinkPHP框架中执行原生SQL语句的方法
本文实例讲述了thinkPHP框架中执行原生SQL语句的方法.分享给大家供大家参考,具体如下: 怎样在thinkphp里面执行原生的sql语句? $Model = new Model();//或者 $Model = D(); 或者 $Model = M(); $sql = "select * from `order`"; $voList = $Model->query($sql); 只是需要new一个空的模型继承Model中的方法. 注意query是查功能,execute是增删改
-
thinkphp中多表查询中防止数据重复的sql语句(必看)
下面先来看看例子: table id name 1 a 2 b 3 c 4 c 5 b 库结构大概这样,这只是一个简单的例子,实际情况会复杂得多. select *, count(distinct name) from table group by name 结果: id name count(distinct name) 1 a 1 2 b 1 3 c 1 最后一 项是多余的,不用管就行了 tp2.0手册 搜索连贯操作 可看到相关的资料 SELECT cat_id, COUNT(*) AS
-
thinkphp区间查询、统计查询与SQL直接查询实例分析
本文实例讲述了thinkphp区间查询.统计查询与SQL直接查询.分享给大家供大家参考.具体方法如下: 一.区间查询: 复制代码 代码如下: $data['id']=array(array('gt',4),array('lt',10));//默认关系是(and)并且的关系 //SELECT * FROM `tp_user` WHERE ( (`id` > 4) AND (`id` < 10) ) $data['id']=array(array('gt',4),array('lt',10
-
thinkPHP使用pclzip打包备份mysql数据库的方法
本文实例讲述了thinkPHP使用pclzip打包备份mysql数据库的方法.分享给大家供大家参考,具体如下: PclZip介绍 PclZip library能够压缩与解压缩Zip格式的压缩档(WinZip.PKZIP);且能对此类类档案进行处理,包括产生压缩档.列出压缩档的内容以及解压缩档案等等 数据库备份是一件非常重要的事情,备份的方式也很多有的通过vps直接进行备份.有的通过phpmyadmin进行数据进行备份.小编觉得这些该麻烦了并且备份好的.sql文件过于太大占用了一定的空间.所以用p
-
ThinkPHP结合ajax、Mysql实现的客户端通信功能代码示例
该实例通过ThinkPHP结合Ajax与mysql实现了客户端的通信功能,具体如下: 1.使用js的ajax局部刷新功能,每次刷新将数据库中读取出的新记录插入到页面的显示区域,代码如下: window.onload =setInterval(showWords1000);//加载完成之后开始执行刷新功能 function showWords()//刷新时被调用函数,实现ajax请求 { xmlHttp=GetXmlHttpObject();//从自定义的函数中获取请求对象. if (xmlHtt
-
Android编程实现TCP、UDP客户端通信功能示例
本文实例讲述了Android编程实现TCP.UDP客户端通信功能.分享给大家供大家参考,具体如下: 在进行Android开发的过程中,免不了,要开发TCP/UDP通讯的程序,下面这两段代码,分别介绍了TCP/UCP通过的一个实例: 代码一 TCP通讯: private void tcpdata() { try { Socket s = new Socket("192.168.0.25", 65500); // outgoing stream redirect to socket Out
-
Java网络编程之TCP通信完整代码示例
一.概述 Socket类是Java执行客户端TCP操作的基础类,这个类本身使用代码通过主机操作系统的本地TCP栈进行通信.Socket类的方法会建立和销毁连接,设置各种Socket选项. ServerSocket类是Java执行服务器端操作的基础类,该类运行于服务器,监听入站TCP连接,每个socket服务器监听服务器的某个端口,当远程主机的客户端尝试连接此端口时,服务器就被唤醒,并返回一个表示两台主机之间socket的正常Socket对象. 二.什么是TCP? TCP是一种面向连接的.可靠的.
-
PHP+jQuery+Ajax+Mysql如何实现发表心情功能
实现发表心情功能通过php+jquery+ajax+mysql技术,大致流程我先给大家理下:主页index.html页面通过ajax获取心情图标及柱状图相关数据,当用户点击其中的一个心情图标时,向后台php发送请求,php对用户cookie验证(是否是首次提交),然后将数据库对应的心情字段内容加1,成功后返回前端页面,告诉首页index页面发表成功,并调整柱状图和统计数据. 请看效果图: html: 先看HTML,我们在index.html中放置一个#msg,用来显示操作结果信息,#mood是操
-
node获取客户端ip功能简单示例
本文实例讲述了node获取客户端ip功能.分享给大家供大家参考,具体如下: 使用nodejs来获取客户端ip 遇到了一个需求,就是服务端让前端自己获取ip,当时就是各种百度,发现通过node来获取是可以的,但是也是node在前端项目内起了一个服务(我起的是express服务),最后证实,服务端自己就可以获取客户端IP... 但是我还是写了一个方法来获取,网上有很多方法,就是一个函数的问题,很简单. 代码如下: var express = require('express') var app =
-
模拟jQuery ajax服务器端与客户端通信的代码
功能如下: 如果用户名为空提示"用户名不能为空 " 如果用户名存在提示"用户名[xxxxxx]已经存在,请使用其他用户名, 4 " 如果用户名不存在提示"用户名[xxxxxx]尚未存在,可以使用该用户名注册, 5" 运行效果如下: 目录结构: 服务器端AjaxServer 复制代码 代码如下: package com.ljq.test; import java.io.IOException; import java.io.PrintWriter;
-
thinkPHP利用ajax异步上传图片并显示、删除的示例
近来学习tp5的过程中,项目中有个发帖功能,选择主题图片.如下: 利用原始的文件上传处理,虽然通过原始js语句能实时显示上传图片,但是这样的话会涉及很多兼容问题.使用ajax技术,实现选择性删除所选图片功能,并不会有兼容问题. 表单文件form: <form method="post" enctype="multipart/form-data"> <div style="margin: 20px 20px 20px 10px;"
-
Yii2实现跨mysql数据库关联查询排序功能代码
背景:在一个mysql服务器上(注意:两个数据库必须在同一个mysql服务器上)有两个数据库: memory (存储常规数据表) 中有一个 user 表(记录用户信息) memory_stat (存储统计数据表) 中有一个 user_stat (记录用户统计数据) 现在在 user 表生成的 GridView 列表中展示 user_stat 中的统计数据 只需要在User的model类中添加关联 public function getStat() { return $this->hasOne(U
-
Jquery：ajax实现翻页无刷新功能代码
不多说,直接贴代码: 下面是js部分: 复制代码 代码如下: var pageSize = "10";//每页行数 var currentPage = "1";//当前页 var totalPage = "0";//总页数 var rowCount = "0";//总条数 var params="";//参数 var url="activity_list.action";//action
-
MySql索引提高查询速度常用方法代码示例
使用索引提高查询速度 1.前言 在web开发中,业务模版,业务逻辑(包括缓存.连接池)和数据库这三个部分,数据库在其中负责执行SQL查询并返回查询结果,是影响网站速度最重要的性能瓶颈.本文主要针对Mysql数据库,在淘宝的去IOE(I 代表IBM的缩写,即去IBM的存储设备和小型机:O是代表Oracle的缩写,去Oracle数据库,采用Mysql和Hadoop代替:E是代表EMC2,去EMC2的设备性,用PC server代替EMC2),大量使用Mysql集群!而优化数据的重要一步就是索引的建立