七星彩玩法中奖条件:php redis 处理websocket聊天记录的实例代码

江西多乐彩11选5走势图 www.ptdvv.cn  更新时间:2018年07月03日 16:36:30   作者:撑一支船蒿   我要评论

本文通过实例代码给大家介绍了php redis 处理websocket聊天记录的相关知识,非常不错,具有一定的参考借鉴价值,需要的朋友可以参考下

具体代码如下所示:

<?phpini_set('display_errors', 'on');
class chatClass {
 private $redis;
 //这个变量模拟用户当前状态,是否登录,是否可查看
 public $checkUserReadable = false;
 //构造函数链接redis数据库
 public function __construct() {
  $this -> redis = new Redis();
  $this -> redis -> connect('127.0.0.1', '6379');
  $this -> redis -> auth('***cnblogs.com/handle');
 }
 /*
 发送消息时保存聊天记录
 * 这里用的redis存储是list数据类型
 * 两个人的聊天用一个list保存
 *
 * @from 消息发送者id
 * @to 消息接受者id
 * @meassage 消息内容
 *
 * 返回值,当前聊天的总聊天记录数
 */
 public function setChatRecord($from, $to, $message) {
  $data = array('from' => $from, 'to' => $to, 'message' => $message, 'sent' => time()/*, 'recd' => 0*/);
  $value = json_encode($data);
  //生成json字符串
  $keyName = 'rec:' . $this -> getRecKeyName($from, $to);
  //echo $keyName;
  $res = $this -> redis -> lPush($keyName, $value);
  if (!$this -> checkUserReadable) {//消息接受者无法立刻查看时,将消息设置为未读
   $this -> cacheUnreadMsg($from, $to);
  }
  return $res;
 }
 /*
 * 获取聊天记录
 * @from 消息发送者id
 * @to 消息接受者id
 * @num 获取的数量
 *
 * 返回值,指定长度的包含聊天记录的数组
 */
 public function getChatRecord($from, $to, $num) {
  $keyName = 'rec:' . $this -> getRecKeyName($from, $to);
  //echo $keyName;
  $recList = $this -> redis -> lRange($keyName, 0, (int)($num));
  return $recList;
 }
 /*
 * 当用户上线时,或点开聊天框时,获取未读消息的数目
 * @user 用户id
 *
 * 返回值,一个所有当前用户未读的消息的发送者和数组
 * 数组格式为‘消息发送者id'=>‘未读消息数目'
 *
 */
 public function getUnreadMsgCount($user) {
  return $this -> redis -> hGetAll('unread_' . $user);
 }
 /*
 * 获取未读消息的内容
 * 通过未读消息数目,在列表中取得最新的相应消息即为未读
 * @from 消息发送者id
 * @to 消息接受者id
 *
 * 返回值,包括所有未读消息内容的数组
 *
 *
 */
 public function getUnreadMsg($from, $to) {
  $countArr = $this -> getUnreadMsgCount($to);
  $count = $countArr[$from];
  $keyName = 'rec:' . $this -> getRecKeyName($from, $to);
  return $this -> redis -> lRange($keyName, 0, (int)($count));
 }
 /*
 * 将消息设为已读
 * 当一个用户打开另一个用户的聊天框时,将所有未读消息设为已读
 * 清楚未读消息中的缓存
 * @from 消息发送者id
 * @to 消息接受者id
 *
 * 返回值,成功将未读消息设为已读则返回true,没有未读消息则返回false
 */
 public function setUnreadToRead($from, $to) {
  $res = $this -> redis -> hDel('unread_' . $to, $from);
  return (bool)$res;
 }
 /*
 * 当用户不在线时,或者当前没有立刻接收消息时,缓存未读消息,将未读消息的数目和发送者信息存到一个与接受者关联的hash数据中
 *
 * @from 发送消息的用户id
 * @to 接收消息的用户id
 *
 * 返回值,当前两个用户聊天中的未读消息
 *
 */
 private function cacheUnreadMsg($from, $to) {
  return $this -> redis -> hIncrBy('unread_' . $to, $from, 1);
 }
 /*生成聊天记录的键名,即按大小规则将两个数字排序
 * @from 消息发送者id
 * @to 消息接受者id
 *
 *
 */
 private function getRecKeyName($from, $to) {
  return ($from > $to) ? $to . '_' . $from : $from . '_' . $to;
 }
}
/*
* 下面为测试用的代码 ,伪造数据模拟场景
* 假定有两个用户id为2和3 ,2 向 3 发送消息
*
$chat = new chatClass();
$chat -> checkUserReadable = true;
for ($i = 0; $i < 20; $i++) {
$chat -> setChatRecord('2', '3', 'message_' . $i);
}
echo 'get 20 chat records</br>';
$arr = $chat -> getChatRecord('2', '3', 20);
for ($j = 0; $j < count($arr); $j++) {
echo $arr[$j] . '</br>';
}
$chat -> checkUserReadable = false;
for ($m = 0; $m < 5; $m++) {
$chat -> setChatRecord('2', '3', 'message_' . $m);
}
echo "</br>";
$umsg_1 = $chat -> getUnreadMsgCount(3);
echo "Unread message counts ";
echo "</br>";
print_r($umsg_1);
echo "Unread message content </br> ";
$umsgContent = $chat -> getUnreadMsg(2, 3);
for ($n = 0; $n < count($umsgContent); $n++) {
echo $arr[$n] . '</br>';
}
echo "</br>";
$chat -> setUnreadToRead(2, 3);
$umsg_2 = $chat -> getUnreadMsgCount(3);
echo "</br>";
echo "Unread message counts ";
echo "</br>";
print_r($umsg_2);
*
*/
?>

