189 8069 5689
最近做了一个聊天室系统，系统有N个聊天室，在并发量很大的情况下，如果用户聊天记录直接写入MySQL的话，对数据库的冲击会很大。这里我写了个简单的解决方案：聊天数据先存入redis的队列中，然后用crontab每隔1分钟执行PHP脚本，把数据从redis队列中“批量”移到mysql。当有多条插入语句时，把数据拼装成1条insert语句，减少数据库的操作次数。
成都创新互联公司是一家以重庆网站建设、网页设计、品牌设计、软件运维、seo优化排名、小程序App开发等移动开发为一体互联网公司。已累计为成都垃圾桶等众行业中小客户提供优质的互联网建站和软件开发服务。
1. 配置文件 config.php
function dbMessageConfig(){
//用户信息库表的配置
return array(
'database_type' => 'mysql',
'database_name' => 'test',
'server' => '127.0.0.1',
'username' => 'root',
'password' => 'root',
'charset' => 'utf8'
);
}
function redisCacheConfig(){
return array(
'ip' => '127.0.0.1',
'port' => '6379',
'password' => '888888'
);
}
2. redis2mysql.php
error_reporting(E_ALL^E_NOTICE^E_WARNING);
require_once dirname(__FILE__).'/config.php';
$dbMessage = dbMessageConfig();
$configRedis = redisCacheConfig();
$r = new \Redis();
$r->connect($configRedis['ip'], $configRedis['port']);
$r->auth($configRedis['password']);
//获取redis中的消息
$message = $r->rpop('chat_message');
$tenantArr = array();
if(!empty($message)){
$tmpArr = explode(':', $message);
$tenant_id = $tmpArr[0];
if(!empty($tenant_id) && is_numeric($tenant_id)){
if(!empty($tmpArr[1])) $tenantArr[$tenant_id] = $tmpArr[1];
}
}
//一次最多取20条记录
$MAX_NUM = 20;
$index = 1;
while(!empty($message) && $MAX_NUM > $index){
$message = $r->rpop('chat_message');
//echo $message;
$tmpArr = explode(':', $message);
$tenant_id = $tmpArr[0];
if(!empty($tenant_id) && is_numeric($tenant_id)){
if(!empty($tmpArr[1])){
if(array_key_exists($tenant_id, $tenantArr)){
$tmp = $tenantArr[$tenant_id];
$tmp = $tmp.",".$tmpArr[1];
$tenantArr[$tenant_id] = $tmp;
}else{
$tenantArr[$tenant_id] = $tmpArr[1];
}
}
}
$index = $index + 1;
}
$table_message = 'chat_message';
$dbh = new \PDO('mysql:host='.$dbMessage['server'].';dbname='.$dbMessage['database_name'], $dbMessage['username'], $dbMessage['password']);
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$dbh->exec('set names '.$dbMessage['charset']);
foreach ($tenantArr as $tenant_id=>$sql) {
$sqlstr = 'insert INTO '.$table_message.'_'.$tenant_id.' VALUES '.$sql.';';
$stmt = $dbh->prepare($sqlstr);
$stmt->execute();
}
3. 配置crontab
*/1 * * * * /opt/php/bin/php -f /usr/local/php/redis2mysql.php >/dev/null 2>&1
启动crontab：/sbin/service crond start
4. 写入redis的sql语句（java代码）：
//把chatmessage发送到redis储存
Jedisredis = RedisUtil.getJedis();
Stringkey="message";
StringBufferstrMsg =new StringBuffer(tenant_id);
strMsg.append(":(NULL,");
strMsg.append(room_id);
strMsg.append(",");
strMsg.append(uid);
strMsg.append(",'");
strMsg.append(username);
strMsg.append("',");
strMsg.append(user_type);
strMsg.append(",'");
strMsg.append(avatar);
strMsg.append("','");
strMsg.append(content);
strMsg.append("',");
strMsg.append(add_time);
strMsg.append(",1)");
redis.lpush(key,strMsg.toString());
参考：
⑴ crontab启动 、运行和编辑查看
http://blog.csdn.net/ariessurfer/article/details/7459183
⑵ crontab定时任务配置
http://www.cnblogs.com/kerrycode/p/3238346.html
⑶ php mysql PDO使用
http://blog.csdn.net/qq635785620/article/details/11284591