基于Redis的PHP聊天室程序

  1. <?php
  2. define(‘DISABLE_REFRESH_LIMIT’, 1);
  3. require_once(‘global.php’);
  4. header(‘Content-Type: text/html; charset=UTF-8’);
  5. $redis = new Redis();
  6. $redis->connect(‘127.0.0.1’,6379);
  7. $if_init = get_string(‘chat_init’);
  8. if(!$if_init)
  9. {
  10.     if(get_string(‘chat_init_lock’)){die;}
  11.     set_string(‘chat_init_lock’, ‘1’);
  12.     set_array(‘chat_channel’, array(‘GLOBAL’));
  13.     set_array(‘chat_motd’, array(‘GLOBAL’ => ‘Hello!’));
  14.     set_array(‘chat_online’, array());
  15.     set_string(‘chat_init’, ‘1’);
  16.     set_string(“0_name”, ‘系统’);
  17.     set_string(“0_flag”, ‘SA’);
  18. }
  20. if(!$winduid){
  21.     echo ‘chatLogin();’;
  22.     die;
  23. }
  25. set_string(“{$winduid}_name”, $windid);
  26. set_string(“uid_{$windid}”, $winduid);
  28. $channel_list = get_array(‘chat_channel’);
  29. $channel_motd = get_array(‘chat_motd’);
  31. $my_channel = get_string(“{$winduid}_in”);
  33. $my_index = get_string(“{$winduid}_index”);
  34. if(!$my_channel || !in_array($my_channel, $channel_list)){
  35.     $my_channel = $channel_list[0];
  36.     set_string(“{$winduid}_in”, $my_channel);
  37.     $my_index = 0;
  38. }
  40. $channel_index = get_string(“{$my_channel}_index”);
  41. $channel_ca = get_array(“{$my_channel}_ca”);
  43. if ($winddb[‘groupid’] == 3 || $winddb[‘groupid’] == 4 || $winddb[‘groupid’] == 22)
  44. {
  45.     $user_flag = ‘SA’;
  46. }
  47. else if(in_array($winduid, $channel_ca))
  48. {
  49.     $user_flag = ‘CA’;
  50. }
  51. else
  52. {
  53.     $user_flag = ‘U’;
  54. }
  56. set_string(“{$winduid}_flag”, $user_flag);
  58. InitGP(array(‘action’, ‘first’));
  60. if(!$my_index || $first){
  61.     if ($my_index == 0)
  62.     {
  63.         send_message(0, ‘MOTD: ‘ . $channel_motd[$my_channel], ‘info’, $my_channel, $winduid);
  64.     }
  65.     $my_index = $first ? ($channel_index – 10) : ($channel_index + 1);
  66.     if($my_index < 0){
  67.         $my_index = 0;
  68.     }
  69.     set_string(“{$winduid}_index”, $my_index);
  70. }
  72. if($action == ‘ui’)
  73. {
  74.     require_once PrintEot(‘chat_ui’);
  75. }
  77. if($action == ‘channel’)
  78. {
  79.     echo “chatChannelListBegin();\r\n”;
  80.     foreach($channel_list as $channel_name)
  81.     {
  82.         echo “chatHandleChannelList(‘” . mb_convert_encoding($channel_name, ‘UTF-8‘, ‘GBK‘) . “‘);\r\n”;
  83.     }
  84.     echo “chatChannelListEnd();\r\n”;
  85. }
  87. if($action == ‘send’)
  88. {
  89.     InitGP(array(‘content’, ‘receiver’));
  90.     if (!$content || !$receiver)
  91.     {
  92.         echo ‘0’;
  93.         die;
  94.     }
  95.     if ($winddb[‘postnum’] < 100)
  96.     {
  97.         send_message(0, ‘您的发贴数不足100，没有发言权限’, ‘warn’, $my_channel, $winduid);
  98.     }
  99.     else
  100.     {
  101.         if (get_string(“{$winduid}_block”) > $timestamp)
  102.         {
  103.             send_message(0, ‘您已被禁言，无法发言’, ‘warn’, $my_channel, $winduid);
  104.         }
  105.         else
  106.         {
  107.             $content = htmlspecialchars($content);
  108.             send_message($winduid, stripslashes(mb_convert_encoding($content, ‘GBK’, ‘UTF-8’)), ‘info’, $my_channel, $receiver);
  109.         }
  110.     }
  111.     echo ‘0’;
  112. }
  114. if($action == ‘get’)
  115. {
  116.     $channel_ca_list = ”;
  117.     if ($user_flag == ‘SA’ || $user_flag == ‘CA’)
  118.     {
  119.         foreach ($channel_ca as $ca)
  120.         {
  121.             $channel_ca_list .= get_string(“{$ca}_name”) . ‘,’;
  122.         }
  123.         $channel_ca_list = mb_convert_encoding($channel_ca_list, ‘UTF-8’, ‘GBK’);
  124.     }
  125.     echo “chatHandleStatus(‘” . mb_convert_encoding($my_channel, ‘UTF-8‘, ‘GBK‘) . “‘, ‘” . mb_convert_encoding($windid, ‘UTF-8‘, ‘GBK‘) . “‘, ‘{$user_flag}’, ‘{$channel_ca_list}’);”;
  126.     for(; $my_index <= $channel_index; $my_index ++)
  127.     {
  128.         $message = get_array(“{$my_channel}_{$my_index}”);
  129.         if ($message[‘receiver’] == ‘all’ || $message[‘receiver’] == $winduid)
  130.         {
  131.             $message[‘content’] = addslashes(mb_convert_encoding($message[‘content’], ‘UTF-8’, ‘GBK’));
  132.             $sender_flag = get_string(“{$message[author]}_flag”);
  133.             $sender_flag == ‘SA’ && $message[‘content’] = ‘<span style=”color:red;font-weight:bold”>’ . $message[‘content’] . ‘</span>’;
  134.             $sender_flag == ‘CA’ && $message[‘content’] = ‘<span style=”color:blue”>’ . $message[‘content’] . ‘</span>’;
  135.             $message[‘author’] = addslashes(mb_convert_encoding(get_string(“{$message[author]}_name”), ‘UTF-8’, ‘GBK’));
  136.             echo “chatHandleMessage(‘{$message[type]}’, ‘” . $message[‘author‘] . “‘, ‘{$message[content]}’, {$message[date]});\r\n”;
  137.         }
  138.     }
  139.     set_string(“{$winduid}_index”, $my_index);
  140. }
  142. if($action == ‘block’)
  143. {
  144.     InitGP(array(‘username’, ‘timespan’));
  145.     $username = mb_convert_encoding($username, ‘GBK’, ‘UTF-8’);
  146.     if ($user_flag == ‘SA’ || $user_flag == ‘CA’)
  147.     {
  148.         set_string(get_string(“uid_{$username}”) . ‘_block’, $timestamp + $timespan * 3600);
  149.         send_message(0, ‘禁言用户[‘ . $username . ‘]成功’, ‘warn’, $my_channel, $winduid);
  150.         echo ‘0’;
  151.     }
  152.     else
  153.     {
  154.         send_message(0, ‘权限不足’, ‘warn’, $my_channel, $winduid);
  155.         echo ‘-1’;
  156.     }
  157. }
  159. if($action == ‘setchannel’)
  160. {
  161.     InitGP(array(‘option’, ‘channel’, ‘channel_name’, ‘channel_ca’));
  162.     if ($option == ‘join’)
  163.     {
  164.         $channel = mb_convert_encoding($channel, ‘GBK’, ‘UTF-8’);
  165.         if (in_array($channel, $channel_list))
  166.         {
  167.             set_string(“{$winduid}_index”, 0);
  168.             set_string(“{$winduid}_in”, $channel);
  169.             echo ‘0’;
  170.         }
  171.         else
  172.         {
  173.             send_message(0, ‘频道不存在’, ‘warn’, $my_channel, $winduid);
  174.             echo ‘-1’;
  175.             die;
  176.         }
  177.     }
  178.     else
  179.     {
  180.         if ($user_flag != ‘SA’)
  181.         {
  182.             send_message(0, ‘目前只有全局管理员可以创建频道’, ‘warn’, $my_channel, $winduid);
  183.             echo ‘-1’;
  184.             die;
  185.         }
  186.         if (!$channel_name)
  187.         {
  188.             send_message(0, ‘请输入频道名’, ‘warn’, $my_channel, $winduid);
  189.             echo ‘-1’;
  190.             die;
  191.         }
  192.         $channel_name = mb_convert_encoding($channel_name, ‘GBK’, ‘UTF-8’);
  193.         $channel_ca = mb_convert_encoding($channel_ca, ‘GBK’, ‘UTF-8’);
  194.         if (in_array($channel, $channel_list))
  195.         {
  196.             send_message(0, ‘频道名重复’, ‘warn’, $my_channel, $winduid);
  197.             echo ‘-1’;
  198.             die;
  199.         }
  200.         $channel_list[] = $channel_name;
  201.         $channel_motd[$channel_name] = ‘Hello!’;
  202.         set_array(‘chat_channel’, $channel_list);
  203.         set_array(‘chat_motd’, $channel_motd);
  204.         set_array(“{$channel_name}_ca”, explode(‘,’, $channel_ca));
  205.         send_message(0, ‘频道创建成功’, ‘warn’, $my_channel, $winduid);
  206.     }
  207. }
  209. if($action == ‘setmotd’)
  210. {
  211.     InitGP(array(‘motd’));
  212.     $motd = mb_convert_encoding($motd, ‘GBK’, ‘UTF-8’);
  213.     if ($user_flag == ‘SA’ || $user_flag == ‘CA’)
  214.     {
  215.         $channel_motd[$my_channel] = $motd;
  216.         set_array(‘chat_motd’, $channel_motd);
  217.         send_message(0, ‘MOTD设置成功’, ‘warn’, $my_channel, $winduid);
  218.         echo ‘0’;
  219.     }
  220.     else
  221.     {
  222.         send_message(0, ‘权限不足’, ‘warn’, $my_channel, $winduid);
  223.         echo ‘-1’;
  224.     }
  225. }
  227. if($action == ‘delchannel’)
  228. {
  229.     if ($user_flag == ‘SA’ || $user_flag == ‘CA’)
  230.     {
  231.         unset($channel_list[array_search($my_channel, $channel_list)]);
  232.         unset($channel_motd[$my_channel]);
  233.         set_array(‘chat_channel’, $channel_list);
  234.         set_array(‘chat_motd’, $channel_motd);
  235.         remove(“{$my_channel}_ca”);
  236.         set_string(“{$winduid}_index”, 0);
  237.         set_string(“{$winduid}_in”, ‘GLOBAL’);
  238.         send_message(0, ‘频道删除成功’, ‘warn’, ‘GLOBAL’, $winduid);
  239.         echo ‘0’;
  240.     }
  241.     else
  242.     {
  243.         send_message(0, ‘权限不足’, ‘warn’, $my_channel, $winduid);
  244.         echo ‘-1’;
  245.     }
  246. }
  248. if($action == ‘setca’)
  249. {
  250.     InitGP(array(‘username’, ‘option’));
  251.     if ($user_flag == ‘SA’ || $user_flag == ‘CA’)
  252.     {
  253.         $username = mb_convert_encoding($username, ‘GBK’, ‘UTF-8’);
  254.         $uid = get_string(“uid_{$username}”);
  255.         if (!$uid)
  256.         {
  257.             send_message(0, ‘用户没有登录’, ‘warn’, $my_channel, $winduid);
  258.             echo ‘-1’;
  259.             die;
  260.         }
  261.         if ($option == ‘add’)
  262.         {
  263.             if (!in_array($uid, $channel_ca))
  264.             {
  265.                 $channel_ca[] = $uid;
  266.                 send_message(0, ‘增加管理员[‘ . $username . ‘]’, ‘warn’, $my_channel, $winduid);
  267.             }
  268.         }
  269.         else
  270.         {
  271.             if (in_array($uid, $channel_ca))
  272.             {
  273.                 unset($channel_ca[array_search($uid, $channel_ca)]);
  274.                 send_message(0, ‘取消管理员[‘ . $username . ‘]’, ‘warn’, $my_channel, $winduid);
  275.             }
  276.         }
  277.         set_array(“{$my_channel}_ca”, $channel_ca);
  278.         echo ‘0’;
  279.     }
  280.     else
  281.     {
  282.         send_message(0, ‘权限不足’, ‘warn’, $my_channel, $winduid);
  283.         echo ‘-1’;
  284.     }
  285. }
  287. function remove()
  288. {
  289.     global $redis;
  290.     $redis->delete($name);
  291. }
  293. function set_string($name, $val)
  294. {
  295.     global $redis;
  296.     $redis->set($name, $val);
  297. }
  299. function get_string($name, $val)
  300. {
  301.     global $redis;
  302.     return $redis->get($name);
  303. }
  305. function append_string($name, $val)
  306. {
  307.     global $redis;
  308.     return $redis->append($name, $val);
  309. }
  311. function set_array($name, $val)
  312. {
  313.     global $redis;
  314.     $redis->set($name, serialize($val));
  315. }
  317. function get_array($name)
  318. {
  319.     global $redis;
  320.     return unserialize($redis->get($name));
  321. }
  323. function send_message($author, $content, $type = ‘info’, $channel = ‘GLOBAL’, $receiver = ‘all’)
  324. {
  325.     global $redis, $timestamp;
  326.     if (strlen($content) > 200)
  327.     {
  328.         $content = substr($content, 0 , 200);
  329.     }
  330.     while(get_string(“{$channel}_lock”)){usleep(100);}
  331.     set_string(“{$channel}_lock”, 1);
  332.     $channel_index = get_string(“{$channel}_index”);
  333.     $channel_index = $channel_index + 1;
  334.     set_array(“{$channel}_{$channel_index}”, array(
  335.         ‘author’ => $author,
  336.         ‘content’ => $content,
  337.         ‘type’ => $type,
  338.         ‘receiver’ => $receiver,
  339.         ‘date’ => $timestamp
  340.     ));
  341.     set_string(“{$channel}_index”, $channel_index);
  342.     $clean_index = $channel_index – 100;
  343.     remove(“{$channel}_{$clean_index}”);
  344.     $author_name = get_string(“{$author}_name”);
  345.     append_string(“{$channel}_record”, get_date($timestamp, ‘Y-m-d H:i:s’) . ” [{$type}] {$author_name} -> {$receiver}: {$content}\r\n”);
  346.     check_channel_record($channel);
  347.     set_string(“{$channel}_lock”, 0);
  348. }
  350. function check_channel_record($channel)
  351. {
  352.     global $timestamp;
  353.     $lastsave = get_string(“{$channel}_lastsave”);
  354.     if($timestamp – $lastsave > 600)
  355.     {
  356.         set_string(“{$channel}_lastsave”, $timestamp);
  357.         save_record($channel);
  358.     }
  359. }
  361. function save_record($channel)
  362. {
  363.     global $db, $timestamp;
  364.     $record = str_replace(
  365.         array(“\\”, “\“”, “‘”),
  366.         array(“\\\\”, “\\\“”, “\\'”),
  367.         get_string(“{$channel}_record”)
  368.     );
  369.     set_string(“{$channel}_record”, ”);
  370.     if(strlen($record)>0){
  371.         $db->update(“INSERT INTO `pw_chatrecord` (`channel`, `time`, `content`) VALUES (‘$channel’, ‘$timestamp’, ‘$record’)”);
  372.     }
  373. }

Myl-Site

相关文章

0 Comments
Leave a Reply