总结

以上所述是小编给大家介绍的php redis 处理websocket聊天记录的实例代码,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

相关文章

  • PHP使用Session遇到的一个Permission denied Notice解决办法

    PHP使用Session遇到的一个Permission denied Notice解决办法

    这篇文章主要介绍了PHP使用Session遇到的一个Permission denied Notice解决办法,本文系统环境是ubuntu、Debian系统,有很小的概率会遇到这个提示,需要的朋友可以参考下
    2014-07-07
  • php网页版聊天软件实现代码

    php网页版聊天软件实现代码

    这篇文章主要介绍了php网页版聊天软件实现代码,可以实现匿名聊天,感兴趣的小伙伴们可以参考一下
    2016-08-08
  • PHP反向代理类代码

    PHP反向代理类代码

    这篇文章主要介绍了PHP反向代理类代码,需要的朋友可以参考下
    2014-08-08
  • Laravel框架中Blade模板的用法示例

    Laravel框架中Blade模板的用法示例

    Blade 是 laravel 提供的一个简单强大的模板引擎,下面这篇文章主要给大家介绍了关于Laravel框架中Blade模板用法的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面来一起看看吧。
    2017-08-08
  • Laravel事件监听器用法实例分析

    Laravel事件监听器用法实例分析

    这篇文章主要介绍了Laravel事件监听器用法,结合实例形式分析了Laravel事件监听器的注册、使用相关流程及操作技巧,需要的朋友可以参考下
    2019-03-03
  • 详解PHP中cookie和session的区别及cookie和session用法小结

    详解PHP中cookie和session的区别及cookie和session用法小结

    这篇文章主要介绍了PHP中cookie和session的区别及cookie和session用法小结的相关资料,非常不错具有参考借鉴价值,需要的朋友可以参考下
    2016-06-06
  • 基于php设计模式中单例模式的应用分析

    基于php设计模式中单例模式的应用分析

    本篇文章是对php设计模式中单例模式的应用进行了详细的分析介绍,需要的朋友参考下
    2013-05-05
  • PHP 实例化类的一点摘记

    PHP 实例化类的一点摘记

    最近在编写 Grace PHP5 Framework 中,我得到很多类的实例化的心得。Grace PHP5 Framework 是一个完全基于 MVC 架构的框架,具有良好的扩展性。它对于类的调用可以说非常的灵活。
    2008-03-03
  • php in_array() 检查数组中是否存在某个值详解

    php in_array() 检查数组中是否存在某个值详解

    php有时候需要判断某一个值是否存在于数组中,我们可以直接使用php内置函数in_array()来实现判断。php in_array 函数用于检查数组中是否存在某个值,如果存在,则返回true,否则返回false。本文章向大家介绍in_array函数的基本语法及使用实例,感兴趣的朋友可以参考一下。
    2016-11-11
  • php版小黄鸡simsimi聊天机器人接口分享

    php版小黄鸡simsimi聊天机器人接口分享

    小黄鸡SimSimi是一个可爱的智能聊天机器人,他能和用户进行有趣的对话,本文主要介绍了php版小黄鸡simsimi接口使用的示例,大家参考使用吧
    2014-01-01

最新评论

721| 778| 926| 864| 628| 4| 864| 80| 125| 298|